81 void dccp_set_state(struct sock *sk, const int state)  in dccp_set_state()  argument
83 	const int oldstate = sk->sk_state;  in dccp_set_state()
85 	dccp_pr_debug("%s(%p)  %s  -->  %s\n", dccp_role(sk), sk,  in dccp_set_state()
95 			dccp_feat_list_purge(&dccp_sk(sk)->dccps_featneg);  in dccp_set_state()
103 		sk->sk_prot->unhash(sk);  in dccp_set_state()
104 		if (inet_csk(sk)->icsk_bind_hash != NULL &&  in dccp_set_state()
105 		    !(sk->sk_userlocks & SOCK_BINDPORT_LOCK))  in dccp_set_state()
106 			inet_put_port(sk);  in dccp_set_state()
116 	inet_sk_set_state(sk, state);  in dccp_set_state()
121 static void dccp_finish_passive_close(struct sock *sk)  in dccp_finish_passive_close()  argument
123 	switch (sk->sk_state) {  in dccp_finish_passive_close()
126 		dccp_send_reset(sk, DCCP_RESET_CODE_CLOSED);  in dccp_finish_passive_close()
127 		dccp_set_state(sk, DCCP_CLOSED);  in dccp_finish_passive_close()
134 		dccp_send_close(sk, 1);  in dccp_finish_passive_close()
135 		dccp_set_state(sk, DCCP_CLOSING);  in dccp_finish_passive_close()
139 void dccp_done(struct sock *sk)  in dccp_done()  argument
141 	dccp_set_state(sk, DCCP_CLOSED);  in dccp_done()
142 	dccp_clear_xmit_timers(sk);  in dccp_done()
144 	sk->sk_shutdown = SHUTDOWN_MASK;  in dccp_done()
146 	if (!sock_flag(sk, SOCK_DEAD))  in dccp_done()
147 		sk->sk_state_change(sk);  in dccp_done()
149 		inet_csk_destroy_sock(sk);  in dccp_done()
177 static void dccp_sk_destruct(struct sock *sk)  in dccp_sk_destruct()  argument
179 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_sk_destruct()
181 	ccid_hc_tx_delete(dp->dccps_hc_tx_ccid, sk);  in dccp_sk_destruct()
183 	inet_sock_destruct(sk);  in dccp_sk_destruct()
186 int dccp_init_sock(struct sock *sk, const __u8 ctl_sock_initialized)  in dccp_init_sock()  argument
188 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_init_sock()
189 	struct inet_connection_sock *icsk = inet_csk(sk);  in dccp_init_sock()
193 	sk->sk_state		= DCCP_CLOSED;  in dccp_init_sock()
194 	sk->sk_write_space	= dccp_write_space;  in dccp_init_sock()
195 	sk->sk_destruct		= dccp_sk_destruct;  in dccp_init_sock()
203 	dccp_init_xmit_timers(sk);  in dccp_init_sock()
208 		return dccp_feat_init(sk);  in dccp_init_sock()
214 void dccp_destroy_sock(struct sock *sk)  in dccp_destroy_sock()  argument
216 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_destroy_sock()
218 	__skb_queue_purge(&sk->sk_write_queue);  in dccp_destroy_sock()
219 	if (sk->sk_send_head != NULL) {  in dccp_destroy_sock()
220 		kfree_skb(sk->sk_send_head);  in dccp_destroy_sock()
221 		sk->sk_send_head = NULL;  in dccp_destroy_sock()
225 	if (inet_csk(sk)->icsk_bind_hash != NULL)  in dccp_destroy_sock()
226 		inet_put_port(sk);  in dccp_destroy_sock()
235 	ccid_hc_rx_delete(dp->dccps_hc_rx_ccid, sk);  in dccp_destroy_sock()
244 static inline int dccp_listen_start(struct sock *sk, int backlog)  in dccp_listen_start()  argument
246 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_listen_start()
252 	return inet_csk_listen_start(sk, backlog);  in dccp_listen_start()
261 int dccp_disconnect(struct sock *sk, int flags)  in dccp_disconnect()  argument
263 	struct inet_connection_sock *icsk = inet_csk(sk);  in dccp_disconnect()
264 	struct inet_sock *inet = inet_sk(sk);  in dccp_disconnect()
265 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_disconnect()
267 	const int old_state = sk->sk_state;  in dccp_disconnect()
270 		dccp_set_state(sk, DCCP_CLOSED);  in dccp_disconnect()
277 		inet_csk_listen_stop(sk);  in dccp_disconnect()
279 		dccp_send_reset(sk, DCCP_RESET_CODE_ABORTED);  in dccp_disconnect()
280 		sk->sk_err = ECONNRESET;  in dccp_disconnect()
282 		sk->sk_err = ECONNRESET;  in dccp_disconnect()
284 	dccp_clear_xmit_timers(sk);  in dccp_disconnect()
285 	ccid_hc_rx_delete(dp->dccps_hc_rx_ccid, sk);  in dccp_disconnect()
288 	__skb_queue_purge(&sk->sk_receive_queue);  in dccp_disconnect()
289 	__skb_queue_purge(&sk->sk_write_queue);  in dccp_disconnect()
290 	if (sk->sk_send_head != NULL) {  in dccp_disconnect()
291 		__kfree_skb(sk->sk_send_head);  in dccp_disconnect()
292 		sk->sk_send_head = NULL;  in dccp_disconnect()
297 	if (!(sk->sk_userlocks & SOCK_BINDADDR_LOCK))  in dccp_disconnect()
298 		inet_reset_saddr(sk);  in dccp_disconnect()
300 	sk->sk_shutdown = 0;  in dccp_disconnect()
301 	sock_reset_flag(sk, SOCK_DONE);  in dccp_disconnect()
304 	inet_csk_delack_init(sk);  in dccp_disconnect()
305 	__sk_dst_reset(sk);  in dccp_disconnect()
309 	sk->sk_error_report(sk);  in dccp_disconnect()
326 	struct sock *sk = sock->sk;  in dccp_poll()  local
329 	if (sk->sk_state == DCCP_LISTEN)  in dccp_poll()
330 		return inet_csk_listen_poll(sk);  in dccp_poll()
338 	if (sk->sk_err)  in dccp_poll()
341 	if (sk->sk_shutdown == SHUTDOWN_MASK || sk->sk_state == DCCP_CLOSED)  in dccp_poll()
343 	if (sk->sk_shutdown & RCV_SHUTDOWN)  in dccp_poll()
347 	if ((1 << sk->sk_state) & ~(DCCPF_REQUESTING | DCCPF_RESPOND)) {  in dccp_poll()
348 		if (atomic_read(&sk->sk_rmem_alloc) > 0)  in dccp_poll()
351 		if (!(sk->sk_shutdown & SEND_SHUTDOWN)) {  in dccp_poll()
352 			if (sk_stream_is_writeable(sk)) {  in dccp_poll()
355 				sk_set_bit(SOCKWQ_ASYNC_NOSPACE, sk);  in dccp_poll()
356 				set_bit(SOCK_NOSPACE, &sk->sk_socket->flags);  in dccp_poll()
362 				if (sk_stream_is_writeable(sk))  in dccp_poll()
372 int dccp_ioctl(struct sock *sk, int cmd, unsigned long arg)  in dccp_ioctl()  argument
376 	lock_sock(sk);  in dccp_ioctl()
378 	if (sk->sk_state == DCCP_LISTEN)  in dccp_ioctl()
386 		skb = skb_peek(&sk->sk_receive_queue);  in dccp_ioctl()
402 	release_sock(sk);  in dccp_ioctl()
408 static int dccp_setsockopt_service(struct sock *sk, const __be32 service,  in dccp_setsockopt_service()  argument
411 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_setsockopt_service()
433 	lock_sock(sk);  in dccp_setsockopt_service()
439 	release_sock(sk);  in dccp_setsockopt_service()
443 static int dccp_setsockopt_cscov(struct sock *sk, int cscov, bool rx)  in dccp_setsockopt_cscov()  argument
467 	rc = dccp_feat_register_sp(sk, DCCPF_MIN_CSUM_COVER, rx, list, len);  in dccp_setsockopt_cscov()
471 			dccp_sk(sk)->dccps_pcrlen = cscov;  in dccp_setsockopt_cscov()
473 			dccp_sk(sk)->dccps_pcslen = cscov;  in dccp_setsockopt_cscov()
479 static int dccp_setsockopt_ccid(struct sock *sk, int type,  in dccp_setsockopt_ccid()  argument
492 	lock_sock(sk);  in dccp_setsockopt_ccid()
494 		rc = dccp_feat_register_sp(sk, DCCPF_CCID, 1, val, optlen);  in dccp_setsockopt_ccid()
497 		rc = dccp_feat_register_sp(sk, DCCPF_CCID, 0, val, optlen);  in dccp_setsockopt_ccid()
498 	release_sock(sk);  in dccp_setsockopt_ccid()
504 static int do_dccp_setsockopt(struct sock *sk, int level, int optname,  in do_dccp_setsockopt()  argument
507 	struct dccp_sock *dp = dccp_sk(sk);  in do_dccp_setsockopt()
521 		return dccp_setsockopt_ccid(sk, optname, optval, optlen);  in do_dccp_setsockopt()
531 		return dccp_setsockopt_service(sk, val, optval, optlen);  in do_dccp_setsockopt()
533 	lock_sock(sk);  in do_dccp_setsockopt()
542 		err = dccp_setsockopt_cscov(sk, val, false);  in do_dccp_setsockopt()
545 		err = dccp_setsockopt_cscov(sk, val, true);  in do_dccp_setsockopt()
548 		if (sk->sk_state != DCCP_CLOSED)  in do_dccp_setsockopt()
565 	release_sock(sk);  in do_dccp_setsockopt()
570 int dccp_setsockopt(struct sock *sk, int level, int optname,  in dccp_setsockopt()  argument
574 		return inet_csk(sk)->icsk_af_ops->setsockopt(sk, level,  in dccp_setsockopt()
577 	return do_dccp_setsockopt(sk, level, optname, optval, optlen);  in dccp_setsockopt()
583 int compat_dccp_setsockopt(struct sock *sk, int level, int optname,  in compat_dccp_setsockopt()  argument
587 		return inet_csk_compat_setsockopt(sk, level, optname,  in compat_dccp_setsockopt()
589 	return do_dccp_setsockopt(sk, level, optname, optval, optlen);  in compat_dccp_setsockopt()
595 static int dccp_getsockopt_service(struct sock *sk, int len,  in dccp_getsockopt_service()  argument
599 	const struct dccp_sock *dp = dccp_sk(sk);  in dccp_getsockopt_service()
603 	lock_sock(sk);  in dccp_getsockopt_service()
619 	release_sock(sk);  in dccp_getsockopt_service()
623 static int do_dccp_getsockopt(struct sock *sk, int level, int optname,  in do_dccp_getsockopt()  argument
635 	dp = dccp_sk(sk);  in do_dccp_getsockopt()
642 		return dccp_getsockopt_service(sk, len,  in do_dccp_getsockopt()
648 		return ccid_getsockopt_builtin_ccids(sk, len, optval, optlen);  in do_dccp_getsockopt()
675 		return ccid_hc_rx_getsockopt(dp->dccps_hc_rx_ccid, sk, optname,  in do_dccp_getsockopt()
678 		return ccid_hc_tx_getsockopt(dp->dccps_hc_tx_ccid, sk, optname,  in do_dccp_getsockopt()
691 int dccp_getsockopt(struct sock *sk, int level, int optname,  in dccp_getsockopt()  argument
695 		return inet_csk(sk)->icsk_af_ops->getsockopt(sk, level,  in dccp_getsockopt()
698 	return do_dccp_getsockopt(sk, level, optname, optval, optlen);  in dccp_getsockopt()
704 int compat_dccp_getsockopt(struct sock *sk, int level, int optname,  in compat_dccp_getsockopt()  argument
708 		return inet_csk_compat_getsockopt(sk, level, optname,  in compat_dccp_getsockopt()
710 	return do_dccp_getsockopt(sk, level, optname, optval, optlen);  in compat_dccp_getsockopt()
740 		    !dccp_qpolicy_param_ok(skb->sk, cmsg->cmsg_type))  in dccp_msghdr_parse()
756 int dccp_sendmsg(struct sock *sk, struct msghdr *msg, size_t len)  in dccp_sendmsg()  argument
758 	const struct dccp_sock *dp = dccp_sk(sk);  in dccp_sendmsg()
765 	trace_dccp_probe(sk, len);  in dccp_sendmsg()
770 	lock_sock(sk);  in dccp_sendmsg()
772 	if (dccp_qpolicy_full(sk)) {  in dccp_sendmsg()
777 	timeo = sock_sndtimeo(sk, noblock);  in dccp_sendmsg()
784 	if ((1 << sk->sk_state) & ~(DCCPF_OPEN | DCCPF_PARTOPEN))  in dccp_sendmsg()
785 		if ((rc = sk_stream_wait_connect(sk, &timeo)) != 0)  in dccp_sendmsg()
788 	size = sk->sk_prot->max_header + len;  in dccp_sendmsg()
789 	release_sock(sk);  in dccp_sendmsg()
790 	skb = sock_alloc_send_skb(sk, size, noblock, &rc);  in dccp_sendmsg()
791 	lock_sock(sk);  in dccp_sendmsg()
795 	if (sk->sk_state == DCCP_CLOSED) {  in dccp_sendmsg()
800 	skb_reserve(skb, sk->sk_prot->max_header);  in dccp_sendmsg()
809 	dccp_qpolicy_push(sk, skb);  in dccp_sendmsg()
816 		dccp_write_xmit(sk);  in dccp_sendmsg()
818 	release_sock(sk);  in dccp_sendmsg()
827 int dccp_recvmsg(struct sock *sk, struct msghdr *msg, size_t len, int nonblock,  in dccp_recvmsg()  argument
833 	lock_sock(sk);  in dccp_recvmsg()
835 	if (sk->sk_state == DCCP_LISTEN) {  in dccp_recvmsg()
840 	timeo = sock_rcvtimeo(sk, nonblock);  in dccp_recvmsg()
843 		struct sk_buff *skb = skb_peek(&sk->sk_receive_queue);  in dccp_recvmsg()
858 				dccp_finish_passive_close(sk);  in dccp_recvmsg()
868 			sk_eat_skb(sk, skb);  in dccp_recvmsg()
871 		if (sock_flag(sk, SOCK_DONE)) {  in dccp_recvmsg()
876 		if (sk->sk_err) {  in dccp_recvmsg()
877 			len = sock_error(sk);  in dccp_recvmsg()
881 		if (sk->sk_shutdown & RCV_SHUTDOWN) {  in dccp_recvmsg()
886 		if (sk->sk_state == DCCP_CLOSED) {  in dccp_recvmsg()
887 			if (!sock_flag(sk, SOCK_DONE)) {  in dccp_recvmsg()
908 		sk_wait_data(sk, &timeo, NULL);  in dccp_recvmsg()
925 			sk_eat_skb(sk, skb);  in dccp_recvmsg()
929 	release_sock(sk);  in dccp_recvmsg()
937 	struct sock *sk = sock->sk;  in inet_dccp_listen()  local
941 	lock_sock(sk);  in inet_dccp_listen()
947 	old_state = sk->sk_state;  in inet_dccp_listen()
959 		err = dccp_listen_start(sk, backlog);  in inet_dccp_listen()
963 	sk->sk_max_ack_backlog = backlog;  in inet_dccp_listen()
967 	release_sock(sk);  in inet_dccp_listen()
973 static void dccp_terminate_connection(struct sock *sk)  in dccp_terminate_connection()  argument
977 	switch (sk->sk_state) {  in dccp_terminate_connection()
980 		dccp_finish_passive_close(sk);  in dccp_terminate_connection()
983 		dccp_pr_debug("Stop PARTOPEN timer (%p)\n", sk);  in dccp_terminate_connection()
984 		inet_csk_clear_xmit_timer(sk, ICSK_TIME_DACK);  in dccp_terminate_connection()
987 		dccp_send_close(sk, 1);  in dccp_terminate_connection()
989 		if (dccp_sk(sk)->dccps_role == DCCP_ROLE_SERVER &&  in dccp_terminate_connection()
990 		    !dccp_sk(sk)->dccps_server_timewait)  in dccp_terminate_connection()
996 		dccp_set_state(sk, next_state);  in dccp_terminate_connection()
1000 void dccp_close(struct sock *sk, long timeout)  in dccp_close()  argument
1002 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_close()
1007 	lock_sock(sk);  in dccp_close()
1009 	sk->sk_shutdown = SHUTDOWN_MASK;  in dccp_close()
1011 	if (sk->sk_state == DCCP_LISTEN) {  in dccp_close()
1012 		dccp_set_state(sk, DCCP_CLOSED);  in dccp_close()
1015 		inet_csk_listen_stop(sk);  in dccp_close()
1020 	sk_stop_timer(sk, &dp->dccps_xmit_timer);  in dccp_close()
1027 	while ((skb = __skb_dequeue(&sk->sk_receive_queue)) != NULL) {  in dccp_close()
1033 	if (sk->sk_state == DCCP_CLOSED)  in dccp_close()
1039 		dccp_send_reset(sk, DCCP_RESET_CODE_ABORTED);  in dccp_close()
1040 		dccp_set_state(sk, DCCP_CLOSED);  in dccp_close()
1041 	} else if (sock_flag(sk, SOCK_LINGER) && !sk->sk_lingertime) {  in dccp_close()
1043 		sk->sk_prot->disconnect(sk, 0);  in dccp_close()
1044 	} else if (sk->sk_state != DCCP_CLOSED) {  in dccp_close()
1049 		dccp_flush_write_queue(sk, &timeout);  in dccp_close()
1050 		dccp_terminate_connection(sk);  in dccp_close()
1059 	__skb_queue_purge(&sk->sk_write_queue);  in dccp_close()
1061 	sk_stream_wait_close(sk, timeout);  in dccp_close()
1064 	state = sk->sk_state;  in dccp_close()
1065 	sock_hold(sk);  in dccp_close()
1066 	sock_orphan(sk);  in dccp_close()
1071 	release_sock(sk);  in dccp_close()
1077 	bh_lock_sock(sk);  in dccp_close()
1078 	WARN_ON(sock_owned_by_user(sk));  in dccp_close()
1080 	percpu_counter_inc(sk->sk_prot->orphan_count);  in dccp_close()
1083 	if (state != DCCP_CLOSED && sk->sk_state == DCCP_CLOSED)  in dccp_close()
1086 	if (sk->sk_state == DCCP_CLOSED)  in dccp_close()
1087 		inet_csk_destroy_sock(sk);  in dccp_close()
1092 	bh_unlock_sock(sk);  in dccp_close()
1094 	sock_put(sk);  in dccp_close()
1099 void dccp_shutdown(struct sock *sk, int how)  in dccp_shutdown()  argument