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

remove unnecesary async lock

This commit is contained in:
Dmitriy Ryajov 2020-02-12 17:36:53 -05:00
parent 934c858542
commit f767614827
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
libp2p/muxers/mplex/lpchannel.nim
View File

@ -33,7 +33,6 @@ type
msgCode*: MessageType msgCode*: MessageType
closeCode*: MessageType closeCode*: MessageType
resetCode*: MessageType resetCode*: MessageType
asyncLock: AsyncLock
proc newChannel*(id: uint, proc newChannel*(id: uint,
conn: Connection, conn: Connection,
@ -49,19 +48,16 @@ proc newChannel*(id: uint,
result.msgCode = if initiator: MessageType.MsgOut else: MessageType.MsgIn result.msgCode = if initiator: MessageType.MsgOut else: MessageType.MsgIn
result.closeCode = if initiator: MessageType.CloseOut else: MessageType.CloseIn result.closeCode = if initiator: MessageType.CloseOut else: MessageType.CloseIn
result.resetCode = if initiator: MessageType.ResetOut else: MessageType.ResetIn result.resetCode = if initiator: MessageType.ResetOut else: MessageType.ResetIn
result.asyncLock = newAsyncLock()
result.isLazy = lazy result.isLazy = lazy
let chan = result let chan = result
proc writeHandler(data: seq[byte]): Future[void] {.async.} = proc writeHandler(data: seq[byte]): Future[void] {.async.} =
# writes should happen in sequence # writes should happen in sequence
await chan.asyncLock.acquire()
trace "sending data ", data = data.toHex(), trace "sending data ", data = data.toHex(),
id = chan.id, id = chan.id,
initiator = chan.initiator initiator = chan.initiator
await conn.writeMsg(chan.id, chan.msgCode, data) # write header await conn.writeMsg(chan.id, chan.msgCode, data) # write header
chan.asyncLock.release()
result.initBufferStream(writeHandler, size) result.initBufferStream(writeHandler, size)