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

Ignore messages in queue that were queued before we disconnected peer (#5131)

Browse source
This commit is contained in:
Chris Stewart 2023-07-05 15:31:27 -05:00 • committed by GitHub
parent cd812ac7a3
commit fc99087c89
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
node/src/main/scala/org/bitcoins/node/PeerManager.scala
View file

@ -754,8 +754,9 @@ case class PeerManager(
val peerMsgSenderOptF = getPeerMsgSender(peer)
peerMsgSenderOptF.flatMap {
case None =>
Future.failed(new RuntimeException(
s"Couldn't find PeerMessageSender that corresponds with peer=$peer msg=${payload.commandName}. Was it disconnected?"))
logger.warn(
s"Ignoring received msg=${payload.commandName} from peer=$peer because it was disconnected, peers=$peers state=${dmh.state}")
Future.successful(dmh)
case Some(_) =>
val peerDmh = dmh.copy(peerDataOpt = getPeerData(peer))