scorch merger checks closeCh
This commit is contained in:
parent
59797c35fa
commit
ea4eb7301b
|
@ -162,7 +162,11 @@ func (s *Scorch) planMergeAtSnapshot(ourSnapshot *IndexSnapshot) error {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
for _, notification := range notifications {
|
for _, notification := range notifications {
|
||||||
<-notification
|
select {
|
||||||
|
case <-s.closeCh:
|
||||||
|
return nil
|
||||||
|
case <-notification:
|
||||||
|
}
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user