Hi All, Is there any geode test class which populate data in *ParallelGatewaySenderQueue and create some back log. * Insert/remove operation i can test.
Thanks, Dinesh Akhand On Fri, Oct 27, 2017 at 9:24 PM, Dinesh Akhand <dines...@amdocs.com> wrote: > Any one suggest about below exception: > > at org.apache.geode.internal.cache.DiskEntry$Helper. > removeFromDisk(DiskEntry.java:1505) > at org.apache.geode.internal.cache.AbstractOplogDiskRegionEntry. > removePhase1(AbstractOplogDiskRegionEntry.java:42) > at org.apache.geode.internal.cache.AbstractRegionEntry. > destroy(AbstractRegionEntry.java:896) > at org.apache.geode.internal.cache.AbstractRegionMap.destroyEntry( > AbstractRegionMap.java:3084) > at org.apache.geode.internal.cache.AbstractRegionMap. > destroy(AbstractRegionMap.java:1422) > at org.apache.geode.internal.cache.LocalRegion.mapDestroy( > LocalRegion.java:6566) > at org.apache.geode.internal.cache.LocalRegion.mapDestroy( > LocalRegion.java:6540) > at org.apache.geode.internal.cache.BucketRegion. > basicDestroy(BucketRegion.java:1183) > at org.apache.geode.internal.cache.AbstractBucketRegionQueue. > basicDestroy(AbstractBucketRegionQueue.java:352) > at org.apache.geode.internal.cache.BucketRegionQueue.basicDestroy( > BucketRegionQueue.java:363) > at org.apache.geode.internal.cache.LocalRegion. > validatedDestroy(LocalRegion.java:1111) > at org.apache.geode.internal.cache.DistributedRegion. > validatedDestroy(DistributedRegion.java:904) > at org.apache.geode.internal.cache.LocalRegion.destroy( > LocalRegion.java:1096) > at org.apache.geode.internal.cache.AbstractRegion.destroy( > AbstractRegion.java:315) > at org.apache.geode.internal.cache.LocalRegion.remove( > LocalRegion.java:8976) > at org.apache.geode.internal.cache.wan.parallel. > ParallelGatewaySenderQueue.clearPartitionedRegion( > ParallelGatewaySenderQueue.java:1830) > at org.apache.geode.internal.cache.wan.parallel. > ParallelGatewaySenderQueue.clearQueue(ParallelGatewaySenderQueue. > java:1800) > at org.apache.geode.internal.cache.wan.parallel. > ConcurrentParallelGatewaySenderQueue.clearQueue( > ConcurrentParallelGatewaySenderQueue.java:237) > at org.apa > > In geode 1.1 Clear queue function is working correctly for us. > But with same configuration in geode 1.2 is not working. > > I tried to add the debug log and printed disk region which is created > inside the LocalRegion.java, diskregion is not null. > > [info 2017/10/27 12:26:43.196 IDT eaasrt-server1 <Pooled Waiting Message > Processor 3> tid=0xf2] akhand diskregion/__PR/_B__AsyncEventQueue > __PWInfoQueue__PARALLEL__GATEWAY__SENDER__QUEUE_4fullpath:=/__PR/_B__ > AsyncEventQueue__PWInfoQueue__PARALLEL__GATEWAY__SENDER__QUEUE_4isuse > > Which is not Null , also DiskStoreImpl is Not null > > info 2017/10/27 13:59:36.407 IDT eaasrt-server1 <Pooled Waiting Message > Processor 2> tid=0xe8] akhand diskregion/__PR/_B__AsyncEventQueue > __PWInfoQueue__PARALLEL__GATEWAY__SENDER__QUEUE_109fullpath:=/__PR/_B__ > AsyncEventQueue__PWInfoQueue__PARALLEL__GATEWAY__SENDER__QUEUE_109i > suse:false,dsi:PWInfo-queue-overflow > > Thanks, > Dinesh Akhand > This message and the information contained herein is proprietary and > confidential and subject to the Amdocs policy statement, > > you may review at https://www.amdocs.com/about/email-disclaimer < > https://www.amdocs.com/about/email-disclaimer> >
