diff options
author | jonmv <venstad@gmail.com> | 2022-11-24 17:07:06 +0100 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2022-11-24 17:12:33 +0100 |
commit | 357315bba6debc9cd32a0eca6dee1b079f661e17 (patch) | |
tree | 65cb0451f8f4847e90e6e9759fa94b070d872c5a /zkfacade | |
parent | bc488eb212f168bfa0992a00d4524d2d349b988e (diff) |
Set private DNS for existing VPC endpoints services
Diffstat (limited to 'zkfacade')
-rw-r--r-- | zkfacade/src/main/java/com/yahoo/vespa/curator/SingletonManager.java | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/zkfacade/src/main/java/com/yahoo/vespa/curator/SingletonManager.java b/zkfacade/src/main/java/com/yahoo/vespa/curator/SingletonManager.java index 42400b82ab6..8eda57b0476 100644 --- a/zkfacade/src/main/java/com/yahoo/vespa/curator/SingletonManager.java +++ b/zkfacade/src/main/java/com/yahoo/vespa/curator/SingletonManager.java @@ -327,7 +327,6 @@ class SingletonManager { Instant ourDoom = doom.get(); boolean shouldBeActive = ourDoom != null && ourDoom != INVALID && ! clock.instant().isAfter(ourDoom); if ( ! active && shouldBeActive) { - logger.log(INFO, "Activating singleton for ID: " + id); try { active = true; if ( ! singletons.isEmpty()) metrics.activation(singletons.peek()::activate); @@ -338,7 +337,6 @@ class SingletonManager { } } if (active && ! shouldBeActive) { - logger.log(INFO, "Deactivating singleton for ID: " + id); logger.log(FINE, () -> "Doom value is " + doom); try { if ( ! singletons.isEmpty()) metrics.deactivation(singletons.peek()::deactivate); @@ -415,6 +413,7 @@ class SingletonManager { Instant start = clock.instant(); boolean failed = false; metric.add(ACTIVATION, 1, context); + logger.log(INFO, "Activating singleton for ID: " + id); try { activation.run(); } @@ -423,7 +422,9 @@ class SingletonManager { throw e; } finally { - metric.set(ACTIVATION_MILLIS, Duration.between(start, clock.instant()).toMillis(), context); + long durationMillis = Duration.between(start, clock.instant()).toMillis(); + metric.set(ACTIVATION_MILLIS, durationMillis, context); + logger.log(INFO, "Activation completed in %.3f seconds".formatted(durationMillis * 1e-3)); if (failed) metric.add(ACTIVATION_FAILURES, 1, context); else isActive = true; ping(); @@ -434,6 +435,7 @@ class SingletonManager { Instant start = clock.instant(); boolean failed = false; metric.add(DEACTIVATION, 1, context); + logger.log(INFO, "Deactivating singleton for ID: " + id); try { deactivation.run(); } @@ -442,7 +444,9 @@ class SingletonManager { throw e; } finally { - metric.set(DEACTIVATION_MILLIS, Duration.between(start, clock.instant()).toMillis(), context); + long durationMillis = Duration.between(start, clock.instant()).toMillis(); + metric.set(DEACTIVATION_MILLIS, durationMillis, context); + logger.log(INFO, "Deactivation completed in %.3f seconds".formatted(durationMillis * 1e-3)); if (failed) metric.add(DEACTIVATION_FAILURES, 1, context); isActive = false; ping(); |