Lines Matching refs:sk
78 void dccp_set_state(struct sock *sk, const int state) in dccp_set_state() argument
80 const int oldstate = sk->sk_state; in dccp_set_state()
82 dccp_pr_debug("%s(%p) %s --> %s\n", dccp_role(sk), sk, in dccp_set_state()
92 dccp_feat_list_purge(&dccp_sk(sk)->dccps_featneg); in dccp_set_state()
100 sk->sk_prot->unhash(sk); in dccp_set_state()
101 if (inet_csk(sk)->icsk_bind_hash != NULL && in dccp_set_state()
102 !(sk->sk_userlocks & SOCK_BINDPORT_LOCK)) in dccp_set_state()
103 inet_put_port(sk); in dccp_set_state()
113 inet_sk_set_state(sk, state); in dccp_set_state()
118 static void dccp_finish_passive_close(struct sock *sk) in dccp_finish_passive_close() argument
120 switch (sk->sk_state) { in dccp_finish_passive_close()
123 dccp_send_reset(sk, DCCP_RESET_CODE_CLOSED); in dccp_finish_passive_close()
124 dccp_set_state(sk, DCCP_CLOSED); in dccp_finish_passive_close()
131 dccp_send_close(sk, 1); in dccp_finish_passive_close()
132 dccp_set_state(sk, DCCP_CLOSING); in dccp_finish_passive_close()
136 void dccp_done(struct sock *sk) in dccp_done() argument
138 dccp_set_state(sk, DCCP_CLOSED); in dccp_done()
139 dccp_clear_xmit_timers(sk); in dccp_done()
141 sk->sk_shutdown = SHUTDOWN_MASK; in dccp_done()
143 if (!sock_flag(sk, SOCK_DEAD)) in dccp_done()
144 sk->sk_state_change(sk); in dccp_done()
146 inet_csk_destroy_sock(sk); in dccp_done()
174 static void dccp_sk_destruct(struct sock *sk) in dccp_sk_destruct() argument
176 struct dccp_sock *dp = dccp_sk(sk); in dccp_sk_destruct()
178 ccid_hc_tx_delete(dp->dccps_hc_tx_ccid, sk); in dccp_sk_destruct()
180 inet_sock_destruct(sk); in dccp_sk_destruct()
183 int dccp_init_sock(struct sock *sk, const __u8 ctl_sock_initialized) in dccp_init_sock() argument
185 struct dccp_sock *dp = dccp_sk(sk); in dccp_init_sock()
186 struct inet_connection_sock *icsk = inet_csk(sk); in dccp_init_sock()
190 sk->sk_state = DCCP_CLOSED; in dccp_init_sock()
191 sk->sk_write_space = dccp_write_space; in dccp_init_sock()
192 sk->sk_destruct = dccp_sk_destruct; in dccp_init_sock()
200 dccp_init_xmit_timers(sk); in dccp_init_sock()
205 return dccp_feat_init(sk); in dccp_init_sock()
211 void dccp_destroy_sock(struct sock *sk) in dccp_destroy_sock() argument
213 struct dccp_sock *dp = dccp_sk(sk); in dccp_destroy_sock()
215 __skb_queue_purge(&sk->sk_write_queue); in dccp_destroy_sock()
216 if (sk->sk_send_head != NULL) { in dccp_destroy_sock()
217 kfree_skb(sk->sk_send_head); in dccp_destroy_sock()
218 sk->sk_send_head = NULL; in dccp_destroy_sock()
222 if (inet_csk(sk)->icsk_bind_hash != NULL) in dccp_destroy_sock()
223 inet_put_port(sk); in dccp_destroy_sock()
232 ccid_hc_rx_delete(dp->dccps_hc_rx_ccid, sk); in dccp_destroy_sock()
241 static inline int dccp_listen_start(struct sock *sk, int backlog) in dccp_listen_start() argument
243 struct dccp_sock *dp = dccp_sk(sk); in dccp_listen_start()
249 return inet_csk_listen_start(sk, backlog); in dccp_listen_start()
258 int dccp_disconnect(struct sock *sk, int flags) in dccp_disconnect() argument
260 struct inet_connection_sock *icsk = inet_csk(sk); in dccp_disconnect()
261 struct inet_sock *inet = inet_sk(sk); in dccp_disconnect()
262 struct dccp_sock *dp = dccp_sk(sk); in dccp_disconnect()
263 const int old_state = sk->sk_state; in dccp_disconnect()
266 dccp_set_state(sk, DCCP_CLOSED); in dccp_disconnect()
273 inet_csk_listen_stop(sk); in dccp_disconnect()
275 dccp_send_reset(sk, DCCP_RESET_CODE_ABORTED); in dccp_disconnect()
276 sk->sk_err = ECONNRESET; in dccp_disconnect()
278 sk->sk_err = ECONNRESET; in dccp_disconnect()
280 dccp_clear_xmit_timers(sk); in dccp_disconnect()
281 ccid_hc_rx_delete(dp->dccps_hc_rx_ccid, sk); in dccp_disconnect()
284 __skb_queue_purge(&sk->sk_receive_queue); in dccp_disconnect()
285 __skb_queue_purge(&sk->sk_write_queue); in dccp_disconnect()
286 if (sk->sk_send_head != NULL) { in dccp_disconnect()
287 __kfree_skb(sk->sk_send_head); in dccp_disconnect()
288 sk->sk_send_head = NULL; in dccp_disconnect()
293 if (!(sk->sk_userlocks & SOCK_BINDADDR_LOCK)) in dccp_disconnect()
294 inet_reset_saddr(sk); in dccp_disconnect()
296 sk->sk_shutdown = 0; in dccp_disconnect()
297 sock_reset_flag(sk, SOCK_DONE); in dccp_disconnect()
300 inet_csk_delack_init(sk); in dccp_disconnect()
301 __sk_dst_reset(sk); in dccp_disconnect()
305 sk->sk_error_report(sk); in dccp_disconnect()
322 struct sock *sk = sock->sk; in dccp_poll() local
325 if (sk->sk_state == DCCP_LISTEN) in dccp_poll()
326 return inet_csk_listen_poll(sk); in dccp_poll()
334 if (sk->sk_err) in dccp_poll()
337 if (sk->sk_shutdown == SHUTDOWN_MASK || sk->sk_state == DCCP_CLOSED) in dccp_poll()
339 if (sk->sk_shutdown & RCV_SHUTDOWN) in dccp_poll()
343 if ((1 << sk->sk_state) & ~(DCCPF_REQUESTING | DCCPF_RESPOND)) { in dccp_poll()
344 if (atomic_read(&sk->sk_rmem_alloc) > 0) in dccp_poll()
347 if (!(sk->sk_shutdown & SEND_SHUTDOWN)) { in dccp_poll()
348 if (sk_stream_is_writeable(sk)) { in dccp_poll()
351 sk_set_bit(SOCKWQ_ASYNC_NOSPACE, sk); in dccp_poll()
352 set_bit(SOCK_NOSPACE, &sk->sk_socket->flags); in dccp_poll()
358 if (sk_stream_is_writeable(sk)) in dccp_poll()
368 int dccp_ioctl(struct sock *sk, int cmd, unsigned long arg) in dccp_ioctl() argument
372 lock_sock(sk); in dccp_ioctl()
374 if (sk->sk_state == DCCP_LISTEN) in dccp_ioctl()
379 int amount = sk_wmem_alloc_get(sk); in dccp_ioctl()
391 skb = skb_peek(&sk->sk_receive_queue); in dccp_ioctl()
407 release_sock(sk); in dccp_ioctl()
413 static int dccp_setsockopt_service(struct sock *sk, const __be32 service, in dccp_setsockopt_service() argument
416 struct dccp_sock *dp = dccp_sk(sk); in dccp_setsockopt_service()
437 lock_sock(sk); in dccp_setsockopt_service()
443 release_sock(sk); in dccp_setsockopt_service()
447 static int dccp_setsockopt_cscov(struct sock *sk, int cscov, bool rx) in dccp_setsockopt_cscov() argument
471 rc = dccp_feat_register_sp(sk, DCCPF_MIN_CSUM_COVER, rx, list, len); in dccp_setsockopt_cscov()
475 dccp_sk(sk)->dccps_pcrlen = cscov; in dccp_setsockopt_cscov()
477 dccp_sk(sk)->dccps_pcslen = cscov; in dccp_setsockopt_cscov()
483 static int dccp_setsockopt_ccid(struct sock *sk, int type, in dccp_setsockopt_ccid() argument
496 lock_sock(sk); in dccp_setsockopt_ccid()
498 rc = dccp_feat_register_sp(sk, DCCPF_CCID, 1, val, optlen); in dccp_setsockopt_ccid()
501 rc = dccp_feat_register_sp(sk, DCCPF_CCID, 0, val, optlen); in dccp_setsockopt_ccid()
502 release_sock(sk); in dccp_setsockopt_ccid()
508 static int do_dccp_setsockopt(struct sock *sk, int level, int optname, in do_dccp_setsockopt() argument
511 struct dccp_sock *dp = dccp_sk(sk); in do_dccp_setsockopt()
525 return dccp_setsockopt_ccid(sk, optname, optval, optlen); in do_dccp_setsockopt()
535 return dccp_setsockopt_service(sk, val, optval, optlen); in do_dccp_setsockopt()
537 lock_sock(sk); in do_dccp_setsockopt()
546 err = dccp_setsockopt_cscov(sk, val, false); in do_dccp_setsockopt()
549 err = dccp_setsockopt_cscov(sk, val, true); in do_dccp_setsockopt()
552 if (sk->sk_state != DCCP_CLOSED) in do_dccp_setsockopt()
569 release_sock(sk); in do_dccp_setsockopt()
574 int dccp_setsockopt(struct sock *sk, int level, int optname, sockptr_t optval, in dccp_setsockopt() argument
578 return inet_csk(sk)->icsk_af_ops->setsockopt(sk, level, in dccp_setsockopt()
581 return do_dccp_setsockopt(sk, level, optname, optval, optlen); in dccp_setsockopt()
586 static int dccp_getsockopt_service(struct sock *sk, int len, in dccp_getsockopt_service() argument
590 const struct dccp_sock *dp = dccp_sk(sk); in dccp_getsockopt_service()
594 lock_sock(sk); in dccp_getsockopt_service()
610 release_sock(sk); in dccp_getsockopt_service()
614 static int do_dccp_getsockopt(struct sock *sk, int level, int optname, in do_dccp_getsockopt() argument
626 dp = dccp_sk(sk); in do_dccp_getsockopt()
633 return dccp_getsockopt_service(sk, len, in do_dccp_getsockopt()
639 return ccid_getsockopt_builtin_ccids(sk, len, optval, optlen); in do_dccp_getsockopt()
666 return ccid_hc_rx_getsockopt(dp->dccps_hc_rx_ccid, sk, optname, in do_dccp_getsockopt()
669 return ccid_hc_tx_getsockopt(dp->dccps_hc_tx_ccid, sk, optname, in do_dccp_getsockopt()
682 int dccp_getsockopt(struct sock *sk, int level, int optname, in dccp_getsockopt() argument
686 return inet_csk(sk)->icsk_af_ops->getsockopt(sk, level, in dccp_getsockopt()
689 return do_dccp_getsockopt(sk, level, optname, optval, optlen); in dccp_getsockopt()
718 !dccp_qpolicy_param_ok(skb->sk, cmsg->cmsg_type)) in dccp_msghdr_parse()
734 int dccp_sendmsg(struct sock *sk, struct msghdr *msg, size_t len) in dccp_sendmsg() argument
736 const struct dccp_sock *dp = dccp_sk(sk); in dccp_sendmsg()
743 trace_dccp_probe(sk, len); in dccp_sendmsg()
748 lock_sock(sk); in dccp_sendmsg()
750 if (dccp_qpolicy_full(sk)) { in dccp_sendmsg()
755 timeo = sock_sndtimeo(sk, noblock); in dccp_sendmsg()
762 if ((1 << sk->sk_state) & ~(DCCPF_OPEN | DCCPF_PARTOPEN)) in dccp_sendmsg()
763 if ((rc = sk_stream_wait_connect(sk, &timeo)) != 0) in dccp_sendmsg()
766 size = sk->sk_prot->max_header + len; in dccp_sendmsg()
767 release_sock(sk); in dccp_sendmsg()
768 skb = sock_alloc_send_skb(sk, size, noblock, &rc); in dccp_sendmsg()
769 lock_sock(sk); in dccp_sendmsg()
773 if (sk->sk_state == DCCP_CLOSED) { in dccp_sendmsg()
778 skb_reserve(skb, sk->sk_prot->max_header); in dccp_sendmsg()
787 dccp_qpolicy_push(sk, skb); in dccp_sendmsg()
794 dccp_write_xmit(sk); in dccp_sendmsg()
796 release_sock(sk); in dccp_sendmsg()
805 int dccp_recvmsg(struct sock *sk, struct msghdr *msg, size_t len, int nonblock, in dccp_recvmsg() argument
811 lock_sock(sk); in dccp_recvmsg()
813 if (sk->sk_state == DCCP_LISTEN) { in dccp_recvmsg()
818 timeo = sock_rcvtimeo(sk, nonblock); in dccp_recvmsg()
821 struct sk_buff *skb = skb_peek(&sk->sk_receive_queue); in dccp_recvmsg()
836 dccp_finish_passive_close(sk); in dccp_recvmsg()
846 sk_eat_skb(sk, skb); in dccp_recvmsg()
849 if (sock_flag(sk, SOCK_DONE)) { in dccp_recvmsg()
854 if (sk->sk_err) { in dccp_recvmsg()
855 len = sock_error(sk); in dccp_recvmsg()
859 if (sk->sk_shutdown & RCV_SHUTDOWN) { in dccp_recvmsg()
864 if (sk->sk_state == DCCP_CLOSED) { in dccp_recvmsg()
865 if (!sock_flag(sk, SOCK_DONE)) { in dccp_recvmsg()
886 sk_wait_data(sk, &timeo, NULL); in dccp_recvmsg()
903 sk_eat_skb(sk, skb); in dccp_recvmsg()
907 release_sock(sk); in dccp_recvmsg()
915 struct sock *sk = sock->sk; in inet_dccp_listen() local
919 lock_sock(sk); in inet_dccp_listen()
925 old_state = sk->sk_state; in inet_dccp_listen()
929 WRITE_ONCE(sk->sk_max_ack_backlog, backlog); in inet_dccp_listen()
938 err = dccp_listen_start(sk, backlog); in inet_dccp_listen()
945 release_sock(sk); in inet_dccp_listen()
951 static void dccp_terminate_connection(struct sock *sk) in dccp_terminate_connection() argument
955 switch (sk->sk_state) { in dccp_terminate_connection()
958 dccp_finish_passive_close(sk); in dccp_terminate_connection()
961 dccp_pr_debug("Stop PARTOPEN timer (%p)\n", sk); in dccp_terminate_connection()
962 inet_csk_clear_xmit_timer(sk, ICSK_TIME_DACK); in dccp_terminate_connection()
965 dccp_send_close(sk, 1); in dccp_terminate_connection()
967 if (dccp_sk(sk)->dccps_role == DCCP_ROLE_SERVER && in dccp_terminate_connection()
968 !dccp_sk(sk)->dccps_server_timewait) in dccp_terminate_connection()
974 dccp_set_state(sk, next_state); in dccp_terminate_connection()
978 void dccp_close(struct sock *sk, long timeout) in dccp_close() argument
980 struct dccp_sock *dp = dccp_sk(sk); in dccp_close()
985 lock_sock(sk); in dccp_close()
987 sk->sk_shutdown = SHUTDOWN_MASK; in dccp_close()
989 if (sk->sk_state == DCCP_LISTEN) { in dccp_close()
990 dccp_set_state(sk, DCCP_CLOSED); in dccp_close()
993 inet_csk_listen_stop(sk); in dccp_close()
998 sk_stop_timer(sk, &dp->dccps_xmit_timer); in dccp_close()
1005 while ((skb = __skb_dequeue(&sk->sk_receive_queue)) != NULL) { in dccp_close()
1011 if (sk->sk_state == DCCP_CLOSED) in dccp_close()
1017 dccp_send_reset(sk, DCCP_RESET_CODE_ABORTED); in dccp_close()
1018 dccp_set_state(sk, DCCP_CLOSED); in dccp_close()
1019 } else if (sock_flag(sk, SOCK_LINGER) && !sk->sk_lingertime) { in dccp_close()
1021 sk->sk_prot->disconnect(sk, 0); in dccp_close()
1022 } else if (sk->sk_state != DCCP_CLOSED) { in dccp_close()
1027 dccp_flush_write_queue(sk, &timeout); in dccp_close()
1028 dccp_terminate_connection(sk); in dccp_close()
1037 __skb_queue_purge(&sk->sk_write_queue); in dccp_close()
1039 sk_stream_wait_close(sk, timeout); in dccp_close()
1042 state = sk->sk_state; in dccp_close()
1043 sock_hold(sk); in dccp_close()
1044 sock_orphan(sk); in dccp_close()
1049 release_sock(sk); in dccp_close()
1055 bh_lock_sock(sk); in dccp_close()
1056 WARN_ON(sock_owned_by_user(sk)); in dccp_close()
1061 if (state != DCCP_CLOSED && sk->sk_state == DCCP_CLOSED) in dccp_close()
1064 if (sk->sk_state == DCCP_CLOSED) in dccp_close()
1065 inet_csk_destroy_sock(sk); in dccp_close()
1070 bh_unlock_sock(sk); in dccp_close()
1072 sock_put(sk); in dccp_close()
1077 void dccp_shutdown(struct sock *sk, int how) in dccp_shutdown() argument