ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [09/35] incubator-ignite git commit: # IGNITE-489 Check recordable of EVT_CACHE_REBALANCE_PART_DATA_LOST before send.
Date Fri, 27 Mar 2015 06:14:15 GMT
# 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 <sevdokimov@gridgain.com>
Authored: Wed Mar 25 16:21:48 2015 +0300
Committer: sevdokimov <sevdokimov@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);


Mime
View raw message