Lines Matching defs:rx
102 struct rxrpc_sock *rx,
112 ASSERT(rx != NULL);
120 sock_hold(&rx->sk);
121 call->socket = rx;
124 ret = rxrpc_connect_call(rx, trans, bundle, call, gfp);
145 struct rxrpc_call *rxrpc_get_client_call(struct rxrpc_sock *rx,
156 rx, trans ? trans->debug_id : -1, bundle ? bundle->debug_id : -1,
161 read_lock(&rx->call_lock);
163 p = rx->calls.rb_node;
175 read_unlock(&rx->call_lock);
182 candidate = rxrpc_alloc_client_call(rx, trans, bundle, gfp);
191 write_lock(&rx->call_lock);
193 pp = &rx->calls.rb_node;
213 rb_insert_color(&call->sock_node, &rx->calls);
214 write_unlock(&rx->call_lock);
228 read_unlock(&rx->call_lock);
235 write_unlock(&rx->call_lock);
245 struct rxrpc_call *rxrpc_incoming_call(struct rxrpc_sock *rx,
256 ASSERT(rx != NULL);
262 candidate->socket = rx;
337 sock_hold(&rx->sk);
379 struct rxrpc_call *rxrpc_find_server_call(struct rxrpc_sock *rx,
385 _enter("%p,%lx", rx, user_call_ID);
389 read_lock(&rx->call_lock);
391 p = rx->calls.rb_node;
403 read_unlock(&rx->call_lock);
410 read_unlock(&rx->call_lock);
421 struct rxrpc_sock *rx = call->socket;
438 write_lock_bh(&rx->call_lock);
444 sk_acceptq_removed(&rx->sk);
446 rb_erase(&call->sock_node, &rx->calls);
450 write_unlock_bh(&rx->call_lock);
585 void rxrpc_release_calls_on_socket(struct rxrpc_sock *rx)
590 _enter("%p", rx);
592 read_lock_bh(&rx->call_lock);
595 for (p = rb_first(&rx->calls); p; p = rb_next(p)) {
601 list_for_each_entry(call, &rx->secureq, accept_link) {
605 list_for_each_entry(call, &rx->acceptq, accept_link) {
609 read_unlock_bh(&rx->call_lock);