ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [26/46] ignite git commit: 2.1 Removed extra add in pendingMsgs
Date Fri, 07 Jul 2017 09:34:29 GMT
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 <sboikov@gridgain.com>
Authored: Thu Jul 6 11:11:38 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
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() {


Mime
View raw message