You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2017/03/17 14:51:04 UTC
[4/6] ignite git commit: Done.
Done.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/19381da3
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/19381da3
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/19381da3
Branch: refs/heads/ignite-4565-ddl
Commit: 19381da3961cbd2fee4f36c2b08638d507b0741c
Parents: e2f382b
Author: devozerov <vo...@gridgain.com>
Authored: Fri Mar 17 16:41:35 2017 +0300
Committer: devozerov <vo...@gridgain.com>
Committed: Fri Mar 17 16:41:35 2017 +0300
----------------------------------------------------------------------
.../cache/GridCachePartitionExchangeManager.java | 15 +++++++++++++--
1 file changed, 13 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/19381da3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
index 26bc27d..1ce8cfe 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
@@ -687,6 +687,17 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana
}
/**
+ * Add custom task.
+ *
+ * @param task Task.
+ */
+ public void addCustomTask(CachePartitionExchangeWorkerTask task) {
+ assert !task.isExchange();
+
+ exchWorker.addCustomTask(task);
+ }
+
+ /**
* @param evt Discovery event.
* @return Affinity topology version.
*/
@@ -818,8 +829,8 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana
@Nullable GridCacheVersion lastVer,
boolean compress) {
GridDhtPartitionsFullMessage m = new GridDhtPartitionsFullMessage(exchId,
- lastVer,
- exchId != null ? exchId.topologyVersion() : AffinityTopologyVersion.NONE);
+ lastVer,
+ exchId != null ? exchId.topologyVersion() : AffinityTopologyVersion.NONE);
boolean useOldApi = false;