You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2015/09/05 03:59:12 UTC
[2/3] storm git commit: Whitespace
Whitespace
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/79ec4181
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/79ec4181
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/79ec4181
Branch: refs/heads/0.10.x-branch
Commit: 79ec418106db7d3a36fe48edfb8ead0f1b3179ff
Parents: fc00ca4
Author: Kyle Nusbaum <Ky...@gmail.com>
Authored: Tue Sep 1 12:37:01 2015 -0500
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Sat Sep 5 10:49:41 2015 +0900
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/messaging/netty/Client.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/79ec4181/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
index 8300b1a..08f5d2a 100644
--- a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
+++ b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
@@ -123,7 +123,7 @@ public class Client extends ConnectionWithStatus implements IStatefulObject {
private final MessageBuffer batcher;
private final Object writeLock = new Object();
-
+
@SuppressWarnings("rawtypes")
Client(Map stormConf, ChannelFactory factory, HashedWheelTimer scheduler, String host, int port, Context context) {
this.stormConf = stormConf;
@@ -256,7 +256,7 @@ public class Client extends ConnectionWithStatus implements IStatefulObject {
}
}
}
-
+
if(channel.isWritable()){
synchronized (writeLock) {
// Netty's internal buffer is not full and we still have message left in the buffer.
@@ -320,7 +320,7 @@ public class Client extends ConnectionWithStatus implements IStatefulObject {
if(batch.isEmpty()){
return;
}
-
+
final int numMessages = batch.size();
LOG.debug("writing {} messages to channel {}", batch.size(), channel.toString());
pendingMessages.addAndGet(numMessages);