# IGNITE-489 Check recordable of EVT_CACHE_REBALANCE_PART_DATA_LOST before send.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/5b0a5f38 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/5b0a5f38 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/5b0a5f38 Branch: refs/heads/sprint-3 Commit: 5b0a5f3878e82dce23b35815ed738d2d12f8e825 Parents: 7d8ad6e Author: sevdokimov <sevdoki...@gridgain.com> Authored: Wed Mar 25 16:21:48 2015 +0300 Committer: sevdokimov <sevdoki...@gridgain.com> Committed: Wed Mar 25 16:21:48 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/GridDhtPartitionTopologyImpl.java | 8 +++++--- .../dht/preloader/GridDhtPartitionDemandPool.java | 8 +++++--- 2 files changed, 10 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/5b0a5f38/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java index 02d2511..593c463 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java @@ -442,9 +442,11 @@ class GridDhtPartitionTopologyImpl<K, V> implements GridDhtPartitionTopology { changed = true; - cctx.events().addEvent(p, null, cctx.localNodeId(), (IgniteUuid)null, - null, EVT_CACHE_REBALANCE_PART_DATA_LOST, null, false, null, - false, null, null, null); + if (cctx.events().isRecordable(EVT_CACHE_REBALANCE_PART_DATA_LOST)) { + cctx.events().addEvent(p, null, cctx.localNodeId(), (IgniteUuid)null, + null, EVT_CACHE_REBALANCE_PART_DATA_LOST, null, false, null, + false, null, null, null); + } if (log.isDebugEnabled()) log.debug("Owned partition: " + locPart); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/5b0a5f38/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandPool.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandPool.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandPool.java index 3920e73..7d7f3b0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandPool.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandPool.java @@ -1041,9 +1041,11 @@ public class GridDhtPartitionDemandPool<K, V> { if (picked.isEmpty()) { top.own(part); - cctx.events().addEvent(p, null, cctx.localNodeId(), (IgniteUuid)null, - null, EVT_CACHE_REBALANCE_PART_DATA_LOST, null, false, null, - false, null, null, null); + if (cctx.events().isRecordable(EVT_CACHE_REBALANCE_PART_DATA_LOST)) { + cctx.events().addEvent(p, null, cctx.localNodeId(), (IgniteUuid)null, + null, EVT_CACHE_REBALANCE_PART_DATA_LOST, null, false, null, + false, null, null, null); + } if (log.isDebugEnabled()) log.debug("Owning partition as there are no other owners: " + part);
