Lines Matching refs:queue

306 	struct request_sock_queue *queue = &icsk->icsk_accept_queue;  in inet_csk_accept()  local
321 if (reqsk_queue_empty(queue)) { in inet_csk_accept()
333 req = reqsk_queue_remove(queue, sk); in inet_csk_accept()
338 spin_lock_bh(&queue->fastopenq.lock); in inet_csk_accept()
349 spin_unlock_bh(&queue->fastopenq.lock); in inet_csk_accept()
522 static bool reqsk_queue_unlink(struct request_sock_queue *queue, in reqsk_queue_unlink() argument
561 struct request_sock_queue *queue = &icsk->icsk_accept_queue; in reqsk_timer_handler() local
588 qlen = reqsk_queue_len(queue); in reqsk_timer_handler()
590 int young = reqsk_queue_len_young(queue) << 1; in reqsk_timer_handler()
599 defer_accept = READ_ONCE(queue->rskq_defer_accept); in reqsk_timer_handler()
612 atomic_dec(&queue->young); in reqsk_timer_handler()
796 struct request_sock_queue *queue = &inet_csk(sk)->icsk_accept_queue; in inet_csk_reqsk_queue_add() local
798 spin_lock(&queue->rskq_lock); in inet_csk_reqsk_queue_add()
805 if (queue->rskq_accept_head == NULL) in inet_csk_reqsk_queue_add()
806 queue->rskq_accept_head = req; in inet_csk_reqsk_queue_add()
808 queue->rskq_accept_tail->dl_next = req; in inet_csk_reqsk_queue_add()
809 queue->rskq_accept_tail = req; in inet_csk_reqsk_queue_add()
812 spin_unlock(&queue->rskq_lock); in inet_csk_reqsk_queue_add()
840 struct request_sock_queue *queue = &icsk->icsk_accept_queue; in inet_csk_listen_stop() local
851 while ((req = reqsk_queue_remove(queue, sk)) != NULL) { in inet_csk_listen_stop()
866 if (queue->fastopenq.rskq_rst_head) { in inet_csk_listen_stop()
868 spin_lock_bh(&queue->fastopenq.lock); in inet_csk_listen_stop()
869 req = queue->fastopenq.rskq_rst_head; in inet_csk_listen_stop()
870 queue->fastopenq.rskq_rst_head = NULL; in inet_csk_listen_stop()
871 spin_unlock_bh(&queue->fastopenq.lock); in inet_csk_listen_stop()