Function InitTasks

worker/queue.go:88–114

InitTasks initializes the global Tasks variable.

()

// InitTasks initializes the global Tasks variable.
func InitTasks() {
	path := filepath.Join(x.WorkerConfig.TmpDir, "tasks.buf")
	log, err := z.NewTreePersistent(path)
	x.Check(err)

	// #nosec G404: weak RNG
	Tasks = &tasks{
		queue: make(chan taskRequest, 16),
		log:   log,
		logMu: new(sync.Mutex),
		rng:   rand.New(rand.NewSource(time.Now().UnixNano())),
	}

	// Mark all pending tasks as failed.
	Tasks.logMu.Lock()
	Tasks.log.IterateKV(func(id, val uint64) uint64 {
		meta := TaskMeta(val)
		if status := meta.Status(); status == TaskStatusQueued || status == TaskStatusRunning {
			return uint64(newTaskMeta(meta.Kind(), TaskStatusFailed))
		}
		return 0
	})
	Tasks.logMu.Unlock()

	// Start the task runner.
	go Tasks.worker()
}

// tasks is a persistent task queue.
type tasks struct {