|
|
@ -234,12 +234,6 @@ class AsyncClient : public Client { |
|
|
|
GPR_ASSERT(false); |
|
|
|
GPR_ASSERT(false); |
|
|
|
break; |
|
|
|
break; |
|
|
|
} |
|
|
|
} |
|
|
|
if ((closed_loop_ || !rpc_deadlines_[thread_idx].empty()) && |
|
|
|
|
|
|
|
grpc_time_source::now() > deadline) { |
|
|
|
|
|
|
|
// we have missed some 1-second deadline, which is worth noting
|
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "Missed an RPC deadline"); |
|
|
|
|
|
|
|
// Don't give up, as there might be some truly heavy tails
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
if (got_event) { |
|
|
|
if (got_event) { |
|
|
|
ClientRpcContext* ctx = ClientRpcContext::detag(got_tag); |
|
|
|
ClientRpcContext* ctx = ClientRpcContext::detag(got_tag); |
|
|
|
if (ctx->RunNextState(ok, histogram) == false) { |
|
|
|
if (ctx->RunNextState(ok, histogram) == false) { |
|
|
|