summaryrefslogtreecommitdiffstats
path: root/zkfacade/src/main/java/com/yahoo/vespa/curator/stats/LockAttempt.java
diff options
context:
space:
mode:
Diffstat (limited to 'zkfacade/src/main/java/com/yahoo/vespa/curator/stats/LockAttempt.java')
-rw-r--r--zkfacade/src/main/java/com/yahoo/vespa/curator/stats/LockAttempt.java11
1 files changed, 7 insertions, 4 deletions
diff --git a/zkfacade/src/main/java/com/yahoo/vespa/curator/stats/LockAttempt.java b/zkfacade/src/main/java/com/yahoo/vespa/curator/stats/LockAttempt.java
index 3a62c7bf988..1478b36d331 100644
--- a/zkfacade/src/main/java/com/yahoo/vespa/curator/stats/LockAttempt.java
+++ b/zkfacade/src/main/java/com/yahoo/vespa/curator/stats/LockAttempt.java
@@ -115,14 +115,17 @@ public class LockAttempt {
activeLockedInterval = lockMetrics.lockAcquired(activeAcquireInterval);
}
- void released() {
+ void preRelease() {
+ lockMetrics.preRelease(activeLockedInterval);
+ }
+
+ void postRelease() {
setTerminalState(LockState.RELEASED);
- lockMetrics.release(activeLockedInterval);
}
- void releasedWithError() {
+ void releaseFailed() {
setTerminalState(LockState.RELEASED_WITH_ERROR);
- lockMetrics.releaseFailed(activeLockedInterval);
+ lockMetrics.releaseFailed();
}
void setTerminalState(LockState terminalState) { setTerminalState(terminalState, Instant.now()); }