Lines Matching refs:rx
79 static int rxrpc_validate_address(struct rxrpc_sock *rx,
97 if (srx->transport.family != rx->proto)
126 struct rxrpc_sock *rx = rxrpc_sk(sk), *prx;
130 _enter("%p,%p,%d", rx, saddr, len);
132 ret = rxrpc_validate_address(rx, srx, len);
136 lock_sock(&rx->sk);
138 if (rx->sk.sk_state != RXRPC_UNCONNECTED) {
143 memcpy(&rx->srx, srx, sizeof(rx->srx));
146 local = rxrpc_lookup_local(&rx->srx);
152 rx->local = local;
161 rx->service_id = service_id;
162 list_add_tail(&rx->listen_link, &local->services);
165 rx->sk.sk_state = RXRPC_SERVER_BOUND;
167 rx->sk.sk_state = RXRPC_CLIENT_BOUND;
170 release_sock(&rx->sk);
178 release_sock(&rx->sk);
190 struct rxrpc_sock *rx = rxrpc_sk(sk);
193 _enter("%p,%d", rx, backlog);
195 lock_sock(&rx->sk);
197 switch (rx->sk.sk_state) {
207 ASSERT(rx->local != NULL);
209 rx->sk.sk_state = RXRPC_SERVER_LISTENING;
214 release_sock(&rx->sk);
229 struct rxrpc_sock *rx = rxrpc_sk(sock->sk);
232 _enter("%p,%p,%d,%d", rx, addr, addr_len, flags);
234 ASSERT(rx->local != NULL);
235 ASSERT(rx->sk.sk_state > RXRPC_UNCONNECTED);
237 if (rx->srx.transport_type != srx->transport_type)
239 if (rx->srx.transport.family != srx->transport.family)
248 trans = rxrpc_get_transport(rx->local, peer, gfp);
277 struct rxrpc_sock *rx = rxrpc_sk(sock->sk);
282 lock_sock(&rx->sk);
293 trans = rx->trans;
301 service_id = rx->service_id;
306 key = rx->key;
310 bundle = rxrpc_get_bundle(rx, trans, key, service_id, gfp);
316 call = rxrpc_get_client_call(rx, trans, bundle, user_call_ID, true,
322 release_sock(&rx->sk);
359 struct rxrpc_sock *rx = rxrpc_sk(sock->sk);
362 rx->interceptor = interceptor;
379 struct rxrpc_sock *rx = rxrpc_sk(sk);
382 _enter("%p,%p,%d,%d", rx, addr, addr_len, flags);
384 ret = rxrpc_validate_address(rx, srx, addr_len);
390 lock_sock(&rx->sk);
392 switch (rx->sk.sk_state) {
395 ASSERTCMP(rx->local, ==, NULL);
396 rx->srx.srx_family = AF_RXRPC;
397 rx->srx.srx_service = 0;
398 rx->srx.transport_type = srx->transport_type;
399 rx->srx.transport_len = sizeof(sa_family_t);
400 rx->srx.transport.family = srx->transport.family;
401 local = rxrpc_lookup_local(&rx->srx);
403 release_sock(&rx->sk);
406 rx->local = local;
407 rx->sk.sk_state = RXRPC_CLIENT_BOUND;
411 release_sock(&rx->sk);
414 release_sock(&rx->sk);
421 release_sock(&rx->sk);
426 rx->trans = trans;
427 rx->service_id = htons(srx->srx_service);
428 rx->sk.sk_state = RXRPC_CLIENT_CONNECTED;
430 release_sock(&rx->sk);
447 struct rxrpc_sock *rx = rxrpc_sk(sock->sk);
450 _enter(",{%d},,%zu", rx->sk.sk_state, len);
456 ret = rxrpc_validate_address(rx, m->msg_name, m->msg_namelen);
464 lock_sock(&rx->sk);
476 trans = rx->trans;
481 switch (rx->sk.sk_state) {
484 ret = rxrpc_server_sendmsg(iocb, rx, m, len);
494 ret = rxrpc_client_sendmsg(iocb, rx, trans, m, len);
502 release_sock(&rx->sk);
515 struct rxrpc_sock *rx = rxrpc_sk(sock->sk);
521 lock_sock(&rx->sk);
531 if (rx->sk.sk_state != RXRPC_UNCONNECTED)
533 set_bit(RXRPC_SOCK_EXCLUSIVE_CONN, &rx->flags);
538 if (rx->key)
541 if (rx->sk.sk_state != RXRPC_UNCONNECTED)
543 ret = rxrpc_request_key(rx, optval, optlen);
548 if (rx->key)
551 if (rx->sk.sk_state != RXRPC_UNCONNECTED)
553 ret = rxrpc_server_keyring(rx, optval, optlen);
561 if (rx->sk.sk_state != RXRPC_UNCONNECTED)
570 rx->min_sec_level = min_sec_level;
581 release_sock(&rx->sk);
617 struct rxrpc_sock *rx;
645 rx = rxrpc_sk(sk);
646 rx->proto = protocol;
647 rx->calls = RB_ROOT;
649 INIT_LIST_HEAD(&rx->listen_link);
650 INIT_LIST_HEAD(&rx->secureq);
651 INIT_LIST_HEAD(&rx->acceptq);
652 rwlock_init(&rx->call_lock);
653 memset(&rx->srx, 0, sizeof(rx->srx));
655 _leave(" = 0 [%p]", rx);
683 struct rxrpc_sock *rx = rxrpc_sk(sk);
695 ASSERTCMP(rx->listen_link.next, !=, LIST_POISON1);
697 if (!list_empty(&rx->listen_link)) {
698 write_lock_bh(&rx->local->services_lock);
699 list_del(&rx->listen_link);
700 write_unlock_bh(&rx->local->services_lock);
704 rxrpc_release_calls_on_socket(rx);
708 if (rx->conn) {
709 rxrpc_put_connection(rx->conn);
710 rx->conn = NULL;
713 if (rx->bundle) {
714 rxrpc_put_bundle(rx->trans, rx->bundle);
715 rx->bundle = NULL;
717 if (rx->trans) {
718 rxrpc_put_transport(rx->trans);
719 rx->trans = NULL;
721 if (rx->local) {
722 rxrpc_put_local(rx->local);
723 rx->local = NULL;
726 key_put(rx->key);
727 rx->key = NULL;
728 key_put(rx->securities);
729 rx->securities = NULL;