Created the pull request for the same.
https://github.com/apache/geode/pull/1139
Thanks,
Dinesh akhand
-Original Message-
From: Dan Smith [mailto:dsm...@pivotal.io]
Sent: Tuesday, July 18, 2017 3:59 AM
To: dev@geode.apache.org
Subject: Re: need information about
SerialGatewaySenderQueue/ParallelGatewaySenderQueue Clear
Hi Dinesh,
I think we probably just never got around to adding a clear. I think you could
probably clear your queues just stop stopping and starting the gateway sender,
which might be the easiest thing to do here.
Regarding your code, for your parallel queue are you doing that inside of a
function? The code you have will try to clear things on a single node. The
queue also maintains some other metadata in memory. I'm not quite sure what the
effect on the queue will be if you delete the region entries without changing
that other metadata. I guess you could test it and find out.
You'll probably want to see what the effect is while the queue is actually
dispatching entries as well, because it's possible you could catch the system
in a state where it is trying to read entries from the region as you are
deleting them. Or maybe pause the queue first in your clear method?
-Dan
On Fri, Jul 14, 2017 at 2:23 AM, Dinesh Akhand wrote:
> Hi Team,
>
>
>
> Please reply . why we don't have implementation of clear method in
> ParallelGatewaySenderQueue/ SerialGatewaySenderQueue in geode. Requirement:
> we want to clear the queue data.
>
>
>
> I have implement below method in our code.
>
> --
>
> Class ParallelGatewaySenderQueue.java
>
>
>
> //clear the partition region
>
> private void clearPartitionedRegion(PartitionedRegion
> partitionedRegion)
>
> {
>
> LocalDataSet lds = (LocalDataSet)
> PartitionRegionHelper.getLocalPrimaryData(partitionedRegion);
>
> Setset = lds.getBucketSet(); // this
> returns bucket ids in the function context
>
>
>
> for (Integer bucketId : set) {
>
> Bucket bucket = partitionedRegion.
> getRegionAdvisor().getBucket(bucketId);
>
> if (bucket instanceof
> ProxyBucketRegion == false) {
>
> if (bucket
> instanceof BucketRegion) {
>
>
> BucketRegion bucketRegion = (BucketRegion) bucket;
>
>
> Set keySet = bucketRegion.keySet();
>
>
> for (Iterator iterator = keySet.iterator(); iterator.hasNext();)
> {
>
>
> Object key = iterator.next();
>
>
> bucketRegion.remove(key);
>
>
> }
>
> }
>
> }
>
> }
>
> }
>
> -
>
> Class : SerialGatewaySenderQueue.java
>
> @Override
>
> public void clearQueue() {
>
>
>
> this.sender.getLifeCycleLock().readLock().lock();
>
> Set keys = this.region.keys();
>
> for (Long key : keys) {
>
> this.region.remove(key);
>
> }
>
> this.sender.getLifeCycleLock().readLock().unlock();
>
>
>
> }
>
> -
>
>
>
> Any comment in above code will welcome.
>
>
>
>
>
> Thanks,
>
> Dinesh Akhand
>
>
>
> -Original Message-
> From: Dinesh Akhand
> Sent: Monday, May 15, 2017 2:39 PM
> To: dev@geode.apache.org
> Subject: need information about RegionQueue
>
>
>
>
>
> Hi Team,
>
>
>
> Why we do't have support to clear complete queue. Is there any
> limitation for it?.
>
>
>
> public void clear(PartitionedRegion pr, int bucketId) {
>
>throw new RuntimeException("This method(clear)is not supported
> by ParallelGatewaySenderQueue");
>
> }
>
>
>
> Class : ParallelGatewaySenderQueue
>
> Class : SerialGatewaySenderQueue
>
>
>
> 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>
> 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>
>
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
