vacp2p/nim-libp2p-experimental
1
0
Fork 0
mirror of https://github.com/vacp2p/nim-libp2p-experimental.git synced 2025-01-27 02:25:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

no more buffer resets on len prefixed reads

Browse Source
This commit is contained in:
Dmitriy Ryajov 2019-09-25 12:53:31 -06:00
parent dd3f85965b
commit 5ae37cac98
2 changed files with 0 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
libp2p/connection.nim
View File

@ -92,7 +92,6 @@ proc readLp*(s: Connection): Future[seq[byte]] {.async, gcsafe.} =
if res == VarintStatus.Success: if res == VarintStatus.Success:
break break
if res != VarintStatus.Success or size > DefaultReadSize: if res != VarintStatus.Success or size > DefaultReadSize:
buffer.setLen(0)
result = buffer result = buffer
return return
buffer.setLen(size) buffer.setLen(size)

1
libp2p/muxers/mplex/coder.nim
View File

@ -38,7 +38,6 @@ proc readMplexVarint(conn: Connection): Future[Option[uint]] {.async, gcsafe.} =
if res == VarintStatus.Success: if res == VarintStatus.Success:
return some(varint) return some(varint)
if res != VarintStatus.Success: if res != VarintStatus.Success:
buffer.setLen(0)
return return
except LPStreamIncompleteError: except LPStreamIncompleteError:
debug "unable to read varing", exc = getCurrentExceptionMsg() debug "unable to read varing", exc = getCurrentExceptionMsg()