Performance improvement, moving write and flush out of enframed and i…

…nto framed write itself
Verizon · Apr 5, 2016 · cfd262b · cfd262b
1 parent d9eb5c9
commit cfd262b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/core/src/main/scala/transport/netty/Client.scala b/core/src/main/scala/transport/netty/Client.scala
@@ -70,7 +70,7 @@ object NettyTransport {
                    })
   }
 
-  def write(c: Channel)(frame: Framed): Task[Unit] = evalCF(c.write(frame))
+  def write(c: Channel)(frame: Framed): Task[Unit] = evalCF(c.writeAndFlush(frame))
 
   def single(host: InetSocketAddress,
              expectedSigs: Set[Signature] = Set.empty,

diff --git a/core/src/main/scala/transport/netty/Transport.scala b/core/src/main/scala/transport/netty/Transport.scala
@@ -126,7 +126,7 @@ class Deframe extends ByteToMessageDecoder {
           } else {
             remaining = Some(rem)
           }
-        } 
+        }
       case Some(rem) =>
         // we are waiting for at least rem more bytes, as that is what
         // is outstanding in the current frame
@@ -177,9 +177,9 @@ object Enframe extends ChannelOutboundHandlerAdapter {
     obj match {
       case Bits(bv) =>
         val byv = bv.toByteVector
-        val _ = ctx.writeAndFlush(Unpooled.wrappedBuffer((codecs.int32.encode(byv.size).require ++ bv).toByteBuffer), cp)
+        val _ = ctx.write(Unpooled.wrappedBuffer((codecs.int32.encode(byv.size).require ++ bv).toByteBuffer), cp)
       case EOS =>
-        val _ = ctx.writeAndFlush(Unpooled.wrappedBuffer(codecs.int32.encode(0).require.toByteBuffer), cp)
+        val _ = ctx.write(Unpooled.wrappedBuffer(codecs.int32.encode(0).require.toByteBuffer), cp)
       case x => throw new IllegalArgumentException("was expecting Framed, got: " + x)
     }
   }