Lines Matching defs:rx
74 static int rxrpc_validate_address(struct rxrpc_sock *rx,
92 if (srx->transport.family != rx->proto)
121 struct rxrpc_sock *rx = rxrpc_sk(sk), *prx;
125 _enter("%p,%p,%d", rx, saddr, len);
127 ret = rxrpc_validate_address(rx, srx, len);
131 lock_sock(&rx->sk);
133 if (rx->sk.sk_state != RXRPC_UNCONNECTED) {
138 memcpy(&rx->srx, srx, sizeof(rx->srx));
141 local = rxrpc_lookup_local(&rx->srx);
147 rx->local = local;
156 rx->service_id = service_id;
157 list_add_tail(&rx->listen_link, &local->services);
160 rx->sk.sk_state = RXRPC_SERVER_BOUND;
162 rx->sk.sk_state = RXRPC_CLIENT_BOUND;
165 release_sock(&rx->sk);
173 release_sock(&rx->sk);
185 struct rxrpc_sock *rx = rxrpc_sk(sk);
188 _enter("%p,%d", rx, backlog);
190 lock_sock(&rx->sk);
192 switch (rx->sk.sk_state) {
202 ASSERT(rx->local != NULL);
204 rx->sk.sk_state = RXRPC_SERVER_LISTENING;
209 release_sock(&rx->sk);
224 struct rxrpc_sock *rx = rxrpc_sk(sock->sk);
227 _enter("%p,%p,%d,%d", rx, addr, addr_len, flags);
229 ASSERT(rx->local != NULL);
230 ASSERT(rx->sk.sk_state > RXRPC_UNCONNECTED);
232 if (rx->srx.transport_type != srx->transport_type)
234 if (rx->srx.transport.family != srx->transport.family)
243 trans = rxrpc_get_transport(rx->local, peer, gfp);
272 struct rxrpc_sock *rx = rxrpc_sk(sock->sk);
277 lock_sock(&rx->sk);
288 trans = rx->trans;
296 service_id = rx->service_id;
301 key = rx->key;
305 bundle = rxrpc_get_bundle(rx, trans, key, service_id, gfp);
311 call = rxrpc_get_client_call(rx, trans, bundle, user_call_ID, true,
316 release_sock(&rx->sk);
353 struct rxrpc_sock *rx = rxrpc_sk(sock->sk);
356 rx->interceptor = interceptor;
373 struct rxrpc_sock *rx = rxrpc_sk(sk);
376 _enter("%p,%p,%d,%d", rx, addr, addr_len, flags);
378 ret = rxrpc_validate_address(rx, srx, addr_len);
384 lock_sock(&rx->sk);
386 switch (rx->sk.sk_state) {
389 ASSERTCMP(rx->local, ==, NULL);
390 rx->srx.srx_family = AF_RXRPC;
391 rx->srx.srx_service = 0;
392 rx->srx.transport_type = srx->transport_type;
393 rx->srx.transport_len = sizeof(sa_family_t);
394 rx->srx.transport.family = srx->transport.family;
395 local = rxrpc_lookup_local(&rx->srx);
397 release_sock(&rx->sk);
400 rx->local = local;
401 rx->sk.sk_state = RXRPC_CLIENT_BOUND;
405 release_sock(&rx->sk);
408 release_sock(&rx->sk);
415 release_sock(&rx->sk);
420 rx->trans = trans;
421 rx->service_id = htons(srx->srx_service);
422 rx->sk.sk_state = RXRPC_CLIENT_CONNECTED;
424 release_sock(&rx->sk);
441 struct rxrpc_sock *rx = rxrpc_sk(sock->sk);
444 _enter(",{%d},,%zu", rx->sk.sk_state, len);
450 ret = rxrpc_validate_address(rx, m->msg_name, m->msg_namelen);
458 lock_sock(&rx->sk);
470 trans = rx->trans;
475 switch (rx->sk.sk_state) {
478 ret = rxrpc_server_sendmsg(iocb, rx, m, len);
488 ret = rxrpc_client_sendmsg(iocb, rx, trans, m, len);
496 release_sock(&rx->sk);
509 struct rxrpc_sock *rx = rxrpc_sk(sock->sk);
515 lock_sock(&rx->sk);
525 if (rx->sk.sk_state != RXRPC_UNCONNECTED)
527 set_bit(RXRPC_SOCK_EXCLUSIVE_CONN, &rx->flags);
532 if (rx->key)
535 if (rx->sk.sk_state != RXRPC_UNCONNECTED)
537 ret = rxrpc_request_key(rx, optval, optlen);
542 if (rx->key)
545 if (rx->sk.sk_state != RXRPC_UNCONNECTED)
547 ret = rxrpc_server_keyring(rx, optval, optlen);
555 if (rx->sk.sk_state != RXRPC_UNCONNECTED)
564 rx->min_sec_level = min_sec_level;
575 release_sock(&rx->sk);
610 struct rxrpc_sock *rx;
635 rx = rxrpc_sk(sk);
636 rx->proto = protocol;
637 rx->calls = RB_ROOT;
639 INIT_LIST_HEAD(&rx->listen_link);
640 INIT_LIST_HEAD(&rx->secureq);
641 INIT_LIST_HEAD(&rx->acceptq);
642 rwlock_init(&rx->call_lock);
643 memset(&rx->srx, 0, sizeof(rx->srx));
645 _leave(" = 0 [%p]", rx);
673 struct rxrpc_sock *rx = rxrpc_sk(sk);
685 ASSERTCMP(rx->listen_link.next, !=, LIST_POISON1);
687 if (!list_empty(&rx->listen_link)) {
688 write_lock_bh(&rx->local->services_lock);
689 list_del(&rx->listen_link);
690 write_unlock_bh(&rx->local->services_lock);
694 rxrpc_release_calls_on_socket(rx);
698 if (rx->conn) {
699 rxrpc_put_connection(rx->conn);
700 rx->conn = NULL;
703 if (rx->bundle) {
704 rxrpc_put_bundle(rx->trans, rx->bundle);
705 rx->bundle = NULL;
707 if (rx->trans) {
708 rxrpc_put_transport(rx->trans);
709 rx->trans = NULL;
711 if (rx->local) {
712 rxrpc_put_local(rx->local);
713 rx->local = NULL;
716 key_put(rx->key);
717 rx->key = NULL;
718 key_put(rx->securities);
719 rx->securities = NULL;