| /third_party/grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | BenchmarkServiceGrpc.cs | 62 …SimpleRequest> __Marshaller_grpc_testing_SimpleRequest = grpc::Marshallers.Create(__Helper_Seriali…
65 …:Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_UnaryCall = new grpc::M…
72 …rpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_StreamingCall = new grpc:…
79 ….Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_StreamingFromClient = new gr…
86 ….Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_StreamingFromServer = new gr…
93 …c.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_StreamingBothWays = new grp…
117 …k<global::Grpc.Testing.SimpleResponse> UnaryCall(global::Grpc.Testing.SimpleRequest request, grpc:… in UnaryCall()
131 …asks.Task StreamingCall(grpc::IAsyncStreamReader<global::Grpc.Testing.SimpleRequest> requestStream… in StreamingCall()
143 …se> StreamingFromClient(grpc::IAsyncStreamReader<global::Grpc.Testing.SimpleRequest> requestStream… in StreamingFromClient()
156 …:System.Threading.Tasks.Task StreamingFromServer(global::Grpc.Testing.SimpleRequest request, grpc:… in StreamingFromServer()
[all …]
|
| D | MetadataCredentialsTest.cs | 88 client.UnaryCall(new SimpleRequest { }); in MetadataCredentials_Channel()
111 client.UnaryCall(new SimpleRequest { }, new CallOptions(credentials: callCredentials)); in MetadataCredentials_PerCall()
144 … client.UnaryCall(new SimpleRequest { }, new CallOptions(credentials: perCallCredentials)); in MetadataCredentials_BothChannelAndPerCall()
224 client.UnaryCall(new SimpleRequest { }); in MetadataCredentials_InterceptorLeavesMetadataEmpty()
239 var ex = Assert.Throws<RpcException>(() => client.UnaryCall(new SimpleRequest { })); in MetadataCredentials_InterceptorThrows()
246 public UnaryServerMethod<SimpleRequest, SimpleResponse> UnaryCallHandler;
250 … public override Task<SimpleResponse> UnaryCall(SimpleRequest request, ServerCallContext context) in UnaryCall()
|
| D | InteropClient.cs | 216 var request = new SimpleRequest in RunLargeUnary()
328 var request = new SimpleRequest in RunComputeEngineCreds()
350 var request = new SimpleRequest in RunJwtTokenCreds()
372 var request = new SimpleRequest in RunOAuth2AuthTokenAsync()
392 var request = new SimpleRequest in RunPerRpcCredsAsync()
490 var request = new SimpleRequest in RunCustomMetadataAsync()
541 var request = new SimpleRequest { ResponseStatus = echoStatus }; in RunStatusCodeAndMessageAsync()
584 await client.UnaryCallAsync(new SimpleRequest in RunSpecialStatusMessageAsync()
620 var probeRequest = new SimpleRequest in RunClientCompressedUnary()
632 var compressedRequest = new SimpleRequest in RunClientCompressedUnary()
[all …]
|
| D | CustomErrorDetailsTest.cs | 70 var call = client.UnaryCallAsync(new SimpleRequest { ResponseSize = 10 }); in ErrorDetailsFromCallObject()
91 await client.UnaryCallAsync(new SimpleRequest { ResponseSize = 10 }); in ErrorDetailsFromRpcException()
111 … public override Task<SimpleResponse> UnaryCall(SimpleRequest request, ServerCallContext context) in UnaryCall()
|
| D | BenchmarkServiceImpl.cs | 38 … public override Task<SimpleResponse> UnaryCall(SimpleRequest request, ServerCallContext context) in UnaryCall()
44 …public override async Task StreamingCall(IAsyncStreamReader<SimpleRequest> requestStream, IServerS… in StreamingCall()
|
| D | TestGrpc.cs | 68 …SimpleRequest> __Marshaller_grpc_testing_SimpleRequest = grpc::Marshallers.Create(__Helper_Seriali…
82 …:Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_UnaryCall = new grpc::M…
89 …c.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_CacheableUnaryCall = new gr…
158 …k<global::Grpc.Testing.SimpleResponse> UnaryCall(global::Grpc.Testing.SimpleRequest request, grpc:… in UnaryCall()
171 …:Grpc.Testing.SimpleResponse> CacheableUnaryCall(global::Grpc.Testing.SimpleRequest request, grpc:… in CacheableUnaryCall()
319 …al global::Grpc.Testing.SimpleResponse UnaryCall(global::Grpc.Testing.SimpleRequest request, grpc:… in UnaryCall()
329 …al global::Grpc.Testing.SimpleResponse UnaryCall(global::Grpc.Testing.SimpleRequest request, grpc:… in UnaryCall()
341 …bal::Grpc.Testing.SimpleResponse> UnaryCallAsync(global::Grpc.Testing.SimpleRequest request, grpc:… in UnaryCallAsync()
351 …bal::Grpc.Testing.SimpleResponse> UnaryCallAsync(global::Grpc.Testing.SimpleRequest request, grpc:… in UnaryCallAsync()
365 …::Grpc.Testing.SimpleResponse CacheableUnaryCall(global::Grpc.Testing.SimpleRequest request, grpc:… in CacheableUnaryCall()
[all …]
|
| /third_party/grpc/src/python/grpcio_tests/tests_aio/unit/ |
| D | client_unary_unary_interceptor_test.py | 70 request_serializer=messages_pb2.SimpleRequest.SerializeToString,
72 call = multicallable(messages_pb2.SimpleRequest())
118 request_serializer=messages_pb2.SimpleRequest.SerializeToString,
121 await multicallable(messages_pb2.SimpleRequest())
147 request_serializer=messages_pb2.SimpleRequest.SerializeToString,
150 call = multicallable(messages_pb2.SimpleRequest())
207 request_serializer=messages_pb2.SimpleRequest.SerializeToString,
210 call = multicallable(messages_pb2.SimpleRequest())
251 request_serializer=messages_pb2.SimpleRequest.SerializeToString,
254 call = multicallable(messages_pb2.SimpleRequest())
[all …]
|
| D | close_channel_test.py | 44 request_serializer=messages_pb2.SimpleRequest.SerializeToString,
48 call = UnaryCallWithSleep(messages_pb2.SimpleRequest())
58 request_serializer=messages_pb2.SimpleRequest.SerializeToString,
62 call = UnaryCallWithSleep(messages_pb2.SimpleRequest())
72 calls = [stub.UnaryCall(messages_pb2.SimpleRequest()) for _ in range(2)]
117 stub.UnaryCall(messages_pb2.SimpleRequest()) for _ in range(2)
129 call1 = stub1.UnaryCall(messages_pb2.SimpleRequest())
130 call2 = stub2.UnaryCall(messages_pb2.SimpleRequest())
|
| D | server_interceptor_test.py | 104 [messages_pb2.SimpleRequest, aio.ServicerContext], argument
109 request: messages_pb2.SimpleRequest, argument
155 request_serializer=messages_pb2.SimpleRequest.SerializeToString,
157 call = multicallable(messages_pb2.SimpleRequest())
176 request_serializer=messages_pb2.SimpleRequest.SerializeToString,
178 call = multicallable(messages_pb2.SimpleRequest())
200 request_serializer=messages_pb2.SimpleRequest.SerializeToString,
204 call = multicallable(messages_pb2.SimpleRequest(),
214 call = multicallable(messages_pb2.SimpleRequest(),
236 messages_pb2.SimpleRequest(response_size=42))
[all …]
|
| D | channel_test.py | 56 request_serializer=messages_pb2.SimpleRequest.SerializeToString,
58 await hi(messages_pb2.SimpleRequest())
64 request_serializer=messages_pb2.SimpleRequest.SerializeToString,
66 response = await hi(messages_pb2.SimpleRequest())
74 request_serializer=messages_pb2.SimpleRequest.SerializeToString,
79 await hi(messages_pb2.SimpleRequest(),
97 request_serializer=messages_pb2.SimpleRequest.SerializeToString,
101 call = hi(messages_pb2.SimpleRequest(),
|
| D | call_test.py | 54 call = self._stub.UnaryCall(messages_pb2.SimpleRequest())
65 call = self._stub.UnaryCall(messages_pb2.SimpleRequest())
84 call = stub.UnaryCall(messages_pb2.SimpleRequest())
96 call = self._stub.UnaryCall(messages_pb2.SimpleRequest())
100 call = self._stub.UnaryCall(messages_pb2.SimpleRequest())
104 call = self._stub.UnaryCall(messages_pb2.SimpleRequest())
108 call = self._stub.UnaryCall(messages_pb2.SimpleRequest())
113 call = self._stub.UnaryCall(messages_pb2.SimpleRequest())
128 call = self._stub.UnaryCall(messages_pb2.SimpleRequest())
142 call = self._stub.UnaryCall(messages_pb2.SimpleRequest())
[all …]
|
| /third_party/grpc/test/cpp/qps/ |
| D | server_sync.cc | 39 Status UnaryCall(ServerContext* /*context*/, const SimpleRequest* request, in UnaryCall()
49 ServerReaderWriter<SimpleResponse, SimpleRequest>* stream) override { in StreamingCall()
50 SimpleRequest request; in StreamingCall()
64 ServerReader<SimpleRequest>* stream, in StreamingFromClient()
73 const SimpleRequest* request, in StreamingFromServer()
84 ServerReaderWriter<SimpleResponse, SimpleRequest>* stream) override { in StreamingBothWays()
86 SimpleRequest request; in StreamingBothWays()
119 SimpleRequest request; in ClientPull()
142 static Status SetResponse(const SimpleRequest* request, in SetResponse()
|
| D | server_callback.cc | 38 const SimpleRequest* request, SimpleResponse* response) override { in UnaryCall()
44 ::grpc::experimental::ServerBidiReactor<::grpc::testing::SimpleRequest,
49 ::grpc::testing::SimpleRequest, ::grpc::testing::SimpleResponse> { in StreamingCall()
77 SimpleRequest request_; in StreamingCall()
84 static Status SetResponse(const SimpleRequest* request, in SetResponse()
|
| D | client_async.cc | 307 : public AsyncClient<BenchmarkService::Stub, SimpleRequest> {
310 : AsyncClient<BenchmarkService::Stub, SimpleRequest>( in AsyncUnaryClient()
323 const SimpleRequest& request, CompletionQueue* cq) { in PrepareReq()
328 const SimpleRequest& req) { in SetupCtx()
329 return new ClientRpcContextUnaryImpl<SimpleRequest, SimpleResponse>( in SetupCtx()
490 : public AsyncClient<BenchmarkService::Stub, SimpleRequest> {
493 : AsyncClient<BenchmarkService::Stub, SimpleRequest>( in AsyncStreamingPingPongClient()
504 grpc::ClientAsyncReaderWriter<SimpleRequest, SimpleResponse>>
512 const SimpleRequest& req) { in SetupCtx()
513 return new ClientRpcContextStreamingPingPongImpl<SimpleRequest, in SetupCtx()
[all …]
|
| D | client_sync.cc | 51 : public ClientImpl<BenchmarkService::Stub, SimpleRequest> {
54 : ClientImpl<BenchmarkService::Stub, SimpleRequest>( in SynchronousClient()
220 grpc::ClientReaderWriter<SimpleRequest, SimpleResponse>> {
277 : public SynchronousStreamingClient<grpc::ClientWriter<SimpleRequest>> {
376 grpc::ClientReaderWriter<SimpleRequest, SimpleResponse>> {
|
| /third_party/grpc/src/proto/grpc/testing/ |
| D | benchmark_service.proto | 26 rpc UnaryCall(SimpleRequest) returns (SimpleResponse);
31 rpc StreamingCall(stream SimpleRequest) returns (stream SimpleResponse);
35 rpc StreamingFromClient(stream SimpleRequest) returns (SimpleResponse);
39 rpc StreamingFromServer(SimpleRequest) returns (stream SimpleResponse);
43 rpc StreamingBothWays(stream SimpleRequest) returns (stream SimpleResponse);
|
| D | echo.proto | 27 rpc CheckDeadlineUpperBound(SimpleRequest) returns (StringValue);
28 rpc CheckDeadlineSet(SimpleRequest) returns (StringValue);
31 rpc CheckClientInitialMetadata(SimpleRequest) returns (SimpleResponse);
44 rpc CheckClientInitialMetadata(SimpleRequest) returns (SimpleResponse);
57 rpc CheckClientInitialMetadata(SimpleRequest) returns (SimpleResponse);
|
| /third_party/grpc/src/php/tests/unit_tests/ |
| D | InterceptorTest.php | 30 class SimpleRequest class
62 * @param SimpleRequest $argument input argument
67 SimpleRequest $argument,
246 $req = new SimpleRequest($req_text);
276 $req = new SimpleRequest($req_text);
302 $req = new SimpleRequest($req_text);
332 $req = new SimpleRequest($req_text);
383 $req = new SimpleRequest($req_text);
|
| /third_party/grpc/test/cpp/interop/ |
| D | interop_client.cc | 58 const SimpleRequest* /*request*/, in NoopChecks() argument
62 const SimpleRequest* request, in UnaryCompressionChecks()
174 bool InteropClient::PerformLargeUnary(SimpleRequest* request, in PerformLargeUnary()
179 bool InteropClient::PerformLargeUnary(SimpleRequest* request, in PerformLargeUnary()
213 SimpleRequest request; in DoComputeEngineCreds()
237 SimpleRequest request; in DoOauth2AuthToken()
261 SimpleRequest request; in DoPerRpcCreds()
287 SimpleRequest request; in DoJwtTokenCreds()
305 SimpleRequest request; in DoGoogleDefaultCredentials()
322 SimpleRequest request; in DoLargeUnary()
[all …]
|
| D | interop_client.h | 34 const SimpleRequest*, const SimpleResponse*)>
124 bool PerformLargeUnary(SimpleRequest* request, SimpleResponse* response);
127 bool PerformLargeUnary(SimpleRequest* request, SimpleResponse* response,
|
| D | http2_client.h | 59 SimpleRequest BuildDefaultRequest();
62 SimpleRequest defaultRequest_;
|
| D | xds_interop_server.cc | 50 using grpc::testing::SimpleRequest;
58 Status UnaryCall(ServerContext* context, const SimpleRequest* request, in UnaryCall()
|
| /third_party/grpc/src/php/tests/qps/generated_code/Grpc/Testing/ |
| D | BenchmarkServiceClient.php | 44 public function UnaryCall(\Grpc\Testing\SimpleRequest $argument,
87 public function StreamingFromServer(\Grpc\Testing\SimpleRequest $argument,
|
| D | TestServiceClient.php | 61 public function UnaryCall(\Grpc\Testing\SimpleRequest $argument,
78 public function CacheableUnaryCall(\Grpc\Testing\SimpleRequest $argument,
|
| /third_party/grpc/src/php/tests/interop/Grpc/Testing/ |
| D | TestServiceClient.php | 61 public function UnaryCall(\Grpc\Testing\SimpleRequest $argument,
78 public function CacheableUnaryCall(\Grpc\Testing\SimpleRequest $argument,
|