summaryrefslogtreecommitdiffstats
path: root/vespajlib
diff options
context:
space:
mode:
authorHÃ¥kon Hallingstad <hakon@oath.com>2018-10-29 10:50:07 +0100
committerGitHub <noreply@github.com>2018-10-29 10:50:07 +0100
commitd7e75c63c3c25474e825488c0daaa328e27472d8 (patch)
tree30f813e6cd54e73180e90affb29dc4a279104211 /vespajlib
parent06056362f9190cf74634e4cce5b4ac0da5a6855c (diff)
Revert "Revert "Enforce CC timeouts in Orchestrator 2""
Diffstat (limited to 'vespajlib')
-rw-r--r--vespajlib/src/main/java/com/yahoo/time/TimeBudget.java12
1 files changed, 12 insertions, 0 deletions
diff --git a/vespajlib/src/main/java/com/yahoo/time/TimeBudget.java b/vespajlib/src/main/java/com/yahoo/time/TimeBudget.java
index a7963df0208..449b0d6bd05 100644
--- a/vespajlib/src/main/java/com/yahoo/time/TimeBudget.java
+++ b/vespajlib/src/main/java/com/yahoo/time/TimeBudget.java
@@ -66,6 +66,18 @@ public class TimeBudget {
});
}
+ /** Returns the time left, possibly negative if the deadline has passed. */
+ public Optional<Duration> timeLeft() {
+ return timeout.map(timeout -> timeout.minus(timePassed()));
+ }
+
+ /** Returns the time left as a new TimeBudget. */
+ public TimeBudget timeLeftAsTimeBudget() {
+ Instant now = clock.instant();
+ Optional<Instant> deadline = deadline();
+ return new TimeBudget(clock, now, deadline.map(d -> Duration.between(now, d)));
+ }
+
private static Duration nonNegativeBetween(Instant start, Instant end) {
return makeNonNegative(Duration.between(start, end));
}