diff --git a/cmd/storemsgcounter/execute.go b/cmd/storemsgcounter/execute.go index 79fefea..61238e8 100644 --- a/cmd/storemsgcounter/execute.go +++ b/cmd/storemsgcounter/execute.go @@ -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) { - var result *store.Result - var err error - if len(messageHashes) == 0 { return } @@ -595,6 +592,9 @@ func (app *Application) verifyMessageExistence(ctx context.Context, runId string go func(messageHashes []pb.MessageHash) { defer wg.Done() + var result *store.Result + var err error + retry := true success := false count := 1