We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 67ababa commit dcc7bd3Copy full SHA for dcc7bd3
pkg/services/object/get/container.go
@@ -41,6 +41,7 @@ func (exec *execCtx) processEpoch(epoch uint64) bool {
41
defer cancel()
42
43
exec.status = statusUndefined
44
+ mProcessedNodes := make(map[string]struct{})
45
46
for {
47
addrs := traverser.Next()
@@ -61,6 +62,13 @@ func (exec *execCtx) processEpoch(epoch uint64) bool {
61
62
default:
63
}
64
65
+ strKey := string(addrs[i].PublicKey())
66
+ if _, ok = mProcessedNodes[strKey]; ok {
67
+ continue
68
+ }
69
+
70
+ mProcessedNodes[strKey] = struct{}{}
71
72
// TODO: #1142 consider parallel execution
73
// TODO: #1142 consider optimization: if status == SPLIT we can continue until
74
// we reach the best result - split info with linking object ID.
0 commit comments