77 void dccp_set_state(struct sock *sk, const int state)  in dccp_set_state()  argument
79 	const int oldstate = sk->sk_state;  in dccp_set_state()
81 	dccp_pr_debug("%s(%p)  %s  -->  %s\n", dccp_role(sk), sk,  in dccp_set_state()
91 			dccp_feat_list_purge(&dccp_sk(sk)->dccps_featneg);  in dccp_set_state()
99 		sk->sk_prot->unhash(sk);  in dccp_set_state()
100 		if (inet_csk(sk)->icsk_bind_hash != NULL &&  in dccp_set_state()
101 		    !(sk->sk_userlocks & SOCK_BINDPORT_LOCK))  in dccp_set_state()
102 			inet_put_port(sk);  in dccp_set_state()
112 	sk->sk_state = state;  in dccp_set_state()
117 static void dccp_finish_passive_close(struct sock *sk)  in dccp_finish_passive_close()  argument
119 	switch (sk->sk_state) {  in dccp_finish_passive_close()
122 		dccp_send_reset(sk, DCCP_RESET_CODE_CLOSED);  in dccp_finish_passive_close()
123 		dccp_set_state(sk, DCCP_CLOSED);  in dccp_finish_passive_close()
130 		dccp_send_close(sk, 1);  in dccp_finish_passive_close()
131 		dccp_set_state(sk, DCCP_CLOSING);  in dccp_finish_passive_close()
135 void dccp_done(struct sock *sk)  in dccp_done()  argument
137 	dccp_set_state(sk, DCCP_CLOSED);  in dccp_done()
138 	dccp_clear_xmit_timers(sk);  in dccp_done()
140 	sk->sk_shutdown = SHUTDOWN_MASK;  in dccp_done()
142 	if (!sock_flag(sk, SOCK_DEAD))  in dccp_done()
143 		sk->sk_state_change(sk);  in dccp_done()
145 		inet_csk_destroy_sock(sk);  in dccp_done()
173 int dccp_init_sock(struct sock *sk, const __u8 ctl_sock_initialized)  in dccp_init_sock()  argument
175 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_init_sock()
176 	struct inet_connection_sock *icsk = inet_csk(sk);  in dccp_init_sock()
180 	sk->sk_state		= DCCP_CLOSED;  in dccp_init_sock()
181 	sk->sk_write_space	= dccp_write_space;  in dccp_init_sock()
189 	dccp_init_xmit_timers(sk);  in dccp_init_sock()
194 		return dccp_feat_init(sk);  in dccp_init_sock()
200 void dccp_destroy_sock(struct sock *sk)  in dccp_destroy_sock()  argument
202 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_destroy_sock()
208 	if (sk->sk_send_head != NULL) {  in dccp_destroy_sock()
209 		kfree_skb(sk->sk_send_head);  in dccp_destroy_sock()
210 		sk->sk_send_head = NULL;  in dccp_destroy_sock()
214 	if (inet_csk(sk)->icsk_bind_hash != NULL)  in dccp_destroy_sock()
215 		inet_put_port(sk);  in dccp_destroy_sock()
224 	ccid_hc_rx_delete(dp->dccps_hc_rx_ccid, sk);  in dccp_destroy_sock()
225 	ccid_hc_tx_delete(dp->dccps_hc_tx_ccid, sk);  in dccp_destroy_sock()
234 static inline int dccp_listen_start(struct sock *sk, int backlog)  in dccp_listen_start()  argument
236 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_listen_start()
242 	return inet_csk_listen_start(sk, backlog);  in dccp_listen_start()
251 int dccp_disconnect(struct sock *sk, int flags)  in dccp_disconnect()  argument
253 	struct inet_connection_sock *icsk = inet_csk(sk);  in dccp_disconnect()
254 	struct inet_sock *inet = inet_sk(sk);  in dccp_disconnect()
256 	const int old_state = sk->sk_state;  in dccp_disconnect()
259 		dccp_set_state(sk, DCCP_CLOSED);  in dccp_disconnect()
266 		inet_csk_listen_stop(sk);  in dccp_disconnect()
268 		dccp_send_reset(sk, DCCP_RESET_CODE_ABORTED);  in dccp_disconnect()
269 		sk->sk_err = ECONNRESET;  in dccp_disconnect()
271 		sk->sk_err = ECONNRESET;  in dccp_disconnect()
273 	dccp_clear_xmit_timers(sk);  in dccp_disconnect()
275 	__skb_queue_purge(&sk->sk_receive_queue);  in dccp_disconnect()
276 	__skb_queue_purge(&sk->sk_write_queue);  in dccp_disconnect()
277 	if (sk->sk_send_head != NULL) {  in dccp_disconnect()
278 		__kfree_skb(sk->sk_send_head);  in dccp_disconnect()
279 		sk->sk_send_head = NULL;  in dccp_disconnect()
284 	if (!(sk->sk_userlocks & SOCK_BINDADDR_LOCK))  in dccp_disconnect()
285 		inet_reset_saddr(sk);  in dccp_disconnect()
287 	sk->sk_shutdown = 0;  in dccp_disconnect()
288 	sock_reset_flag(sk, SOCK_DONE);  in dccp_disconnect()
291 	inet_csk_delack_init(sk);  in dccp_disconnect()
292 	__sk_dst_reset(sk);  in dccp_disconnect()
296 	sk->sk_error_report(sk);  in dccp_disconnect()
313 	struct sock *sk = sock->sk;  in dccp_poll()  local
315 	sock_poll_wait(file, sk_sleep(sk), wait);  in dccp_poll()
316 	if (sk->sk_state == DCCP_LISTEN)  in dccp_poll()
317 		return inet_csk_listen_poll(sk);  in dccp_poll()
325 	if (sk->sk_err)  in dccp_poll()
328 	if (sk->sk_shutdown == SHUTDOWN_MASK || sk->sk_state == DCCP_CLOSED)  in dccp_poll()
330 	if (sk->sk_shutdown & RCV_SHUTDOWN)  in dccp_poll()
334 	if ((1 << sk->sk_state) & ~(DCCPF_REQUESTING | DCCPF_RESPOND)) {  in dccp_poll()
335 		if (atomic_read(&sk->sk_rmem_alloc) > 0)  in dccp_poll()
338 		if (!(sk->sk_shutdown & SEND_SHUTDOWN)) {  in dccp_poll()
339 			if (sk_stream_is_writeable(sk)) {  in dccp_poll()
343 					&sk->sk_socket->flags);  in dccp_poll()
344 				set_bit(SOCK_NOSPACE, &sk->sk_socket->flags);  in dccp_poll()
350 				if (sk_stream_is_writeable(sk))  in dccp_poll()
360 int dccp_ioctl(struct sock *sk, int cmd, unsigned long arg)  in dccp_ioctl()  argument
364 	lock_sock(sk);  in dccp_ioctl()
366 	if (sk->sk_state == DCCP_LISTEN)  in dccp_ioctl()
374 		skb = skb_peek(&sk->sk_receive_queue);  in dccp_ioctl()
390 	release_sock(sk);  in dccp_ioctl()
396 static int dccp_setsockopt_service(struct sock *sk, const __be32 service,  in dccp_setsockopt_service()  argument
399 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_setsockopt_service()
421 	lock_sock(sk);  in dccp_setsockopt_service()
427 	release_sock(sk);  in dccp_setsockopt_service()
431 static int dccp_setsockopt_cscov(struct sock *sk, int cscov, bool rx)  in dccp_setsockopt_cscov()  argument
455 	rc = dccp_feat_register_sp(sk, DCCPF_MIN_CSUM_COVER, rx, list, len);  in dccp_setsockopt_cscov()
459 			dccp_sk(sk)->dccps_pcrlen = cscov;  in dccp_setsockopt_cscov()
461 			dccp_sk(sk)->dccps_pcslen = cscov;  in dccp_setsockopt_cscov()
467 static int dccp_setsockopt_ccid(struct sock *sk, int type,  in dccp_setsockopt_ccid()  argument
480 	lock_sock(sk);  in dccp_setsockopt_ccid()
482 		rc = dccp_feat_register_sp(sk, DCCPF_CCID, 1, val, optlen);  in dccp_setsockopt_ccid()
485 		rc = dccp_feat_register_sp(sk, DCCPF_CCID, 0, val, optlen);  in dccp_setsockopt_ccid()
486 	release_sock(sk);  in dccp_setsockopt_ccid()
492 static int do_dccp_setsockopt(struct sock *sk, int level, int optname,  in do_dccp_setsockopt()  argument
495 	struct dccp_sock *dp = dccp_sk(sk);  in do_dccp_setsockopt()
509 		return dccp_setsockopt_ccid(sk, optname, optval, optlen);  in do_dccp_setsockopt()
519 		return dccp_setsockopt_service(sk, val, optval, optlen);  in do_dccp_setsockopt()
521 	lock_sock(sk);  in do_dccp_setsockopt()
530 		err = dccp_setsockopt_cscov(sk, val, false);  in do_dccp_setsockopt()
533 		err = dccp_setsockopt_cscov(sk, val, true);  in do_dccp_setsockopt()
536 		if (sk->sk_state != DCCP_CLOSED)  in do_dccp_setsockopt()
553 	release_sock(sk);  in do_dccp_setsockopt()
558 int dccp_setsockopt(struct sock *sk, int level, int optname,  in dccp_setsockopt()  argument
562 		return inet_csk(sk)->icsk_af_ops->setsockopt(sk, level,  in dccp_setsockopt()
565 	return do_dccp_setsockopt(sk, level, optname, optval, optlen);  in dccp_setsockopt()
571 int compat_dccp_setsockopt(struct sock *sk, int level, int optname,  in compat_dccp_setsockopt()  argument
575 		return inet_csk_compat_setsockopt(sk, level, optname,  in compat_dccp_setsockopt()
577 	return do_dccp_setsockopt(sk, level, optname, optval, optlen);  in compat_dccp_setsockopt()
583 static int dccp_getsockopt_service(struct sock *sk, int len,  in dccp_getsockopt_service()  argument
587 	const struct dccp_sock *dp = dccp_sk(sk);  in dccp_getsockopt_service()
591 	lock_sock(sk);  in dccp_getsockopt_service()
607 	release_sock(sk);  in dccp_getsockopt_service()
611 static int do_dccp_getsockopt(struct sock *sk, int level, int optname,  in do_dccp_getsockopt()  argument
623 	dp = dccp_sk(sk);  in do_dccp_getsockopt()
630 		return dccp_getsockopt_service(sk, len,  in do_dccp_getsockopt()
636 		return ccid_getsockopt_builtin_ccids(sk, len, optval, optlen);  in do_dccp_getsockopt()
663 		return ccid_hc_rx_getsockopt(dp->dccps_hc_rx_ccid, sk, optname,  in do_dccp_getsockopt()
666 		return ccid_hc_tx_getsockopt(dp->dccps_hc_tx_ccid, sk, optname,  in do_dccp_getsockopt()
679 int dccp_getsockopt(struct sock *sk, int level, int optname,  in dccp_getsockopt()  argument
683 		return inet_csk(sk)->icsk_af_ops->getsockopt(sk, level,  in dccp_getsockopt()
686 	return do_dccp_getsockopt(sk, level, optname, optval, optlen);  in dccp_getsockopt()
692 int compat_dccp_getsockopt(struct sock *sk, int level, int optname,  in compat_dccp_getsockopt()  argument
696 		return inet_csk_compat_getsockopt(sk, level, optname,  in compat_dccp_getsockopt()
698 	return do_dccp_getsockopt(sk, level, optname, optval, optlen);  in compat_dccp_getsockopt()
728 		    !dccp_qpolicy_param_ok(skb->sk, cmsg->cmsg_type))  in dccp_msghdr_parse()
744 int dccp_sendmsg(struct sock *sk, struct msghdr *msg, size_t len)  in dccp_sendmsg()  argument
746 	const struct dccp_sock *dp = dccp_sk(sk);  in dccp_sendmsg()
756 	lock_sock(sk);  in dccp_sendmsg()
758 	if (dccp_qpolicy_full(sk)) {  in dccp_sendmsg()
763 	timeo = sock_sndtimeo(sk, noblock);  in dccp_sendmsg()
770 	if ((1 << sk->sk_state) & ~(DCCPF_OPEN | DCCPF_PARTOPEN))  in dccp_sendmsg()
771 		if ((rc = sk_stream_wait_connect(sk, &timeo)) != 0)  in dccp_sendmsg()
774 	size = sk->sk_prot->max_header + len;  in dccp_sendmsg()
775 	release_sock(sk);  in dccp_sendmsg()
776 	skb = sock_alloc_send_skb(sk, size, noblock, &rc);  in dccp_sendmsg()
777 	lock_sock(sk);  in dccp_sendmsg()
781 	skb_reserve(skb, sk->sk_prot->max_header);  in dccp_sendmsg()
790 	dccp_qpolicy_push(sk, skb);  in dccp_sendmsg()
797 		dccp_write_xmit(sk);  in dccp_sendmsg()
799 	release_sock(sk);  in dccp_sendmsg()
808 int dccp_recvmsg(struct sock *sk, struct msghdr *msg, size_t len, int nonblock,  in dccp_recvmsg()  argument
814 	lock_sock(sk);  in dccp_recvmsg()
816 	if (sk->sk_state == DCCP_LISTEN) {  in dccp_recvmsg()
821 	timeo = sock_rcvtimeo(sk, nonblock);  in dccp_recvmsg()
824 		struct sk_buff *skb = skb_peek(&sk->sk_receive_queue);  in dccp_recvmsg()
839 				dccp_finish_passive_close(sk);  in dccp_recvmsg()
849 			sk_eat_skb(sk, skb);  in dccp_recvmsg()
852 		if (sock_flag(sk, SOCK_DONE)) {  in dccp_recvmsg()
857 		if (sk->sk_err) {  in dccp_recvmsg()
858 			len = sock_error(sk);  in dccp_recvmsg()
862 		if (sk->sk_shutdown & RCV_SHUTDOWN) {  in dccp_recvmsg()
867 		if (sk->sk_state == DCCP_CLOSED) {  in dccp_recvmsg()
868 			if (!sock_flag(sk, SOCK_DONE)) {  in dccp_recvmsg()
889 		sk_wait_data(sk, &timeo);  in dccp_recvmsg()
906 			sk_eat_skb(sk, skb);  in dccp_recvmsg()
910 	release_sock(sk);  in dccp_recvmsg()
918 	struct sock *sk = sock->sk;  in inet_dccp_listen()  local
922 	lock_sock(sk);  in inet_dccp_listen()
928 	old_state = sk->sk_state;  in inet_dccp_listen()
940 		err = dccp_listen_start(sk, backlog);  in inet_dccp_listen()
944 	sk->sk_max_ack_backlog = backlog;  in inet_dccp_listen()
948 	release_sock(sk);  in inet_dccp_listen()
954 static void dccp_terminate_connection(struct sock *sk)  in dccp_terminate_connection()  argument
958 	switch (sk->sk_state) {  in dccp_terminate_connection()
961 		dccp_finish_passive_close(sk);  in dccp_terminate_connection()
964 		dccp_pr_debug("Stop PARTOPEN timer (%p)\n", sk);  in dccp_terminate_connection()
965 		inet_csk_clear_xmit_timer(sk, ICSK_TIME_DACK);  in dccp_terminate_connection()
968 		dccp_send_close(sk, 1);  in dccp_terminate_connection()
970 		if (dccp_sk(sk)->dccps_role == DCCP_ROLE_SERVER &&  in dccp_terminate_connection()
971 		    !dccp_sk(sk)->dccps_server_timewait)  in dccp_terminate_connection()
977 		dccp_set_state(sk, next_state);  in dccp_terminate_connection()
981 void dccp_close(struct sock *sk, long timeout)  in dccp_close()  argument
983 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_close()
988 	lock_sock(sk);  in dccp_close()
990 	sk->sk_shutdown = SHUTDOWN_MASK;  in dccp_close()
992 	if (sk->sk_state == DCCP_LISTEN) {  in dccp_close()
993 		dccp_set_state(sk, DCCP_CLOSED);  in dccp_close()
996 		inet_csk_listen_stop(sk);  in dccp_close()
1001 	sk_stop_timer(sk, &dp->dccps_xmit_timer);  in dccp_close()
1008 	while ((skb = __skb_dequeue(&sk->sk_receive_queue)) != NULL) {  in dccp_close()
1016 		dccp_send_reset(sk, DCCP_RESET_CODE_ABORTED);  in dccp_close()
1017 		dccp_set_state(sk, DCCP_CLOSED);  in dccp_close()
1018 	} else if (sock_flag(sk, SOCK_LINGER) && !sk->sk_lingertime) {  in dccp_close()
1020 		sk->sk_prot->disconnect(sk, 0);  in dccp_close()
1021 	} else if (sk->sk_state != DCCP_CLOSED) {  in dccp_close()
1026 		dccp_flush_write_queue(sk, &timeout);  in dccp_close()
1027 		dccp_terminate_connection(sk);  in dccp_close()
1036 	__skb_queue_purge(&sk->sk_write_queue);  in dccp_close()
1038 	sk_stream_wait_close(sk, timeout);  in dccp_close()
1041 	state = sk->sk_state;  in dccp_close()
1042 	sock_hold(sk);  in dccp_close()
1043 	sock_orphan(sk);  in dccp_close()
1048 	release_sock(sk);  in dccp_close()
1054 	bh_lock_sock(sk);  in dccp_close()
1055 	WARN_ON(sock_owned_by_user(sk));  in dccp_close()
1057 	percpu_counter_inc(sk->sk_prot->orphan_count);  in dccp_close()
1060 	if (state != DCCP_CLOSED && sk->sk_state == DCCP_CLOSED)  in dccp_close()
1063 	if (sk->sk_state == DCCP_CLOSED)  in dccp_close()
1064 		inet_csk_destroy_sock(sk);  in dccp_close()
1069 	bh_unlock_sock(sk);  in dccp_close()
1071 	sock_put(sk);  in dccp_close()
1076 void dccp_shutdown(struct sock *sk, int how)  in dccp_shutdown()  argument