Lines Matching refs:call
422 struct rxrpc_call __rcu *call; /* Active call */ member
727 struct rxrpc_call_params call; member
762 static inline void rxrpc_reduce_call_timer(struct rxrpc_call *call, in rxrpc_reduce_call_timer() argument
767 trace_rxrpc_timer(call, why, now); in rxrpc_reduce_call_timer()
768 timer_reduce(&call->timer, expire_at); in rxrpc_reduce_call_timer()
798 static inline bool rxrpc_is_service_call(const struct rxrpc_call *call) in rxrpc_is_service_call() argument
800 return test_bit(RXRPC_CALL_IS_SERVICE, &call->flags); in rxrpc_is_service_call()
803 static inline bool rxrpc_is_client_call(const struct rxrpc_call *call) in rxrpc_is_client_call() argument
805 return !rxrpc_is_service_call(call); in rxrpc_is_client_call()
811 static inline bool __rxrpc_set_call_completion(struct rxrpc_call *call, in __rxrpc_set_call_completion() argument
816 if (call->state < RXRPC_CALL_COMPLETE) { in __rxrpc_set_call_completion()
817 call->abort_code = abort_code; in __rxrpc_set_call_completion()
818 call->error = error; in __rxrpc_set_call_completion()
819 call->completion = compl, in __rxrpc_set_call_completion()
820 call->state = RXRPC_CALL_COMPLETE; in __rxrpc_set_call_completion()
821 trace_rxrpc_call_complete(call); in __rxrpc_set_call_completion()
822 wake_up(&call->waitq); in __rxrpc_set_call_completion()
828 static inline bool rxrpc_set_call_completion(struct rxrpc_call *call, in rxrpc_set_call_completion() argument
835 write_lock_bh(&call->state_lock); in rxrpc_set_call_completion()
836 ret = __rxrpc_set_call_completion(call, compl, abort_code, error); in rxrpc_set_call_completion()
837 write_unlock_bh(&call->state_lock); in rxrpc_set_call_completion()
844 static inline bool __rxrpc_call_completed(struct rxrpc_call *call) in __rxrpc_call_completed() argument
846 return __rxrpc_set_call_completion(call, RXRPC_CALL_SUCCEEDED, 0, 0); in __rxrpc_call_completed()
849 static inline bool rxrpc_call_completed(struct rxrpc_call *call) in rxrpc_call_completed() argument
853 write_lock_bh(&call->state_lock); in rxrpc_call_completed()
854 ret = __rxrpc_call_completed(call); in rxrpc_call_completed()
855 write_unlock_bh(&call->state_lock); in rxrpc_call_completed()
862 static inline bool __rxrpc_abort_call(const char *why, struct rxrpc_call *call, in __rxrpc_abort_call() argument
866 trace_rxrpc_abort(call->debug_id, why, call->cid, call->call_id, seq, in __rxrpc_abort_call()
868 return __rxrpc_set_call_completion(call, RXRPC_CALL_LOCALLY_ABORTED, in __rxrpc_abort_call()
872 static inline bool rxrpc_abort_call(const char *why, struct rxrpc_call *call, in rxrpc_abort_call() argument
877 write_lock_bh(&call->state_lock); in rxrpc_abort_call()
878 ret = __rxrpc_abort_call(why, call, seq, abort_code, error); in rxrpc_abort_call()
879 write_unlock_bh(&call->state_lock); in rxrpc_abort_call()
886 static inline bool __rxrpc_abort_eproto(struct rxrpc_call *call, in __rxrpc_abort_eproto() argument
894 trace_rxrpc_rx_eproto(call, sp->hdr.serial, eproto_why); in __rxrpc_abort_eproto()
895 return rxrpc_abort_call(why, call, sp->hdr.seq, abort_code, -EPROTO); in __rxrpc_abort_eproto()
898 #define rxrpc_abort_eproto(call, skb, eproto_why, abort_why, abort_code) \ argument
899 __rxrpc_abort_eproto((call), (skb), tracepoint_string(eproto_why), \