Lines Matching refs:queue
297 struct request_sock_queue *queue = &icsk->icsk_accept_queue; in inet_csk_accept() local
312 if (reqsk_queue_empty(queue)) { in inet_csk_accept()
324 req = reqsk_queue_remove(queue); in inet_csk_accept()
330 queue->fastopenq) { in inet_csk_accept()
331 spin_lock_bh(&queue->fastopenq->lock); in inet_csk_accept()
342 spin_unlock_bh(&queue->fastopenq->lock); in inet_csk_accept()
568 static bool reqsk_queue_unlink(struct request_sock_queue *queue, in reqsk_queue_unlink() argument
575 spin_lock(&queue->syn_wait_lock); in reqsk_queue_unlink()
576 lopt = queue->listen_opt; in reqsk_queue_unlink()
587 spin_unlock(&queue->syn_wait_lock); in reqsk_queue_unlink()
607 struct request_sock_queue *queue = &icsk->icsk_accept_queue; in reqsk_timer_handler() local
608 struct listen_sock *lopt = queue->listen_opt; in reqsk_timer_handler()
648 defer_accept = READ_ONCE(queue->rskq_defer_accept); in reqsk_timer_handler()
670 void reqsk_queue_hash_req(struct request_sock_queue *queue, in reqsk_queue_hash_req() argument
674 struct listen_sock *lopt = queue->listen_opt; in reqsk_queue_hash_req()
690 spin_lock(&queue->syn_wait_lock); in reqsk_queue_hash_req()
693 spin_unlock(&queue->syn_wait_lock); in reqsk_queue_hash_req()
827 struct request_sock_queue *queue = &icsk->icsk_accept_queue; in inet_csk_listen_stop() local
832 acc_req = reqsk_queue_yank_acceptq(queue); in inet_csk_listen_stop()
842 reqsk_queue_destroy(queue); in inet_csk_listen_stop()
881 if (queue->fastopenq) { in inet_csk_listen_stop()
883 spin_lock_bh(&queue->fastopenq->lock); in inet_csk_listen_stop()
884 acc_req = queue->fastopenq->rskq_rst_head; in inet_csk_listen_stop()
885 queue->fastopenq->rskq_rst_head = NULL; in inet_csk_listen_stop()
886 spin_unlock_bh(&queue->fastopenq->lock); in inet_csk_listen_stop()