[GEODE-7530] For AEQ queue size, GEODE should return local size only

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.6.0
• Fix Version/s: 1.12.0
• Component/s: wan
• Labels: GeodeCommons
• Assignee: Ernest Burghardt
• Reporter: Eric Shu
• Created: 03/Dec/19 23:40
• Updated: 30/Mar/20 23:32
• Resolved: 05/Feb/20 20:37

Description

The following stack shows that current it does not.

[warn 2019/11/24 19:48:51.755 PST <ThreadsMonitor> tid=0x1f] Thread <96> (0x60) that was executed at <24 Nov 2019 19:47:30 PST> has been stuck for <81.69 seconds> and number of thread monitor iteration <1>
Thread Name <Event Processor for GatewaySender_AsyncEventQueue_index#_testRegion_0> state <TIMED_WAITING>
Waiting on <java.util.concurrent.CountDownLatch$Sync@607baea6>
Executor Group <GatewaySenderEventProcessor>
Monitored metric <ResourceManagerStats.numThreadsStuck>
Thread stack:
sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037)
java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328)
java.util.concurrent.CountDownLatch.await(CountDownLatch.java:277)
org.apache.geode.internal.util.concurrent.StoppableCountDownLatch.await(StoppableCountDownLatch.java:72)
org.apache.geode.distributed.internal.ReplyProcessor21.basicWait(ReplyProcessor21.java:731)
org.apache.geode.distributed.internal.ReplyProcessor21.waitForRepliesUninterruptibly(ReplyProcessor21.java:802)
org.apache.geode.distributed.internal.ReplyProcessor21.waitForRepliesUninterruptibly(ReplyProcessor21.java:779)
org.apache.geode.distributed.internal.ReplyProcessor21.waitForRepliesUninterruptibly(ReplyProcessor21.java:865)
org.apache.geode.internal.cache.partitioned.SizeMessage$SizeResponse.waitBucketSizes(SizeMessage.java:344)
org.apache.geode.internal.cache.PartitionedRegion.getSizeRemotely(PartitionedRegion.java:6718)
org.apache.geode.internal.cache.PartitionedRegion.entryCount(PartitionedRegion.java:6669)
org.apache.geode.internal.cache.PartitionedRegion.entryCount(PartitionedRegion.java:6651)
org.apache.geode.internal.cache.PartitionedRegion.getRegionSize(PartitionedRegion.java:6623)
org.apache.geode.internal.cache.LocalRegionDataView.entryCount(LocalRegionDataView.java:99)
org.apache.geode.internal.cache.LocalRegion.entryCount(LocalRegion.java:2078)
org.apache.geode.internal.cache.LocalRegion.size(LocalRegion.java:8262)
org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderQueue.size(ParallelGatewaySenderQueue.java:1502)
org.apache.geode.internal.cache.wan.AbstractGatewaySenderEventProcessor.eventQueueSize(AbstractGatewaySenderEventProcessor.java:271)
org.apache.geode.internal.cache.wan.AbstractGatewaySenderEventProcessor.handleSuccessfulBatchDispatch(AbstractGatewaySenderEventProcessor.java:969)
org.apache.geode.internal.cache.wan.AbstractGatewaySenderEventProcessor.processQueue(AbstractGatewaySenderEventProcessor.java:667)
org.apache.geode.internal.cache.wan.AbstractGatewaySenderEventProcessor.run(AbstractGatewaySenderEventProcessor.java:1111)

Issue Links

• links to: GitHub Pull Request #4424