Lines Matching refs:rx
252 struct rxrpc_sock *rx, in rxrpc_alloc_client_call() argument
262 ASSERT(rx != NULL); in rxrpc_alloc_client_call()
270 sock_hold(&rx->sk); in rxrpc_alloc_client_call()
271 call->socket = rx; in rxrpc_alloc_client_call()
274 ret = rxrpc_connect_call(rx, trans, bundle, call, gfp); in rxrpc_alloc_client_call()
281 call->proto = rx->proto; in rxrpc_alloc_client_call()
315 struct rxrpc_call *rxrpc_get_client_call(struct rxrpc_sock *rx, in rxrpc_get_client_call() argument
326 rx, trans ? trans->debug_id : -1, bundle ? bundle->debug_id : -1, in rxrpc_get_client_call()
331 read_lock(&rx->call_lock); in rxrpc_get_client_call()
333 p = rx->calls.rb_node; in rxrpc_get_client_call()
345 read_unlock(&rx->call_lock); in rxrpc_get_client_call()
352 candidate = rxrpc_alloc_client_call(rx, trans, bundle, gfp); in rxrpc_get_client_call()
361 write_lock(&rx->call_lock); in rxrpc_get_client_call()
363 pp = &rx->calls.rb_node; in rxrpc_get_client_call()
383 rb_insert_color(&call->sock_node, &rx->calls); in rxrpc_get_client_call()
384 write_unlock(&rx->call_lock); in rxrpc_get_client_call()
398 read_unlock(&rx->call_lock); in rxrpc_get_client_call()
405 write_unlock(&rx->call_lock); in rxrpc_get_client_call()
415 struct rxrpc_call *rxrpc_incoming_call(struct rxrpc_sock *rx, in rxrpc_incoming_call() argument
426 ASSERT(rx != NULL); in rxrpc_incoming_call()
432 candidate->socket = rx; in rxrpc_incoming_call()
510 sock_hold(&rx->sk); in rxrpc_incoming_call()
523 call->proto = rx->proto; in rxrpc_incoming_call()
574 struct rxrpc_call *rxrpc_find_server_call(struct rxrpc_sock *rx, in rxrpc_find_server_call() argument
580 _enter("%p,%lx", rx, user_call_ID); in rxrpc_find_server_call()
584 read_lock(&rx->call_lock); in rxrpc_find_server_call()
586 p = rx->calls.rb_node; in rxrpc_find_server_call()
598 read_unlock(&rx->call_lock); in rxrpc_find_server_call()
605 read_unlock(&rx->call_lock); in rxrpc_find_server_call()
616 struct rxrpc_sock *rx = call->socket; in rxrpc_release_call() local
633 write_lock_bh(&rx->call_lock); in rxrpc_release_call()
639 sk_acceptq_removed(&rx->sk); in rxrpc_release_call()
641 rb_erase(&call->sock_node, &rx->calls); in rxrpc_release_call()
645 write_unlock_bh(&rx->call_lock); in rxrpc_release_call()
780 void rxrpc_release_calls_on_socket(struct rxrpc_sock *rx) in rxrpc_release_calls_on_socket() argument
785 _enter("%p", rx); in rxrpc_release_calls_on_socket()
787 read_lock_bh(&rx->call_lock); in rxrpc_release_calls_on_socket()
790 for (p = rb_first(&rx->calls); p; p = rb_next(p)) { in rxrpc_release_calls_on_socket()
796 list_for_each_entry(call, &rx->secureq, accept_link) { in rxrpc_release_calls_on_socket()
800 list_for_each_entry(call, &rx->acceptq, accept_link) { in rxrpc_release_calls_on_socket()
804 read_unlock_bh(&rx->call_lock); in rxrpc_release_calls_on_socket()