Fix yamux simultaneous closing (#823)

2022-12-16 18:14:40 +01:00 · 2022-12-16 18:14:40 +01:00 · 63e1872516
parent 67ef25fae0
commit 63e1872516
1 changed files with 2 additions and 1 deletions
--- a/libp2p/muxers/yamux/yamux.nim
+++ b/libp2p/muxers/yamux/yamux.nim
@ -414,7 +414,8 @@ method close*(m: Yamux) {.async.} =
  let channels = toSeq(m.channels.values())
  for channel in channels:
    await channel.reset(true)
-  await m.connection.write(YamuxHeader.goAway(NormalTermination))
+  try: await m.connection.write(YamuxHeader.goAway(NormalTermination))
+  except CatchableError as exc: trace "failed to send goAway", msg=exc.msg
  await m.connection.close()
  trace "Closed yamux"