geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aging...@apache.org
Subject [06/50] [abbrv] incubator-geode git commit: GEODE-1282: fix wan off-heap leak
Date Tue, 17 May 2016 00:38:15 GMT
GEODE-1282: fix wan off-heap leak

destroyFromTempQueue now releases GatewaySenderEventImpl when it is removed from the tempQueue


Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/1db55d88
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/1db55d88
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/1db55d88

Branch: refs/heads/feature/GEODE-1209
Commit: 1db55d88473f19166d3665477ff7d65548d40652
Parents: 03a7389
Author: Darrel Schneider <dschneider@pivotal.io>
Authored: Mon May 9 10:23:25 2016 -0700
Committer: Anil <agingade@pivotal.io>
Committed: Mon May 16 17:31:53 2016 -0700

----------------------------------------------------------------------
 .../internal/cache/wan/parallel/ParallelQueueRemovalMessage.java    | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1db55d88/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelQueueRemovalMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelQueueRemovalMessage.java
b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelQueueRemovalMessage.java
index 09f70a6..14d2f20 100644
--- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelQueueRemovalMessage.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelQueueRemovalMessage.java
@@ -237,6 +237,7 @@ public class ParallelQueueRemovalMessage extends PooledDistributionMessage
{
           afterAckForSecondary_EventInTempQueue(qPR.getParallelGatewaySender(), eventForFilter);
           if (eventForFilter.getShadowKey().equals(key)) {
             itr.remove();
+            eventForFilter.release(); // GEODE-1282
             isDestroyed = true;
           }
         }


Mime
View raw message