| /third_party/grpc/src/php/tests/interop/ |
| D | interop_client.php | 59 function emptyUnary($stub)
72 function largeUnary($stub)
84 function performLargeUnary($stub, $fillUsername = false,
124 function clientCompressedUnary($stub)
172 function serviceAccountCreds($stub, $args)
195 function computeEngineCreds($stub, $args)
215 function jwtTokenCreds($stub, $args)
232 function oauth2AuthToken($stub, $args)
264 function perRpcCreds($stub, $args)
282 function clientStreaming($stub)
[all …]
|
| D | xds_client.php | 166 public function sendUnaryCall($stub, $metadata) {
172 public function sendEmptyCall($stub, $metadata) {
|
| /third_party/grpc/src/python/grpcio_tests/tests/interop/ |
| D | methods.py | 69 def _large_unary_common_behavior(stub, fill_username, fill_oauth_scope, argument
85 def _empty_unary(stub): argument
92 def _large_unary(stub): argument
96 def _client_streaming(stub): argument
113 def _server_streaming(stub): argument
174 def _ping_pong(stub): argument
204 def _cancel_after_begin(stub): argument
214 def _cancel_after_first_response(stub): argument
252 def _timeout_on_sleeping_server(stub): argument
270 def _empty_stream(stub): argument
[all …]
|
| /third_party/grpc/examples/ruby/errors_and_cancellation/ |
| D | error_examples_client.rb | 31 def run_get_feature_expect_error(stub) argument
35 def run_list_features_expect_error(stub) argument
42 def run_record_route_expect_error(stub) argument
46 def run_route_chat_expect_error(stub) argument
|
| /third_party/grpc/examples/python/route_guide/ |
| D | route_guide_client.py | 34 def guide_get_one_feature(stub, point): argument
46 def guide_get_feature(stub): argument
52 def guide_list_features(stub): argument
71 def guide_record_route(stub): argument
95 def guide_route_chat(stub): argument
|
| /third_party/grpc/src/python/grpcio_tests/tests/http2/ |
| D | negative_http2_client.py | 60 def _goaway(stub): argument
70 def _rst_after_header(stub): argument
76 def _rst_during_data(stub): argument
82 def _rst_after_data(stub): argument
88 def _ping(stub): argument
94 def _max_streams(stub): argument
110 def _run_test_case(test_case, stub): argument
|
| /third_party/mesa3d/src/mapi/ |
| D | stub.c | 65 const struct mapi_stub *stub = (const struct mapi_stub *) elem; in stub_compare() local
89 struct mapi_stub *stub; in stub_add_dynamic() local
122 struct mapi_stub *stub = NULL; in stub_find_dynamic() local
162 const struct mapi_stub *stub = in stub_find_by_slot() local
170 stub_fix_dynamic(struct mapi_stub *stub, const struct mapi_stub *alias) in stub_fix_dynamic()
190 stub_get_name(const struct mapi_stub *stub) in stub_get_name()
207 stub_get_slot(const struct mapi_stub *stub) in stub_get_slot()
216 stub_get_addr(const struct mapi_stub *stub) in stub_get_addr()
|
| D | mapi_glapi.c | 129 const struct mapi_stub *stub; in _glapi_add_dispatch() local
155 struct mapi_stub *stub; in _glapi_add_dispatch() local
184 const struct mapi_stub *stub; in _glapi_get_stub() local
211 const struct mapi_stub *stub = _glapi_get_stub(funcName, 0); in _glapi_get_proc_offset() local
223 const struct mapi_stub *stub = _glapi_get_stub(funcName, 1); in _glapi_get_proc_address() local
234 const struct mapi_stub *stub = stub_find_by_slot(offset); in _glapi_get_proc_name() local
|
| /third_party/grpc/src/ruby/bin/ |
| D | math_client.rb | 44 def do_div(stub) argument
54 def do_sum(stub) argument
65 def do_fib(stub) argument
77 def do_div_many(stub) argument
|
| /third_party/grpc/examples/python/data_transmission/ |
| D | client.py | 38 def simple_method(stub): argument
51 def client_streaming_method(stub): argument
72 def server_streaming_method(stub): argument
87 def bidirectional_streaming_method(stub): argument
|
| /third_party/grpc/src/python/grpcio_tests/tests/testing/ |
| D | _client_application.py | 101 def _run_unary_unary(stub): argument
109 def _run_unary_stream(stub): argument
119 def _run_stream_unary(stub): argument
129 def _run_stream_stream(stub): argument
151 def _run_concurrent_stream_unary(stub): argument
167 def _run_concurrent_stream_stream(stub): argument
192 def _run_cancel_unary_unary(stub): argument
203 def _run_infinite_request_stream(stub): argument
|
| /third_party/grpc/examples/ruby/route_guide/ |
| D | route_guide_client.rb | 40 def run_get_feature(stub) argument
61 def run_list_features(stub) argument
100 def run_record_route(stub, features) argument
125 def run_route_chat(stub) argument
|
| /third_party/grpc/test/cpp/end2end/ |
| D | service_config_end2end_test.cc | 258 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in SendRpc()
275 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in CheckRpcSendOk()
291 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub) { in CheckRpcSendFailure()
353 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in WaitForServer()
437 auto stub = BuildStub(channel); in TEST_F() local
446 auto stub = BuildStub(channel); in TEST_F() local
456 auto stub = BuildStub(channel); in TEST_F() local
464 auto stub = BuildStub(channel); in TEST_F() local
474 auto stub = BuildStub(channel); in TEST_F() local
487 auto stub = BuildStub(channel); in TEST_F() local
[all …]
|
| D | interceptors_util.cc | 29 auto stub = grpc::testing::EchoTestService::NewStub(channel); in MakeCall() local
42 auto stub = grpc::testing::EchoTestService::NewStub(channel); in MakeClientStreamingCall() local
62 auto stub = grpc::testing::EchoTestService::NewStub(channel); in MakeServerStreamingCall() local
81 auto stub = grpc::testing::EchoTestService::NewStub(channel); in MakeBidiStreamingCall() local
100 auto stub = grpc::testing::EchoTestService::NewStub(channel); in MakeAsyncCQCall() local
122 auto stub = grpc::testing::EchoTestService::NewStub(channel); in MakeAsyncCQServerStreamingCall() local
154 auto stub = grpc::testing::EchoTestService::NewStub(channel); in MakeCallbackCall() local
|
| D | client_lb_end2end_test.cc | 291 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in SendRpc()
312 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in CheckRpcSendOk()
328 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub) { in CheckRpcSendFailure()
390 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in WaitForServer()
466 auto stub = BuildStub(channel); in TEST_F() local
490 auto stub = BuildStub(channel); in TEST_F() local
515 auto stub = BuildStub(channel); in TEST_F() local
564 auto stub = BuildStub(channel); in TEST_F() local
594 auto stub = BuildStub(channel); in TEST_F() local
620 auto stub = BuildStub(channel); in TEST_F() local
[all …]
|
| D | time_change_test.cc | 190 auto stub = CreateStub(); in TEST_F() local
217 auto stub = CreateStub(); in TEST_F() local
245 auto stub = CreateStub(); in TEST_F() local
277 auto stub = CreateStub(); in TEST_F() local
310 auto stub = CreateStub(); in TEST_F() local
|
| D | flaky_network_test.cc | 207 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in SendRpc()
365 auto stub = BuildStub(channel); in TEST_P() local
412 auto stub = BuildStub(channel); in TEST_P() local
447 auto stub = BuildStub(channel); in TEST_P() local
482 auto stub = BuildStub(channel); in TEST_P() local
508 auto stub = BuildStub(channel); in TEST_P() local
530 auto stub = BuildStub(channel); in TEST_P() local
|
| /third_party/grpc/src/python/grpcio_tests/tests_aio/unit/ |
| D | wait_for_ready_test.py | 36 async def _perform_unary_unary(stub, wait_for_ready): argument
42 async def _perform_unary_stream(stub, wait_for_ready): argument
57 async def _perform_stream_unary(stub, wait_for_ready): argument
70 async def _perform_stream_stream(stub, wait_for_ready): argument
|
| /third_party/flatbuffers/grpc/examples/python/greeter/ |
| D | client.py | 14 def say_hello(stub, hello_request): argument
19 def say_many_hellos(stub, hello_request): argument
|
| /third_party/grpc/test/cpp/interop/ |
| D | grpclb_fallback_test.cc | 91 GrpclbRouteType DoRPCAndGetPath(TestService::Stub* stub, int deadline_seconds, in DoRPCAndGetPath()
120 GrpclbRouteType DoRPCAndGetPath(TestService::Stub* stub, int deadline_seconds) { in DoRPCAndGetPath()
124 GrpclbRouteType DoWaitForReadyRPCAndGetPath(TestService::Stub* stub, in DoWaitForReadyRPCAndGetPath()
197 std::unique_ptr<TestService::Stub> stub = CreateFallbackTestStub(); in RunFallbackBeforeStartupTest() local
221 std::unique_ptr<TestService::Stub> stub = CreateFallbackTestStub(); in RunFallbackAfterStartupTest() local
|
| /third_party/grpc/test/cpp/qps/ |
| D | client_sync.cc | 126 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in ThreadFuncImpl() local
231 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in InitThreadFuncImpl() local
263 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in ThreadFuncImpl() local
290 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in InitThreadFuncImpl() local
316 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in ThreadFuncImpl() local
340 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in InitThreadFuncImpl() local
361 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in ThreadFuncImpl() local
387 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in InitThreadFuncImpl() local
|
| D | client_async.cc | 67 BenchmarkService::Stub* stub, const RequestType& req, in ClientRpcContextUnaryImpl()
322 PrepareReq(BenchmarkService::Stub* stub, grpc::ClientContext* ctx, in PrepareReq()
326 static ClientRpcContext* SetupCtx(BenchmarkService::Stub* stub, in SetupCtx()
339 BenchmarkService::Stub* stub, const RequestType& req, in ClientRpcContextStreamingPingPongImpl()
505 PrepareReq(BenchmarkService::Stub* stub, grpc::ClientContext* ctx, in PrepareReq()
510 static ClientRpcContext* SetupCtx(BenchmarkService::Stub* stub, in SetupCtx()
525 BenchmarkService::Stub* stub, const RequestType& req, in ClientRpcContextStreamingFromClientImpl()
637 BenchmarkService::Stub* stub, grpc::ClientContext* ctx, in PrepareReq()
642 static ClientRpcContext* SetupCtx(BenchmarkService::Stub* stub, in SetupCtx()
657 BenchmarkService::Stub* stub, const RequestType& req, in ClientRpcContextStreamingFromServerImpl()
[all …]
|
| /third_party/grpc/src/ruby/spec/generic/ |
| D | client_stub_spec.rb | 295 def get_response(stub, credentials: nil) argument
310 def get_response(stub, run_start_call_first: false, credentials: nil) argument
399 def get_response(stub) argument
412 def get_response(stub, run_start_call_first: false) argument
538 def get_responses(stub, unmarshal: noop) argument
552 def get_responses(stub, run_start_call_first: false, unmarshal: noop) argument
699 def verify_error_from_write_thread(stub, requests_to_push, argument
856 def get_responses(stub, deadline: nil, marshal_proc: noop) argument
870 def get_responses(stub, run_start_call_first: false, deadline: nil, argument
|
| /third_party/grpc/src/ruby/qps/ |
| D | client.rb | 109 def unary_ping_ponger(req, stub, config,waiter) argument
117 def streaming_ping_ponger(req, stub, config, waiter) argument
|
| /third_party/flatbuffers/grpc/tests/ |
| D | grpctest.cpp | 101 template<class Builder> void StoreRPC(MonsterStorage::Stub *stub) { in StoreRPC()
122 template<class Builder> void RetrieveRPC(MonsterStorage::Stub *stub) { in RetrieveRPC()
149 auto stub = MyGame::Example::MonsterStorage::NewStub(channel); in grpc_server_test() local
|