Skip to content

Commit

Permalink
use num total peers instead of intra shard peers
Browse files Browse the repository at this point in the history
  • Loading branch information
miiu96 committed Sep 11, 2024
1 parent 2d2ff6d commit 78fe9d0
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -185,7 +185,7 @@ func (mrcf *metaRequestersContainerFactory) generateMetaChainHeaderRequesters()
func (mrcf *metaRequestersContainerFactory) generateReceiptRequesters() error {
// only one receipts topic
identifierReceipt := factory.ReceiptTopic + mrcf.shardCoordinator.CommunicationIdentifier(core.MetachainShardId)
requester, err := mrcf.createReceiptRequester(identifierReceipt, EmptyExcludePeersOnTopic, core.MetachainShardId, mrcf.numIntraShardPeers)
requester, err := mrcf.createReceiptRequester(identifierReceipt, EmptyExcludePeersOnTopic, core.MetachainShardId, mrcf.numTotalPeers)
if err != nil {
return err
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -145,7 +145,7 @@ func (srcf *shardRequestersContainerFactory) generateReceiptRequesters() error {
// only one receipts topic
selfShardID := srcf.shardCoordinator.SelfId()
identifierReceipt := factory.ReceiptTopic
requester, err := srcf.createReceiptRequester(identifierReceipt, EmptyExcludePeersOnTopic, selfShardID, srcf.numIntraShardPeers)
requester, err := srcf.createReceiptRequester(identifierReceipt, EmptyExcludePeersOnTopic, selfShardID, srcf.numTotalPeers)
if err != nil {
return err
}
Expand Down

0 comments on commit 78fe9d0

Please sign in to comment.