Lines Matching defs:rx
73 struct rxrpc_sock *rx,
117 call = rxrpc_incoming_call(rx, conn, &sp->hdr, GFP_NOIO);
127 if (rx->sk.sk_state == RXRPC_CLOSE)
130 write_lock(&rx->call_lock);
138 list_add_tail(&call->accept_link, &rx->secureq);
146 list_add_tail(&call->accept_link, &rx->acceptq);
166 write_unlock(&rx->call_lock);
207 struct rxrpc_sock *rx;
255 list_for_each_entry(rx, &local->services, listen_link) {
256 if (rx->service_id == service_id &&
257 rx->sk.sk_state != RXRPC_CLOSE)
264 _debug("found service %hd", ntohs(rx->service_id));
265 if (sk_acceptq_is_full(&rx->sk))
267 sk_acceptq_added(&rx->sk);
268 sock_hold(&rx->sk);
271 ret = rxrpc_accept_incoming_call(local, rx, skb, &srx);
273 sk_acceptq_removed(&rx->sk);
274 sock_put(&rx->sk);
313 struct rxrpc_call *rxrpc_accept_call(struct rxrpc_sock *rx,
324 write_lock(&rx->call_lock);
327 if (list_empty(&rx->acceptq))
332 pp = &rx->calls.rb_node;
347 call = list_entry(rx->acceptq.next, struct rxrpc_call, accept_link);
349 sk_acceptq_removed(&rx->sk);
373 rb_insert_color(&call->sock_node, &rx->calls);
382 write_unlock(&rx->call_lock);
398 write_unlock(&rx->call_lock);
407 int rxrpc_reject_call(struct rxrpc_sock *rx)
416 write_lock(&rx->call_lock);
419 if (list_empty(&rx->acceptq))
423 call = list_entry(rx->acceptq.next, struct rxrpc_call, accept_link);
425 sk_acceptq_removed(&rx->sk);
461 write_unlock(&rx->call_lock);