2.1 Removed extra add in pendingMsgs
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/907d4a8e Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/907d4a8e Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/907d4a8e Branch: refs/heads/ignite-2.1 Commit: 907d4a8e04ee96b78d4e53db69acf13d00798c91 Parents: dd30e58 Author: sboikov <[email protected]> Authored: Thu Jul 6 11:11:38 2017 +0300 Committer: sboikov <[email protected]> Committed: Thu Jul 6 11:11:38 2017 +0300 ---------------------------------------------------------------------- .../ignite/internal/processors/cache/GridCacheIoManager.java | 5 ----- 1 file changed, 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/907d4a8e/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java index f9d1114..1d2be13 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java @@ -244,11 +244,6 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter { final int stripe = curThread instanceof IgniteThread ? ((IgniteThread)curThread).stripe() : -1; - synchronized (pendingMsgs) { - if (pendingMsgs.size() < 100) - pendingMsgs.add(cacheMsg); - } - fut.listen(new CI1<IgniteInternalFuture<?>>() { @Override public void apply(IgniteInternalFuture<?> t) { Runnable c = new Runnable() {
