Method put

protocols/cpc/syncer/queue.go:50–57

(task resultTask)

}

func (q *queue) put(task resultTask) error {
	if atomic.LoadInt32(&q.size) >= q.limit {
		return ErrQueueFull
	}
	q.queue <- task
	atomic.AddInt32(&q.size, 1)
	return nil
}

func (q *queue) empty() bool {
	return atomic.LoadInt32(&q.size) == 0