mirrors/bitcoin-s
1
0
Fork 0
mirror of https://github.com/bitcoin-s/bitcoin-s.git synced 2025-03-03 18:47:38 +01:00
Code Issues Projects Releases Packages Wiki Activity

Log instead of throwing exception when sending message to peer without an active connection (#5392)

Browse source
This commit is contained in:
Chris Stewart 2024-02-11 09:08:05 -06:00 • committed by GitHub
parent cac546bb57
commit d4ae659887
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
node/src/main/scala/org/bitcoins/node/networking/peer/PeerConnection.scala
View file

@ -390,9 +390,10 @@ case class PeerConnection(peer: Peer, queue: SourceQueue[NodeStreamMessage])(
case Some(g) => case Some(g) =>
sendMsg(msg.bytes, g.mergeHubSink) sendMsg(msg.bytes, g.mergeHubSink)
case None => case None =>
val exn = new RuntimeException( val log =
s"Could not send msg=${msg.payload.commandName} because we do not have an active connection to peer=${peer} socket=$socket") s"Could not send msg=${msg.payload.commandName} because we do not have an active connection to peer=${peer} socket=$socket"
Future.failed(exn) logger.warn(log)
Future.unit
} }
} }