logos-messaging/storenode-messages-counter
1
0
Fork 0
mirror of https://github.com/logos-messaging/storenode-messages-counter.git synced 2026-01-05 23:53:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: nil

Browse Source
This commit is contained in:
Richard Ramos 2024-08-19 18:14:07 -04:00
parent 54fa01757b
commit 824d708e9a
No known key found for this signature in database
GPG Key ID: 1CE87DB518195760
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
cmd/storemsgcounter/execute.go
View File

@ -572,9 +572,6 @@ func (app *Application) retrieveHistory(ctx context.Context, runId string, store
} }
func (app *Application) verifyMessageExistence(ctx context.Context, runId string, peerID peer.ID, messageHashes []pb.MessageHash, onResult func(result *store.Result), logger *zap.Logger) { func (app *Application) verifyMessageExistence(ctx context.Context, runId string, peerID peer.ID, messageHashes []pb.MessageHash, onResult func(result *store.Result), logger *zap.Logger) {
var result *store.Result
var err error
if len(messageHashes) == 0 { if len(messageHashes) == 0 {
return return
} }
@ -595,6 +592,9 @@ func (app *Application) verifyMessageExistence(ctx context.Context, runId string
go func(messageHashes []pb.MessageHash) { go func(messageHashes []pb.MessageHash) {
defer wg.Done() defer wg.Done()
var result *store.Result
var err error
retry := true retry := true
success := false success := false
count := 1 count := 1