sends -> replies
This commit is contained in:
parent
35e47e0d3e
commit
49bebb5520
|
@ -123,7 +123,7 @@ proc onClientReceive(stream: ptr quicly_stream_t, offset: csize_t,
|
||||||
let msg = newString(input.len)
|
let msg = newString(input.len)
|
||||||
copyMem(msg.cstring, input.base, input.len)
|
copyMem(msg.cstring, input.base, input.len)
|
||||||
let conn = cast[Connection](quicly_get_data(stream.conn)[])
|
let conn = cast[Connection](quicly_get_data(stream.conn)[])
|
||||||
echo &"server {conn.getPeerId()} sends \"{msg}\""
|
echo &"server {conn.getPeerId()} replies \"{msg}\""
|
||||||
if quicly_recvstate_transfer_complete(addr stream.recvstate) != 0:
|
if quicly_recvstate_transfer_complete(addr stream.recvstate) != 0:
|
||||||
discard quicly_close(stream.conn, 0, "")
|
discard quicly_close(stream.conn, 0, "")
|
||||||
quicly_streambuf_ingress_shift(stream, input.len)
|
quicly_streambuf_ingress_shift(stream, input.len)
|
||||||
|
|
Loading…
Reference in New Issue