anmolnar commented on a change in pull request #753: ZOOKEEPER-3204: Reconfig
tests are constantly failing on 3.5 after applying Java 11 fix
URL: https://github.com/apache/zookeeper/pull/753#discussion_r253894823
##########
File path:
zookeeper-server/src/main/java/org/apache/zookeeper/server/NettyServerCnxn.java
##########
@@ -411,19 +494,44 @@ public void receiveMessage(ChannelBuffer message) {
}
}
+ /**
+ * An event that triggers a change in the channel's "Auto Read" setting.
+ * Used for throttling. By using an enum we can treat the two values as
+ * singletons and compare with ==.
+ */
+ enum AutoReadEvent {
+ DISABLE,
+ ENABLE
+ }
+
@Override
public void disableRecv() {
- disableRecvNoWait().awaitUninterruptibly();
+ if (throttled.compareAndSet(false, true)) {
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Throttling - disabling recv {}", this);
+ }
+ channel.pipeline().fireUserEventTriggered(AutoReadEvent.DISABLE);
+ }
}
-
- private ChannelFuture disableRecvNoWait() {
- throttled = true;
- if (LOG.isDebugEnabled()) {
- LOG.debug("Throttling - disabling recv " + this);
+
+ /**
+ * Note that the netty implementation ignores the
<code>waitDisableRecv</code>
Review comment:
Done.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
