Compare commits

...

9 Commits

Author SHA1 Message Date
Etan Kissling
65d57c0aff Merge branch 'unstable' into dev/etan/zz-dbg 2024-01-25 16:40:36 +01:00
Etan Kissling
1ac8cf9010 Merge commit '4e7eaba67ae1d35eb89af5882b85a7d091c6c95a' into dev/etan/zz-dbg 2023-12-21 17:59:42 +01:00
Etan Kissling
280bcc519f Merge commit '0011a5e720e2e61beb75b3384cd788c72548284a' into dev/etan/zz-dbg 2023-11-07 13:22:07 +01:00
Diego
0011a5e720 Revert "Prevent concurrent IWANT of the same message (#943)"
This reverts commit c6aa085e98.
2023-10-31 19:01:04 +01:00
Etan Kissling
be26c88311 Merge commit 'b2eac7ecbdb695b0b7033f2069b03a63d28aee2b' into dev/etan/zz-dbg 2023-10-23 16:47:33 +02:00
Etan Kissling
13870b2ae6 Merge commit '1b8a7d271359418d6fe72bbe2976b66ab370df9b' into dev/etan/zz-dbg 2023-09-12 22:45:34 +02:00
Tanguy
1b8a7d2713 IDontWant metrics (#946) 2023-09-07 09:15:34 +02:00
Tanguy
87d2322622 more logs 2023-09-04 12:31:10 +02:00
Etan Kissling
4379fabd8a X 2023-09-01 17:28:54 +02:00

View File

@@ -566,7 +566,7 @@ method publish*(g: GossipSub,
trace "Publishing message on topic", data = data.shortLog
if topic.len <= 0: # data could be 0/empty
debug "Empty topic, skipping publish"
info "Empty topic, skipping publish"
return 0
var peers: HashSet[PubSubPeer]
@@ -617,9 +617,9 @@ method publish*(g: GossipSub,
if peers.len == 0:
let topicPeers = g.gossipsub.getOrDefault(topic).toSeq()
debug "No peers for topic, skipping publish", peersOnTopic = topicPeers.len,
connectedPeers = topicPeers.filterIt(it.connected).len,
topic
info "No peers for topic, skipping publish", peersOnTopic = topicPeers.len,
connectedPeers = topicPeers.filterIt(it.connected).len,
topic
libp2p_gossipsub_failed_publish.inc()
return 0
@@ -631,7 +631,7 @@ method publish*(g: GossipSub,
inc g.msgSeqno
Message.init(some(g.peerInfo), data, topic, some(g.msgSeqno), g.sign)
msgId = g.msgIdProvider(msg).valueOr:
trace "Error generating message id, skipping publish",
info "Error generating message id, skipping publish",
error = error
libp2p_gossipsub_failed_publish.inc()
return 0
@@ -642,7 +642,7 @@ method publish*(g: GossipSub,
if g.addSeen(msgId):
# custom msgid providers might cause this
trace "Dropping already-seen message"
info "Dropping already-seen message"
return 0
g.mcache.put(msgId, msg)