status-im/nim-libp2p
2
0
Fork 0
mirror of https://github.com/status-im/nim-libp2p.git synced 2025-03-02 05:20:43 +00:00
Code Issues Projects Releases Wiki Activity

address review comments

Browse Source
This commit is contained in:
Tanguy 2022-06-20 15:44:02 +02:00
parent 9b7e1c6515
commit 40ab9ff6d1
No known key found for this signature in database
GPG Key ID: 7DD8EC6B6CE6C45E
1 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
libp2p/transports/quictransport.nim
View File

@ -44,14 +44,9 @@ method readOnce*(stream: QuicStream,
nbytes: int): Future[int] {.async.} = nbytes: int): Future[int] {.async.} =
if stream.cached.len == 0: if stream.cached.len == 0:
stream.cached = await mapExceptions(stream.stream.read()) stream.cached = await mapExceptions(stream.stream.read())
if stream.cached.len <= nbytes: result = min(nbytes, stream.cached.len)
copyMem(pbytes, addr stream.cached[0], stream.cached.len) copyMem(pbytes, addr stream.cached[0], result)
result = stream.cached.len stream.cached = stream.cached[result..^1]
stream.cached = @[]
else:
copyMem(pbytes, addr stream.cached[0], nbytes)
result = nbytes
stream.cached = stream.cached[nbytes..^1]
{.push warning[LockLevel]: off.} {.push warning[LockLevel]: off.}
method write*(stream: QuicStream, bytes: seq[byte]) {.async.} = method write*(stream: QuicStream, bytes: seq[byte]) {.async.} =