Method newId

worker/queue.go:291–300

newId generates a random unique task ID. logMu must be acquired before calling this function. The format of this is: 32 bits: raft ID 32 bits: random number

()

// 32 bits: raft ID
// 32 bits: random number
func (t *tasks) newId() uint64 {
	myRaftId := State.WALstore.Uint(raftwal.RaftId)
	for {
		id := myRaftId<<32 | uint64(t.rng.Uint32())
		// z.Tree cannot store 0 or math.MaxUint64. Check that id is unique.
		if id != 0 && id != math.MaxUint64 && t.log.Get(id) == 0 {
			return id
		}
	}
}

type taskRequest struct {
	id  uint64