74 				      struct rxrpc_sock *rx,  in rxrpc_accept_incoming_call()  argument
123 	call = rxrpc_incoming_call(rx, conn, &sp->hdr, GFP_NOIO);  in rxrpc_accept_incoming_call()
133 	if (rx->sk.sk_state == RXRPC_CLOSE)  in rxrpc_accept_incoming_call()
136 	write_lock(&rx->call_lock);  in rxrpc_accept_incoming_call()
144 			list_add_tail(&call->accept_link, &rx->secureq);  in rxrpc_accept_incoming_call()
152 			list_add_tail(&call->accept_link, &rx->acceptq);  in rxrpc_accept_incoming_call()
171 	write_unlock(&rx->call_lock);  in rxrpc_accept_incoming_call()
213 	struct rxrpc_sock *rx;  in rxrpc_accept_incoming_calls()  local
261 	list_for_each_entry(rx, &local->services, listen_link) {  in rxrpc_accept_incoming_calls()
262 		if (rx->service_id == service_id &&  in rxrpc_accept_incoming_calls()
263 		    rx->sk.sk_state != RXRPC_CLOSE)  in rxrpc_accept_incoming_calls()
270 	_debug("found service %hd", ntohs(rx->service_id));  in rxrpc_accept_incoming_calls()
271 	if (sk_acceptq_is_full(&rx->sk))  in rxrpc_accept_incoming_calls()
273 	sk_acceptq_added(&rx->sk);  in rxrpc_accept_incoming_calls()
274 	sock_hold(&rx->sk);  in rxrpc_accept_incoming_calls()
277 	ret = rxrpc_accept_incoming_call(local, rx, skb, &srx);  in rxrpc_accept_incoming_calls()
279 		sk_acceptq_removed(&rx->sk);  in rxrpc_accept_incoming_calls()
280 	sock_put(&rx->sk);  in rxrpc_accept_incoming_calls()
319 struct rxrpc_call *rxrpc_accept_call(struct rxrpc_sock *rx,  in rxrpc_accept_call()  argument
330 	write_lock(&rx->call_lock);  in rxrpc_accept_call()
333 	if (list_empty(&rx->acceptq))  in rxrpc_accept_call()
338 	pp = &rx->calls.rb_node;  in rxrpc_accept_call()
353 	call = list_entry(rx->acceptq.next, struct rxrpc_call, accept_link);  in rxrpc_accept_call()
355 	sk_acceptq_removed(&rx->sk);  in rxrpc_accept_call()
379 	rb_insert_color(&call->sock_node, &rx->calls);  in rxrpc_accept_call()
388 	write_unlock(&rx->call_lock);  in rxrpc_accept_call()
404 	write_unlock(&rx->call_lock);  in rxrpc_accept_call()
413 int rxrpc_reject_call(struct rxrpc_sock *rx)  in rxrpc_reject_call()  argument
422 	write_lock(&rx->call_lock);  in rxrpc_reject_call()
425 	if (list_empty(&rx->acceptq))  in rxrpc_reject_call()
429 	call = list_entry(rx->acceptq.next, struct rxrpc_call, accept_link);  in rxrpc_reject_call()
431 	sk_acceptq_removed(&rx->sk);  in rxrpc_reject_call()
467 	write_unlock(&rx->call_lock);  in rxrpc_reject_call()