Lines Matching refs:call
293 struct rxrpc_call *call; in rxrpc_kernel_begin_call() local
323 call = rxrpc_new_client_call(rx, &cp, srx, &p, gfp, debug_id); in rxrpc_kernel_begin_call()
325 if (!IS_ERR(call)) { in rxrpc_kernel_begin_call()
326 call->notify_rx = notify_rx; in rxrpc_kernel_begin_call()
327 mutex_unlock(&call->user_mutex); in rxrpc_kernel_begin_call()
331 _leave(" = %p", call); in rxrpc_kernel_begin_call()
332 return call; in rxrpc_kernel_begin_call()
352 void rxrpc_kernel_end_call(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_end_call() argument
354 _enter("%d{%d}", call->debug_id, refcount_read(&call->ref)); in rxrpc_kernel_end_call()
356 mutex_lock(&call->user_mutex); in rxrpc_kernel_end_call()
357 rxrpc_release_call(rxrpc_sk(sock->sk), call); in rxrpc_kernel_end_call()
360 if (call->notify_rx) { in rxrpc_kernel_end_call()
361 spin_lock_bh(&call->notify_lock); in rxrpc_kernel_end_call()
362 call->notify_rx = rxrpc_dummy_notify_rx; in rxrpc_kernel_end_call()
363 spin_unlock_bh(&call->notify_lock); in rxrpc_kernel_end_call()
366 mutex_unlock(&call->user_mutex); in rxrpc_kernel_end_call()
367 rxrpc_put_call(call, rxrpc_call_put_kernel); in rxrpc_kernel_end_call()
380 const struct rxrpc_call *call) in rxrpc_kernel_check_life() argument
382 return call->state != RXRPC_CALL_COMPLETE; in rxrpc_kernel_check_life()
394 u32 rxrpc_kernel_get_epoch(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_get_epoch() argument
396 return call->conn->proto.epoch; in rxrpc_kernel_get_epoch()
429 void rxrpc_kernel_set_max_life(struct socket *sock, struct rxrpc_call *call, in rxrpc_kernel_set_max_life() argument
434 mutex_lock(&call->user_mutex); in rxrpc_kernel_set_max_life()
438 WRITE_ONCE(call->expect_term_by, hard_timeout); in rxrpc_kernel_set_max_life()
439 rxrpc_reduce_call_timer(call, hard_timeout, now, rxrpc_timer_set_for_hard); in rxrpc_kernel_set_max_life()
441 mutex_unlock(&call->user_mutex); in rxrpc_kernel_set_max_life()