|
|
@ -130,11 +130,8 @@ class SynchronousUnaryClient GRPC_FINAL : public SynchronousClient { |
|
|
|
grpc::Status s = |
|
|
|
grpc::Status s = |
|
|
|
stub->UnaryCall(&context, request_, &responses_[thread_idx]); |
|
|
|
stub->UnaryCall(&context, request_, &responses_[thread_idx]); |
|
|
|
entry->set_value((UsageTimer::Now() - start) * 1e9); |
|
|
|
entry->set_value((UsageTimer::Now() - start) * 1e9); |
|
|
|
if (!s.ok()) { |
|
|
|
entry->set_status(s.error_code()); |
|
|
|
gpr_log(GPR_ERROR, "RPC error: %d: %s", s.error_code(), |
|
|
|
return true; |
|
|
|
s.error_message().c_str()); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
return s.ok(); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
}; |
|
|
|
}; |
|
|
|
|
|
|
|
|
|
|
|