Home
last modified time | relevance | path

Searched refs:sk_state (Results 1 – 25 of 125) sorted by relevance

12345

/linux/net/smc/
H A Dsmc_close.c133 if (sk->sk_state != SMC_INIT && smc->clcsock && smc->clcsock->sk) { in smc_close_active_abort()
138 switch (sk->sk_state) { in smc_close_active_abort()
142 sk->sk_state = SMC_PEERABORTWAIT; in smc_close_active_abort()
144 if (sk->sk_state != SMC_PEERABORTWAIT) in smc_close_active_abort()
146 sk->sk_state = SMC_CLOSED; in smc_close_active_abort()
152 sk->sk_state = SMC_PEERABORTWAIT; in smc_close_active_abort()
154 if (sk->sk_state != SMC_PEERABORTWAIT) in smc_close_active_abort()
156 sk->sk_state = SMC_CLOSED; in smc_close_active_abort()
163 sk->sk_state = SMC_PEERABORTWAIT; in smc_close_active_abort()
165 if (sk->sk_state != SMC_PEERABORTWAIT) in smc_close_active_abort()
[all …]
H A Daf_smc.c298 if (sk->sk_state != SMC_CLOSED) { in __smc_release()
299 if (sk->sk_state != SMC_LISTEN && in __smc_release()
300 sk->sk_state != SMC_INIT) in __smc_release()
302 if (sk->sk_state == SMC_LISTEN) { in __smc_release()
307 sk->sk_state = SMC_CLOSED; in __smc_release()
315 if (sk->sk_state == SMC_CLOSED) { in __smc_release()
340 old_state = sk->sk_state; in smc_release()
349 if (sk->sk_state == SMC_LISTEN) in smc_release()
357 if (old_state == SMC_INIT && sk->sk_state == SMC_ACTIVE && in smc_release()
376 if (sk->sk_state != SMC_CLOSED) in smc_destruct()
[all …]
H A Dsmc_rx.c47 (sk->sk_state == SMC_CLOSED)) in smc_rx_wake_up()
327 if (sk->sk_state == SMC_CLOSED || sk->sk_shutdown & RCV_SHUTDOWN) in smc_rx_recv_urg()
372 if (sk->sk_state == SMC_LISTEN) in smc_rx_recvmsg()
409 sk->sk_state == SMC_CLOSED || in smc_rx_recvmsg()
418 if (sk->sk_state == SMC_CLOSED) { in smc_rx_recvmsg()
/linux/net/bluetooth/
H A Dsco.c162 BT_DBG("sock %p state %d", sk, sk->sk_state); in sco_sock_timeout()
176 BT_DBG("sock %p state %d timeout %ld", sk, sk->sk_state, timeout); in sco_sock_set_timer()
186 BT_DBG("sock %p state %d", sk, sk->sk_state); in sco_sock_clear_timer()
251 sk->sk_state = BT_CLOSED; in sco_chan_del()
371 if (sk->sk_state != BT_OPEN && sk->sk_state != BT_BOUND) { in sco_connect()
390 sk->sk_state = BT_CONNECTED; in sco_connect()
392 sk->sk_state = BT_CONNECT; in sco_connect()
435 if (sk->sk_state != BT_CONNECTED) in sco_recv_frame()
455 if (sk->sk_state != BT_LISTEN) in __sco_get_sock_listen_by_addr()
475 if (sk->sk_state != BT_LISTEN) in sco_get_sock_listen()
[all …]
H A Dl2cap_sock.c114 if (sk->sk_state != BT_OPEN) { in l2cap_sock_bind()
173 sk->sk_state = BT_BOUND; in l2cap_sock_bind()
281 if (sk->sk_state != BT_BOUND) { in l2cap_sock_listen()
321 sk->sk_state = BT_LISTEN; in l2cap_sock_listen()
345 if (sk->sk_state != BT_LISTEN) { in l2cap_sock_accept()
398 if (peer && sk->sk_state != BT_CONNECTED && in l2cap_sock_getname()
399 sk->sk_state != BT_CONNECT && sk->sk_state != BT_CONNECT2 && in l2cap_sock_getname()
400 sk->sk_state != BT_CONFIG) in l2cap_sock_getname()
549 if (sk->sk_state ! in l2cap_sock_getsockopt_old()
[all...]
H A Diso.c190 BT_DBG("sock %p state %d", sk, sk->sk_state); in iso_sock_timeout()
209 BT_DBG("sock %p state %d timeout %ld", sk, sk->sk_state, timeout); in iso_sock_set_timer()
215 BT_DBG("sock %p state %d", sk, sk->sk_state); in iso_sock_clear_timer()
223 BT_DBG("sock %p state %d", sk, sk->sk_state); in iso_sock_disable_timer()
284 sk->sk_state = BT_CLOSED; in iso_chan_del()
476 sk->sk_state = BT_CONNECTED; in iso_connect_bis()
479 sk->sk_state = BT_CONNECT; in iso_connect_bis()
481 sk->sk_state = BT_CONNECT; in iso_connect_bis()
581 sk->sk_state = BT_CONNECTED; in iso_connect_cis()
584 sk->sk_state in iso_connect_cis()
[all...]
H A Daf_bluetooth.c159 sk->sk_state = BT_OPEN; in bt_sock_alloc()
261 BT_DBG("sk %p state %d", sk, sk->sk_state); in bt_accept_unlink()
326 if (sk->sk_state == BT_CLOSED) { in bt_accept_dequeue()
333 if (sk->sk_state == BT_CONNECTED || !newsock || in bt_accept_dequeue()
561 state = READ_ONCE(sk->sk_state); in bt_accept_poll()
583 if (sk->sk_state == BT_LISTEN) in bt_sock_poll()
599 if (sk->sk_state == BT_CLOSED) in bt_sock_poll()
602 if (sk->sk_state == BT_CONNECT || in bt_sock_poll()
603 sk->sk_state == BT_CONNECT2 || in bt_sock_poll()
604 sk->sk_state == BT_CONFIG) in bt_sock_poll()
[all …]
/linux/net/nfc/
H A Dllcp_sock.c27 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/net/iucv/
H A Daf_iucv.c155 return (sk->sk_state == state || sk->sk_state == state2); in iucv_sock_in_state()
170 if (sk->sk_state != IUCV_CONNECTED) in iucv_below_msglim()
306 parent->sk_state = IUCV_CLOSED; in iucv_sock_cleanup_listen()
403 switch (sk->sk_state) { in iucv_sock_close()
411 sk->sk_state = IUCV_DISCONN; in iucv_sock_close()
417 sk->sk_state = IUCV_CLOSING; in iucv_sock_close()
432 sk->sk_state = IUCV_CLOSED; in iucv_sock_close()
504 sk->sk_state = IUCV_OPEN; in iucv_sock_alloc()
546 if (sk->sk_state in iucv_accept_dequeue()
[all...]
/linux/net/bluetooth/rfcomm/
H A Dsock.c77 sk->sk_state = d->state; in rfcomm_sk_state_change()
116 if (sk->sk_state == BT_BOUND || sk->sk_state == BT_LISTEN) in __rfcomm_get_listen_sock_by_addr()
133 if (state && sk->sk_state != state) in rfcomm_get_sock_by_channel()
196 parent->sk_state = BT_CLOSED; in rfcomm_sock_cleanup_listen()
208 BT_DBG("sk %p state %d refcnt %d", sk, sk->sk_state, refcount_read(&sk->sk_refcnt)); in rfcomm_sock_kill()
220 BT_DBG("sk %p state %d socket %p", sk, sk->sk_state, sk->sk_socket); in __rfcomm_sock_close()
222 switch (sk->sk_state) { in __rfcomm_sock_close()
356 if (sk->sk_state != BT_OPEN) { in rfcomm_sock_bind()
375 sk->sk_state = BT_BOUND; in rfcomm_sock_bind()
402 if (sk->sk_state != BT_OPEN && sk->sk_state != BT_BOUND) { in rfcomm_sock_connect()
[all …]
/linux/net/rxrpc/
H A Daf_rxrpc.c148 switch (rx->sk.sk_state) { in rxrpc_bind()
165 rx->sk.sk_state = RXRPC_SERVER_BOUND; in rxrpc_bind()
168 rx->sk.sk_state = RXRPC_CLIENT_BOUND; in rxrpc_bind()
184 rx->sk.sk_state = RXRPC_SERVER_BOUND2; in rxrpc_bind()
222 switch (rx->sk.sk_state) { in rxrpc_listen()
239 rx->sk.sk_state = RXRPC_SERVER_LISTENING; in rxrpc_listen()
245 rx->sk.sk_state = RXRPC_SERVER_LISTEN_DISABLED; in rxrpc_listen()
508 switch (rx->sk.sk_state) { in rxrpc_connect()
510 rx->sk.sk_state = RXRPC_CLIENT_UNBOUND; in rxrpc_connect()
544 _enter(",{%d},,%zu", rx->sk.sk_state, le in rxrpc_sendmsg()
[all...]
/linux/net/phonet/
H A Dpep.c233 BUG_ON(sk->sk_state != TCP_ESTABLISHED); in pipe_grant_credits()
342 BUG_ON(sk->sk_state == TCP_CLOSE_WAIT); in pipe_do_rcv()
351 sk->sk_state = TCP_CLOSE_WAIT; in pipe_do_rcv()
432 if (sk->sk_state == TCP_ESTABLISHED) in pipe_do_rcv()
434 sk->sk_state = TCP_ESTABLISHED; in pipe_do_rcv()
439 sk->sk_state = TCP_SYN_RECV; in pipe_do_rcv()
585 if (sk->sk_state != TCP_SYN_SENT) in pipe_handler_do_rcv()
590 sk->sk_state = TCP_CLOSE_WAIT; in pipe_handler_do_rcv()
594 sk->sk_state = TCP_SYN_RECV; in pipe_handler_do_rcv()
596 sk->sk_state = TCP_ESTABLISHED; in pipe_handler_do_rcv()
[all …]
H A Dsocket.c179 if (sk->sk_state != TCP_CLOSE || pn_port(pn->sobject)) { in pn_socket_bind()
244 if (sk->sk_state != TCP_CLOSE) { in pn_socket_connect()
268 while (sk->sk_state == TCP_SYN_SENT) { in pn_socket_connect()
288 if ((1 << sk->sk_state) & (TCPF_SYN_RECV|TCPF_ESTABLISHED)) in pn_socket_connect()
290 else if (sk->sk_state == TCP_CLOSE_WAIT) in pn_socket_connect()
306 if (unlikely(sk->sk_state != TCP_LISTEN)) in pn_socket_accept()
344 if (sk->sk_state == TCP_CLOSE) in pn_socket_poll()
350 if (!mask && sk->sk_state == TCP_CLOSE_WAIT) in pn_socket_poll()
353 if (sk->sk_state == TCP_ESTABLISHED && in pn_socket_poll()
412 if (sk->sk_state != TCP_LISTEN) { in pn_socket_listen()
[all …]
/linux/net/x25/
H A Daf_x25.c279 s->sk_state == TCP_LISTEN) { in x25_find_listener()
391 skb->sk->sk_state = TCP_LISTEN; in __x25_destroy_socket()
487 if (sk->sk_state != TCP_LISTEN) { in x25_listen()
490 sk->sk_state = TCP_LISTEN; in x25_listen()
601 sk->sk_state = TCP_ESTABLISHED; in x25_make_new()
648 sk->sk_state = TCP_CLOSE; in x25_release()
725 if (sk->sk_state == TCP_CLOSE) { in x25_wait_for_connection_establishment()
730 if (sk->sk_state != TCP_ESTABLISHED) { in x25_wait_for_connection_establishment()
752 if (sk->sk_state == TCP_ESTABLISHED && sock->state == SS_CONNECTING) { in x25_connect()
758 if (sk->sk_state == TCP_CLOSE && sock->state == SS_CONNECTING) { in x25_connect()
[all …]
/linux/net/dccp/
H A Dinput.c
H A Dproto.c
H A Dtimer.c
H A Dipv6.c
/linux/drivers/net/ppp/
H A Dpppox.c57 if (sk->sk_state & (PPPOX_BOUND | PPPOX_CONNECTED)) { in pppox_unbind_sock()
59 sk->sk_state = PPPOX_DEAD; in pppox_unbind_sock()
81 if (!(sk->sk_state & PPPOX_CONNECTED)) in pppox_ioctl()
94 sk->sk_state |= PPPOX_BOUND; in pppox_ioctl()
H A Dpptp.c167 if (po->sk.sk_state & PPPOX_DEAD) in pptp_xmit()
281 if (!(sk->sk_state & PPPOX_CONNECTED)) in pptp_rcv_core()
395 if (sk->sk_state & PPPOX_DEAD) { in pptp_bind()
400 if (sk->sk_state & PPPOX_BOUND) { in pptp_bind()
408 sk->sk_state |= PPPOX_BOUND; in pptp_bind()
437 if (sk->sk_state & PPPOX_CONNECTED) { in pptp_connect()
443 if (sk->sk_state & PPPOX_DEAD) { in pptp_connect()
477 sk->sk_state |= PPPOX_CONNECTED; in pptp_connect()
522 sk->sk_state = PPPOX_DEAD; in pptp_release()
535 if (!(sk->sk_state & PPPOX_DEAD)) { in pptp_sock_destruct()
[all …]
H A Dpppoe.c290 sk->sk_state & (PPPOX_CONNECTED | PPPOX_BOUND)) { in pppoe_flush_dev()
358 if (sk->sk_state & PPPOX_BOUND) { in pppoe_rcv_core()
527 sk->sk_state = PPPOX_NONE; in pppoe_create()
564 sk->sk_state = PPPOX_DEAD; in pppoe_release()
608 if ((sk->sk_state & PPPOX_CONNECTED) && in pppoe_connect()
614 if ((sk->sk_state & PPPOX_DEAD) && in pppoe_connect()
637 sk->sk_state = PPPOX_NONE; in pppoe_connect()
680 sk->sk_state = PPPOX_CONNECTED; in pppoe_connect()
723 if (!(sk->sk_state & PPPOX_CONNECTED)) in pppoe_ioctl()
737 if (!(sk->sk_state & PPPOX_CONNECTED)) in pppoe_ioctl()
[all …]
/linux/net/ipv4/
H A Dtcp_timer.c229 if ((1 << sk->sk_state) & (TCPF_SYN_SENT | TCPF_SYN_RECV)) in retransmits_timed_out()
251 if ((1 << sk->sk_state) & (TCPF_SYN_SENT | TCPF_SYN_RECV)) { in tcp_write_timeout()
259 if (sk->sk_state == TCP_SYN_SENT) in tcp_write_timeout()
314 if ((1 << sk->sk_state) & (TCPF_CLOSE | TCPF_LISTEN)) in tcp_delack_timer_handler()
548 WARN_ON_ONCE(sk->sk_state != TCP_SYN_RECV && in tcp_retransmit_timer()
549 sk->sk_state != TCP_FIN_WAIT1); in tcp_retransmit_timer()
565 !((1 << sk->sk_state) & (TCPF_SYN_SENT | TCPF_SYN_RECV))) { in tcp_retransmit_timer()
669 if (sk->sk_state == TCP_ESTABLISHED && in tcp_retransmit_timer()
677 } else if (sk->sk_state != TCP_SYN_SENT || in tcp_retransmit_timer()
702 if (((1 << sk->sk_state) & (TCPF_CLOSE | TCPF_LISTEN)) || in tcp_write_timer_handler()
[all …]
/linux/net/llc/
H A Daf_llc.c447 if (unlikely(sk->sk_state != TCP_ESTABLISHED)) in llc_ui_shutdown()
505 sk->sk_state = TCP_SYN_SENT; in llc_ui_connect()
512 sk->sk_state = TCP_CLOSE; in llc_ui_connect()
516 if (sk->sk_state == TCP_SYN_SENT) { in llc_ui_connect()
529 if (sk->sk_state == TCP_CLOSE) in llc_ui_connect()
569 if (sk->sk_state != TCP_LISTEN) { in llc_ui_listen()
571 sk->sk_state = TCP_LISTEN; in llc_ui_listen()
587 READ_ONCE(sk->sk_state) == TCP_CLOSE, &wait)) in llc_ui_wait_for_disc()
608 READ_ONCE(sk->sk_state) != TCP_SYN_SENT, &wait)) in llc_ui_wait_for_conn()
709 sk->sk_state != TCP_LISTEN)) in llc_ui_accept()
[all …]
/linux/net/vmw_vsock/
H A Ddiag.c35 rep->vdiag_state = sk->sk_state; in sk_diag_fill()
83 if (!(req->vdiag_states & (1 << sk->sk_state))) in vsock_diag_dump()
117 if (!(req->vdiag_states & (1 << sk->sk_state))) in vsock_diag_dump()
/linux/net/unix/
H A Daf_unix.c140 if (a->sk.sk_state == TCP_LISTEN) { in unix_state_lock_cmp_fn()
153 switch (b->sk.sk_state) { in unix_state_lock_cmp_fn()
165 if (b->sk.sk_state == TCP_LISTEN) { in unix_state_lock_cmp_fn()
166 switch (b->sk.sk_state) { in unix_state_lock_cmp_fn()
188 if (a->sk_state == TCP_LISTEN && unix_sk(b)->listener == a) in unix_recvq_lock_cmp_fn()
192 if (b->sk_state == TCP_LISTEN && unix_sk(a)->listener == b) in unix_recvq_lock_cmp_fn()
602 if (unix_writable(sk, READ_ONCE(sk->sk_state))) { in unix_write_space()
683 state = sk->sk_state; in unix_release_sock()
684 WRITE_ONCE(sk->sk_state, TCP_CLOSE); in unix_release_sock()
827 if (sk->sk_state != TCP_CLOSE && sk->sk_state != TCP_LISTEN) in unix_listen()
[all …]

12345