File tree Expand file tree Collapse file tree 2 files changed +4
-3
lines changed
Routers/Gossipsub/PeerStore Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -897,7 +897,8 @@ open class BasePubSub {
897
897
let bytes = try BasePubSub . MessagePrefix + msg. serializedData ( )
898
898
msgToSend = msg
899
899
msgToSend. signature = try self . peerID. signature ( for: bytes)
900
- msgToSend. key = try Data ( self . peerID. marshalPublicKey ( ) ) // pubkey.data and marshalPublicKey have an extra 0801 prepended
900
+ // pubkey.data and marshalPublicKey have an extra 0801 prepended
901
+ msgToSend. key = try Data ( self . peerID. marshalPublicKey ( ) )
901
902
self . logger. trace ( " Signed Message: \( msgToSend) " )
902
903
case . strictNoSign:
903
904
// Nothing to do...
Original file line number Diff line number Diff line change @@ -372,15 +372,15 @@ class PeeringState: PeerStateProtocol {
372
372
eventLoop. submit { ( ) -> [ PeerID ] in
373
373
let subbed = self . mesh [ topic] ?? [ ]
374
374
//let known = self.fanout[topic] ?? []
375
- return self . idsToPeers ( subbed /*+ known*/ )
375
+ return self . idsToPeers ( subbed) // known
376
376
} . hop ( to: loop ?? eventLoop)
377
377
}
378
378
379
379
func peersSubscribedTo( topic: String , on loop: EventLoop ? ) -> EventLoopFuture < [ PubSub . Subscriber ] > {
380
380
eventLoop. submit { ( ) -> [ PubSub . Subscriber ] in
381
381
let subbed = self . mesh [ topic] ?? [ ]
382
382
//let known = self.fanout[topic] ?? []
383
- return self . idsToSubs ( subbed /*+ known*/ )
383
+ return self . idsToSubs ( subbed) // known
384
384
} . hop ( to: loop ?? eventLoop)
385
385
}
386
386
You can’t perform that action at this time.
0 commit comments