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()
247 int dccp_disconnect(struct sock *sk, int flags)  in dccp_disconnect()  argument
249 	struct inet_connection_sock *icsk = inet_csk(sk);  in dccp_disconnect()
250 	struct inet_sock *inet = inet_sk(sk);  in dccp_disconnect()
251 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_disconnect()
252 	const int old_state = sk->sk_state;  in dccp_disconnect()
255 		dccp_set_state(sk, DCCP_CLOSED);  in dccp_disconnect()
262 		inet_csk_listen_stop(sk);  in dccp_disconnect()
264 		dccp_send_reset(sk, DCCP_RESET_CODE_ABORTED);  in dccp_disconnect()
265 		sk->sk_err = ECONNRESET;  in dccp_disconnect()
267 		sk->sk_err = ECONNRESET;  in dccp_disconnect()
269 	dccp_clear_xmit_timers(sk);  in dccp_disconnect()
270 	ccid_hc_rx_delete(dp->dccps_hc_rx_ccid, sk);  in dccp_disconnect()
273 	__skb_queue_purge(&sk->sk_receive_queue);  in dccp_disconnect()
274 	__skb_queue_purge(&sk->sk_write_queue);  in dccp_disconnect()
275 	if (sk->sk_send_head != NULL) {  in dccp_disconnect()
276 		__kfree_skb(sk->sk_send_head);  in dccp_disconnect()
277 		sk->sk_send_head = NULL;  in dccp_disconnect()
282 	inet_bhash2_reset_saddr(sk);  in dccp_disconnect()
284 	sk->sk_shutdown = 0;  in dccp_disconnect()
285 	sock_reset_flag(sk, SOCK_DONE);  in dccp_disconnect()
288 	inet_csk_delack_init(sk);  in dccp_disconnect()
289 	__sk_dst_reset(sk);  in dccp_disconnect()
293 	sk_error_report(sk);  in dccp_disconnect()
310 	struct sock *sk = sock->sk;  in dccp_poll()  local
313 	if (sk->sk_state == DCCP_LISTEN)  in dccp_poll()
314 		return inet_csk_listen_poll(sk);  in dccp_poll()
322 	if (sk->sk_err)  in dccp_poll()
325 	if (sk->sk_shutdown == SHUTDOWN_MASK || sk->sk_state == DCCP_CLOSED)  in dccp_poll()
327 	if (sk->sk_shutdown & RCV_SHUTDOWN)  in dccp_poll()
331 	if ((1 << sk->sk_state) & ~(DCCPF_REQUESTING | DCCPF_RESPOND)) {  in dccp_poll()
332 		if (atomic_read(&sk->sk_rmem_alloc) > 0)  in dccp_poll()
335 		if (!(sk->sk_shutdown & SEND_SHUTDOWN)) {  in dccp_poll()
336 			if (sk_stream_is_writeable(sk)) {  in dccp_poll()
339 				sk_set_bit(SOCKWQ_ASYNC_NOSPACE, sk);  in dccp_poll()
340 				set_bit(SOCK_NOSPACE, &sk->sk_socket->flags);  in dccp_poll()
346 				if (sk_stream_is_writeable(sk))  in dccp_poll()
356 int dccp_ioctl(struct sock *sk, int cmd, unsigned long arg)  in dccp_ioctl()  argument
360 	lock_sock(sk);  in dccp_ioctl()
362 	if (sk->sk_state == DCCP_LISTEN)  in dccp_ioctl()
367 		int amount = sk_wmem_alloc_get(sk);  in dccp_ioctl()
379 		skb = skb_peek(&sk->sk_receive_queue);  in dccp_ioctl()
395 	release_sock(sk);  in dccp_ioctl()
401 static int dccp_setsockopt_service(struct sock *sk, const __be32 service,  in dccp_setsockopt_service()  argument
404 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_setsockopt_service()
425 	lock_sock(sk);  in dccp_setsockopt_service()
431 	release_sock(sk);  in dccp_setsockopt_service()
435 static int dccp_setsockopt_cscov(struct sock *sk, int cscov, bool rx)  in dccp_setsockopt_cscov()  argument
459 	rc = dccp_feat_register_sp(sk, DCCPF_MIN_CSUM_COVER, rx, list, len);  in dccp_setsockopt_cscov()
463 			dccp_sk(sk)->dccps_pcrlen = cscov;  in dccp_setsockopt_cscov()
465 			dccp_sk(sk)->dccps_pcslen = cscov;  in dccp_setsockopt_cscov()
471 static int dccp_setsockopt_ccid(struct sock *sk, int type,  in dccp_setsockopt_ccid()  argument
484 	lock_sock(sk);  in dccp_setsockopt_ccid()
486 		rc = dccp_feat_register_sp(sk, DCCPF_CCID, 1, val, optlen);  in dccp_setsockopt_ccid()
489 		rc = dccp_feat_register_sp(sk, DCCPF_CCID, 0, val, optlen);  in dccp_setsockopt_ccid()
490 	release_sock(sk);  in dccp_setsockopt_ccid()
496 static int do_dccp_setsockopt(struct sock *sk, int level, int optname,  in do_dccp_setsockopt()  argument
499 	struct dccp_sock *dp = dccp_sk(sk);  in do_dccp_setsockopt()
513 		return dccp_setsockopt_ccid(sk, optname, optval, optlen);  in do_dccp_setsockopt()
523 		return dccp_setsockopt_service(sk, val, optval, optlen);  in do_dccp_setsockopt()
525 	lock_sock(sk);  in do_dccp_setsockopt()
534 		err = dccp_setsockopt_cscov(sk, val, false);  in do_dccp_setsockopt()
537 		err = dccp_setsockopt_cscov(sk, val, true);  in do_dccp_setsockopt()
540 		if (sk->sk_state != DCCP_CLOSED)  in do_dccp_setsockopt()
557 	release_sock(sk);  in do_dccp_setsockopt()
562 int dccp_setsockopt(struct sock *sk, int level, int optname, sockptr_t optval,  in dccp_setsockopt()  argument
566 		return inet_csk(sk)->icsk_af_ops->setsockopt(sk, level,  in dccp_setsockopt()
569 	return do_dccp_setsockopt(sk, level, optname, optval, optlen);  in dccp_setsockopt()
574 static int dccp_getsockopt_service(struct sock *sk, int len,  in dccp_getsockopt_service()  argument
578 	const struct dccp_sock *dp = dccp_sk(sk);  in dccp_getsockopt_service()
582 	lock_sock(sk);  in dccp_getsockopt_service()
598 	release_sock(sk);  in dccp_getsockopt_service()
602 static int do_dccp_getsockopt(struct sock *sk, int level, int optname,  in do_dccp_getsockopt()  argument
614 	dp = dccp_sk(sk);  in do_dccp_getsockopt()
621 		return dccp_getsockopt_service(sk, len,  in do_dccp_getsockopt()
627 		return ccid_getsockopt_builtin_ccids(sk, len, optval, optlen);  in do_dccp_getsockopt()
654 		return ccid_hc_rx_getsockopt(dp->dccps_hc_rx_ccid, sk, optname,  in do_dccp_getsockopt()
657 		return ccid_hc_tx_getsockopt(dp->dccps_hc_tx_ccid, sk, optname,  in do_dccp_getsockopt()
670 int dccp_getsockopt(struct sock *sk, int level, int optname,  in dccp_getsockopt()  argument
674 		return inet_csk(sk)->icsk_af_ops->getsockopt(sk, level,  in dccp_getsockopt()
677 	return do_dccp_getsockopt(sk, level, optname, optval, optlen);  in dccp_getsockopt()
706 		    !dccp_qpolicy_param_ok(skb->sk, cmsg->cmsg_type))  in dccp_msghdr_parse()
722 int dccp_sendmsg(struct sock *sk, struct msghdr *msg, size_t len)  in dccp_sendmsg()  argument
724 	const struct dccp_sock *dp = dccp_sk(sk);  in dccp_sendmsg()
731 	trace_dccp_probe(sk, len);  in dccp_sendmsg()
736 	lock_sock(sk);  in dccp_sendmsg()
738 	timeo = sock_sndtimeo(sk, noblock);  in dccp_sendmsg()
745 	if ((1 << sk->sk_state) & ~(DCCPF_OPEN | DCCPF_PARTOPEN))  in dccp_sendmsg()
746 		if ((rc = sk_stream_wait_connect(sk, &timeo)) != 0)  in dccp_sendmsg()
749 	size = sk->sk_prot->max_header + len;  in dccp_sendmsg()
750 	release_sock(sk);  in dccp_sendmsg()
751 	skb = sock_alloc_send_skb(sk, size, noblock, &rc);  in dccp_sendmsg()
752 	lock_sock(sk);  in dccp_sendmsg()
756 	if (dccp_qpolicy_full(sk)) {  in dccp_sendmsg()
761 	if (sk->sk_state == DCCP_CLOSED) {  in dccp_sendmsg()
766 	skb_reserve(skb, sk->sk_prot->max_header);  in dccp_sendmsg()
775 	dccp_qpolicy_push(sk, skb);  in dccp_sendmsg()
782 		dccp_write_xmit(sk);  in dccp_sendmsg()
784 	release_sock(sk);  in dccp_sendmsg()
793 int dccp_recvmsg(struct sock *sk, struct msghdr *msg, size_t len, int flags,  in dccp_recvmsg()  argument
799 	lock_sock(sk);  in dccp_recvmsg()
801 	if (sk->sk_state == DCCP_LISTEN) {  in dccp_recvmsg()
806 	timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);  in dccp_recvmsg()
809 		struct sk_buff *skb = skb_peek(&sk->sk_receive_queue);  in dccp_recvmsg()
824 				dccp_finish_passive_close(sk);  in dccp_recvmsg()
834 			sk_eat_skb(sk, skb);  in dccp_recvmsg()
837 		if (sock_flag(sk, SOCK_DONE)) {  in dccp_recvmsg()
842 		if (sk->sk_err) {  in dccp_recvmsg()
843 			len = sock_error(sk);  in dccp_recvmsg()
847 		if (sk->sk_shutdown & RCV_SHUTDOWN) {  in dccp_recvmsg()
852 		if (sk->sk_state == DCCP_CLOSED) {  in dccp_recvmsg()
853 			if (!sock_flag(sk, SOCK_DONE)) {  in dccp_recvmsg()
874 		sk_wait_data(sk, &timeo, NULL);  in dccp_recvmsg()
891 			sk_eat_skb(sk, skb);  in dccp_recvmsg()
895 	release_sock(sk);  in dccp_recvmsg()
903 	struct sock *sk = sock->sk;  in inet_dccp_listen()  local
907 	lock_sock(sk);  in inet_dccp_listen()
913 	old_state = sk->sk_state;  in inet_dccp_listen()
917 	WRITE_ONCE(sk->sk_max_ack_backlog, backlog);  in inet_dccp_listen()
922 		struct dccp_sock *dp = dccp_sk(sk);  in inet_dccp_listen()
932 		err = inet_csk_listen_start(sk);  in inet_dccp_listen()
939 	release_sock(sk);  in inet_dccp_listen()
945 static void dccp_terminate_connection(struct sock *sk)  in dccp_terminate_connection()  argument
949 	switch (sk->sk_state) {  in dccp_terminate_connection()
952 		dccp_finish_passive_close(sk);  in dccp_terminate_connection()
955 		dccp_pr_debug("Stop PARTOPEN timer (%p)\n", sk);  in dccp_terminate_connection()
956 		inet_csk_clear_xmit_timer(sk, ICSK_TIME_DACK);  in dccp_terminate_connection()
959 		dccp_send_close(sk, 1);  in dccp_terminate_connection()
961 		if (dccp_sk(sk)->dccps_role == DCCP_ROLE_SERVER &&  in dccp_terminate_connection()
962 		    !dccp_sk(sk)->dccps_server_timewait)  in dccp_terminate_connection()
968 		dccp_set_state(sk, next_state);  in dccp_terminate_connection()
972 void dccp_close(struct sock *sk, long timeout)  in dccp_close()  argument
974 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_close()
979 	lock_sock(sk);  in dccp_close()
981 	sk->sk_shutdown = SHUTDOWN_MASK;  in dccp_close()
983 	if (sk->sk_state == DCCP_LISTEN) {  in dccp_close()
984 		dccp_set_state(sk, DCCP_CLOSED);  in dccp_close()
987 		inet_csk_listen_stop(sk);  in dccp_close()
992 	sk_stop_timer(sk, &dp->dccps_xmit_timer);  in dccp_close()
999 	while ((skb = __skb_dequeue(&sk->sk_receive_queue)) != NULL) {  in dccp_close()
1005 	if (sk->sk_state == DCCP_CLOSED)  in dccp_close()
1011 		dccp_send_reset(sk, DCCP_RESET_CODE_ABORTED);  in dccp_close()
1012 		dccp_set_state(sk, DCCP_CLOSED);  in dccp_close()
1013 	} else if (sock_flag(sk, SOCK_LINGER) && !sk->sk_lingertime) {  in dccp_close()
1015 		sk->sk_prot->disconnect(sk, 0);  in dccp_close()
1016 	} else if (sk->sk_state != DCCP_CLOSED) {  in dccp_close()
1021 		dccp_flush_write_queue(sk, &timeout);  in dccp_close()
1022 		dccp_terminate_connection(sk);  in dccp_close()
1031 	__skb_queue_purge(&sk->sk_write_queue);  in dccp_close()
1033 	sk_stream_wait_close(sk, timeout);  in dccp_close()
1036 	state = sk->sk_state;  in dccp_close()
1037 	sock_hold(sk);  in dccp_close()
1038 	sock_orphan(sk);  in dccp_close()
1043 	release_sock(sk);  in dccp_close()
1049 	bh_lock_sock(sk);  in dccp_close()
1050 	WARN_ON(sock_owned_by_user(sk));  in dccp_close()
1055 	if (state != DCCP_CLOSED && sk->sk_state == DCCP_CLOSED)  in dccp_close()
1058 	if (sk->sk_state == DCCP_CLOSED)  in dccp_close()
1059 		inet_csk_destroy_sock(sk);  in dccp_close()
1064 	bh_unlock_sock(sk);  in dccp_close()
1066 	sock_put(sk);  in dccp_close()
1071 void dccp_shutdown(struct sock *sk, int how)  in dccp_shutdown()  argument