From 62e2547bea445c4f67935a57f59886757facbd2d Mon Sep 17 00:00:00 2001
From: baomingyu <baomingyu_5@163.com>
Date: Fri, 5 Nov 2021 22:05:04 +0800
Subject: [PATCH] modify check waitingForPingResponse with volatile (#12615)

---
 .../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 481517c794ab9..f9e7b47f73731 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() {