Whitespace
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/5ce3f11f Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/5ce3f11f Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/5ce3f11f Branch: refs/heads/0.9.x-branch Commit: 5ce3f11f3184cd27b62492cffc28b6c32a7b8069 Parents: 8a29593 Author: Kyle Nusbaum <[email protected]> Authored: Tue Sep 1 12:37:01 2015 -0500 Committer: Jungtaek Lim <[email protected]> Committed: Sat Oct 17 23:11:55 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/5ce3f11f/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 56ed300..0bb28fd 100644 --- a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java +++ b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java @@ -120,7 +120,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) { closing = false; @@ -251,7 +251,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. @@ -315,7 +315,7 @@ public class Client extends ConnectionWithStatus implements IStatefulObject { if (null == batch || batch.isEmpty()) { return; } - + final int numMessages = batch.size(); LOG.debug("writing {} messages to channel {}", batch.size(), channel.toString()); pendingMessages.addAndGet(numMessages);
