Lines Matching refs:rx
76 static int rxrpc_validate_address(struct rxrpc_sock *rx, in rxrpc_validate_address() argument
98 if (rx->family != AF_INET && in rxrpc_validate_address()
99 rx->family != AF_INET6) in rxrpc_validate_address()
108 if (rx->family != AF_INET6) in rxrpc_validate_address()
134 struct rxrpc_sock *rx = rxrpc_sk(sock->sk); in rxrpc_bind() local
138 _enter("%p,%p,%d", rx, saddr, len); in rxrpc_bind()
140 ret = rxrpc_validate_address(rx, srx, len); in rxrpc_bind()
145 lock_sock(&rx->sk); in rxrpc_bind()
147 switch (rx->sk.sk_state) { in rxrpc_bind()
149 rx->srx = *srx; in rxrpc_bind()
150 local = rxrpc_lookup_local(sock_net(&rx->sk), &rx->srx); in rxrpc_bind()
160 rx->local = local; in rxrpc_bind()
161 local->service = rx; in rxrpc_bind()
164 rx->sk.sk_state = RXRPC_SERVER_BOUND; in rxrpc_bind()
166 rx->local = local; in rxrpc_bind()
167 rx->sk.sk_state = RXRPC_CLIENT_BOUND; in rxrpc_bind()
176 if (service_id == rx->srx.srx_service) in rxrpc_bind()
179 srx->srx_service = rx->srx.srx_service; in rxrpc_bind()
180 if (memcmp(srx, &rx->srx, sizeof(*srx)) != 0) in rxrpc_bind()
182 rx->second_service = service_id; in rxrpc_bind()
183 rx->sk.sk_state = RXRPC_SERVER_BOUND2; in rxrpc_bind()
191 release_sock(&rx->sk); in rxrpc_bind()
201 release_sock(&rx->sk); in rxrpc_bind()
213 struct rxrpc_sock *rx = rxrpc_sk(sk); in rxrpc_listen() local
217 _enter("%p,%d", rx, backlog); in rxrpc_listen()
219 lock_sock(&rx->sk); in rxrpc_listen()
221 switch (rx->sk.sk_state) { in rxrpc_listen()
227 ASSERT(rx->local != NULL); in rxrpc_listen()
236 ret = rxrpc_service_prealloc(rx, GFP_KERNEL); in rxrpc_listen()
238 rx->sk.sk_state = RXRPC_SERVER_LISTENING; in rxrpc_listen()
244 rx->sk.sk_state = RXRPC_SERVER_LISTEN_DISABLED; in rxrpc_listen()
246 rxrpc_discard_prealloc(rx); in rxrpc_listen()
256 release_sock(&rx->sk); in rxrpc_listen()
295 struct rxrpc_sock *rx = rxrpc_sk(sock->sk); in rxrpc_kernel_begin_call() local
300 ret = rxrpc_validate_address(rx, srx, sizeof(*srx)); in rxrpc_kernel_begin_call()
304 lock_sock(&rx->sk); in rxrpc_kernel_begin_call()
307 key = rx->key; in rxrpc_kernel_begin_call()
318 cp.local = rx->local; in rxrpc_kernel_begin_call()
320 cp.security_level = rx->min_sec_level; in rxrpc_kernel_begin_call()
324 call = rxrpc_new_client_call(rx, &cp, srx, &p, gfp, debug_id); in rxrpc_kernel_begin_call()
417 struct rxrpc_sock *rx = rxrpc_sk(sock->sk); in rxrpc_kernel_new_call_notification() local
419 rx->notify_new_call = notify_new_call; in rxrpc_kernel_new_call_notification()
420 rx->discard_new_call = discard_new_call; in rxrpc_kernel_new_call_notification()
458 struct rxrpc_sock *rx = rxrpc_sk(sock->sk); in rxrpc_connect() local
461 _enter("%p,%p,%d,%d", rx, addr, addr_len, flags); in rxrpc_connect()
463 ret = rxrpc_validate_address(rx, srx, addr_len); in rxrpc_connect()
469 lock_sock(&rx->sk); in rxrpc_connect()
472 if (test_bit(RXRPC_SOCK_CONNECTED, &rx->flags)) in rxrpc_connect()
475 switch (rx->sk.sk_state) { in rxrpc_connect()
477 rx->sk.sk_state = RXRPC_CLIENT_UNBOUND; in rxrpc_connect()
487 rx->connect_srx = *srx; in rxrpc_connect()
488 set_bit(RXRPC_SOCK_CONNECTED, &rx->flags); in rxrpc_connect()
492 release_sock(&rx->sk); in rxrpc_connect()
508 struct rxrpc_sock *rx = rxrpc_sk(sock->sk); in rxrpc_sendmsg() local
511 _enter(",{%d},,%zu", rx->sk.sk_state, len); in rxrpc_sendmsg()
517 ret = rxrpc_validate_address(rx, m->msg_name, m->msg_namelen); in rxrpc_sendmsg()
524 lock_sock(&rx->sk); in rxrpc_sendmsg()
526 switch (rx->sk.sk_state) { in rxrpc_sendmsg()
529 rx->srx.srx_family = AF_RXRPC; in rxrpc_sendmsg()
530 rx->srx.srx_service = 0; in rxrpc_sendmsg()
531 rx->srx.transport_type = SOCK_DGRAM; in rxrpc_sendmsg()
532 rx->srx.transport.family = rx->family; in rxrpc_sendmsg()
533 switch (rx->family) { in rxrpc_sendmsg()
535 rx->srx.transport_len = sizeof(struct sockaddr_in); in rxrpc_sendmsg()
539 rx->srx.transport_len = sizeof(struct sockaddr_in6); in rxrpc_sendmsg()
546 local = rxrpc_lookup_local(sock_net(sock->sk), &rx->srx); in rxrpc_sendmsg()
552 rx->local = local; in rxrpc_sendmsg()
553 rx->sk.sk_state = RXRPC_CLIENT_BOUND; in rxrpc_sendmsg()
558 test_bit(RXRPC_SOCK_CONNECTED, &rx->flags)) { in rxrpc_sendmsg()
559 m->msg_name = &rx->connect_srx; in rxrpc_sendmsg()
560 m->msg_namelen = sizeof(rx->connect_srx); in rxrpc_sendmsg()
565 ret = rxrpc_do_sendmsg(rx, m, len); in rxrpc_sendmsg()
574 release_sock(&rx->sk); in rxrpc_sendmsg()
599 struct rxrpc_sock *rx = rxrpc_sk(sock->sk); in rxrpc_setsockopt() local
606 lock_sock(&rx->sk); in rxrpc_setsockopt()
616 if (rx->sk.sk_state != RXRPC_UNBOUND) in rxrpc_setsockopt()
618 rx->exclusive = true; in rxrpc_setsockopt()
623 if (rx->key) in rxrpc_setsockopt()
626 if (rx->sk.sk_state != RXRPC_UNBOUND) in rxrpc_setsockopt()
628 ret = rxrpc_request_key(rx, optval, optlen); in rxrpc_setsockopt()
633 if (rx->key) in rxrpc_setsockopt()
636 if (rx->sk.sk_state != RXRPC_UNBOUND) in rxrpc_setsockopt()
638 ret = rxrpc_server_keyring(rx, optval, optlen); in rxrpc_setsockopt()
646 if (rx->sk.sk_state != RXRPC_UNBOUND) in rxrpc_setsockopt()
655 rx->min_sec_level = min_sec_level; in rxrpc_setsockopt()
661 rx->service_upgrade.from != 0) in rxrpc_setsockopt()
664 if (rx->sk.sk_state != RXRPC_SERVER_BOUND2) in rxrpc_setsockopt()
671 if ((service_upgrade[0] != rx->srx.srx_service || in rxrpc_setsockopt()
672 service_upgrade[1] != rx->second_service) && in rxrpc_setsockopt()
673 (service_upgrade[0] != rx->second_service || in rxrpc_setsockopt()
674 service_upgrade[1] != rx->srx.srx_service)) in rxrpc_setsockopt()
676 rx->service_upgrade.from = service_upgrade[0]; in rxrpc_setsockopt()
677 rx->service_upgrade.to = service_upgrade[1]; in rxrpc_setsockopt()
688 release_sock(&rx->sk); in rxrpc_setsockopt()
727 struct rxrpc_sock *rx = rxrpc_sk(sk); in rxrpc_poll() local
735 if (!list_empty(&rx->recvmsg_q)) in rxrpc_poll()
754 struct rxrpc_sock *rx; in rxrpc_create() local
781 rx = rxrpc_sk(sk); in rxrpc_create()
782 rx->family = protocol; in rxrpc_create()
783 rx->calls = RB_ROOT; in rxrpc_create()
785 spin_lock_init(&rx->incoming_lock); in rxrpc_create()
786 INIT_LIST_HEAD(&rx->sock_calls); in rxrpc_create()
787 INIT_LIST_HEAD(&rx->to_be_accepted); in rxrpc_create()
788 INIT_LIST_HEAD(&rx->recvmsg_q); in rxrpc_create()
789 spin_lock_init(&rx->recvmsg_lock); in rxrpc_create()
790 rwlock_init(&rx->call_lock); in rxrpc_create()
791 memset(&rx->srx, 0, sizeof(rx->srx)); in rxrpc_create()
793 rxnet = rxrpc_net(sock_net(&rx->sk)); in rxrpc_create()
796 _leave(" = 0 [%p]", rx); in rxrpc_create()
806 struct rxrpc_sock *rx = rxrpc_sk(sk); in rxrpc_shutdown() local
825 rxrpc_discard_prealloc(rx); in rxrpc_shutdown()
855 struct rxrpc_sock *rx = rxrpc_sk(sk); in rxrpc_release_sock() local
872 rx->local->service_closed = true; in rxrpc_release_sock()
878 if (rx->local && rx->local->service == rx) { in rxrpc_release_sock()
879 write_lock(&rx->local->services_lock); in rxrpc_release_sock()
880 rx->local->service = NULL; in rxrpc_release_sock()
881 write_unlock(&rx->local->services_lock); in rxrpc_release_sock()
885 rxrpc_discard_prealloc(rx); in rxrpc_release_sock()
886 rxrpc_release_calls_on_socket(rx); in rxrpc_release_sock()
890 rxrpc_unuse_local(rx->local, rxrpc_local_unuse_release_sock); in rxrpc_release_sock()
891 rxrpc_put_local(rx->local, rxrpc_local_put_release_sock); in rxrpc_release_sock()
892 rx->local = NULL; in rxrpc_release_sock()
893 key_put(rx->key); in rxrpc_release_sock()
894 rx->key = NULL; in rxrpc_release_sock()
895 key_put(rx->securities); in rxrpc_release_sock()
896 rx->securities = NULL; in rxrpc_release_sock()