Method HeadPos

pkg/jobmanager/cirbuf.go:146–150

()

}

func (cb *CirBuf) HeadPos() int64 {
	cb.lock.Lock()
	defer cb.lock.Unlock()
	return cb.totalSize - int64(cb.count)
}

func (cb *CirBuf) Size() int {
	cb.lock.Lock()