Method setPhase

dgraph/cmd/bulk/progress.go:54–56 · view source on GitHub ↗

(ph phase)

Source from the content-addressed store, hash-verified

52	}
53
54	func (p *progress) setPhase(ph phase) {
55	atomic.StoreInt32((*int32)(&p.phase), int32(ph))
56	}
57
58	func (p *progress) report() {
59	t := time.Tick(time.Second)

mapStageMethod · 0.80

reduceStageMethod · 0.80

no outgoing calls

no test coverage detected