diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-09-29 19:52:28 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2020-09-29 19:52:28 +0000 |
commit | bc02293768d4e0434689c34edffe5d9fef9a866b (patch) | |
tree | d08904fdd441fc02b4390a8486b6c3fea2437405 | |
parent | cae8ba3bfc5573828a6e4a28d2616694b09cb616 (diff) |
Ensure that the EroorMessage class has been loaded prior to shutdown/close to avoid classloading issue when bundle is gone.
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcPing.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcPing.java b/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcPing.java index 5992d47855f..26abe92a6f1 100644 --- a/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcPing.java +++ b/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcPing.java @@ -22,6 +22,7 @@ public class RpcPing implements Pinger, Client.ResponseReceiver { private static final Logger log = Logger.getLogger(RpcPing.class.getName()); private static final String RPC_METHOD = "vespa.searchprotocol.ping"; private static final CompressionType PING_COMPRESSION = CompressionType.NONE; + private static final boolean triggeredClassLoading = ErrorMessage.createBackendCommunicationError("TriggerClassLoading") instanceof ErrorMessage; private final Node node; private final RpcResourcePool resourcePool; @@ -86,7 +87,7 @@ public class RpcPing implements Pinger, Client.ResponseReceiver { @Override public void receive(ResponseOrError<ProtobufResponse> response) { - if (clusterMonitor.isClosed()) return; + if (clusterMonitor.isClosed() && ! triggeredClassLoading) return; if (node.isLastReceivedPong(pingSequenceId)) { pongHandler.handle(toPong(response)); } else { |