slot.go

type slot struct {
	cond sync.Cond
	mark uint32
	req  request
	ch   chan response
}

func newRing() *ring {
	r := &ring{}
	for i := range r.slots {
		r.slots[i] = slot{ch: make(chan response, 0)}
		r.slots[i].cond.L = &sync.Mutex{}
	}
	return r
}