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()
382 		skb = skb_peek(&sk->sk_receive_queue);  in dccp_ioctl()
398 	release_sock(sk);  in dccp_ioctl()
404 static int dccp_setsockopt_service(struct sock *sk, const __be32 service,  in dccp_setsockopt_service()  argument
407 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_setsockopt_service()
429 	lock_sock(sk);  in dccp_setsockopt_service()
435 	release_sock(sk);  in dccp_setsockopt_service()
439 static int dccp_setsockopt_cscov(struct sock *sk, int cscov, bool rx)  in dccp_setsockopt_cscov()  argument
463 	rc = dccp_feat_register_sp(sk, DCCPF_MIN_CSUM_COVER, rx, list, len);  in dccp_setsockopt_cscov()
467 			dccp_sk(sk)->dccps_pcrlen = cscov;  in dccp_setsockopt_cscov()
469 			dccp_sk(sk)->dccps_pcslen = cscov;  in dccp_setsockopt_cscov()
475 static int dccp_setsockopt_ccid(struct sock *sk, int type,  in dccp_setsockopt_ccid()  argument
488 	lock_sock(sk);  in dccp_setsockopt_ccid()
490 		rc = dccp_feat_register_sp(sk, DCCPF_CCID, 1, val, optlen);  in dccp_setsockopt_ccid()
493 		rc = dccp_feat_register_sp(sk, DCCPF_CCID, 0, val, optlen);  in dccp_setsockopt_ccid()
494 	release_sock(sk);  in dccp_setsockopt_ccid()
500 static int do_dccp_setsockopt(struct sock *sk, int level, int optname,  in do_dccp_setsockopt()  argument
503 	struct dccp_sock *dp = dccp_sk(sk);  in do_dccp_setsockopt()
517 		return dccp_setsockopt_ccid(sk, optname, optval, optlen);  in do_dccp_setsockopt()
527 		return dccp_setsockopt_service(sk, val, optval, optlen);  in do_dccp_setsockopt()
529 	lock_sock(sk);  in do_dccp_setsockopt()
538 		err = dccp_setsockopt_cscov(sk, val, false);  in do_dccp_setsockopt()
541 		err = dccp_setsockopt_cscov(sk, val, true);  in do_dccp_setsockopt()
544 		if (sk->sk_state != DCCP_CLOSED)  in do_dccp_setsockopt()
561 	release_sock(sk);  in do_dccp_setsockopt()
566 int dccp_setsockopt(struct sock *sk, int level, int optname,  in dccp_setsockopt()  argument
570 		return inet_csk(sk)->icsk_af_ops->setsockopt(sk, level,  in dccp_setsockopt()
573 	return do_dccp_setsockopt(sk, level, optname, optval, optlen);  in dccp_setsockopt()
579 int compat_dccp_setsockopt(struct sock *sk, int level, int optname,  in compat_dccp_setsockopt()  argument
583 		return inet_csk_compat_setsockopt(sk, level, optname,  in compat_dccp_setsockopt()
585 	return do_dccp_setsockopt(sk, level, optname, optval, optlen);  in compat_dccp_setsockopt()
591 static int dccp_getsockopt_service(struct sock *sk, int len,  in dccp_getsockopt_service()  argument
595 	const struct dccp_sock *dp = dccp_sk(sk);  in dccp_getsockopt_service()
599 	lock_sock(sk);  in dccp_getsockopt_service()
615 	release_sock(sk);  in dccp_getsockopt_service()
619 static int do_dccp_getsockopt(struct sock *sk, int level, int optname,  in do_dccp_getsockopt()  argument
631 	dp = dccp_sk(sk);  in do_dccp_getsockopt()
638 		return dccp_getsockopt_service(sk, len,  in do_dccp_getsockopt()
644 		return ccid_getsockopt_builtin_ccids(sk, len, optval, optlen);  in do_dccp_getsockopt()
671 		return ccid_hc_rx_getsockopt(dp->dccps_hc_rx_ccid, sk, optname,  in do_dccp_getsockopt()
674 		return ccid_hc_tx_getsockopt(dp->dccps_hc_tx_ccid, sk, optname,  in do_dccp_getsockopt()
687 int dccp_getsockopt(struct sock *sk, int level, int optname,  in dccp_getsockopt()  argument
691 		return inet_csk(sk)->icsk_af_ops->getsockopt(sk, level,  in dccp_getsockopt()
694 	return do_dccp_getsockopt(sk, level, optname, optval, optlen);  in dccp_getsockopt()
700 int compat_dccp_getsockopt(struct sock *sk, int level, int optname,  in compat_dccp_getsockopt()  argument
704 		return inet_csk_compat_getsockopt(sk, level, optname,  in compat_dccp_getsockopt()
706 	return do_dccp_getsockopt(sk, level, optname, optval, optlen);  in compat_dccp_getsockopt()
736 		    !dccp_qpolicy_param_ok(skb->sk, cmsg->cmsg_type))  in dccp_msghdr_parse()
752 int dccp_sendmsg(struct sock *sk, struct msghdr *msg, size_t len)  in dccp_sendmsg()  argument
754 	const struct dccp_sock *dp = dccp_sk(sk);  in dccp_sendmsg()
761 	trace_dccp_probe(sk, len);  in dccp_sendmsg()
766 	lock_sock(sk);  in dccp_sendmsg()
768 	if (dccp_qpolicy_full(sk)) {  in dccp_sendmsg()
773 	timeo = sock_sndtimeo(sk, noblock);  in dccp_sendmsg()
780 	if ((1 << sk->sk_state) & ~(DCCPF_OPEN | DCCPF_PARTOPEN))  in dccp_sendmsg()
781 		if ((rc = sk_stream_wait_connect(sk, &timeo)) != 0)  in dccp_sendmsg()
784 	size = sk->sk_prot->max_header + len;  in dccp_sendmsg()
785 	release_sock(sk);  in dccp_sendmsg()
786 	skb = sock_alloc_send_skb(sk, size, noblock, &rc);  in dccp_sendmsg()
787 	lock_sock(sk);  in dccp_sendmsg()
791 	if (sk->sk_state == DCCP_CLOSED) {  in dccp_sendmsg()
796 	skb_reserve(skb, sk->sk_prot->max_header);  in dccp_sendmsg()
805 	dccp_qpolicy_push(sk, skb);  in dccp_sendmsg()
812 		dccp_write_xmit(sk);  in dccp_sendmsg()
814 	release_sock(sk);  in dccp_sendmsg()
823 int dccp_recvmsg(struct sock *sk, struct msghdr *msg, size_t len, int nonblock,  in dccp_recvmsg()  argument
829 	lock_sock(sk);  in dccp_recvmsg()
831 	if (sk->sk_state == DCCP_LISTEN) {  in dccp_recvmsg()
836 	timeo = sock_rcvtimeo(sk, nonblock);  in dccp_recvmsg()
839 		struct sk_buff *skb = skb_peek(&sk->sk_receive_queue);  in dccp_recvmsg()
854 				dccp_finish_passive_close(sk);  in dccp_recvmsg()
864 			sk_eat_skb(sk, skb);  in dccp_recvmsg()
867 		if (sock_flag(sk, SOCK_DONE)) {  in dccp_recvmsg()
872 		if (sk->sk_err) {  in dccp_recvmsg()
873 			len = sock_error(sk);  in dccp_recvmsg()
877 		if (sk->sk_shutdown & RCV_SHUTDOWN) {  in dccp_recvmsg()
882 		if (sk->sk_state == DCCP_CLOSED) {  in dccp_recvmsg()
883 			if (!sock_flag(sk, SOCK_DONE)) {  in dccp_recvmsg()
904 		sk_wait_data(sk, &timeo, NULL);  in dccp_recvmsg()
921 			sk_eat_skb(sk, skb);  in dccp_recvmsg()
925 	release_sock(sk);  in dccp_recvmsg()
933 	struct sock *sk = sock->sk;  in inet_dccp_listen()  local
937 	lock_sock(sk);  in inet_dccp_listen()
943 	old_state = sk->sk_state;  in inet_dccp_listen()
947 	sk->sk_max_ack_backlog = backlog;  in inet_dccp_listen()
956 		err = dccp_listen_start(sk, backlog);  in inet_dccp_listen()
963 	release_sock(sk);  in inet_dccp_listen()
969 static void dccp_terminate_connection(struct sock *sk)  in dccp_terminate_connection()  argument
973 	switch (sk->sk_state) {  in dccp_terminate_connection()
976 		dccp_finish_passive_close(sk);  in dccp_terminate_connection()
979 		dccp_pr_debug("Stop PARTOPEN timer (%p)\n", sk);  in dccp_terminate_connection()
980 		inet_csk_clear_xmit_timer(sk, ICSK_TIME_DACK);  in dccp_terminate_connection()
983 		dccp_send_close(sk, 1);  in dccp_terminate_connection()
985 		if (dccp_sk(sk)->dccps_role == DCCP_ROLE_SERVER &&  in dccp_terminate_connection()
986 		    !dccp_sk(sk)->dccps_server_timewait)  in dccp_terminate_connection()
992 		dccp_set_state(sk, next_state);  in dccp_terminate_connection()
996 void dccp_close(struct sock *sk, long timeout)  in dccp_close()  argument
998 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_close()
1003 	lock_sock(sk);  in dccp_close()
1005 	sk->sk_shutdown = SHUTDOWN_MASK;  in dccp_close()
1007 	if (sk->sk_state == DCCP_LISTEN) {  in dccp_close()
1008 		dccp_set_state(sk, DCCP_CLOSED);  in dccp_close()
1011 		inet_csk_listen_stop(sk);  in dccp_close()
1016 	sk_stop_timer(sk, &dp->dccps_xmit_timer);  in dccp_close()
1023 	while ((skb = __skb_dequeue(&sk->sk_receive_queue)) != NULL) {  in dccp_close()
1029 	if (sk->sk_state == DCCP_CLOSED)  in dccp_close()
1035 		dccp_send_reset(sk, DCCP_RESET_CODE_ABORTED);  in dccp_close()
1036 		dccp_set_state(sk, DCCP_CLOSED);  in dccp_close()
1037 	} else if (sock_flag(sk, SOCK_LINGER) && !sk->sk_lingertime) {  in dccp_close()
1039 		sk->sk_prot->disconnect(sk, 0);  in dccp_close()
1040 	} else if (sk->sk_state != DCCP_CLOSED) {  in dccp_close()
1045 		dccp_flush_write_queue(sk, &timeout);  in dccp_close()
1046 		dccp_terminate_connection(sk);  in dccp_close()
1055 	__skb_queue_purge(&sk->sk_write_queue);  in dccp_close()
1057 	sk_stream_wait_close(sk, timeout);  in dccp_close()
1060 	state = sk->sk_state;  in dccp_close()
1061 	sock_hold(sk);  in dccp_close()
1062 	sock_orphan(sk);  in dccp_close()
1067 	release_sock(sk);  in dccp_close()
1073 	bh_lock_sock(sk);  in dccp_close()
1074 	WARN_ON(sock_owned_by_user(sk));  in dccp_close()
1076 	percpu_counter_inc(sk->sk_prot->orphan_count);  in dccp_close()
1079 	if (state != DCCP_CLOSED && sk->sk_state == DCCP_CLOSED)  in dccp_close()
1082 	if (sk->sk_state == DCCP_CLOSED)  in dccp_close()
1083 		inet_csk_destroy_sock(sk);  in dccp_close()
1088 	bh_unlock_sock(sk);  in dccp_close()
1090 	sock_put(sk);  in dccp_close()
1095 void dccp_shutdown(struct sock *sk, int how)  in dccp_shutdown()  argument