Searched refs:workerManager (Results 1 – 2 of 2) sorted by relevance
57 wm *workerManager86 func newWorker(wm *workerManager) *worker { argument181 func (wm *workerManager) handleJobs() error {200 func (wm *workerManager) updateParents(j *job) {211 type workerManager struct { struct230 func newWorkerManager(numJobs int) (*workerManager, error) {231 wm := &workerManager{266 func (wm *workerManager) hasTodo() bool { argument270 func (wm *workerManager) maybePushToReadyQueue(j *job) { argument278 func (wm *workerManager) handleNewDep(j *job, neededBy *job) { argument[all …]
34 wm *workerManager