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

fix: reset accept fut in stop (#1082) 

Co-authored-by: diegomrsantos <diego@status.im>
This commit is contained in:
Ivan FB 2024-04-17 22:44:41 +02:00 committed by GitHub
parent 89cad5a3ba
commit b30b2656d5
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
libp2p/transports/tcptransport.nim
View File

@ -190,6 +190,7 @@ method stop*(self: TcpTransport) {.async.} =
await allFutures(toWait) await allFutures(toWait)
self.servers = @[] self.servers = @[]
self.acceptFuts = @[]
trace "Transport stopped" trace "Transport stopped"
untrackCounter(TcpTransportTrackerName) untrackCounter(TcpTransportTrackerName)
@ -221,6 +222,7 @@ method accept*(self: TcpTransport): Future[Connection] {.async.} =
let observedAddr = MultiAddress.init(transp.remoteAddress).tryGet() let observedAddr = MultiAddress.init(transp.remoteAddress).tryGet()
return await self.connHandler(transp, Opt.some(observedAddr), Direction.In) return await self.connHandler(transp, Opt.some(observedAddr), Direction.In)
except CancelledError as exc: except CancelledError as exc:
debug "CancelledError", exc = exc.msg
transp.close() transp.close()
raise exc raise exc
except CatchableError as exc: except CatchableError as exc: