76 static int rxrpc_validate_address(struct rxrpc_sock *rx,  in rxrpc_validate_address()  argument
96 	if (srx->transport.family != rx->family &&  in rxrpc_validate_address()
97 	    srx->transport.family == AF_INET && rx->family != AF_INET6)  in rxrpc_validate_address()
133 	struct rxrpc_sock *rx = rxrpc_sk(sock->sk);  in rxrpc_bind()  local
137 	_enter("%p,%p,%d", rx, saddr, len);  in rxrpc_bind()
139 	ret = rxrpc_validate_address(rx, srx, len);  in rxrpc_bind()
144 	lock_sock(&rx->sk);  in rxrpc_bind()
146 	switch (rx->sk.sk_state) {  in rxrpc_bind()
148 		rx->srx = *srx;  in rxrpc_bind()
149 		local = rxrpc_lookup_local(sock_net(&rx->sk), &rx->srx);  in rxrpc_bind()
159 			rx->local = local;  in rxrpc_bind()
160 			rcu_assign_pointer(local->service, rx);  in rxrpc_bind()
163 			rx->sk.sk_state = RXRPC_SERVER_BOUND;  in rxrpc_bind()
165 			rx->local = local;  in rxrpc_bind()
166 			rx->sk.sk_state = RXRPC_CLIENT_BOUND;  in rxrpc_bind()
175 		if (service_id == rx->srx.srx_service)  in rxrpc_bind()
178 		srx->srx_service = rx->srx.srx_service;  in rxrpc_bind()
179 		if (memcmp(srx, &rx->srx, sizeof(*srx)) != 0)  in rxrpc_bind()
181 		rx->second_service = service_id;  in rxrpc_bind()
182 		rx->sk.sk_state = RXRPC_SERVER_BOUND2;  in rxrpc_bind()
190 	release_sock(&rx->sk);  in rxrpc_bind()
199 	release_sock(&rx->sk);  in rxrpc_bind()
211 	struct rxrpc_sock *rx = rxrpc_sk(sk);  in rxrpc_listen()  local
215 	_enter("%p,%d", rx, backlog);  in rxrpc_listen()
217 	lock_sock(&rx->sk);  in rxrpc_listen()
219 	switch (rx->sk.sk_state) {  in rxrpc_listen()
225 		ASSERT(rx->local != NULL);  in rxrpc_listen()
234 		ret = rxrpc_service_prealloc(rx, GFP_KERNEL);  in rxrpc_listen()
236 			rx->sk.sk_state = RXRPC_SERVER_LISTENING;  in rxrpc_listen()
242 			rx->sk.sk_state = RXRPC_SERVER_LISTEN_DISABLED;  in rxrpc_listen()
244 			rxrpc_discard_prealloc(rx);  in rxrpc_listen()
254 	release_sock(&rx->sk);  in rxrpc_listen()
293 	struct rxrpc_sock *rx = rxrpc_sk(sock->sk);  in rxrpc_kernel_begin_call()  local
298 	ret = rxrpc_validate_address(rx, srx, sizeof(*srx));  in rxrpc_kernel_begin_call()
302 	lock_sock(&rx->sk);  in rxrpc_kernel_begin_call()
305 		key = rx->key;  in rxrpc_kernel_begin_call()
315 	cp.local		= rx->local;  in rxrpc_kernel_begin_call()
317 	cp.security_level	= rx->min_sec_level;  in rxrpc_kernel_begin_call()
321 	call = rxrpc_new_client_call(rx, &cp, srx, &p, gfp, debug_id);  in rxrpc_kernel_begin_call()
438 	struct rxrpc_sock *rx = rxrpc_sk(sock->sk);  in rxrpc_kernel_new_call_notification()  local
440 	rx->notify_new_call = notify_new_call;  in rxrpc_kernel_new_call_notification()
441 	rx->discard_new_call = discard_new_call;  in rxrpc_kernel_new_call_notification()
479 	struct rxrpc_sock *rx = rxrpc_sk(sock->sk);  in rxrpc_connect()  local
482 	_enter("%p,%p,%d,%d", rx, addr, addr_len, flags);  in rxrpc_connect()
484 	ret = rxrpc_validate_address(rx, srx, addr_len);  in rxrpc_connect()
490 	lock_sock(&rx->sk);  in rxrpc_connect()
493 	if (test_bit(RXRPC_SOCK_CONNECTED, &rx->flags))  in rxrpc_connect()
496 	switch (rx->sk.sk_state) {  in rxrpc_connect()
498 		rx->sk.sk_state = RXRPC_CLIENT_UNBOUND;  in rxrpc_connect()
507 	rx->connect_srx = *srx;  in rxrpc_connect()
508 	set_bit(RXRPC_SOCK_CONNECTED, &rx->flags);  in rxrpc_connect()
512 	release_sock(&rx->sk);  in rxrpc_connect()
528 	struct rxrpc_sock *rx = rxrpc_sk(sock->sk);  in rxrpc_sendmsg()  local
531 	_enter(",{%d},,%zu", rx->sk.sk_state, len);  in rxrpc_sendmsg()
537 		ret = rxrpc_validate_address(rx, m->msg_name, m->msg_namelen);  in rxrpc_sendmsg()
544 	lock_sock(&rx->sk);  in rxrpc_sendmsg()
546 	switch (rx->sk.sk_state) {  in rxrpc_sendmsg()
549 		rx->srx.srx_family = AF_RXRPC;  in rxrpc_sendmsg()
550 		rx->srx.srx_service = 0;  in rxrpc_sendmsg()
551 		rx->srx.transport_type = SOCK_DGRAM;  in rxrpc_sendmsg()
552 		rx->srx.transport.family = rx->family;  in rxrpc_sendmsg()
553 		switch (rx->family) {  in rxrpc_sendmsg()
555 			rx->srx.transport_len = sizeof(struct sockaddr_in);  in rxrpc_sendmsg()
559 			rx->srx.transport_len = sizeof(struct sockaddr_in6);  in rxrpc_sendmsg()
566 		local = rxrpc_lookup_local(sock_net(sock->sk), &rx->srx);  in rxrpc_sendmsg()
572 		rx->local = local;  in rxrpc_sendmsg()
573 		rx->sk.sk_state = RXRPC_CLIENT_BOUND;  in rxrpc_sendmsg()
578 		    test_bit(RXRPC_SOCK_CONNECTED, &rx->flags)) {  in rxrpc_sendmsg()
579 			m->msg_name = &rx->connect_srx;  in rxrpc_sendmsg()
580 			m->msg_namelen = sizeof(rx->connect_srx);  in rxrpc_sendmsg()
585 		ret = rxrpc_do_sendmsg(rx, m, len);  in rxrpc_sendmsg()
594 	release_sock(&rx->sk);  in rxrpc_sendmsg()
606 	struct rxrpc_sock *rx = rxrpc_sk(sock->sk);  in rxrpc_setsockopt()  local
613 	lock_sock(&rx->sk);  in rxrpc_setsockopt()
623 			if (rx->sk.sk_state != RXRPC_UNBOUND)  in rxrpc_setsockopt()
625 			rx->exclusive = true;  in rxrpc_setsockopt()
630 			if (rx->key)  in rxrpc_setsockopt()
633 			if (rx->sk.sk_state != RXRPC_UNBOUND)  in rxrpc_setsockopt()
635 			ret = rxrpc_request_key(rx, optval, optlen);  in rxrpc_setsockopt()
640 			if (rx->key)  in rxrpc_setsockopt()
643 			if (rx->sk.sk_state != RXRPC_UNBOUND)  in rxrpc_setsockopt()
645 			ret = rxrpc_server_keyring(rx, optval, optlen);  in rxrpc_setsockopt()
653 			if (rx->sk.sk_state != RXRPC_UNBOUND)  in rxrpc_setsockopt()
662 			rx->min_sec_level = min_sec_level;  in rxrpc_setsockopt()
668 			    rx->service_upgrade.from != 0)  in rxrpc_setsockopt()
671 			if (rx->sk.sk_state != RXRPC_SERVER_BOUND2)  in rxrpc_setsockopt()
678 			if ((service_upgrade[0] != rx->srx.srx_service ||  in rxrpc_setsockopt()
679 			     service_upgrade[1] != rx->second_service) &&  in rxrpc_setsockopt()
680 			    (service_upgrade[0] != rx->second_service ||  in rxrpc_setsockopt()
681 			     service_upgrade[1] != rx->srx.srx_service))  in rxrpc_setsockopt()
683 			rx->service_upgrade.from = service_upgrade[0];  in rxrpc_setsockopt()
684 			rx->service_upgrade.to = service_upgrade[1];  in rxrpc_setsockopt()
695 	release_sock(&rx->sk);  in rxrpc_setsockopt()
734 	struct rxrpc_sock *rx = rxrpc_sk(sk);  in rxrpc_poll()  local
740 	/* the socket is readable if there are any messages waiting on the Rx  in rxrpc_poll()
742 	if (!list_empty(&rx->recvmsg_q))  in rxrpc_poll()
761 	struct rxrpc_sock *rx;  in rxrpc_create()  local
788 	rx = rxrpc_sk(sk);  in rxrpc_create()
789 	rx->family = protocol;  in rxrpc_create()
790 	rx->calls = RB_ROOT;  in rxrpc_create()
792 	spin_lock_init(&rx->incoming_lock);  in rxrpc_create()
793 	INIT_LIST_HEAD(&rx->sock_calls);  in rxrpc_create()
794 	INIT_LIST_HEAD(&rx->to_be_accepted);  in rxrpc_create()
795 	INIT_LIST_HEAD(&rx->recvmsg_q);  in rxrpc_create()
796 	rwlock_init(&rx->recvmsg_lock);  in rxrpc_create()
797 	rwlock_init(&rx->call_lock);  in rxrpc_create()
798 	memset(&rx->srx, 0, sizeof(rx->srx));  in rxrpc_create()
800 	rxnet = rxrpc_net(sock_net(&rx->sk));  in rxrpc_create()
803 	_leave(" = 0 [%p]", rx);  in rxrpc_create()
813 	struct rxrpc_sock *rx = rxrpc_sk(sk);  in rxrpc_shutdown()  local
834 	rxrpc_discard_prealloc(rx);  in rxrpc_shutdown()
864 	struct rxrpc_sock *rx = rxrpc_sk(sk);  in rxrpc_release_sock()  local
881 		rx->local->service_closed = true;  in rxrpc_release_sock()
889 	if (rx->local && rcu_access_pointer(rx->local->service) == rx) {  in rxrpc_release_sock()
890 		write_lock(&rx->local->services_lock);  in rxrpc_release_sock()
891 		rcu_assign_pointer(rx->local->service, NULL);  in rxrpc_release_sock()
892 		write_unlock(&rx->local->services_lock);  in rxrpc_release_sock()
896 	rxrpc_discard_prealloc(rx);  in rxrpc_release_sock()
897 	rxrpc_release_calls_on_socket(rx);  in rxrpc_release_sock()
901 	rxrpc_unuse_local(rx->local);  in rxrpc_release_sock()
902 	rx->local = NULL;  in rxrpc_release_sock()
903 	key_put(rx->key);  in rxrpc_release_sock()
904 	rx->key = NULL;  in rxrpc_release_sock()
905 	key_put(rx->securities);  in rxrpc_release_sock()
906 	rx->securities = NULL;  in rxrpc_release_sock()