Whitespace
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/3783f4e6 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/3783f4e6 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/3783f4e6 Branch: refs/heads/master Commit: 3783f4e6669d185d5a0fd42468347238350c2774 Parents: 11886c0 Author: Kyle Nusbaum <[email protected]> Authored: Tue Sep 1 12:37:01 2015 -0500 Committer: Kyle Nusbaum <[email protected]> Committed: Tue Sep 1 12:37:01 2015 -0500 ---------------------------------------------------------------------- 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/3783f4e6/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);
