Home
last modified time | relevance | path

Searched refs:call_status_ (Results 1 – 6 of 6) sorted by relevance

/external/grpc-grpc/src/cpp/server/load_reporter/
Dload_reporter_async_service_impl.cc145 call_status_(WAITING_FOR_DELIVERY) {} in ReportLoadHandler()
150 call_status_ = DELIVERED; in OnRequestDelivered()
190 if (!ok && call_status_ < INITIAL_REQUEST_RECEIVED) { in OnReadDone()
202 if (call_status_ < INITIAL_REQUEST_RECEIVED) { in OnReadDone()
206 call_status_ = INITIAL_REQUEST_RECEIVED; in OnReadDone()
288 if (call_status_ < INITIAL_RESPONSE_SENT) { in SendReport()
294 call_status_ = INITIAL_RESPONSE_SENT; in SendReport()
337 if (call_status_ >= INITIAL_REQUEST_RECEIVED) { in Shutdown()
344 if (call_status_ >= DELIVERED && call_status_ < FINISH_CALLED) { in Shutdown()
355 call_status_ = FINISH_CALLED; in Shutdown()
Dload_reporter_async_service_impl.h161 } call_status_; variable
/external/rust/crates/grpcio-sys/grpc/src/cpp/server/load_reporter/
Dload_reporter_async_service_impl.cc150 call_status_(WAITING_FOR_DELIVERY) {} in ReportLoadHandler()
155 call_status_ = DELIVERED; in OnRequestDelivered()
195 if (!ok && call_status_ < INITIAL_REQUEST_RECEIVED) { in OnReadDone()
207 if (call_status_ < INITIAL_REQUEST_RECEIVED) { in OnReadDone()
211 call_status_ = INITIAL_REQUEST_RECEIVED; in OnReadDone()
293 if (call_status_ < INITIAL_RESPONSE_SENT) { in SendReport()
299 call_status_ = INITIAL_RESPONSE_SENT; in SendReport()
342 if (call_status_ >= INITIAL_REQUEST_RECEIVED) { in Shutdown()
349 if (call_status_ >= DELIVERED && call_status_ < FINISH_CALLED) { in Shutdown()
360 call_status_ = FINISH_CALLED; in Shutdown()
Dload_reporter_async_service_impl.h162 } call_status_; variable
/external/pigweed/pw_rpc/public/pw_rpc/
Dsynchronous_call_result.h79 : call_status_(internal::SynchronousCallStatus::kServer), in SynchronousCallResult()
135 : call_status_(call_status), status_(status) {} in SynchronousCallResult()
137 internal::SynchronousCallStatus call_status_ = variable
175 return call_status_ == internal::SynchronousCallStatus::kTimeout; in is_timeout()
180 return call_status_ == internal::SynchronousCallStatus::kRpc; in is_rpc_error()
185 return call_status_ == internal::SynchronousCallStatus::kServer; in is_server_response()
190 PW_ASSERT(call_status_ != internal::SynchronousCallStatus::kInvalid); in status()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_state.h549 Status s = FromGrpcStatus(call_status_); in CallFinished()
619 call_->Finish(&call_status_, &finished_tag_); in IssueCallFinishLocked()
634 ::grpc::Status call_status_ TF_GUARDED_BY(mu_);