Lines Matching refs:reqs
618 struct http_client_request **reqs;
626 reqs = array_get_modifiable(&queue->queued_urgent_requests, &count);
628 if (reqs[i] == req) {
634 reqs = array_get_modifiable(&queue->queued_requests, &count);
636 if (reqs[i] == req) {
645 reqs = array_get_modifiable(&queue->delayed_requests, &count);
647 if (reqs[i] == req)
655 i_assert(reqs[1]->release_time.tv_sec > 0);
656 http_client_queue_set_delay_timer(queue, reqs[1]->release_time);
665 reqs = array_get_modifiable(&queue->requests, &count);
667 if (reqs[i] == req)
675 if (count > 1 && reqs[1]->timeout_time.tv_sec > 0)
676 http_client_queue_set_request_timer(queue, &reqs[1]->timeout_time);
690 struct http_client_request *const *reqs;
704 reqs = array_get(&queue->requests, &count);
708 if (reqs[i]->timeout_time.tv_sec > 0 &&
709 timeval_cmp_margin(&reqs[i]->timeout_time,
713 array_append(&failed_requests, &reqs[i], 1);
718 new_to = reqs[i]->timeout_time;
725 reqs = array_get(&failed_requests, &count);
728 struct http_client_request *req = reqs[i];
839 struct http_client_request *const *reqs;
846 reqs = array_get(&queue->delayed_requests, &count);
848 if (timeval_cmp_margin(&reqs[i]->release_time,
854 http_client_request_label(reqs[i]),
855 (reqs[i]->urgent ? " (urgent)" : ""));
856 http_client_queue_submit_now(queue, reqs[i]);
860 http_client_queue_set_delay_timer(queue, reqs[i]->release_time);