You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2018/08/22 15:07:34 UTC
ignite git commit: IGNITE-9273 Do not touch topology for LOCAL cache
Repository: ignite
Updated Branches:
refs/heads/ignite-9273 3c3fe20c6 -> 74991e14f
IGNITE-9273 Do not touch topology for LOCAL cache
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/74991e14
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/74991e14
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/74991e14
Branch: refs/heads/ignite-9273
Commit: 74991e14f6da5c3de47e0f8af80870e683310877
Parents: 3c3fe20
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Wed Aug 22 18:07:24 2018 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Wed Aug 22 18:07:24 2018 +0300
----------------------------------------------------------------------
.../internal/processors/cache/IgniteCacheOffheapManagerImpl.java | 2 +-
.../cache/persistence/GridCacheDatabaseSharedManager.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/74991e14/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java
index 5482b3a..17aa9e6 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java
@@ -252,7 +252,7 @@ public class IgniteCacheOffheapManagerImpl implements IgniteCacheOffheapManager
* @param part Partition.
* @return Data store for given entry.
*/
- public CacheDataStore dataStore(GridDhtLocalPartition part) {
+ @Override public CacheDataStore dataStore(GridDhtLocalPartition part) {
if (grp.isLocal())
return locCacheDataStore;
else {
http://git-wip-us.apache.org/repos/asf/ignite/blob/74991e14/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java
index fa1d4c3..f73fc78 100755
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java
@@ -2458,7 +2458,7 @@ public class GridCacheDatabaseSharedManager extends IgniteCacheDatabaseSharedMan
if (partId == -1)
partId = cacheCtx.affinity().partition(dataEntry.key());
- GridDhtLocalPartition locPart = cacheCtx.topology().forceCreatePartition(partId);
+ GridDhtLocalPartition locPart = cacheCtx.isLocal() ? null : cacheCtx.topology().forceCreatePartition(partId);
switch (dataEntry.op()) {
case CREATE: