[jira] [Created] (GEODE-9620) The CacheServerStats currentQueueConnections statistic is incremented and decremented twice per client queue

["Barrett Oglesby (Jira)" <ji...@apache.org>]

Barrett Oglesby created GEODE-9620:
--------------------------------------

             Summary: The CacheServerStats currentQueueConnections statistic is incremented and decremented twice per client queue
                 Key: GEODE-9620
                 URL: https://issues.apache.org/jira/browse/GEODE-9620
             Project: Geode
          Issue Type: Bug
          Components: client queues
            Reporter: Barrett Oglesby


The CacheServerStats currentQueueConnections statistic is incremented and decremented twice per client queue

When a client with subscription enabled joins connects to the server, the CacheServerStats currentQueueConnections statistic is incremented twice.

Once by the ServerConnection thread here:
{noformat}
[warn 2021/09/21 11:22:18.851 PDT server-1 <ServerConnection on port 63920 Thread 1> tid=0x41] XXX CacheServerStats.incCurrentQueueConnections currentQueueConnectionsId=1
java.lang.Exception
	at org.apache.geode.internal.cache.tier.sockets.CacheServerStats.incCurrentQueueConnections(CacheServerStats.java:660)
	at org.apache.geode.internal.cache.tier.sockets.ServerConnection.handshakeAccepted(ServerConnection.java:705)
	at org.apache.geode.internal.cache.tier.sockets.ServerConnection.acceptHandShake(ServerConnection.java:682)
	at org.apache.geode.internal.cache.tier.sockets.ServerConnection.processHandShake(ServerConnection.java:613)
	at org.apache.geode.internal.cache.tier.sockets.ServerConnection.verifyClientConnection(ServerConnection.java:404)
	at org.apache.geode.internal.cache.tier.sockets.ServerConnection.doHandshake(ServerConnection.java:787)
{noformat}
And once by the Client Queue Initialization Thread here:
{noformat}
[warn 2021/09/21 11:22:18.884 PDT server-1 <Client Queue Initialization Thread 1> tid=0x44] XXX CacheServerStats.incCurrentQueueConnections currentQueueConnectionsId=2
java.lang.Exception
	at org.apache.geode.internal.cache.tier.sockets.CacheServerStats.incCurrentQueueConnections(CacheServerStats.java:660)
	at org.apache.geode.internal.cache.tier.sockets.CacheClientProxy.<init>(CacheClientProxy.java:342)
	at org.apache.geode.internal.cache.tier.sockets.CacheClientProxy.<init>(CacheClientProxy.java:306)
	at org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier.registerClientInternal(CacheClientNotifier.java:379)
	at org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier.registerClient(CacheClientNotifier.java:198)
	at org.apache.geode.internal.cache.tier.sockets.AcceptorImpl$ClientQueueInitializerTask.run(AcceptorImpl.java:1896)
{noformat}
When the client disconnects from the server, the CacheServerStats currentQueueConnections statistic is decremented twice.

Once by the ServerConnection thread here:
{noformat}
[warn 2021/09/21 11:24:01.129 PDT server-1 <ServerConnection on port 63920 Thread 1> tid=0x41] XXX CacheServerStats.decCurrentQueueConnections currentQueueConnectionsId=1
java.lang.Exception
	at org.apache.geode.internal.cache.tier.sockets.CacheServerStats.decCurrentQueueConnections(CacheServerStats.java:665)
	at org.apache.geode.internal.cache.tier.sockets.ServerConnection.handleTermination(ServerConnection.java:956)
	at org.apache.geode.internal.cache.tier.sockets.ServerConnection.handleTermination(ServerConnection.java:929)
	at org.apache.geode.internal.cache.tier.sockets.ServerConnection.run(ServerConnection.java:1289)
{noformat}
And once by a different ServerConnection thread here:
{noformat}
[warn 2021/09/21 11:24:01.135 PDT server-1 <ServerConnection on port 63920 Thread 2> tid=0x42] XXX CacheServerStats.decCurrentQueueConnections currentQueueConnectionsId=0
java.lang.Exception
	at org.apache.geode.internal.cache.tier.sockets.CacheServerStats.decCurrentQueueConnections(CacheServerStats.java:665)
	at org.apache.geode.internal.cache.tier.sockets.CacheClientProxy.closeSocket(CacheClientProxy.java:939)
	at org.apache.geode.internal.cache.tier.sockets.CacheClientProxy.terminateDispatching(CacheClientProxy.java:895)
	at org.apache.geode.internal.cache.tier.sockets.CacheClientProxy.close(CacheClientProxy.java:773)
	at org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier.closeDeadProxies(CacheClientNotifier.java:1558)
	at org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier.unregisterClient(CacheClientNotifier.java:572)
	at org.apache.geode.internal.cache.tier.sockets.ClientHealthMonitor.unregisterClient(ClientHealthMonitor.java:268)
	at org.apache.geode.internal.cache.tier.sockets.ServerConnection.handleTermination(ServerConnection.java:1008)
	at org.apache.geode.internal.cache.tier.sockets.ServerConnection.handleTermination(ServerConnection.java:929)
	at org.apache.geode.internal.cache.tier.sockets.ServerConnection.run(ServerConnection.java:1289)
{noformat}




--
This message was sent by Atlassian Jira
(v8.3.4#803005)