(id op)
| 204 | } |
| 205 | |
| 206 | func (n *node) waitForTask(id op) { |
| 207 | n.opsLock.Lock() |
| 208 | closer, ok := n.ops[id] |
| 209 | n.opsLock.Unlock() |
| 210 | if !ok { |
| 211 | return |
| 212 | } |
| 213 | closer.Wait() |
| 214 | } |
| 215 | |
| 216 | func (n *node) isRunningTask(id op) bool { |
| 217 | n.opsLock.Lock() |
no test coverage detected