| /kernel/linux/linux-5.10/include/net/ |
| H A D | inet_connection_sock.h | 62 * @icsk_accept_queue: FIFO of established children
89 struct request_sock_queue icsk_accept_queue; member
332 reqsk_queue_added(&inet_csk(sk)->icsk_accept_queue); in inet_csk_reqsk_queue_added()
337 return reqsk_queue_len(&inet_csk(sk)->icsk_accept_queue); in inet_csk_reqsk_queue_len()
363 return !reqsk_queue_empty(&inet_csk(sk)->icsk_accept_queue) ? in inet_csk_listen_poll()
404 spin_lock_init(&icsk->icsk_accept_queue.rskq_lock); in inet_init_csk_locks()
405 spin_lock_init(&icsk->icsk_accept_queue.fastopenq.lock); in inet_init_csk_locks()
|
| /kernel/linux/linux-6.6/include/net/ |
| H A D | inet_connection_sock.h | 59 * @icsk_accept_queue: FIFO of established children
86 struct request_sock_queue icsk_accept_queue; member
274 reqsk_queue_added(&inet_csk(sk)->icsk_accept_queue); in inet_csk_reqsk_queue_added()
279 return reqsk_queue_len(&inet_csk(sk)->icsk_accept_queue); in inet_csk_reqsk_queue_len()
313 return !reqsk_queue_empty(&inet_csk(sk)->icsk_accept_queue) ? in inet_csk_listen_poll()
354 spin_lock_init(&icsk->icsk_accept_queue.rskq_lock); in inet_init_csk_locks()
355 spin_lock_init(&icsk->icsk_accept_queue.fastopenq.lock); in inet_init_csk_locks()
|
| /kernel/linux/linux-6.6/net/ipv4/ |
| H A D | inet_connection_sock.c | 633 if (reqsk_queue_empty(&icsk->icsk_accept_queue)) in inet_csk_wait_for_connect()
638 if (!reqsk_queue_empty(&icsk->icsk_accept_queue)) in inet_csk_wait_for_connect()
660 struct request_sock_queue *queue = &icsk->icsk_accept_queue; in inet_csk_accept()
976 reqsk_queue_removed(&inet_csk(sk)->icsk_accept_queue, req); in inet_csk_reqsk_queue_drop()
1018 reqsk_queue_migrated(&inet_csk(nsk)->icsk_accept_queue, req); in reqsk_timer_handler()
1045 queue = &icsk->icsk_accept_queue; in reqsk_timer_handler()
1079 reqsk_queue_removed(&inet_csk(oreq->rsk_listener)->icsk_accept_queue, oreq); in reqsk_timer_handler()
1175 memset(&newicsk->icsk_accept_queue, 0, sizeof(newicsk->icsk_accept_queue)); in inet_csk_clone_lock()
1248 reqsk_queue_alloc(&icsk->icsk_accept_queue); in inet_csk_listen_start()
[all...] |
| H A D | tcp_fastopen.c | 43 inet_csk(sk)->icsk_accept_queue.fastopenq.ctx, 1); in tcp_fastopen_destroy_cipher()
82 q = &inet_csk(sk)->icsk_accept_queue.fastopenq; in tcp_fastopen_reset_cipher()
102 ctx = rcu_dereference(icsk->icsk_accept_queue.fastopenq.ctx); in tcp_fastopen_get_cipher()
243 struct request_sock_queue *queue = &inet_csk(sk)->icsk_accept_queue; in tcp_fastopen_create_child()
311 fastopenq = &inet_csk(sk)->icsk_accept_queue.fastopenq; in tcp_fastopen_queue_check()
|
| H A D | tcp_minisocks.c | 699 If icsk->icsk_accept_queue.rskq_defer_accept, we silently drop this in tcp_check_req()
790 if (req->num_timeout < READ_ONCE(inet_csk(sk)->icsk_accept_queue.rskq_defer_accept) && in tcp_check_req()
809 reqsk_queue_removed(&inet_csk(req->rsk_listener)->icsk_accept_queue, req); in tcp_check_req()
|
| /kernel/linux/linux-5.10/net/ipv4/ |
| H A D | tcp_fastopen.c | 49 inet_csk(sk)->icsk_accept_queue.fastopenq.ctx, 1); in tcp_fastopen_destroy_cipher()
94 q = &inet_csk(sk)->icsk_accept_queue.fastopenq; in tcp_fastopen_reset_cipher()
119 ctx = rcu_dereference(icsk->icsk_accept_queue.fastopenq.ctx); in tcp_fastopen_get_cipher()
260 struct request_sock_queue *queue = &inet_csk(sk)->icsk_accept_queue; in tcp_fastopen_create_child()
327 fastopenq = &inet_csk(sk)->icsk_accept_queue.fastopenq; in tcp_fastopen_queue_check()
|
| H A D | inet_connection_sock.c | 444 if (reqsk_queue_empty(&icsk->icsk_accept_queue)) in inet_csk_wait_for_connect()
449 if (!reqsk_queue_empty(&icsk->icsk_accept_queue)) in inet_csk_wait_for_connect()
471 struct request_sock_queue *queue = &icsk->icsk_accept_queue; in inet_csk_accept()
736 reqsk_queue_removed(&inet_csk(sk)->icsk_accept_queue, req); in inet_csk_reqsk_queue_drop()
756 struct request_sock_queue *queue = &icsk->icsk_accept_queue; in reqsk_timer_handler()
884 memset(&newicsk->icsk_accept_queue, 0, sizeof(newicsk->icsk_accept_queue)); in inet_csk_clone_lock()
959 reqsk_queue_alloc(&icsk->icsk_accept_queue); in inet_csk_listen_start()
1014 struct request_sock_queue *queue = &inet_csk(sk)->icsk_accept_queue; in inet_csk_reqsk_queue_add()
1040 reqsk_queue_removed(&inet_csk(sk)->icsk_accept_queue, re in inet_csk_complete_hashdance()
[all...] |
| H A D | tcp_minisocks.c | 674 If icsk->icsk_accept_queue.rskq_defer_accept, we silently drop this in tcp_check_req()
765 if (req->num_timeout < inet_csk(sk)->icsk_accept_queue.rskq_defer_accept && in tcp_check_req()
784 reqsk_queue_removed(&inet_csk(sk)->icsk_accept_queue, req); in tcp_check_req()
|
| H A D | tcp.c | 3417 WRITE_ONCE(icsk->icsk_accept_queue.rskq_defer_accept, in do_tcp_setsockopt()
3821 val = READ_ONCE(icsk->icsk_accept_queue.rskq_defer_accept); in do_tcp_getsockopt()
3963 val = READ_ONCE(icsk->icsk_accept_queue.fastopenq.max_qlen); in do_tcp_getsockopt()
|
| /kernel/linux/linux-5.10/net/core/ |
| H A D | request_sock.c | 68 * icsk_accept_queue.rskq_accept_head. To protect the access a simple spin
69 * lock per listener "icsk->icsk_accept_queue.fastopenq->lock" is created.
94 fastopenq = &inet_csk(lsk)->icsk_accept_queue.fastopenq; in reqsk_fastopen_remove()
|
| /kernel/linux/linux-6.6/net/core/ |
| H A D | request_sock.c | 68 * icsk_accept_queue.rskq_accept_head. To protect the access a simple spin
69 * lock per listener "icsk->icsk_accept_queue.fastopenq->lock" is created.
94 fastopenq = &inet_csk(lsk)->icsk_accept_queue.fastopenq; in reqsk_fastopen_remove()
|
| /kernel/linux/common_modules/newip/third_party/linux-5.10/net/newip/ |
| H A D | ninet_connection_sock.c | 40 struct request_sock_queue *queue = &icsk->icsk_accept_queue; in ninet_reqsk_timer_handler()
|
| /kernel/linux/linux-5.10/tools/testing/selftests/bpf/progs/ |
| H A D | bpf_iter_tcp4.c | 92 fastopenq = &icsk->icsk_accept_queue.fastopenq; in dump_tcp_sock()
|
| H A D | bpf_iter_tcp6.c | 92 fastopenq = &icsk->icsk_accept_queue.fastopenq; in dump_tcp6_sock()
|
| /kernel/linux/linux-5.10/drivers/net/ethernet/chelsio/inline_crypto/chtls/ |
| H A D | chtls_cm.h | 89 #define ACCEPT_QUEUE(sk) (&inet_csk(sk)->icsk_accept_queue.rskq_accept_head)
|
| H A D | chtls_cm.c | 615 reqsk_queue_removed(&inet_csk(parent)->icsk_accept_queue, req); in cleanup_syn_rcv_conn()
1549 reqsk_queue_removed(&inet_csk(lsk)->icsk_accept_queue, oreq); in add_pass_open_to_parent()
|
| /kernel/linux/linux-6.6/drivers/net/ethernet/chelsio/inline_crypto/chtls/ |
| H A D | chtls_cm.h | 89 #define ACCEPT_QUEUE(sk) (&inet_csk(sk)->icsk_accept_queue.rskq_accept_head)
|
| H A D | chtls_cm.c | 615 reqsk_queue_removed(&inet_csk(parent)->icsk_accept_queue, req); in cleanup_syn_rcv_conn()
1549 reqsk_queue_removed(&inet_csk(lsk)->icsk_accept_queue, oreq); in add_pass_open_to_parent()
|
| /kernel/linux/linux-6.6/tools/testing/selftests/bpf/progs/ |
| H A D | bpf_iter_tcp4.c | 91 fastopenq = &icsk->icsk_accept_queue.fastopenq; in dump_tcp_sock()
|
| H A D | bpf_iter_tcp6.c | 91 fastopenq = &icsk->icsk_accept_queue.fastopenq; in dump_tcp6_sock()
|
| /kernel/linux/linux-5.10/include/linux/ |
| H A D | tcp.h | 476 struct request_sock_queue *queue = &inet_csk(sk)->icsk_accept_queue; in fastopen_queue_tune()
|
| /kernel/linux/linux-5.10/net/dccp/ |
| H A D | input.c | 480 icsk->icsk_accept_queue.rskq_defer_accept) { in dccp_rcv_request_sent_state_process()
|
| /kernel/linux/linux-6.6/include/linux/ |
| H A D | tcp.h | 515 struct request_sock_queue *queue = &inet_csk(sk)->icsk_accept_queue; in fastopen_queue_tune()
|
| /kernel/linux/linux-6.6/net/dccp/ |
| H A D | input.c | 480 icsk->icsk_accept_queue.rskq_defer_accept) { in dccp_rcv_request_sent_state_process()
|
| /kernel/linux/linux-6.6/net/mptcp/ |
| H A D | subflow.c | 1423 if (reqsk_queue_empty(&inet_csk(sk)->icsk_accept_queue)) in subflow_data_ready()
1784 struct request_sock_queue *queue = &inet_csk(listener_ssk)->icsk_accept_queue; in mptcp_subflow_queue_clean()
|