cerc-io/lotus
15
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

sched: Fix tests

Browse Source
This commit is contained in:
Łukasz Magiera 2020-09-02 17:37:19 +02:00
parent 7fe8580da5
commit 5a2b439773
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
extern/sector-storage/sched.go vendored
View File

@ -774,14 +774,19 @@ func (sh *scheduler) dropWorker(wid WorkerID) {
} }
func (sh *scheduler) workerCleanup(wid WorkerID, w *workerHandle) { func (sh *scheduler) workerCleanup(wid WorkerID, w *workerHandle) {
if !w.cleanupStarted { select {
case <-w.closingMgr:
default:
close(w.closingMgr) close(w.closingMgr)
} }
sh.workersLk.Unlock()
select { select {
case <-w.closedMgr: case <-w.closedMgr:
case <-time.After(time.Second): case <-time.After(time.Second):
log.Errorf("timeout closing worker manager goroutine %d", wid) log.Errorf("timeout closing worker manager goroutine %d", wid)
} }
sh.workersLk.Lock()
if !w.cleanupStarted { if !w.cleanupStarted {
w.cleanupStarted = true w.cleanupStarted = true