AtHeartEngineer/prysm
1
0
Fork 0
mirror of https://github.com/OffchainLabs/prysm.git synced 2026-01-08 21:08:10 -05:00
Code Issues Packages Projects Releases Wiki Activity

wrap errors

Browse Source
This commit is contained in:
aarshkshah1992
2026-01-05 12:02:04 +05:30
parent 74ace53d3a
commit 294affaad9
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
beacon-chain/p2p/pubsub.go
View File

@@ -103,12 +103,12 @@ func (s *Service) PublishToTopic(ctx context.Context, topic string, data []byte,
func (s *Service) addToBatch(ctx context.Context, batch *pubsub.MessageBatch, topic string, data []byte, opts ...pubsub.PubOpt) error { func (s *Service) addToBatch(ctx context.Context, batch *pubsub.MessageBatch, topic string, data []byte, opts ...pubsub.PubOpt) error {
topicHandle, err := s.JoinTopic(topic) topicHandle, err := s.JoinTopic(topic)
if err != nil { if err != nil {
return err return fmt.Errorf("joining topic: %w", err)
} }
// Wait for at least 1 peer to be available to receive the published message. // Wait for at least 1 peer to be available to receive the published message.
for { for {
if flags.Get().MinimumSyncPeers == 0 || len(topicHandle.ListPeers()) > 0 { if flags.Get().MinimumSyncPeers == 0 || len(topicHandle.ListPeers()) > 0 {
return topicHandle.AddToBatch(ctx, batch, data, opts...) return topicHandle.AddToBatch(ctx, batch, data, opts...)
} }
select { select {