95 struct rxrpc_call *rxrpc_find_call_by_user_ID(struct rxrpc_sock *rx,  in rxrpc_find_call_by_user_ID()  argument
101 	_enter("%p,%lx", rx, user_call_ID);  in rxrpc_find_call_by_user_ID()
103 	read_lock(&rx->call_lock);  in rxrpc_find_call_by_user_ID()
105 	p = rx->calls.rb_node;  in rxrpc_find_call_by_user_ID()
117 	read_unlock(&rx->call_lock);  in rxrpc_find_call_by_user_ID()
123 	read_unlock(&rx->call_lock);  in rxrpc_find_call_by_user_ID()
131 struct rxrpc_call *rxrpc_alloc_call(struct rxrpc_sock *rx, gfp_t gfp,  in rxrpc_alloc_call()  argument
135 	struct rxrpc_net *rxnet = rxrpc_net(sock_net(&rx->sk));  in rxrpc_alloc_call()
146 	if (rx->sk.sk_kern_sock)  in rxrpc_alloc_call()
190 static struct rxrpc_call *rxrpc_alloc_client_call(struct rxrpc_sock *rx,  in rxrpc_alloc_client_call()  argument
203 	call = rxrpc_alloc_call(rx, gfp, debug_id);  in rxrpc_alloc_client_call()
330 struct rxrpc_call *rxrpc_new_client_call(struct rxrpc_sock *rx,  in rxrpc_new_client_call()  argument
336 	__releases(&rx->sk.sk_lock.slock)  in rxrpc_new_client_call()
345 	_enter("%p,%lx", rx, p->user_call_ID);  in rxrpc_new_client_call()
349 		release_sock(&rx->sk);  in rxrpc_new_client_call()
353 	call = rxrpc_alloc_client_call(rx, srx, cp, p, gfp, debug_id);  in rxrpc_new_client_call()
355 		release_sock(&rx->sk);  in rxrpc_new_client_call()
367 	write_lock(&rx->call_lock);  in rxrpc_new_client_call()
369 	pp = &rx->calls.rb_node;  in rxrpc_new_client_call()
383 	rcu_assign_pointer(call->socket, rx);  in rxrpc_new_client_call()
388 	rb_insert_color(&call->sock_node, &rx->calls);  in rxrpc_new_client_call()
389 	list_add(&call->sock_link, &rx->sock_calls);  in rxrpc_new_client_call()
391 	write_unlock(&rx->call_lock);  in rxrpc_new_client_call()
399 	release_sock(&rx->sk);  in rxrpc_new_client_call()
417 	write_unlock(&rx->call_lock);  in rxrpc_new_client_call()
418 	release_sock(&rx->sk);  in rxrpc_new_client_call()
444 void rxrpc_incoming_call(struct rxrpc_sock *rx,  in rxrpc_incoming_call()  argument
454 	rcu_assign_pointer(call->socket, rx);  in rxrpc_incoming_call()
550 void rxrpc_release_call(struct rxrpc_sock *rx, struct rxrpc_call *call)  in rxrpc_release_call()  argument
566 	spin_lock(&rx->recvmsg_lock);  in rxrpc_release_call()
579 	spin_unlock(&rx->recvmsg_lock);  in rxrpc_release_call()
583 	write_lock(&rx->call_lock);  in rxrpc_release_call()
586 		rb_erase(&call->sock_node, &rx->calls);  in rxrpc_release_call()
592 	write_unlock(&rx->call_lock);  in rxrpc_release_call()
605 void rxrpc_release_calls_on_socket(struct rxrpc_sock *rx)  in rxrpc_release_calls_on_socket()  argument
609 	_enter("%p", rx);  in rxrpc_release_calls_on_socket()
611 	while (!list_empty(&rx->to_be_accepted)) {  in rxrpc_release_calls_on_socket()
612 		call = list_entry(rx->to_be_accepted.next,  in rxrpc_release_calls_on_socket()
620 	while (!list_empty(&rx->sock_calls)) {  in rxrpc_release_calls_on_socket()
621 		call = list_entry(rx->sock_calls.next,  in rxrpc_release_calls_on_socket()
626 		rxrpc_release_call(rx, call);  in rxrpc_release_calls_on_socket()