dkirillov/frostfs-node
1
0
Fork 0
forked from TrueCloudLab/frostfs-node
Code Issues Pull requests Projects Releases Packages Wiki Activity

[#204] gc: Fix GC handlers start

Browse source 
Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>
This commit is contained in:
Dmitrii Stepanov 2023-04-03 19:15:13 +03:00 committed by Gitea
parent 0948a280fa
commit 8e5a0dcf27
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
pkg/local_object_storage/shard/gc.go
View file

@ -136,7 +136,8 @@ func (gc *gc) listenEvents(ctx context.Context) {
v.cancelFunc() v.cancelFunc()
v.prevGroup.Wait() v.prevGroup.Wait()
ctx, v.cancelFunc = context.WithCancel(ctx) var runCtx context.Context
runCtx, v.cancelFunc = context.WithCancel(ctx)
v.prevGroup.Add(len(v.handlers)) v.prevGroup.Add(len(v.handlers))
@ -144,7 +145,7 @@ func (gc *gc) listenEvents(ctx context.Context) {
h := v.handlers[i] h := v.handlers[i]
err := gc.workerPool.Submit(func() { err := gc.workerPool.Submit(func() {
h(ctx, event) h(runCtx, event)
v.prevGroup.Done() v.prevGroup.Done()
}) })
if err != nil { if err != nil {