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

close connections

This commit is contained in:
Dmitriy Ryajov 2020-04-04 20:43:23 -06:00
parent bae4713a85
commit 87b35de83e
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
libp2p/protocols/secure/secio.nim
View File

@ -281,11 +281,11 @@ proc transactMessage(conn: Connection,
else: else:
trace "Received size of message exceed limits", conn = $conn, trace "Received size of message exceed limits", conn = $conn,
length = length length = length
except AsyncStreamIncompleteError: except LPStreamIncompleteError:
trace "Connection dropped while reading", conn = $conn trace "Connection dropped while reading", conn = $conn
except AsyncStreamReadError: except LPStreamReadError:
trace "Error reading from connection", conn = $conn trace "Error reading from connection", conn = $conn
except AsyncStreamWriteError: except LPStreamWriteError:
trace "Could not write to connection", conn = $conn trace "Could not write to connection", conn = $conn
method handshake*(s: Secio, conn: Connection, initiator: bool = false): Future[SecureConn] {.async.} = method handshake*(s: Secio, conn: Connection, initiator: bool = false): Future[SecureConn] {.async.} =

4
libp2p/protocols/secure/secure.nim
View File

@ -47,12 +47,14 @@ proc readLoop(sconn: SecureConn, conn: Connection) {.async.} =
except CatchableError as exc: except CatchableError as exc:
trace "Exception occurred Secure.readLoop", exc = exc.msg trace "Exception occurred Secure.readLoop", exc = exc.msg
finally: finally:
trace "closing conn", closed = conn.closed()
if not conn.closed: if not conn.closed:
await conn.close() await conn.close()
trace "closing sconn", closed = sconn.closed()
if not sconn.closed: if not sconn.closed:
await sconn.close() await sconn.close()
trace "ending Secure readLoop", isclosed = sconn.closed() trace "ending Secure readLoop"
proc handleConn*(s: Secure, conn: Connection, initiator: bool = false): Future[Connection] {.async, gcsafe.} = proc handleConn*(s: Secure, conn: Connection, initiator: bool = false): Future[Connection] {.async, gcsafe.} =
var sconn = await s.handshake(conn, initiator) var sconn = await s.handshake(conn, initiator)