MCPcopy Index your code
hub / github.com/imroc/req / completeTask

Method completeTask

parallel_download.go:38–48  ·  view source on GitHub ↗
(task *downloadTask)

Source from the content-addressed store, hash-verified

36}
37
38func (pd *ParallelDownload) completeTask(task *downloadTask) {
39 pd.mu.Lock()
40 pd.taskMap[task.index] = task
41 pd.mu.Unlock()
42 go func() {
43 select {
44 case pd.taskNotifyCh <- task:
45 case <-pd.doneCh:
46 }
47 }()
48}
49
50func (pd *ParallelDownload) popTask(index int) *downloadTask {
51 pd.mu.Lock()

Callers 1

handleTaskMethod · 0.95

Calls 2

LockMethod · 0.80
UnlockMethod · 0.80

Tested by

no test coverage detected