vacp2p
/
nim-libp2p
mirror of https://github.com/vacp2p/nim-libp2p.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

don't reset buffer on exception

This commit is contained in:
Dmitriy Ryajov 2019-09-25 12:41:57 -06:00
parent 6baf089bb4
commit 99869aa8b8
2 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
libp2p/connection.nim
View File

@ -100,7 +100,6 @@ proc readLp*(s: Connection): Future[seq[byte]] {.async, gcsafe.} =
await s.readExactly(addr buffer[0], int(size)) await s.readExactly(addr buffer[0], int(size))
except LPStreamIncompleteError, LPStreamReadError: except LPStreamIncompleteError, LPStreamReadError:
error "readLp: could not read from remote", exception = getCurrentExceptionMsg() error "readLp: could not read from remote", exception = getCurrentExceptionMsg()
buffer.setLen(0)
result = buffer result = buffer

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

@ -41,7 +41,7 @@ proc readMplexVarint(conn: Connection): Future[Option[uint]] {.async, gcsafe.} =
buffer.setLen(0) buffer.setLen(0)
return return
except LPStreamIncompleteError: except LPStreamIncompleteError:
buffer.setLen(0) debug "unable to read varing", exc = getCurrentExceptionMsg()
proc readMsg*(conn: Connection): Future[Option[Msg]] {.async, gcsafe.} = proc readMsg*(conn: Connection): Future[Option[Msg]] {.async, gcsafe.} =
let headerVarint = await conn.readMplexVarint() let headerVarint = await conn.readMplexVarint()