Lines Matching refs:call
292 struct rxrpc_call *call; in rxrpc_kernel_begin_call() local
321 call = rxrpc_new_client_call(rx, &cp, srx, &p, gfp, debug_id); in rxrpc_kernel_begin_call()
323 if (!IS_ERR(call)) { in rxrpc_kernel_begin_call()
324 call->notify_rx = notify_rx; in rxrpc_kernel_begin_call()
325 mutex_unlock(&call->user_mutex); in rxrpc_kernel_begin_call()
329 _leave(" = %p", call); in rxrpc_kernel_begin_call()
330 return call; in rxrpc_kernel_begin_call()
350 void rxrpc_kernel_end_call(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_end_call() argument
352 _enter("%d{%d}", call->debug_id, atomic_read(&call->usage)); in rxrpc_kernel_end_call()
354 mutex_lock(&call->user_mutex); in rxrpc_kernel_end_call()
355 rxrpc_release_call(rxrpc_sk(sock->sk), call); in rxrpc_kernel_end_call()
358 if (call->notify_rx) { in rxrpc_kernel_end_call()
359 spin_lock_bh(&call->notify_lock); in rxrpc_kernel_end_call()
360 call->notify_rx = rxrpc_dummy_notify_rx; in rxrpc_kernel_end_call()
361 spin_unlock_bh(&call->notify_lock); in rxrpc_kernel_end_call()
364 mutex_unlock(&call->user_mutex); in rxrpc_kernel_end_call()
365 rxrpc_put_call(call, rxrpc_call_put_kernel); in rxrpc_kernel_end_call()
384 const struct rxrpc_call *call, in rxrpc_kernel_check_life() argument
387 *_life = call->acks_latest; in rxrpc_kernel_check_life()
388 return call->state != RXRPC_CALL_COMPLETE; in rxrpc_kernel_check_life()
403 void rxrpc_kernel_probe_life(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_probe_life() argument
405 rxrpc_propose_ACK(call, RXRPC_ACK_PING, 0, true, false, in rxrpc_kernel_probe_life()
407 rxrpc_send_ack_packet(call, true, NULL); in rxrpc_kernel_probe_life()
419 u32 rxrpc_kernel_get_epoch(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_get_epoch() argument
421 return call->conn->proto.epoch; in rxrpc_kernel_get_epoch()
454 void rxrpc_kernel_set_max_life(struct socket *sock, struct rxrpc_call *call, in rxrpc_kernel_set_max_life() argument
459 mutex_lock(&call->user_mutex); in rxrpc_kernel_set_max_life()
463 WRITE_ONCE(call->expect_term_by, hard_timeout); in rxrpc_kernel_set_max_life()
464 rxrpc_reduce_call_timer(call, hard_timeout, now, rxrpc_timer_set_for_hard); in rxrpc_kernel_set_max_life()
466 mutex_unlock(&call->user_mutex); in rxrpc_kernel_set_max_life()