You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2019/02/24 17:40:38 UTC
[ignite] branch ignite-invokeAll-backup updated: invokeAll
This is an automated email from the ASF dual-hosted git repository.
sboikov pushed a commit to branch ignite-invokeAll-backup
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/ignite-invokeAll-backup by this push:
new 068a40f invokeAll
068a40f is described below
commit 068a40f430cee7c4fd16eae02731d5fc1c3b2ce5
Author: sboikov <sb...@apache.org>
AuthorDate: Sun Feb 24 20:38:51 2019 +0300
invokeAll
---
.../processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java
index cf23e25..c24a91f 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java
@@ -3600,11 +3600,11 @@ public class GridDhtAtomicCache<K, V> extends GridDhtCacheAdapter<K, V> {
try {
List<SearchRowEx<AtomicCacheUpdateClosure>> locked = new ArrayList<>(batchSize);
- SearchRowEx<AtomicCacheUpdateClosure> prev = null;
+ while (true) {
+ SearchRowEx<AtomicCacheUpdateClosure> prev = null;
- GridDhtLocalPartition part = null;
+ GridDhtLocalPartition part = null;
- while (true) {
for (int i = 0; i < batchSize; i++) {
int idx = batchStart + i;