use fixed size buffer for control messages

smtp2006 · May 11, 2013 · 687cc25 · 687cc25
1 parent 2718142
commit 687cc25
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/storm-netty/src/jvm/backtype/storm/messaging/netty/ControlMessage.java b/storm-netty/src/jvm/backtype/storm/messaging/netty/ControlMessage.java
@@ -31,11 +31,10 @@ static ControlMessage mkMessage(short encoded) {
 
     /**
      * encode the current Control Message into a channel buffer
-     * @param bout
      * @throws Exception
      */
     ChannelBuffer buffer() throws Exception {
-        ChannelBufferOutputStream bout = new ChannelBufferOutputStream(ChannelBuffers.dynamicBuffer());      
+        ChannelBufferOutputStream bout = new ChannelBufferOutputStream(ChannelBuffers.buffer(2));      
         write(bout);
         bout.close();
         return bout.buffer();