Home
last modified time | relevance | path

Searched refs:cancel_state (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc/src/core/lib/iomgr/
Dcall_combiner.cc31 static grpc_error* decode_cancel_state_error(gpr_atm cancel_state) { in decode_cancel_state_error() argument
32 if (cancel_state & 1) { in decode_cancel_state_error()
33 return (grpc_error*)(cancel_state & ~static_cast<gpr_atm>(1)); in decode_cancel_state_error()
48 GRPC_ERROR_UNREF(decode_cancel_state_error(call_combiner->cancel_state)); in grpc_call_combiner_destroy()
148 gpr_atm original_state = gpr_atm_acq_load(&call_combiner->cancel_state); in grpc_call_combiner_set_notify_on_cancel()
162 if (gpr_atm_full_cas(&call_combiner->cancel_state, original_state, in grpc_call_combiner_set_notify_on_cancel()
191 gpr_atm original_state = gpr_atm_acq_load(&call_combiner->cancel_state); in grpc_call_combiner_cancel()
197 if (gpr_atm_full_cas(&call_combiner->cancel_state, original_state, in grpc_call_combiner_cancel()
Dcall_combiner.h49 gpr_atm cancel_state; member
/external/grpc-grpc/src/core/lib/surface/
Dcall.cc648 } cancel_state; typedef
653 cancel_state* state = static_cast<cancel_state*>(arg); in done_termination()
671 cancel_state* state = static_cast<cancel_state*>(gpr_malloc(sizeof(*state))); in cancel_with_error()