MCPcopy
hub / github.com/dgraph-io/dgraph / waitForTask

Method waitForTask

worker/draft.go:206–214  ·  view source on GitHub ↗
(id op)

Source from the content-addressed store, hash-verified

204}
205
206func (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
216func (n *node) isRunningTask(id op) bool {
217 n.opsLock.Lock()

Callers 1

runSchemaMutationFunction · 0.80

Calls 3

WaitMethod · 0.80
LockMethod · 0.45
UnlockMethod · 0.45

Tested by

no test coverage detected