This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.8 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 8e3c70207ef7dec44d0df15577ca33e81c38b59d Author: baomingyu <[email protected]> AuthorDate: Fri Nov 5 22:05:04 2021 +0800 modify check waitingForPingResponse with volatile (#12615) (cherry picked from commit 62e2547bea445c4f67935a57f59886757facbd2d) --- .../src/main/java/org/apache/pulsar/common/protocol/PulsarHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarHandler.java b/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarHandler.java index 481517c..f9e7b47 100644 --- a/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarHandler.java +++ b/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarHandler.java @@ -36,7 +36,7 @@ public abstract class PulsarHandler extends PulsarDecoder { protected SocketAddress remoteAddress; private int remoteEndpointProtocolVersion = ProtocolVersion.v0.getValue(); private final long keepAliveIntervalSeconds; - private boolean waitingForPingResponse = false; + private volatile boolean waitingForPingResponse = false; private ScheduledFuture<?> keepAliveTask; public int getRemoteEndpointProtocolVersion() {
