Searched refs:recv_state (Results 1 – 3 of 3) sorted by relevance
| /external/tensorflow/tensorflow/core/framework/ |
| D | local_rendezvous.cc | 45 recv_state.waiter.Init(std::move(waiter)); in Item()
46 recv_state.cancellation_token = cancellation_token; in Item()
56 recv_state.waiter.Destroy(); in ~Item()
76 } recv_state; member
162 (*item->recv_state.waiter)(Status::OK(), send_args, item->args, val, is_dead); in Send()
215 if (curr->recv_state.cancellation_token == token) { in RecvAsync()
241 (*item->recv_state.waiter)( in RecvAsync()
326 (*item->recv_state.waiter)(status, Rendezvous::Args(), in StartAbort()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | call.cc | 228 gpr_atm recv_state; member
1308 !gpr_atm_rel_cas(&call->recv_state, RECV_NONE, (gpr_atm)bctlp)) { in receiving_stream_ready()
1416 gpr_atm rsr_bctlp = gpr_atm_acq_load(&call->recv_state); in receiving_initial_metadata_ready()
1425 if (gpr_atm_no_barrier_cas(&call->recv_state, RECV_NONE, in receiving_initial_metadata_ready()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | call.cc | 269 gpr_atm recv_state = 0; member
1364 !gpr_atm_rel_cas(&call->recv_state, RECV_NONE, in receiving_stream_ready()
1496 gpr_atm rsr_bctlp = gpr_atm_acq_load(&call->recv_state); in receiving_initial_metadata_ready()
1505 if (gpr_atm_no_barrier_cas(&call->recv_state, RECV_NONE, in receiving_initial_metadata_ready()
|