les/downloader/queue.go

55 type fetchRequest struct {  struct
120 	headerPendPool  map[string]*fetchRequest       // Currently pending header retrieval operations
129 	blockPendPool  map[string]*fetchRequest      // Currently pending block (body) retrieval operations
133 	receiptPendPool  map[string]*fetchRequest      // Currently pending receipt retrieval operations
168 	q.headerPendPool = make(map[string]*fetchRequest)
172 	q.blockPendPool = make(map[string]*fetchRequest)
176 	q.receiptPendPool = make(map[string]*fetchRequest)
413 func (q *queue) ReserveHeaders(p *peerConnection, count int) *fetchRequest {
442 	request := &fetchRequest{
454 func (q *queue) ReserveBodies(p *peerConnection, count int) (*fetchRequest, bool, bool) {
464 func (q *queue) ReserveReceipts(p *peerConnection, count int) (*fetchRequest, bool, bool) {
484 	pendPool map[string]*fetchRequest, kind uint) (*fetchRequest, bool, bool) {
560 	request := &fetchRequest{
570 func (q *queue) CancelHeaders(request *fetchRequest) {
578 func (q *queue) CancelBodies(request *fetchRequest) {
586 func (q *queue) CancelReceipts(request *fetchRequest) {
593 func (q *queue) cancel(request *fetchRequest, taskQueue *prque.Prque, pendPool map[string]*fetchReq…
657 func (q *queue) expire(timeout time.Duration, pendPool map[string]*fetchRequest, taskQueue *prque.P…
833 	taskQueue *prque.Prque, pendPool map[string]*fetchRequest, reqTimer metrics.Timer,