ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yzhda...@apache.org
Subject ignite git commit: ignite-5658 disabling striped pool for benchmarks
Date Tue, 01 Aug 2017 07:38:52 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-5658 b16455779 -> e9b851ae4


ignite-5658 disabling striped pool for benchmarks


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e9b851ae
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e9b851ae
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e9b851ae

Branch: refs/heads/ignite-5658
Commit: e9b851ae49a4aaebc8eae8161e76a0389edfc8ec
Parents: b164557
Author: Yakov Zhdanov <yzhdanov@gridgain.com>
Authored: Tue Aug 1 10:38:43 2017 +0300
Committer: Yakov Zhdanov <yzhdanov@gridgain.com>
Committed: Tue Aug 1 10:38:43 2017 +0300

----------------------------------------------------------------------
 .../internal/processors/datastreamer/DataStreamerImpl.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/e9b851ae/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
index 6e9fbb5..9d56668 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
@@ -1716,8 +1716,8 @@ public class DataStreamerImpl<K, V> implements IgniteDataStreamer<K,
V>, Delayed
                     rcvr == ISOLATED_UPDATER ? partId : GridIoMessage.STRIPE_DISABLED_PART);
 
                 try {
-                    ctx.io().sendToGridTopic(node, TOPIC_DATASTREAM, req,
-                        req.partition() == GridIoMessage.STRIPE_DISABLED_PART ? plc : GridIoPolicy.SYSTEM_POOL);
+                    ctx.io().sendToGridTopic(node, TOPIC_DATASTREAM, req, plc); // TODO
+//                        req.partition() == GridIoMessage.STRIPE_DISABLED_PART ? plc : GridIoPolicy.SYSTEM_POOL);
 
                     if (log.isDebugEnabled())
                         log.debug("Sent request to node [nodeId=" + node.id() + ", req="
+ req + ']');


Mime
View raw message