Eric Shu created GEODE-7530: ------------------------------- Summary: For AEQ queue size, GEODE should return local size only Key: GEODE-7530 URL: https://issues.apache.org/jira/browse/GEODE-7530 Project: Geode Issue Type: Bug Components: wan Reporter: Eric Shu
The following stack shows that current it does not. {noformat} [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) {noformat} -- This message was sent by Atlassian Jira (v8.3.4#803005)