/Linux-v6.1/net/smc/ |
D | smc_close.c | 132 if (sk->sk_state != SMC_INIT && smc->clcsock && smc->clcsock->sk) { in smc_close_active_abort() 137 switch (sk->sk_state) { in smc_close_active_abort() 141 sk->sk_state = SMC_PEERABORTWAIT; in smc_close_active_abort() 143 if (sk->sk_state != SMC_PEERABORTWAIT) in smc_close_active_abort() 145 sk->sk_state = SMC_CLOSED; in smc_close_active_abort() 151 sk->sk_state = SMC_PEERABORTWAIT; in smc_close_active_abort() 153 if (sk->sk_state != SMC_PEERABORTWAIT) in smc_close_active_abort() 155 sk->sk_state = SMC_CLOSED; in smc_close_active_abort() 162 sk->sk_state = SMC_PEERABORTWAIT; in smc_close_active_abort() 164 if (sk->sk_state != SMC_PEERABORTWAIT) in smc_close_active_abort() [all …]
|
D | af_smc.c | 280 if (sk->sk_state != SMC_CLOSED) { in __smc_release() 281 if (sk->sk_state != SMC_LISTEN && in __smc_release() 282 sk->sk_state != SMC_INIT) in __smc_release() 284 if (sk->sk_state == SMC_LISTEN) { in __smc_release() 289 sk->sk_state = SMC_CLOSED; in __smc_release() 297 if (sk->sk_state == SMC_CLOSED) { in __smc_release() 322 old_state = sk->sk_state; in smc_release() 331 if (sk->sk_state == SMC_LISTEN) in smc_release() 339 if (old_state == SMC_INIT && sk->sk_state == SMC_ACTIVE && in smc_release() 358 if (sk->sk_state != SMC_CLOSED) in smc_destruct() [all …]
|
D | smc_rx.c | 43 (sk->sk_state == SMC_CLOSED)) in smc_rx_wake_up() 118 if (sk->sk_state == SMC_CLOSED || in smc_rx_pipe_buf_release() 119 sk->sk_state == SMC_PEERFINCLOSEWAIT || in smc_rx_pipe_buf_release() 120 sk->sk_state == SMC_APPFINCLOSEWAIT) in smc_rx_pipe_buf_release() 315 if (sk->sk_state == SMC_CLOSED || sk->sk_shutdown & RCV_SHUTDOWN) in smc_rx_recv_urg() 360 if (sk->sk_state == SMC_LISTEN) in smc_rx_recvmsg() 397 sk->sk_state == SMC_CLOSED || in smc_rx_recvmsg() 406 if (sk->sk_state == SMC_CLOSED) { in smc_rx_recvmsg()
|
/Linux-v6.1/net/bluetooth/ |
D | sco.c | 95 BT_DBG("sock %p state %d", sk, sk->sk_state); in sco_sock_timeout() 109 BT_DBG("sock %p state %d timeout %ld", sk, sk->sk_state, timeout); in sco_sock_set_timer() 119 BT_DBG("sock %p state %d", sk, sk->sk_state); in sco_sock_clear_timer() 172 sk->sk_state = BT_CLOSED; in sco_chan_del() 275 sk->sk_state = BT_CONNECTED; in sco_connect() 277 sk->sk_state = BT_CONNECT; in sco_connect() 313 if (sk->sk_state != BT_CONNECTED) in sco_recv_frame() 329 if (sk->sk_state != BT_LISTEN) in __sco_get_sock_listen_by_addr() 349 if (sk->sk_state != BT_LISTEN) in sco_get_sock_listen() 386 parent->sk_state = BT_CLOSED; in sco_sock_cleanup_listen() [all …]
|
D | iso.c | 86 BT_DBG("sock %p state %d", sk, sk->sk_state); in iso_sock_timeout() 100 BT_DBG("sock %p state %d timeout %ld", sk, sk->sk_state, timeout); in iso_sock_set_timer() 110 BT_DBG("sock %p state %d", sk, sk->sk_state); in iso_sock_clear_timer() 158 sk->sk_state = BT_CLOSED; in iso_chan_del() 297 sk->sk_state = BT_CONNECTED; in iso_connect_bis() 299 sk->sk_state = BT_CONNECT; in iso_connect_bis() 371 sk->sk_state = BT_CONNECTED; in iso_connect_cis() 374 sk->sk_state = BT_CONNECT; in iso_connect_cis() 376 sk->sk_state = BT_CONNECT; in iso_connect_cis() 388 if (sk->sk_state == BT_CONNECTED || sk->sk_state == BT_CONNECT2) in iso_sock_get_qos() [all …]
|
D | l2cap_sock.c | 114 if (sk->sk_state != BT_OPEN) { in l2cap_sock_bind() 173 sk->sk_state = BT_BOUND; in l2cap_sock_bind() 297 if (sk->sk_state != BT_BOUND) { in l2cap_sock_listen() 339 sk->sk_state = BT_LISTEN; in l2cap_sock_listen() 363 if (sk->sk_state != BT_LISTEN) { in l2cap_sock_accept() 411 if (peer && sk->sk_state != BT_CONNECTED && in l2cap_sock_getname() 412 sk->sk_state != BT_CONNECT && sk->sk_state != BT_CONNECT2 && in l2cap_sock_getname() 413 sk->sk_state != BT_CONFIG) in l2cap_sock_getname() 545 if (sk->sk_state != BT_CONNECTED && in l2cap_sock_getsockopt_old() 546 !(sk->sk_state == BT_CONNECT2 && in l2cap_sock_getsockopt_old() [all …]
|
D | af_bluetooth.c | 187 BT_DBG("sk %p state %d", sk, sk->sk_state); in bt_accept_unlink() 230 if (sk->sk_state == BT_CLOSED) { in bt_accept_dequeue() 236 if (sk->sk_state == BT_CONNECTED || !newsock || in bt_accept_dequeue() 445 if (sk->sk_state == BT_CONNECTED || in bt_accept_poll() 447 sk->sk_state == BT_CONNECT2)) in bt_accept_poll() 462 if (sk->sk_state == BT_LISTEN) in bt_sock_poll() 478 if (sk->sk_state == BT_CLOSED) in bt_sock_poll() 481 if (sk->sk_state == BT_CONNECT || in bt_sock_poll() 482 sk->sk_state == BT_CONNECT2 || in bt_sock_poll() 483 sk->sk_state == BT_CONFIG) in bt_sock_poll() [all …]
|
/Linux-v6.1/net/nfc/ |
D | llcp_sock.c | 27 while (sk->sk_state != state) { in sock_wait_state() 84 if (sk->sk_state != LLCP_CLOSED) { in llcp_sock_bind() 126 sk->sk_state = LLCP_BOUND; in llcp_sock_bind() 171 if (sk->sk_state != LLCP_CLOSED) { in llcp_raw_sock_bind() 194 sk->sk_state = LLCP_BOUND; in llcp_raw_sock_bind() 214 sk->sk_state != LLCP_BOUND) { in llcp_sock_listen() 223 sk->sk_state = LLCP_LISTEN; in llcp_sock_listen() 248 if (sk->sk_state == LLCP_CONNECTED || in nfc_llcp_setsockopt() 249 sk->sk_state == LLCP_BOUND || in nfc_llcp_setsockopt() 250 sk->sk_state == LLCP_LISTEN) { in nfc_llcp_setsockopt() [all …]
|
/Linux-v6.1/net/iucv/ |
D | af_iucv.c | 152 return (sk->sk_state == state || sk->sk_state == state2); in iucv_sock_in_state() 167 if (sk->sk_state != IUCV_CONNECTED) in iucv_below_msglim() 303 parent->sk_state = IUCV_CLOSED; in iucv_sock_cleanup_listen() 386 switch (sk->sk_state) { in iucv_sock_close() 394 sk->sk_state = IUCV_DISCONN; in iucv_sock_close() 400 sk->sk_state = IUCV_CLOSING; in iucv_sock_close() 415 sk->sk_state = IUCV_CLOSED; in iucv_sock_close() 487 sk->sk_state = IUCV_OPEN; in iucv_sock_alloc() 529 if (sk->sk_state == IUCV_CLOSED) { in iucv_accept_dequeue() 535 if (sk->sk_state == IUCV_CONNECTED || in iucv_accept_dequeue() [all …]
|
/Linux-v6.1/net/phonet/ |
D | pep.c | 231 BUG_ON(sk->sk_state != TCP_ESTABLISHED); in pipe_grant_credits() 340 BUG_ON(sk->sk_state == TCP_CLOSE_WAIT); in pipe_do_rcv() 349 sk->sk_state = TCP_CLOSE_WAIT; in pipe_do_rcv() 430 if (sk->sk_state == TCP_ESTABLISHED) in pipe_do_rcv() 432 sk->sk_state = TCP_ESTABLISHED; in pipe_do_rcv() 437 sk->sk_state = TCP_SYN_RECV; in pipe_do_rcv() 583 if (sk->sk_state != TCP_SYN_SENT) in pipe_handler_do_rcv() 588 sk->sk_state = TCP_CLOSE_WAIT; in pipe_handler_do_rcv() 592 sk->sk_state = TCP_SYN_RECV; in pipe_handler_do_rcv() 594 sk->sk_state = TCP_ESTABLISHED; in pipe_handler_do_rcv() [all …]
|
D | socket.c | 179 if (sk->sk_state != TCP_CLOSE || pn_port(pn->sobject)) { in pn_socket_bind() 238 if (sk->sk_state != TCP_CLOSE) { in pn_socket_connect() 262 while (sk->sk_state == TCP_SYN_SENT) { in pn_socket_connect() 282 if ((1 << sk->sk_state) & (TCPF_SYN_RECV|TCPF_ESTABLISHED)) in pn_socket_connect() 284 else if (sk->sk_state == TCP_CLOSE_WAIT) in pn_socket_connect() 301 if (unlikely(sk->sk_state != TCP_LISTEN)) in pn_socket_accept() 339 if (sk->sk_state == TCP_CLOSE) in pn_socket_poll() 345 if (!mask && sk->sk_state == TCP_CLOSE_WAIT) in pn_socket_poll() 348 if (sk->sk_state == TCP_ESTABLISHED && in pn_socket_poll() 407 if (sk->sk_state != TCP_LISTEN) { in pn_socket_listen() [all …]
|
/Linux-v6.1/net/bluetooth/rfcomm/ |
D | sock.c | 78 sk->sk_state = d->state; in rfcomm_sk_state_change() 117 if (sk->sk_state == BT_BOUND || sk->sk_state == BT_LISTEN) in __rfcomm_get_listen_sock_by_addr() 134 if (state && sk->sk_state != state) in rfcomm_get_sock_by_channel() 185 parent->sk_state = BT_CLOSED; in rfcomm_sock_cleanup_listen() 197 BT_DBG("sk %p state %d refcnt %d", sk, sk->sk_state, refcount_read(&sk->sk_refcnt)); in rfcomm_sock_kill() 209 BT_DBG("sk %p state %d socket %p", sk, sk->sk_state, sk->sk_socket); in __rfcomm_sock_close() 211 switch (sk->sk_state) { in __rfcomm_sock_close() 304 sk->sk_state = BT_OPEN; in rfcomm_sock_alloc() 352 if (sk->sk_state != BT_OPEN) { in rfcomm_sock_bind() 371 sk->sk_state = BT_BOUND; in rfcomm_sock_bind() [all …]
|
/Linux-v6.1/net/rxrpc/ |
D | af_rxrpc.c | 146 switch (rx->sk.sk_state) { in rxrpc_bind() 163 rx->sk.sk_state = RXRPC_SERVER_BOUND; in rxrpc_bind() 166 rx->sk.sk_state = RXRPC_CLIENT_BOUND; in rxrpc_bind() 182 rx->sk.sk_state = RXRPC_SERVER_BOUND2; in rxrpc_bind() 220 switch (rx->sk.sk_state) { in rxrpc_listen() 237 rx->sk.sk_state = RXRPC_SERVER_LISTENING; in rxrpc_listen() 243 rx->sk.sk_state = RXRPC_SERVER_LISTEN_DISABLED; in rxrpc_listen() 471 switch (rx->sk.sk_state) { in rxrpc_connect() 473 rx->sk.sk_state = RXRPC_CLIENT_UNBOUND; in rxrpc_connect() 507 _enter(",{%d},,%zu", rx->sk.sk_state, len); in rxrpc_sendmsg() [all …]
|
/Linux-v6.1/net/caif/ |
D | caif_socket.c | 168 if (unlikely(cf_sk->sk.sk_state != CAIF_CONNECTED)) { in caif_sktrecv_cb() 211 cf_sk->sk.sk_state = CAIF_CONNECTED; in caif_ctrl_cb() 219 cf_sk->sk.sk_state = CAIF_DISCONNECTED; in caif_ctrl_cb() 226 cf_sk->sk.sk_state = CAIF_DISCONNECTED; in caif_ctrl_cb() 314 sk->sk_state != CAIF_CONNECTED || in caif_stream_data_wait() 360 if (sk->sk_state == CAIF_CONNECTING) in caif_stream_recvmsg() 393 if (sk->sk_state != CAIF_CONNECTED) in caif_stream_recvmsg() 483 if (cf_sk->sk.sk_state != CAIF_CONNECTED) in caif_wait_for_flow_on() 549 if (cf_sk->sk.sk_state != CAIF_CONNECTED || in caif_seqpkt_sendmsg() 764 caif_assert(sk->sk_state == CAIF_DISCONNECTED); in caif_connect() [all …]
|
/Linux-v6.1/drivers/net/ppp/ |
D | pppoe.c | 307 sk->sk_state & (PPPOX_CONNECTED | PPPOX_BOUND)) { in pppoe_flush_dev() 378 if (sk->sk_state & PPPOX_BOUND) { in pppoe_rcv_core() 380 } else if (sk->sk_state & PPPOX_RELAY) { in pppoe_rcv_core() 386 if ((sk_pppox(relay_po)->sk_state & PPPOX_CONNECTED) == 0) in pppoe_rcv_core() 550 sk->sk_state = PPPOX_NONE; in pppoe_create() 587 sk->sk_state = PPPOX_DEAD; in pppoe_release() 632 if ((sk->sk_state & PPPOX_CONNECTED) && in pppoe_connect() 638 if ((sk->sk_state & PPPOX_DEAD) && in pppoe_connect() 662 sk->sk_state = PPPOX_NONE; in pppoe_connect() 704 sk->sk_state = PPPOX_CONNECTED; in pppoe_connect() [all …]
|
D | pppox.c | 57 if (sk->sk_state & (PPPOX_BOUND | PPPOX_CONNECTED)) { in pppox_unbind_sock() 59 sk->sk_state = PPPOX_DEAD; in pppox_unbind_sock() 79 if (!(sk->sk_state & PPPOX_CONNECTED)) in pppox_ioctl() 88 sk->sk_state |= PPPOX_BOUND; in pppox_ioctl()
|
D | pptp.c | 151 if (sk_pppox(po)->sk_state & PPPOX_DEAD) in pptp_xmit() 263 if (!(sk->sk_state & PPPOX_CONNECTED)) { in pptp_rcv_core() 380 if (sk->sk_state & PPPOX_DEAD) { in pptp_bind() 385 if (sk->sk_state & PPPOX_BOUND) { in pptp_bind() 393 sk->sk_state |= PPPOX_BOUND; in pptp_bind() 422 if (sk->sk_state & PPPOX_CONNECTED) { in pptp_connect() 428 if (sk->sk_state & PPPOX_DEAD) { in pptp_connect() 466 sk->sk_state |= PPPOX_CONNECTED; in pptp_connect() 511 sk->sk_state = PPPOX_DEAD; in pptp_release() 524 if (!(sk->sk_state & PPPOX_DEAD)) { in pptp_sock_destruct() [all …]
|
/Linux-v6.1/net/dccp/ |
D | proto.c | 80 const int oldstate = sk->sk_state; in dccp_set_state() 120 switch (sk->sk_state) { in dccp_finish_passive_close() 190 sk->sk_state = DCCP_CLOSED; in dccp_init_sock() 252 const int old_state = sk->sk_state; in dccp_disconnect() 313 if (sk->sk_state == DCCP_LISTEN) in dccp_poll() 325 if (sk->sk_shutdown == SHUTDOWN_MASK || sk->sk_state == DCCP_CLOSED) in dccp_poll() 331 if ((1 << sk->sk_state) & ~(DCCPF_REQUESTING | DCCPF_RESPOND)) { in dccp_poll() 362 if (sk->sk_state == DCCP_LISTEN) in dccp_ioctl() 540 if (sk->sk_state != DCCP_CLOSED) in do_dccp_setsockopt() 745 if ((1 << sk->sk_state) & ~(DCCPF_OPEN | DCCPF_PARTOPEN)) in dccp_sendmsg() [all …]
|
D | input.c | 47 switch (sk->sk_state) { in dccp_rcv_close() 105 switch (sk->sk_state) { in dccp_rcv_closereq() 531 if (sk->sk_state == DCCP_RESPOND) in dccp_rcv_respond_partopen_state_process() 546 if (sk->sk_state == DCCP_PARTOPEN) in dccp_rcv_respond_partopen_state_process() 576 const int old_state = sk->sk_state; in dccp_rcv_state_process() 602 if (sk->sk_state == DCCP_LISTEN) { in dccp_rcv_state_process() 623 } else if (sk->sk_state == DCCP_CLOSED) { in dccp_rcv_state_process() 629 if (sk->sk_state != DCCP_REQUESTING && dccp_check_seqno(sk, skb)) in dccp_rcv_state_process() 644 (sk->sk_state == DCCP_RESPOND && dh->dccph_type == DCCP_PKT_DATA)) { in dccp_rcv_state_process() 674 switch (sk->sk_state) { in dccp_rcv_state_process()
|
D | timer.c | 36 if (sk->sk_state == DCCP_REQUESTING || sk->sk_state == DCCP_PARTOPEN) { in dccp_write_timeout() 139 if (sk->sk_state == DCCP_CLOSED || !icsk->icsk_pending) in dccp_write_timer() 185 if (sk->sk_state == DCCP_CLOSED || in dccp_delack_timer()
|
/Linux-v6.1/net/x25/ |
D | af_x25.c | 278 s->sk_state == TCP_LISTEN) { in x25_find_listener() 389 skb->sk->sk_state = TCP_LISTEN; in __x25_destroy_socket() 485 if (sk->sk_state != TCP_LISTEN) { in x25_listen() 488 sk->sk_state = TCP_LISTEN; in x25_listen() 599 sk->sk_state = TCP_ESTABLISHED; in x25_make_new() 646 sk->sk_state = TCP_CLOSE; in x25_release() 723 if (sk->sk_state == TCP_CLOSE) { in x25_wait_for_connection_establishment() 728 if (sk->sk_state != TCP_ESTABLISHED) { in x25_wait_for_connection_establishment() 750 if (sk->sk_state == TCP_ESTABLISHED && sock->state == SS_CONNECTING) { in x25_connect() 756 if (sk->sk_state == TCP_CLOSE && sock->state == SS_CONNECTING) { in x25_connect() [all …]
|
/Linux-v6.1/net/ipv4/ |
D | tcp_timer.c | 222 if ((1 << sk->sk_state) & (TCPF_SYN_SENT | TCPF_SYN_RECV)) in retransmits_timed_out() 239 if ((1 << sk->sk_state) & (TCPF_SYN_SENT | TCPF_SYN_RECV)) { in tcp_write_timeout() 294 if (((1 << sk->sk_state) & (TCPF_CLOSE | TCPF_LISTEN)) || in tcp_delack_timer_handler() 457 WARN_ON_ONCE(sk->sk_state != TCP_SYN_RECV && in tcp_retransmit_timer() 458 sk->sk_state != TCP_FIN_WAIT1); in tcp_retransmit_timer() 476 !((1 << sk->sk_state) & (TCPF_SYN_SENT | TCPF_SYN_RECV))) { in tcp_retransmit_timer() 574 if (sk->sk_state == TCP_ESTABLISHED && in tcp_retransmit_timer() 599 if (((1 << sk->sk_state) & (TCPF_CLOSE | TCPF_LISTEN)) || in tcp_write_timer_handler() 657 if ((1 << sk->sk_state) & (TCPF_CLOSE | TCPF_LISTEN)) in tcp_set_keepalive() 683 if (sk->sk_state == TCP_LISTEN) { in tcp_keepalive_timer() [all …]
|
/Linux-v6.1/tools/testing/selftests/bpf/progs/ |
D | bpf_iter_unix.c | 44 sk->sk_state == TCP_LISTEN ? __SO_ACCEPTCON : 0, in dump_unix() 47 (sk->sk_state == TCP_ESTABLISHED ? SS_CONNECTED : SS_UNCONNECTED) : in dump_unix() 48 (sk->sk_state == TCP_ESTABLISHED ? SS_CONNECTING : SS_DISCONNECTING), in dump_unix()
|
/Linux-v6.1/net/netrom/ |
D | af_netrom.c | 152 s->sk_state == TCP_LISTEN) { in nr_find_listener() 403 if (sk->sk_state != TCP_LISTEN) { in nr_listen() 406 sk->sk_state = TCP_LISTEN; in nr_listen() 489 sk->sk_state = TCP_ESTABLISHED; in nr_make_new() 542 sk->sk_state = TCP_CLOSE; in nr_release() 642 if (sk->sk_state == TCP_ESTABLISHED && sock->state == SS_CONNECTING) { in nr_connect() 647 if (sk->sk_state == TCP_CLOSE && sock->state == SS_CONNECTING) { in nr_connect() 653 if (sk->sk_state == TCP_ESTABLISHED) { in nr_connect() 658 sk->sk_state = TCP_CLOSE; in nr_connect() 711 sk->sk_state = TCP_SYN_SENT; in nr_connect() [all …]
|
/Linux-v6.1/net/rose/ |
D | af_rose.c | 254 !rose->source_ndigis && s->sk_state == TCP_LISTEN) in rose_find_listener() 263 s->sk_state == TCP_LISTEN) in rose_find_listener() 491 if (sk->sk_state != TCP_LISTEN) { in rose_listen() 499 sk->sk_state = TCP_LISTEN; in rose_listen() 582 sk->sk_state = TCP_ESTABLISHED; in rose_make_new() 640 sk->sk_state = TCP_CLOSE; in rose_release() 750 if (sk->sk_state == TCP_ESTABLISHED && sock->state == SS_CONNECTING) { in rose_connect() 756 if (sk->sk_state == TCP_CLOSE && sock->state == SS_CONNECTING) { in rose_connect() 762 if (sk->sk_state == TCP_ESTABLISHED) { in rose_connect() 768 sk->sk_state = TCP_CLOSE; in rose_connect() [all …]
|