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 <[email protected]> Authored: Tue Sep 1 12:37:01 2015 -0500 Committer: Jungtaek Lim <[email protected]> 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);
