Darrel Schneider created GEODE-1282:
---------------------------------------
Summary: missing release of GatewaySenderEventImpl when it is
removed from tempQueue
Key: GEODE-1282
URL: https://issues.apache.org/jira/browse/GEODE-1282
Project: Geode
Issue Type: Bug
Components: offheap
Reporter: Darrel Schneider
This code might be the cause of off-heap orphans in gateway tests:
com.gemstone.gemfire.internal.cache.wan.parallel.ParallelQueueRemovalMessage.destroyFromTempQueue(PartitionedRegion,
int, Object)
BlockingQueue<GatewaySenderEventImpl> tempQueue = prq
.getBucketTmpQueue(bId);
if (tempQueue != null) {
Iterator<GatewaySenderEventImpl> itr = tempQueue.iterator();
while (itr.hasNext()) {
GatewaySenderEventImpl eventForFilter = itr.next();
//fix for #48082
afterAckForSecondary_EventInTempQueue(qPR.getParallelGatewaySender(),
eventForFilter);
if (eventForFilter.getShadowKey().equals(key)) {
itr.remove();
isDestroyed = true;
}
}
}
The bug is when it does "itr.remove();". It needs to also do
"eventForFilter.release();".
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
