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()
342 				sk_set_bit(SOCKWQ_ASYNC_NOSPACE, sk);  in dccp_poll()
343 				set_bit(SOCK_NOSPACE, &sk->sk_socket->flags);  in dccp_poll()
349 				if (sk_stream_is_writeable(sk))  in dccp_poll()
359 int dccp_ioctl(struct sock *sk, int cmd, unsigned long arg)  in dccp_ioctl()  argument
363 	lock_sock(sk);  in dccp_ioctl()
365 	if (sk->sk_state == DCCP_LISTEN)  in dccp_ioctl()
373 		skb = skb_peek(&sk->sk_receive_queue);  in dccp_ioctl()
389 	release_sock(sk);  in dccp_ioctl()
395 static int dccp_setsockopt_service(struct sock *sk, const __be32 service,  in dccp_setsockopt_service()  argument
398 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_setsockopt_service()
420 	lock_sock(sk);  in dccp_setsockopt_service()
426 	release_sock(sk);  in dccp_setsockopt_service()
430 static int dccp_setsockopt_cscov(struct sock *sk, int cscov, bool rx)  in dccp_setsockopt_cscov()  argument
454 	rc = dccp_feat_register_sp(sk, DCCPF_MIN_CSUM_COVER, rx, list, len);  in dccp_setsockopt_cscov()
458 			dccp_sk(sk)->dccps_pcrlen = cscov;  in dccp_setsockopt_cscov()
460 			dccp_sk(sk)->dccps_pcslen = cscov;  in dccp_setsockopt_cscov()
466 static int dccp_setsockopt_ccid(struct sock *sk, int type,  in dccp_setsockopt_ccid()  argument
479 	lock_sock(sk);  in dccp_setsockopt_ccid()
481 		rc = dccp_feat_register_sp(sk, DCCPF_CCID, 1, val, optlen);  in dccp_setsockopt_ccid()
484 		rc = dccp_feat_register_sp(sk, DCCPF_CCID, 0, val, optlen);  in dccp_setsockopt_ccid()
485 	release_sock(sk);  in dccp_setsockopt_ccid()
491 static int do_dccp_setsockopt(struct sock *sk, int level, int optname,  in do_dccp_setsockopt()  argument
494 	struct dccp_sock *dp = dccp_sk(sk);  in do_dccp_setsockopt()
508 		return dccp_setsockopt_ccid(sk, optname, optval, optlen);  in do_dccp_setsockopt()
518 		return dccp_setsockopt_service(sk, val, optval, optlen);  in do_dccp_setsockopt()
520 	lock_sock(sk);  in do_dccp_setsockopt()
529 		err = dccp_setsockopt_cscov(sk, val, false);  in do_dccp_setsockopt()
532 		err = dccp_setsockopt_cscov(sk, val, true);  in do_dccp_setsockopt()
535 		if (sk->sk_state != DCCP_CLOSED)  in do_dccp_setsockopt()
552 	release_sock(sk);  in do_dccp_setsockopt()
557 int dccp_setsockopt(struct sock *sk, int level, int optname,  in dccp_setsockopt()  argument
561 		return inet_csk(sk)->icsk_af_ops->setsockopt(sk, level,  in dccp_setsockopt()
564 	return do_dccp_setsockopt(sk, level, optname, optval, optlen);  in dccp_setsockopt()
570 int compat_dccp_setsockopt(struct sock *sk, int level, int optname,  in compat_dccp_setsockopt()  argument
574 		return inet_csk_compat_setsockopt(sk, level, optname,  in compat_dccp_setsockopt()
576 	return do_dccp_setsockopt(sk, level, optname, optval, optlen);  in compat_dccp_setsockopt()
582 static int dccp_getsockopt_service(struct sock *sk, int len,  in dccp_getsockopt_service()  argument
586 	const struct dccp_sock *dp = dccp_sk(sk);  in dccp_getsockopt_service()
590 	lock_sock(sk);  in dccp_getsockopt_service()
606 	release_sock(sk);  in dccp_getsockopt_service()
610 static int do_dccp_getsockopt(struct sock *sk, int level, int optname,  in do_dccp_getsockopt()  argument
622 	dp = dccp_sk(sk);  in do_dccp_getsockopt()
629 		return dccp_getsockopt_service(sk, len,  in do_dccp_getsockopt()
635 		return ccid_getsockopt_builtin_ccids(sk, len, optval, optlen);  in do_dccp_getsockopt()
662 		return ccid_hc_rx_getsockopt(dp->dccps_hc_rx_ccid, sk, optname,  in do_dccp_getsockopt()
665 		return ccid_hc_tx_getsockopt(dp->dccps_hc_tx_ccid, sk, optname,  in do_dccp_getsockopt()
678 int dccp_getsockopt(struct sock *sk, int level, int optname,  in dccp_getsockopt()  argument
682 		return inet_csk(sk)->icsk_af_ops->getsockopt(sk, level,  in dccp_getsockopt()
685 	return do_dccp_getsockopt(sk, level, optname, optval, optlen);  in dccp_getsockopt()
691 int compat_dccp_getsockopt(struct sock *sk, int level, int optname,  in compat_dccp_getsockopt()  argument
695 		return inet_csk_compat_getsockopt(sk, level, optname,  in compat_dccp_getsockopt()
697 	return do_dccp_getsockopt(sk, level, optname, optval, optlen);  in compat_dccp_getsockopt()
727 		    !dccp_qpolicy_param_ok(skb->sk, cmsg->cmsg_type))  in dccp_msghdr_parse()
743 int dccp_sendmsg(struct sock *sk, struct msghdr *msg, size_t len)  in dccp_sendmsg()  argument
745 	const struct dccp_sock *dp = dccp_sk(sk);  in dccp_sendmsg()
755 	lock_sock(sk);  in dccp_sendmsg()
757 	if (dccp_qpolicy_full(sk)) {  in dccp_sendmsg()
762 	timeo = sock_sndtimeo(sk, noblock);  in dccp_sendmsg()
769 	if ((1 << sk->sk_state) & ~(DCCPF_OPEN | DCCPF_PARTOPEN))  in dccp_sendmsg()
770 		if ((rc = sk_stream_wait_connect(sk, &timeo)) != 0)  in dccp_sendmsg()
773 	size = sk->sk_prot->max_header + len;  in dccp_sendmsg()
774 	release_sock(sk);  in dccp_sendmsg()
775 	skb = sock_alloc_send_skb(sk, size, noblock, &rc);  in dccp_sendmsg()
776 	lock_sock(sk);  in dccp_sendmsg()
780 	skb_reserve(skb, sk->sk_prot->max_header);  in dccp_sendmsg()
789 	dccp_qpolicy_push(sk, skb);  in dccp_sendmsg()
796 		dccp_write_xmit(sk);  in dccp_sendmsg()
798 	release_sock(sk);  in dccp_sendmsg()
807 int dccp_recvmsg(struct sock *sk, struct msghdr *msg, size_t len, int nonblock,  in dccp_recvmsg()  argument
813 	lock_sock(sk);  in dccp_recvmsg()
815 	if (sk->sk_state == DCCP_LISTEN) {  in dccp_recvmsg()
820 	timeo = sock_rcvtimeo(sk, nonblock);  in dccp_recvmsg()
823 		struct sk_buff *skb = skb_peek(&sk->sk_receive_queue);  in dccp_recvmsg()
838 				dccp_finish_passive_close(sk);  in dccp_recvmsg()
848 			sk_eat_skb(sk, skb);  in dccp_recvmsg()
851 		if (sock_flag(sk, SOCK_DONE)) {  in dccp_recvmsg()
856 		if (sk->sk_err) {  in dccp_recvmsg()
857 			len = sock_error(sk);  in dccp_recvmsg()
861 		if (sk->sk_shutdown & RCV_SHUTDOWN) {  in dccp_recvmsg()
866 		if (sk->sk_state == DCCP_CLOSED) {  in dccp_recvmsg()
867 			if (!sock_flag(sk, SOCK_DONE)) {  in dccp_recvmsg()
888 		sk_wait_data(sk, &timeo, NULL);  in dccp_recvmsg()
905 			sk_eat_skb(sk, skb);  in dccp_recvmsg()
909 	release_sock(sk);  in dccp_recvmsg()
917 	struct sock *sk = sock->sk;  in inet_dccp_listen()  local
921 	lock_sock(sk);  in inet_dccp_listen()
927 	old_state = sk->sk_state;  in inet_dccp_listen()
939 		err = dccp_listen_start(sk, backlog);  in inet_dccp_listen()
943 	sk->sk_max_ack_backlog = backlog;  in inet_dccp_listen()
947 	release_sock(sk);  in inet_dccp_listen()
953 static void dccp_terminate_connection(struct sock *sk)  in dccp_terminate_connection()  argument
957 	switch (sk->sk_state) {  in dccp_terminate_connection()
960 		dccp_finish_passive_close(sk);  in dccp_terminate_connection()
963 		dccp_pr_debug("Stop PARTOPEN timer (%p)\n", sk);  in dccp_terminate_connection()
964 		inet_csk_clear_xmit_timer(sk, ICSK_TIME_DACK);  in dccp_terminate_connection()
967 		dccp_send_close(sk, 1);  in dccp_terminate_connection()
969 		if (dccp_sk(sk)->dccps_role == DCCP_ROLE_SERVER &&  in dccp_terminate_connection()
970 		    !dccp_sk(sk)->dccps_server_timewait)  in dccp_terminate_connection()
976 		dccp_set_state(sk, next_state);  in dccp_terminate_connection()
980 void dccp_close(struct sock *sk, long timeout)  in dccp_close()  argument
982 	struct dccp_sock *dp = dccp_sk(sk);  in dccp_close()
987 	lock_sock(sk);  in dccp_close()
989 	sk->sk_shutdown = SHUTDOWN_MASK;  in dccp_close()
991 	if (sk->sk_state == DCCP_LISTEN) {  in dccp_close()
992 		dccp_set_state(sk, DCCP_CLOSED);  in dccp_close()
995 		inet_csk_listen_stop(sk);  in dccp_close()
1000 	sk_stop_timer(sk, &dp->dccps_xmit_timer);  in dccp_close()
1007 	while ((skb = __skb_dequeue(&sk->sk_receive_queue)) != NULL) {  in dccp_close()
1015 		dccp_send_reset(sk, DCCP_RESET_CODE_ABORTED);  in dccp_close()
1016 		dccp_set_state(sk, DCCP_CLOSED);  in dccp_close()
1017 	} else if (sock_flag(sk, SOCK_LINGER) && !sk->sk_lingertime) {  in dccp_close()
1019 		sk->sk_prot->disconnect(sk, 0);  in dccp_close()
1020 	} else if (sk->sk_state != DCCP_CLOSED) {  in dccp_close()
1025 		dccp_flush_write_queue(sk, &timeout);  in dccp_close()
1026 		dccp_terminate_connection(sk);  in dccp_close()
1035 	__skb_queue_purge(&sk->sk_write_queue);  in dccp_close()
1037 	sk_stream_wait_close(sk, timeout);  in dccp_close()
1040 	state = sk->sk_state;  in dccp_close()
1041 	sock_hold(sk);  in dccp_close()
1042 	sock_orphan(sk);  in dccp_close()
1047 	release_sock(sk);  in dccp_close()
1053 	bh_lock_sock(sk);  in dccp_close()
1054 	WARN_ON(sock_owned_by_user(sk));  in dccp_close()
1056 	percpu_counter_inc(sk->sk_prot->orphan_count);  in dccp_close()
1059 	if (state != DCCP_CLOSED && sk->sk_state == DCCP_CLOSED)  in dccp_close()
1062 	if (sk->sk_state == DCCP_CLOSED)  in dccp_close()
1063 		inet_csk_destroy_sock(sk);  in dccp_close()
1068 	bh_unlock_sock(sk);  in dccp_close()
1070 	sock_put(sk);  in dccp_close()
1075 void dccp_shutdown(struct sock *sk, int how)  in dccp_shutdown()  argument