diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-09-21 17:47:07 +0200 |
|---|---|---|
| committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-09-21 17:47:07 +0200 |
| commit | 62c76fb625ede6326c3e14c491218a114a551b92 (patch) | |
| tree | c0333cffb8ea5e0afd6a4a1a263ae5db521c8f04 /metrics-proxy | |
| parent | df28b55c35d8c2f96d4c5077671699d379cb01ff (diff) | |
Add synchronization.
Diffstat (limited to 'metrics-proxy')
| -rw-r--r-- | metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java index 9236c68ec87..3d834106ebc 100644 --- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java +++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java @@ -35,8 +35,11 @@ public class ConfigSentinelClient extends AbstractComponent { @Override public void deconstruct() { - if (connection != null) { - connection.close(); + synchronized (this) { + if (connection != null) { + connection.close(); + connection = null; + } } supervisor.transport().shutdown().join(); super.deconstruct(); |