| /aosp_15_r20/external/grpc-grpc/src/php/tests/interop/ |
| H A 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 …]
|
| /aosp_15_r20/out/soong/.intermediates/external/grpc-grpc-java/stub/grpc-java-stub/android_common_apex30/turbine/ |
| D | grpc-java-stub.jar | ... grpc.stub.AbstractAsyncStub extends io.grpc.stub.AbstractStub {
protected void <init> (io ... |
| /aosp_15_r20/out/soong/.intermediates/external/grpc-grpc-java/stub/grpc-java-stub/android_common_apex10000/turbine/ |
| D | grpc-java-stub.jar | ... grpc.stub.AbstractAsyncStub extends io.grpc.stub.AbstractStub {
protected void <init> (io ... |
| /aosp_15_r20/out/soong/.intermediates/external/grpc-grpc-java/stub/grpc-java-stub/android_common_apex33/turbine/ |
| D | grpc-java-stub.jar | ... grpc.stub.AbstractAsyncStub extends io.grpc.stub.AbstractStub {
protected void <init> (io ... |
| /aosp_15_r20/out/soong/.intermediates/external/grpc-grpc-java/stub/grpc-java-stub/android_common_apex34/turbine/ |
| D | grpc-java-stub.jar | ... grpc.stub.AbstractAsyncStub extends io.grpc.stub.AbstractStub {
protected void <init> (io ... |
| /aosp_15_r20/out/soong/.intermediates/external/grpc-grpc-java/stub/grpc-java-stub/android_common_apex33/javac/ |
| D | grpc-java-stub.jar | ... .grpc.stub
public abstract io.grpc.stub.AbstractAsyncStub extends io.grpc.stub.AbstractStub ... |
| /aosp_15_r20/out/soong/.intermediates/external/grpc-grpc-java/stub/grpc-java-stub/android_common_apex34/javac/ |
| D | grpc-java-stub.jar | ... .grpc.stub
public abstract io.grpc.stub.AbstractAsyncStub extends io.grpc.stub.AbstractStub ... |
| /aosp_15_r20/out/soong/.intermediates/external/grpc-grpc-java/stub/grpc-java-stub/android_common_apex30/javac/ |
| D | grpc-java-stub.jar | ... .grpc.stub
public abstract io.grpc.stub.AbstractAsyncStub extends io.grpc.stub.AbstractStub ... |
| /aosp_15_r20/out/soong/.intermediates/external/grpc-grpc-java/stub/grpc-java-stub/android_common_apex10000/javac/ |
| D | grpc-java-stub.jar | ... .grpc.stub
public abstract io.grpc.stub.AbstractAsyncStub extends io.grpc.stub.AbstractStub ... |
| /aosp_15_r20/prebuilts/tools/common/m2/repository/io/grpc/grpc-stub/1.0.3/ |
| HD | grpc-stub-1.0.3.jar | ... io/
io/grpc/
io/grpc/stub/
io/grpc/stub/CallStreamObserver.class ... |
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio_tests/tests/interop/ |
| H A D | methods.py | 77 stub, fill_username, fill_oauth_scope, call_credentials argument
95 def _empty_unary(stub): argument
103 def _large_unary(stub): argument
107 def _client_streaming(stub): argument
128 def _server_streaming(stub): argument
190 def _ping_pong(stub): argument
223 def _cancel_after_begin(stub): argument
233 def _cancel_after_first_response(stub): argument
273 def _timeout_on_sleeping_server(stub): argument
292 def _empty_stream(stub): argument
[all …]
|
| /aosp_15_r20/external/cronet/net/websockets/ |
| H A D | websocket_deflate_stream_test.cc | 382 ReadFramesStub stub(OK, &frames_to_output); in TEST_F() local
400 ReadFramesStub stub(ERR_IO_PENDING); in TEST_F() local
431 ReadFramesStub stub(ERR_IO_PENDING); in TEST_F() local
463 ReadFramesStub stub(OK, &frames_to_output); in TEST_F() local
480 ReadFramesStub stub(ERR_IO_PENDING); in TEST_F() local
558 ReadFramesStub stub(OK, &frames_to_output); in TEST_F() local
583 ReadFramesStub stub(OK, &frames_to_output); in TEST_F() local
608 ReadFramesStub stub(OK, &frames_to_output); in TEST_F() local
639 ReadFramesStub stub(OK, &frames_to_output); in TEST_F() local
667 ReadFramesStub stub(OK, &frames_to_output); in TEST_F() local
[all …]
|
| /aosp_15_r20/external/grpc-grpc/test/cpp/end2end/ |
| H A D | client_lb_end2end_test.cc | 326 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in SendRpc()
346 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in CheckRpcSendOk()
370 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in CheckRpcSendFailure()
383 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in SendRpcsUntil()
494 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in WaitForServers()
523 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in WaitForServer()
603 auto stub = BuildStub(channel); in TEST_F() local
634 auto stub = BuildStub(channel); in TEST_F() local
661 auto stub = BuildStub(channel); in TEST_F() local
679 auto stub = BuildStub(channel); in TEST_F() local
[all …]
|
| H A D | service_config_end2end_test.cc | 260 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in SendRpc()
277 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in CheckRpcSendOk()
293 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub) { in CheckRpcSendFailure()
357 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in WaitForServer()
441 auto stub = BuildStub(channel); in TEST_F() local
450 auto stub = BuildStub(channel); in TEST_F() local
460 auto stub = BuildStub(channel); in TEST_F() local
468 auto stub = BuildStub(channel); in TEST_F() local
481 auto stub = BuildStub(channel); in TEST_F() local
494 auto stub = BuildStub(channel); in TEST_F() local
[all …]
|
| H A D | interceptors_util.cc | 34 auto stub = grpc::testing::EchoTestService::NewStub(channel, options); in MakeCall() local
47 auto stub = grpc::testing::EchoTestService::NewStub(channel); in MakeClientStreamingCall() local
67 auto stub = grpc::testing::EchoTestService::NewStub(channel); in MakeServerStreamingCall() local
86 auto stub = grpc::testing::EchoTestService::NewStub(channel); in MakeBidiStreamingCall() local
105 auto stub = grpc::testing::EchoTestService::NewStub(channel); in MakeAsyncCQCall() local
128 auto stub = grpc::testing::EchoTestService::NewStub(channel); in MakeAsyncCQServerStreamingCall() local
160 auto stub = grpc::testing::EchoTestService::NewStub(channel); in MakeCallbackCall() local
|
| /aosp_15_r20/external/grpc-grpc/test/core/transport/binder/end2end/ |
| H A D | end2end_binder_transport_test.cc | 93 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub = NewStub(); in TEST_P() local
104 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub = NewStub(); in TEST_P() local
124 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub = NewStub(); in TEST_P() local
141 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub = NewStub(); in TEST_P() local
159 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub = NewStub(); in TEST_P() local
171 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub = NewStub(); in TEST_P() local
184 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub = NewStub(); in TEST_P() local
200 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub = NewStub(); in TEST_P() local
216 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub = NewStub(); in TEST_P() local
230 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub = NewStub(); in TEST_P() local
[all …]
|
| /aosp_15_r20/packages/modules/DeviceLock/DeviceLockController/src/com/android/devicelockcontroller/provision/grpc/impl/ |
| D | DeviceCheckInClientImpl.java | 188 DeviceLockCheckinServiceBlockingStub stub; in getDeviceCheckInStatus() local
204 @NonNull DeviceLockCheckinServiceBlockingStub stub) { in getDeviceCheckInStatus()
222 DeviceLockCheckinServiceBlockingStub stub; in isDeviceInApprovedCountry() local
237 @Nullable String carrierInfo, @NonNull DeviceLockCheckinServiceBlockingStub stub) { in isDeviceInApprovedCountry()
254 DeviceLockCheckinServiceBlockingStub stub; in pauseDeviceProvisioning() local
268 @NonNull DeviceLockCheckinServiceBlockingStub stub) { in pauseDeviceProvisioning()
287 DeviceLockCheckinServiceBlockingStub stub; in reportDeviceProvisionState() local
304 @NonNull DeviceLockCheckinServiceBlockingStub stub) { in reportDeviceProvisionState()
326 DeviceLockCheckinServiceBlockingStub stub; in updateFcmToken() local
342 @NonNull DeviceLockCheckinServiceBlockingStub stub) { in updateFcmToken()
|
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio_tests/tests/testing/ |
| H A D | _client_application.py | 99 def _run_unary_unary(stub): argument
107 def _run_unary_stream(stub): argument
117 def _run_stream_unary(stub): argument
130 def _run_stream_stream(stub): argument
154 def _run_concurrent_stream_unary(stub): argument
172 def _run_concurrent_stream_stream(stub): argument
197 def _run_cancel_unary_unary(stub): argument
209 def _run_infinite_request_stream(stub): argument
|
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio_tests/tests/http2/ |
| H A D | negative_http2_client.py | 68 def _goaway(stub): argument
80 def _rst_after_header(stub): argument
89 def _rst_during_data(stub): argument
98 def _rst_after_data(stub): argument
107 def _ping(stub): argument
114 def _max_streams(stub): argument
131 def _run_test_case(test_case, stub): argument
|
| /aosp_15_r20/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| H A D | AbstractInteropTest.java | 1083 TestServiceGrpc.TestServiceBlockingStub stub = blockingStub.withInterceptors( in exchangeMetadataUnaryCall() local
1104 TestServiceGrpc.TestServiceStub stub = asyncStub.withInterceptors( in exchangeMetadataStreamingCall() local
1140 TestServiceGrpc.TestServiceBlockingStub stub = in sendsTimeoutHeader() local
1168 TestServiceGrpc.TestServiceBlockingStub stub = in deadlineExceeded() local
1317 TestServiceGrpc.TestServiceBlockingStub stub = in maxInboundSize_exact() local
1342 TestServiceGrpc.TestServiceBlockingStub stub = in maxInboundSize_tooBig() local
1374 TestServiceGrpc.TestServiceBlockingStub stub = in maxOutboundSize_exact() local
1399 TestServiceGrpc.TestServiceBlockingStub stub = in maxOutboundSize_tooBig() local
1543 TestServiceGrpc.TestServiceStub stub = asyncStub.withInterceptors( in customMetadata() local
1687 UnimplementedServiceGrpc.UnimplementedServiceBlockingStub stub = in unimplementedService() local
[all …]
|
| /aosp_15_r20/external/cronet/base/fuchsia/ |
| H A D | scoped_natural_service_binding_unittest.cc | 39 auto stub = in TEST_F() local
56 auto stub = CreateTestInterfaceClient( in TEST_F() local
105 auto stub = in TEST_F() local
117 auto stub = in TEST_F() local
145 auto stub = in TEST_F() local
157 auto stub = in TEST_F() local
|
| /aosp_15_r20/external/grpc-grpc/test/cpp/qps/ |
| H A D | client_async.cc | 70 BenchmarkService::Stub* stub, const RequestType& req, in ClientRpcContextUnaryImpl()
325 PrepareReq(BenchmarkService::Stub* stub, grpc::ClientContext* ctx, in PrepareReq()
329 static ClientRpcContext* SetupCtx(BenchmarkService::Stub* stub, in SetupCtx()
342 BenchmarkService::Stub* stub, const RequestType& req, in ClientRpcContextStreamingPingPongImpl()
508 PrepareReq(BenchmarkService::Stub* stub, grpc::ClientContext* ctx, in PrepareReq()
513 static ClientRpcContext* SetupCtx(BenchmarkService::Stub* stub, in SetupCtx()
528 BenchmarkService::Stub* stub, const RequestType& req, in ClientRpcContextStreamingFromClientImpl()
640 BenchmarkService::Stub* stub, grpc::ClientContext* ctx, in PrepareReq()
645 static ClientRpcContext* SetupCtx(BenchmarkService::Stub* stub, in SetupCtx()
660 BenchmarkService::Stub* stub, const RequestType& req, in ClientRpcContextStreamingFromServerImpl()
[all …]
|
| H A D | client_sync.cc | 126 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in ThreadFuncImpl() local
230 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in InitThreadFuncImpl() local
261 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in ThreadFuncImpl() local
288 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in InitThreadFuncImpl() local
313 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in ThreadFuncImpl() local
337 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in InitThreadFuncImpl() local
357 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in ThreadFuncImpl() local
383 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in InitThreadFuncImpl() local
|
| /aosp_15_r20/external/grpc-grpc/src/ruby/spec/generic/ |
| H A 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
517 def get_responses(stub, unmarshal: noop) argument
531 def get_responses(stub, run_start_call_first: false, unmarshal: noop) argument
679 def verify_error_from_write_thread(stub, requests_to_push, argument
836 def get_responses(stub, deadline: nil, marshal_proc: noop) argument
850 def get_responses(stub, run_start_call_first: false, deadline: nil, argument
|
| /aosp_15_r20/external/grpc-grpc/examples/python/route_guide/ |
| H A D | route_guide_client.py | 34 def guide_get_one_feature(stub, point): argument
46 def guide_get_feature(stub): argument
53 def guide_list_features(stub): argument
73 def guide_record_route(stub): argument
97 def guide_route_chat(stub): argument
|