mirrors/bitcoin-s
1
0
Fork 0
mirror of https://github.com/bitcoin-s/bitcoin-s.git synced 2024-11-19 18:02:54 +01:00
Code Issues Packages Projects Releases Wiki Activity

Ignore block messages while syncing (#2587)

Browse Source
This commit is contained in:
benthecarman 2021-01-29 09:28:57 -06:00 committed by GitHub
parent beac2be195
commit ff6b85d195
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
node/src/main/scala/org/bitcoins/node/networking/peer/DataMessageHandler.scala
View File

@ -378,18 +378,19 @@ case class DataMessageHandler(
invMsg: InventoryMessage,
peerMsgSender: PeerMessageSender): Future[DataMessageHandler] = {
logger.info(s"Received inv=${invMsg}")
val getData = GetDataMessage(invMsg.inventories.map {
val getData = GetDataMessage(invMsg.inventories.flatMap {
case Inventory(TypeIdentifier.MsgBlock, hash) =>
// only request the merkle block if we are spv enabled
appConfig.nodeType match {
case NodeType.SpvNode =>
Inventory(TypeIdentifier.MsgFilteredBlock, hash)
Some(Inventory(TypeIdentifier.MsgFilteredBlock, hash))
case NodeType.NeutrinoNode | NodeType.FullNode =>
Inventory(TypeIdentifier.MsgWitnessBlock, hash)
if (syncing) None
else Some(Inventory(TypeIdentifier.MsgWitnessBlock, hash))
case NodeType.BitcoindBackend =>
throw new RuntimeException("This is impossible")
}
case other: Inventory => other
case other: Inventory => Some(other)
})
peerMsgSender.sendMsg(getData).map(_ => this)
}