You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/12/20 15:21:32 UTC
[pulsar] 03/11: modify check waitingForPingResponse with volatile (#12615)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 47b8e44660c2f15934381c8d5d13edd0d9d9090a
Author: baomingyu <ba...@163.com>
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 557dbfa..cdf372d 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
@@ -37,7 +37,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() {