samples: Fix echo server

This commit is contained in:
Ilya Matveev
2017-10-24 16:44:49 +03:00
committed by ilmat192
parent 0863f8e3c9
commit 09b1f09071
+3 -3
View File
@@ -54,14 +54,14 @@ fun main(args: Array<String>) {
buffer.usePinned { pinned ->
while (true) {
val length = recv(commFd, pinned.addressOf(0), buffer.size, 0)
val length = recv(commFd, pinned.addressOf(0), buffer.size.signExtend(), 0)
.ensureUnixCallResult("read") { it >= 0 }
if (length == 0) {
if (length == 0L) {
break
}
send(commFd, prefixBuffer.refTo(0), prefixBuffer.size, 0)
send(commFd, prefixBuffer.refTo(0), prefixBuffer.size.signExtend(), 0)
.ensureUnixCallResult("write") { it >= 0 }
send(commFd, pinned.addressOf(0), length, 0)
.ensureUnixCallResult("write") { it >= 0 }