MCPcopy Create free account
hub / github.com/apache/impala / SyncRequest

Method SyncRequest

be/src/kudu/rpc/proxy.cc:252–261  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

250
251
252Status Proxy::SyncRequest(const string& method,
253 const google::protobuf::Message& req,
254 google::protobuf::Message* resp,
255 RpcController* controller) {
256 Notification note;
257 AsyncRequest(method, req, DCHECK_NOTNULL(resp), controller,
258 [&note]() { note.Notify(); });
259 note.WaitForNotification();
260 return controller->status();
261}
262
263void Proxy::set_user_credentials(UserCredentials user_credentials) {
264 CHECK(base::subtle::NoBarrier_Load(&is_started_) == false)

Callers 8

DoTestSyncCallMethod · 0.80
DoTestSidecarMethod · 0.80
DoTestOutgoingSidecarMethod · 0.80
DoTestExpectTimeoutMethod · 0.80
SendRequestFunction · 0.80
TEST_FFunction · 0.80
TEST_FFunction · 0.80
TEST_PFunction · 0.80

Calls 3

WaitForNotificationMethod · 0.80
NotifyMethod · 0.45
statusMethod · 0.45

Tested by 8

DoTestSyncCallMethod · 0.64
DoTestSidecarMethod · 0.64
DoTestOutgoingSidecarMethod · 0.64
DoTestExpectTimeoutMethod · 0.64
SendRequestFunction · 0.64
TEST_FFunction · 0.64
TEST_FFunction · 0.64
TEST_PFunction · 0.64