aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJakob Odersky <jodersky@gmail.com>2014-04-03 19:22:59 +0200
committerJakob Odersky <jodersky@gmail.com>2014-04-03 19:22:59 +0200
commitd6d266693f2ab81db6abc35b28f00f1d72282338 (patch)
tree1732c5244f4225820ab976e29cefab1c8cc231fc
parentbd33e17b3a11008cf3415d6dfc01f237f197bfe2 (diff)
downloadakka-serial-d6d266693f2ab81db6abc35b28f00f1d72282338.tar.gz
akka-serial-d6d266693f2ab81db6abc35b28f00f1d72282338.tar.bz2
akka-serial-d6d266693f2ab81db6abc35b28f00f1d72282338.zip
fix: sending excessive, empty bytes
-rw-r--r--flow/src/main/scala/com/github/jodersky/flow/internal/SerialConnection.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/flow/src/main/scala/com/github/jodersky/flow/internal/SerialConnection.scala b/flow/src/main/scala/com/github/jodersky/flow/internal/SerialConnection.scala
index 3bdc7ec..74b7f23 100644
--- a/flow/src/main/scala/com/github/jodersky/flow/internal/SerialConnection.scala
+++ b/flow/src/main/scala/com/github/jodersky/flow/internal/SerialConnection.scala
@@ -103,8 +103,8 @@ class SerialConnection private (
writing = true
try {
transfer(
- b => NativeSerial.writeDirect(pointer, b, b.remaining()),
- b => NativeSerial.write(pointer, b.array(), b.remaining()))(buffer)
+ b => NativeSerial.writeDirect(pointer, b, b.position()),
+ b => NativeSerial.write(pointer, b.array(), b.position()))(buffer)
} finally {
writing = false
if (closed.get) writeLock.notify()