| /third_party/grpc/src/core/lib/gprpp/ |
| D | mpscq.h | 41 MultiProducerSingleConsumerQueue() : head_{&stub_}, tail_(&stub_) {} in MultiProducerSingleConsumerQueue()
43 GPR_ASSERT(head_.Load(MemoryOrder::RELAXED) == &stub_); in ~MultiProducerSingleConsumerQueue()
44 GPR_ASSERT(tail_ == &stub_); in ~MultiProducerSingleConsumerQueue()
67 Node stub_; variable
|
| D | mpscq.cc | 33 return prev == &stub_; in Push()
46 if (tail == &stub_) { in PopAndCheckEnd()
67 Push(&stub_); in PopAndCheckEnd()
|
| /third_party/mindspore/mindspore/ccsrc/debug/debugger/ |
| D | grpc_client.cc | 35 GrpcClient::GrpcClient(const std::string &host, const std::string &port) : stub_(nullptr) { Init(ho… in GrpcClient()
42 stub_ = EventListener::NewStub(channel); in Init()
45 void GrpcClient::Reset() { stub_ = nullptr; } in Reset()
50 grpc::Status status = stub_->WaitCMD(&context, metadata, &reply); in WaitForCommand()
62 grpc::Status status = stub_->SendMetadata(&context, metadata, &reply); in SendMetadata()
100 std::unique_ptr<grpc::ClientWriter<Chunk> > writer(stub_->SendGraph(&context, &reply)); in SendGraph()
127 std::unique_ptr<grpc::ClientWriter<Chunk> > writer(stub_->SendMultiGraphs(&context, &reply)); in SendMultiGraphs()
148 std::unique_ptr<grpc::ClientWriter<TensorProto> > writer(stub_->SendTensors(&context, &reply)); in SendTensors()
169 …std::unique_ptr<grpc::ClientWriter<WatchpointHit> > writer(stub_->SendWatchpointHits(&context, &re… in SendWatchpointHits()
190 grpc::Status status = stub_->SendHeartbeat(&context, heartbeat, &reply); in SendHeartbeat()
[all …]
|
| /third_party/grpc/test/cpp/end2end/ |
| D | end2end_test.cc | 250 : stub_(grpc::testing::EchoTestService::NewStub(channel)) {} in Proxy()
256 return stub_->Echo(client_context.get(), *request, response); in Echo()
260 std::unique_ptr<::grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::__anon3e928b420111::Proxy
449 stub_ = grpc::testing::EchoTestService::NewStub(channel_);
455 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::__anon3e928b420111::End2endTest
518 auto stream = stub_->RequestStream(&context, &response); in TestRequestStreamServerCancel()
597 auto stream = stub_->ResponseStream(&context, request); in TestResponseStreamServerCancel()
677 auto stream = stub_->BidiStream(&context); in TestBidiStreamServerCancel()
749 Status s = stub_->Echo(&context, request, &response); in TEST_P()
816 Status s = stub_->Echo(&context, request, &response); in TEST_P()
[all …]
|
| D | mock_test.cc | 67 explicit FakeClient(EchoTestService::StubInterface* stub) : stub_(stub) {} in FakeClient()
74 Status s = stub_->Echo(&context, request, &response); in DoEcho()
88 stub_->RequestStream(&context, &response); in DoRequestStream()
112 stub_->ResponseStream(&context, request); in DoResponseStream()
135 stream = stub_->BidiStream(&context); in DoBidiStream()
159 void ResetStub(EchoTestService::StubInterface* stub) { stub_ = stub; } in ResetStub()
162 EchoTestService::StubInterface* stub_; member in grpc::testing::__anonc912ef6c0111::FakeClient
332 stub_ = grpc::testing::EchoTestService::NewStub(channel); in ResetStub()
335 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::__anonc912ef6c0111::MockTest
344 FakeClient client(stub_.get()); in TEST_F()
[all …]
|
| D | client_callback_end2end_test.cc | 150 stub_ = grpc::testing::EchoTestService::NewStub(channel_); in ResetStub()
190 stub_->experimental_async()->Echo( in SendRpcs()
228 stub_->experimental_async()->Echo( in SendRpcsRawReq()
358 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::__anon3934da2c0111::ClientCallbackEnd2endTest
388 stub_->experimental_async()->Echo( in TEST_P()
418 stub_->experimental_async()->Echo( in TEST_P()
427 this->stub_->experimental_async()->Echo( in TEST_P()
436 stub_->experimental_async()->Echo( in TEST_P()
466 stub_->experimental_async()->Echo( in TEST_P()
504 stub_->experimental_async()->CheckClientInitialMetadata( in TEST_P()
[all …]
|
| D | exception_test.cc | 76 stub_ = grpc::testing::EchoTestService::NewStub(channel_); in ResetStub()
80 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::ExceptionTest
93 Status s = stub_->Echo(&context, request, &response); in TEST_F()
105 auto stream = stub_->RequestStream(&context, &response); in TEST_F()
|
| D | raw_end2end_test.cc | 115 stub_.reset(); in TearDown()
135 stub_ = grpc::testing::EchoTestService::NewStub(channel); in ResetStub()
139 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::__anon95f61f2b0111::RawEnd2EndTest
177 stub_->AsyncEcho(&cli_ctx_, send_request_, cq_.get())); in TEST_F()
202 stub_->AsyncEcho(&cli_ctx_, send_request_, cq_.get())); in TEST_F()
231 stub_->AsyncRequestStream(&cli_ctx_, &recv_response_, cq_.get(), tag(1))); in TEST_F()
276 stub_->AsyncResponseStream(&cli_ctx_, send_request_, cq_.get(), tag(1))); in TEST_F()
319 cli_stream(stub_->AsyncBidiStream(&cli_ctx_, cq_.get(), tag(1))); in TEST_F()
|
| D | nonblocking_test.cc | 104 stub_.reset(); in TearDown()
121 stub_ = grpc::testing::EchoTestService::NewStub(channel); in ResetStub()
138 stub_->PrepareAsyncEcho(&cli_ctx, send_request, cq_.get())); in SendRpc()
176 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::__anon8ea606960211::NonblockingTest
|
| D | server_early_return_test.cc | 127 stub_ = grpc::testing::EchoTestService::NewStub(channel_); in SetUp()
152 auto stream = stub_->BidiStream(&context); in DoBidiStream()
190 auto stream = stub_->RequestStream(&context, &response); in DoRequestStream()
208 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::__anon86206e540111::ServerEarlyReturnTest
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | callback_unary_ping_pong.h | 41 EchoTestService::Stub* stub_, bool* done, in SendCallbackUnaryPingPong() argument
45 stub_->experimental_async()->Echo( in SendCallbackUnaryPingPong()
47 [state, cli_ctx, request, response, stub_, done, mu, cv](Status s) { in SendCallbackUnaryPingPong()
52 SendCallbackUnaryPingPong(state, cli_ctx, request, response, stub_, in SendCallbackUnaryPingPong()
68 std::unique_ptr<EchoTestService::Stub> stub_( in BM_CallbackUnaryPingPong()
86 stub_.get(), &done, &mu, &cv); in BM_CallbackUnaryPingPong()
|
| D | callback_streaming_ping_pong.h | 44 stub_{stub},
87 stub_->experimental_async()->BidiStream(cli_ctx_, this); in StartNewRpc()
109 EchoTestService::Stub* stub_; variable
127 std::unique_ptr<EchoTestService::Stub> stub_( in BM_CallbackBidiStreaming()
139 BidiClient test{&state, stub_.get(), &cli_ctx, &request, &response}; in BM_CallbackBidiStreaming()
|
| /third_party/flatbuffers/grpc/samples/greeter/ |
| D | client.cpp | 13 : stub_(Greeter::NewStub(channel)) {} in GreeterClient()
26 auto status = stub_->SayHello(&context, request_msg, &response_msg); in SayHello()
50 auto stream = stub_->SayManyHellos(&context, request_msg); in SayManyHellos()
64 std::unique_ptr<Greeter::Stub> stub_; member in GreeterClient
|
| /third_party/grpc/test/cpp/qps/ |
| D | client_async.cc | 76 stub_(stub), in ClientRpcContextUnaryImpl()
93 response_reader_ = prepare_req_(stub_, &context_, req_, cq_); in RunNextState()
112 auto* clone = new ClientRpcContextUnaryImpl(stub_, req_, next_issue_, in StartNewClone()
120 BenchmarkService::Stub* stub_; member in grpc::testing::ClientRpcContextUnaryImpl
347 stub_(stub), in ClientRpcContextStreamingPingPongImpl()
428 stub_, req_, next_issue_, prepare_req_, callback_); in StartNewClone()
435 BenchmarkService::Stub* stub_; member in grpc::testing::ClientRpcContextStreamingPingPongImpl
478 stream_ = prepare_req_(stub_, &context_, cq); in StartInternal()
533 stub_(stub), in ClientRpcContextStreamingFromClientImpl()
584 stub_, req_, next_issue_, prepare_req_, callback_); in StartNewClone()
[all …]
|
| D | client_callback.cc | 47 : alarm_(nullptr), stub_(stub) {} in CallbackClientRpcContext()
54 BenchmarkService::Stub* stub_; member
188 ctx_[vector_idx]->stub_->experimental_async()->UnaryCall( in IssueUnaryCallbackRpc()
205 new CallbackClientRpcContext(ctx_[vector_idx]->stub_)); in IssueUnaryCallbackRpc()
260 ctx_->stub_->experimental_async()->StreamingCall(&(ctx_->context_), this); in StartNewRpc()
311 ctx_.reset(new CallbackClientRpcContext(ctx_->stub_)); in OnDone()
|
| /third_party/grpc/examples/cpp/load_balancing/ |
| D | greeter_client.cc | 42 : stub_(Greeter::NewStub(channel)) {} in GreeterClient()
59 Status status = stub_->SayHello(&context, request, &reply); in SayHello()
72 std::unique_ptr<Greeter::Stub> stub_; member in GreeterClient
|
| /third_party/grpc/examples/cpp/compression/ |
| D | greeter_client.cc | 42 : stub_(Greeter::NewStub(channel)) {} in GreeterClient()
62 Status status = stub_->SayHello(&context, request, &reply); in SayHello()
75 std::unique_ptr<Greeter::Stub> stub_; member in GreeterClient
|
| /third_party/grpc/examples/cpp/route_guide/ |
| D | route_guide_client.cc | 77 : stub_(RouteGuide::NewStub(channel)) { in RouteGuideClient()
103 stub_->ListFeatures(&context, rect)); in ListFeatures()
132 stub_->RecordRoute(&context, &stats)); in RecordRoute()
162 stub_->RouteChat(&context)); in RouteChat()
196 Status status = stub_->GetFeature(&context, point, feature); in GetOneFeature()
218 std::unique_ptr<RouteGuide::Stub> stub_; member in RouteGuideClient
|
| /third_party/grpc/examples/cpp/metadata/ |
| D | greeter_client.cc | 41 : stub_(Greeter::NewStub(channel)) {} in CustomHeaderClient()
66 Status status = stub_->SayHello(&context, request, &reply); in SayHello()
81 std::unique_ptr<Greeter::Stub> stub_; member in CustomHeaderClient
|
| /third_party/grpc/examples/cpp/helloworld/ |
| D | greeter_async_client.cc | 44 : stub_(Greeter::NewStub(channel)) {} in GreeterClient()
72 stub_->PrepareAsyncSayHello(&context, request, &cq)); in SayHello()
106 std::unique_ptr<Greeter::Stub> stub_; member in GreeterClient
|
| D | greeter_client.cc | 41 : stub_(Greeter::NewStub(channel)) {} in GreeterClient()
58 Status status = stub_->SayHello(&context, request, &reply); in SayHello()
71 std::unique_ptr<Greeter::Stub> stub_; member in GreeterClient
|
| D | greeter_async_client2.cc | 45 : stub_(Greeter::NewStub(channel)) {} in GreeterClient()
61 stub_->PrepareAsyncSayHello(&call->context, request, &cq_); in SayHello()
118 std::unique_ptr<Greeter::Stub> stub_; member in GreeterClient
|
| /third_party/grpc/examples/cpp/keyvaluestore/ |
| D | client.cc | 44 : stub_(KeyValueStore::NewStub(channel)) {} in KeyValueStoreClient()
52 auto stream = stub_->GetValues(&context); in GetValues()
74 std::unique_ptr<KeyValueStore::Stub> stub_; member in KeyValueStoreClient
|
| /third_party/grpc/include/grpcpp/generic/ |
| D | generic_stub.h | 121 explicit experimental_type(TemplatedGenericStub* stub) : stub_(stub) {} in experimental_type()
128 stub_->UnaryCallInternal(context, method, request, response, in UnaryCall()
139 stub_->PrepareUnaryCallInternal(context, method, request, response, in PrepareUnaryCall()
149 stub_->PrepareBidiStreamingCallInternal(context, method, reactor); in PrepareBidiStreamingCall()
153 TemplatedGenericStub* stub_;
|
| /third_party/ffmpeg/libavcodec/x86/ |
| D | h264_qpel_10bit.asm | 115 call stub_%1_h264_qpel%3_%2_10 %+ SUFFIX
120 call stub_%1_h264_qpel%3_%2_10 %+ SUFFIX
125 call stub_%1_h264_qpel%3_%2_10 %+ SUFFIX
130 call stub_%1_h264_qpel%3_%2_10 %+ SUFFIX
137 call stub_%1_h264_qpel%3_%2_10 %+ SUFFIX
140 call stub_%1_h264_qpel%3_%2_10 %+ SUFFIX
143 call stub_%1_h264_qpel%3_%2_10 %+ SUFFIX
147 call stub_%1_h264_qpel%3_%2_10 %+ SUFFIX
162 call stub_%1_h264_qpel%3_%2_10 %+ SUFFIX
166 stub_%1_h264_qpel%3_%2_10 %+ SUFFIX:
[all …]
|