Lines Matching refs:call
37 struct rxrpc_call *call; in rxrpc_service_prealloc_one() local
94 call = rxrpc_alloc_call(rx, gfp, debug_id); in rxrpc_service_prealloc_one()
95 if (!call) in rxrpc_service_prealloc_one()
97 call->flags |= (1 << RXRPC_CALL_IS_SERVICE); in rxrpc_service_prealloc_one()
98 call->state = RXRPC_CALL_SERVER_PREALLOC; in rxrpc_service_prealloc_one()
100 trace_rxrpc_call(call->debug_id, rxrpc_call_new_service, in rxrpc_service_prealloc_one()
101 atomic_read(&call->usage), in rxrpc_service_prealloc_one()
123 call->user_call_ID = user_call_ID; in rxrpc_service_prealloc_one()
124 call->notify_rx = notify_rx; in rxrpc_service_prealloc_one()
125 rxrpc_get_call(call, rxrpc_call_got_kernel); in rxrpc_service_prealloc_one()
126 user_attach_call(call, user_call_ID); in rxrpc_service_prealloc_one()
127 rxrpc_get_call(call, rxrpc_call_got_userid); in rxrpc_service_prealloc_one()
128 rb_link_node(&call->sock_node, parent, pp); in rxrpc_service_prealloc_one()
129 rb_insert_color(&call->sock_node, &rx->calls); in rxrpc_service_prealloc_one()
130 set_bit(RXRPC_CALL_HAS_USERID, &call->flags); in rxrpc_service_prealloc_one()
133 list_add(&call->sock_link, &rx->sock_calls); in rxrpc_service_prealloc_one()
137 rxnet = call->rxnet; in rxrpc_service_prealloc_one()
139 list_add_tail(&call->link, &rxnet->calls); in rxrpc_service_prealloc_one()
142 b->call_backlog[call_head] = call; in rxrpc_service_prealloc_one()
144 _leave(" = 0 [%d -> %lx]", call->debug_id, user_call_ID); in rxrpc_service_prealloc_one()
149 rxrpc_cleanup_call(call); in rxrpc_service_prealloc_one()
226 struct rxrpc_call *call = b->call_backlog[tail]; in rxrpc_discard_prealloc() local
227 rcu_assign_pointer(call->socket, rx); in rxrpc_discard_prealloc()
229 _debug("discard %lx", call->user_call_ID); in rxrpc_discard_prealloc()
230 rx->discard_new_call(call, call->user_call_ID); in rxrpc_discard_prealloc()
231 rxrpc_put_call(call, rxrpc_call_put_kernel); in rxrpc_discard_prealloc()
233 rxrpc_call_completed(call); in rxrpc_discard_prealloc()
234 rxrpc_release_call(rx, call); in rxrpc_discard_prealloc()
235 rxrpc_put_call(call, rxrpc_call_put); in rxrpc_discard_prealloc()
246 static void rxrpc_send_ping(struct rxrpc_call *call, struct sk_buff *skb) in rxrpc_send_ping() argument
251 if (call->peer->rtt_usage < 3 || in rxrpc_send_ping()
252 ktime_before(ktime_add_ms(call->peer->rtt_last_req, 1000), now)) in rxrpc_send_ping()
253 rxrpc_propose_ACK(call, RXRPC_ACK_PING, sp->hdr.serial, in rxrpc_send_ping()
271 struct rxrpc_call *call; in rxrpc_alloc_incoming_call() local
321 call = b->call_backlog[call_tail]; in rxrpc_alloc_incoming_call()
326 rxrpc_see_call(call); in rxrpc_alloc_incoming_call()
327 call->conn = conn; in rxrpc_alloc_incoming_call()
328 call->security = conn->security; in rxrpc_alloc_incoming_call()
329 call->peer = rxrpc_get_peer(conn->params.peer); in rxrpc_alloc_incoming_call()
330 call->cong_cwnd = call->peer->cong_cwnd; in rxrpc_alloc_incoming_call()
331 return call; in rxrpc_alloc_incoming_call()
357 struct rxrpc_call *call = NULL; in rxrpc_new_incoming_call() local
382 call = rxrpc_alloc_incoming_call(rx, local, peer, conn, sec, key, skb); in rxrpc_new_incoming_call()
384 if (!call) { in rxrpc_new_incoming_call()
389 trace_rxrpc_receive(call, rxrpc_receive_incoming, in rxrpc_new_incoming_call()
393 rxrpc_incoming_call(rx, call, skb); in rxrpc_new_incoming_call()
394 conn = call->conn; in rxrpc_new_incoming_call()
397 rx->notify_new_call(&rx->sk, call, call->user_call_ID); in rxrpc_new_incoming_call()
405 set_bit(RXRPC_CONN_EV_CHALLENGE, &call->conn->events); in rxrpc_new_incoming_call()
406 rxrpc_queue_conn(call->conn); in rxrpc_new_incoming_call()
410 write_lock(&call->state_lock); in rxrpc_new_incoming_call()
411 if (call->state < RXRPC_CALL_COMPLETE) { in rxrpc_new_incoming_call()
413 call->state = RXRPC_CALL_SERVER_RECV_REQUEST; in rxrpc_new_incoming_call()
415 call->state = RXRPC_CALL_SERVER_ACCEPTING; in rxrpc_new_incoming_call()
417 write_unlock(&call->state_lock); in rxrpc_new_incoming_call()
421 rxrpc_set_call_completion(call, RXRPC_CALL_REMOTELY_ABORTED, in rxrpc_new_incoming_call()
425 rxrpc_abort_call("CON", call, sp->hdr.seq, in rxrpc_new_incoming_call()
434 rxrpc_send_ping(call, skb); in rxrpc_new_incoming_call()
436 if (call->state == RXRPC_CALL_SERVER_ACCEPTING) in rxrpc_new_incoming_call()
437 rxrpc_notify_socket(call); in rxrpc_new_incoming_call()
444 rxrpc_put_call(call, rxrpc_call_put); in rxrpc_new_incoming_call()
446 _leave(" = %p{%d}", call, call->debug_id); in rxrpc_new_incoming_call()
447 return call; in rxrpc_new_incoming_call()
464 __acquires(call->user_mutex) in rxrpc_accept_call()
466 struct rxrpc_call *call; in rxrpc_accept_call() local
488 call = rb_entry(parent, struct rxrpc_call, sock_node); in rxrpc_accept_call()
490 if (user_call_ID < call->user_call_ID) in rxrpc_accept_call()
492 else if (user_call_ID > call->user_call_ID) in rxrpc_accept_call()
501 call = list_entry(rx->to_be_accepted.next, in rxrpc_accept_call()
510 if (mutex_lock_interruptible(&call->user_mutex) < 0) { in rxrpc_accept_call()
517 list_del_init(&call->accept_link); in rxrpc_accept_call()
519 rxrpc_see_call(call); in rxrpc_accept_call()
526 call = rb_entry(parent, struct rxrpc_call, sock_node); in rxrpc_accept_call()
528 if (user_call_ID < call->user_call_ID) in rxrpc_accept_call()
530 else if (user_call_ID > call->user_call_ID) in rxrpc_accept_call()
536 write_lock_bh(&call->state_lock); in rxrpc_accept_call()
537 switch (call->state) { in rxrpc_accept_call()
539 call->state = RXRPC_CALL_SERVER_RECV_REQUEST; in rxrpc_accept_call()
542 ret = call->error; in rxrpc_accept_call()
549 call->notify_rx = notify_rx; in rxrpc_accept_call()
550 call->user_call_ID = user_call_ID; in rxrpc_accept_call()
551 rxrpc_get_call(call, rxrpc_call_got_userid); in rxrpc_accept_call()
552 rb_link_node(&call->sock_node, parent, pp); in rxrpc_accept_call()
553 rb_insert_color(&call->sock_node, &rx->calls); in rxrpc_accept_call()
554 if (test_and_set_bit(RXRPC_CALL_HAS_USERID, &call->flags)) in rxrpc_accept_call()
557 write_unlock_bh(&call->state_lock); in rxrpc_accept_call()
559 rxrpc_notify_socket(call); in rxrpc_accept_call()
562 _leave(" = %p{%d}", call, call->debug_id); in rxrpc_accept_call()
563 return call; in rxrpc_accept_call()
566 _debug("release %p", call); in rxrpc_accept_call()
567 write_unlock_bh(&call->state_lock); in rxrpc_accept_call()
569 rxrpc_release_call(rx, call); in rxrpc_accept_call()
570 rxrpc_put_call(call, rxrpc_call_put); in rxrpc_accept_call()
589 struct rxrpc_call *call; in rxrpc_reject_call() local
607 call = list_entry(rx->to_be_accepted.next, in rxrpc_reject_call()
609 list_del_init(&call->accept_link); in rxrpc_reject_call()
611 rxrpc_see_call(call); in rxrpc_reject_call()
613 write_lock_bh(&call->state_lock); in rxrpc_reject_call()
614 switch (call->state) { in rxrpc_reject_call()
616 __rxrpc_abort_call("REJ", call, 1, RX_USER_ABORT, -ECONNABORTED); in rxrpc_reject_call()
620 ret = call->error; in rxrpc_reject_call()
627 write_unlock_bh(&call->state_lock); in rxrpc_reject_call()
630 rxrpc_send_abort_packet(call); in rxrpc_reject_call()
631 rxrpc_release_call(rx, call); in rxrpc_reject_call()
632 rxrpc_put_call(call, rxrpc_call_put); in rxrpc_reject_call()