Lines Matching refs:queue
662 struct request_sock_queue *queue = &icsk->icsk_accept_queue; in inet_csk_accept() local
677 if (reqsk_queue_empty(queue)) { in inet_csk_accept()
689 req = reqsk_queue_remove(queue, sk); in inet_csk_accept()
690 arg->is_empty = reqsk_queue_empty(queue); in inet_csk_accept()
695 spin_lock_bh(&queue->fastopenq.lock); in inet_csk_accept()
706 spin_unlock_bh(&queue->fastopenq.lock); in inet_csk_accept()
987 static void reqsk_queue_migrated(struct request_sock_queue *queue, in reqsk_queue_migrated() argument
991 atomic_inc(&queue->young); in reqsk_queue_migrated()
992 atomic_inc(&queue->qlen); in reqsk_queue_migrated()
1060 struct request_sock_queue *queue; in reqsk_timer_handler() local
1109 queue = &icsk->icsk_accept_queue; in reqsk_timer_handler()
1110 qlen = reqsk_queue_len(queue); in reqsk_timer_handler()
1112 int young = reqsk_queue_len_young(queue) << 1; in reqsk_timer_handler()
1121 syn_ack_recalc(req, max_syn_ack_retries, READ_ONCE(queue->rskq_defer_accept), in reqsk_timer_handler()
1129 atomic_dec(&queue->young); in reqsk_timer_handler()
1158 reqsk_queue_removed(queue, nreq); in reqsk_timer_handler()
1394 struct request_sock_queue *queue = &inet_csk(sk)->icsk_accept_queue; in inet_csk_reqsk_queue_add() local
1396 spin_lock(&queue->rskq_lock); in inet_csk_reqsk_queue_add()
1403 if (queue->rskq_accept_head == NULL) in inet_csk_reqsk_queue_add()
1404 WRITE_ONCE(queue->rskq_accept_head, req); in inet_csk_reqsk_queue_add()
1406 queue->rskq_accept_tail->dl_next = req; in inet_csk_reqsk_queue_add()
1407 queue->rskq_accept_tail = req; in inet_csk_reqsk_queue_add()
1410 spin_unlock(&queue->rskq_lock); in inet_csk_reqsk_queue_add()
1467 struct request_sock_queue *queue = &icsk->icsk_accept_queue; in inet_csk_listen_stop() local
1478 while ((req = reqsk_queue_remove(queue, sk)) != NULL) { in inet_csk_listen_stop()
1520 if (queue->fastopenq.rskq_rst_head) { in inet_csk_listen_stop()
1522 spin_lock_bh(&queue->fastopenq.lock); in inet_csk_listen_stop()
1523 req = queue->fastopenq.rskq_rst_head; in inet_csk_listen_stop()
1524 queue->fastopenq.rskq_rst_head = NULL; in inet_csk_listen_stop()
1525 spin_unlock_bh(&queue->fastopenq.lock); in inet_csk_listen_stop()