Lines Matching refs:request_queue
365 if (conn->pending_count == aqueue_count(conn->request_queue)) {
375 aqueue_idx(conn->request_queue,
422 aqueue_delete_tail(conn->request_queue);
435 count = aqueue_count(conn->request_queue);
440 aqueue_idx(conn->request_queue, 0));
459 aqueue_append(conn->request_queue, &request);
508 while (aqueue_count(conn->request_queue) > 0 && max_count > 0) {
510 aqueue_idx(conn->request_queue, 0));
518 aqueue_delete_tail(conn->request_queue);
543 count = aqueue_count(conn->request_queue);
549 request = requests[aqueue_idx(conn->request_queue, i)];
835 aqueue_delete(conn->request_queue, idx);
958 } else if (aqueue_count(conn->request_queue) > 0 ||
1311 if (aqueue_count(conn->request_queue) == 0) {
1331 request = requests[aqueue_idx(conn->request_queue, i)];
1349 if (aqueue_count(conn->request_queue) > 0) {
1970 conn->request_queue = aqueue_init(&conn->request_array.arr);
2002 aqueue_deinit(&conn->request_queue);