send IDONTWANT on outbound

libp2p · Sep 25, 2024 · 01ea9a7 · 01ea9a7
1 parent a25c5fc
commit 01ea9a7
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/libp2p/src/main/kotlin/io/libp2p/pubsub/gossip/GossipRouter.kt b/libp2p/src/main/kotlin/io/libp2p/pubsub/gossip/GossipRouter.kt
@@ -420,7 +420,14 @@ open class GossipRouter(
             }
         val list = peers
             .filterNot { peerDoesNotWantMessage(it, msg.messageId) }
-            .map { submitPublishMessage(it, msg) }
+            .map {
+                if (this.protocol.supportsIDontWant() &&
+                    msg.protobufMessage.serializedSize >= params.iDontWantMinMessageSizeThreshold
+                ) {
+                    sendIdontwant(it, msg.messageId)
+                }
+                submitPublishMessage(it, msg)
+            }
 
         mCache += msg
         flushAllPending()