Home
last modified time | relevance | path

Searched refs:SimpleRequest (Results 1 – 25 of 103) sorted by relevance

12345

/external/grpc-grpc-java/testing-proto/src/generated/main/java/io/grpc/testing/protobuf/
DSimpleRequest.java13 public final class SimpleRequest extends class
19 private SimpleRequest(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in SimpleRequest() method in SimpleRequest
22 private SimpleRequest() { in SimpleRequest() method in SimpleRequest
31 private SimpleRequest( in SimpleRequest() method in SimpleRequest
84 …io.grpc.testing.protobuf.SimpleRequest.class, io.grpc.testing.protobuf.SimpleRequest.Builder.class… in internalGetFieldAccessorTable()
165 if (!(obj instanceof io.grpc.testing.protobuf.SimpleRequest)) { in equals()
168 io.grpc.testing.protobuf.SimpleRequest other = (io.grpc.testing.protobuf.SimpleRequest) obj; in equals()
191 public static io.grpc.testing.protobuf.SimpleRequest parseFrom( in parseFrom()
196 public static io.grpc.testing.protobuf.SimpleRequest parseFrom( in parseFrom()
202 public static io.grpc.testing.protobuf.SimpleRequest parseFrom( in parseFrom()
[all …]
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DBenchmarkServiceGrpc.cs32 …SimpleRequest> __Marshaller_grpc_testing_SimpleRequest = grpc::Marshallers.Create((arg) => global:…
35 …:Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_UnaryCall = new grpc::M…
42 …rpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_StreamingCall = new grpc:…
49 ….Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_StreamingFromClient = new gr…
56 ….Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_StreamingFromServer = new gr…
63 …c.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_StreamingBothWays = new grp…
86 …k<global::Grpc.Testing.SimpleResponse> UnaryCall(global::Grpc.Testing.SimpleRequest request, grpc:… in UnaryCall()
100 …asks.Task StreamingCall(grpc::IAsyncStreamReader<global::Grpc.Testing.SimpleRequest> requestStream… in StreamingCall()
112 …se> StreamingFromClient(grpc::IAsyncStreamReader<global::Grpc.Testing.SimpleRequest> requestStream… in StreamingFromClient()
125 …:System.Threading.Tasks.Task StreamingFromServer(global::Grpc.Testing.SimpleRequest request, grpc:… in StreamingFromServer()
[all …]
DTestGrpc.cs38 …SimpleRequest> __Marshaller_grpc_testing_SimpleRequest = grpc::Marshallers.Create((arg) => global:…
52 …:Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_UnaryCall = new grpc::M…
59 …c.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_CacheableUnaryCall = new gr…
127 …k<global::Grpc.Testing.SimpleResponse> UnaryCall(global::Grpc.Testing.SimpleRequest request, grpc:… in UnaryCall()
140 …:Grpc.Testing.SimpleResponse> CacheableUnaryCall(global::Grpc.Testing.SimpleRequest request, grpc:… in CacheableUnaryCall()
288 …al global::Grpc.Testing.SimpleResponse UnaryCall(global::Grpc.Testing.SimpleRequest request, grpc:… in UnaryCall()
298 …al global::Grpc.Testing.SimpleResponse UnaryCall(global::Grpc.Testing.SimpleRequest request, grpc:… in UnaryCall()
310 …bal::Grpc.Testing.SimpleResponse> UnaryCallAsync(global::Grpc.Testing.SimpleRequest request, grpc:… in UnaryCallAsync()
320 …bal::Grpc.Testing.SimpleResponse> UnaryCallAsync(global::Grpc.Testing.SimpleRequest request, grpc:… in UnaryCallAsync()
334 …::Grpc.Testing.SimpleResponse CacheableUnaryCall(global::Grpc.Testing.SimpleRequest request, grpc:… in CacheableUnaryCall()
[all …]
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
DBenchmarkServiceGrpc.java30 private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
35 requestType = io.grpc.benchmarks.proto.Messages.SimpleRequest.class,
38 public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
40 …io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto… in getUnaryCallMethod()
45 …io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.prot… in getUnaryCallMethod()
51 io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance())) in getUnaryCallMethod()
62 private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
67 requestType = io.grpc.benchmarks.proto.Messages.SimpleRequest.class,
70 public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
72 …io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto… in getStreamingCallMethod()
[all …]
/external/grpc-grpc-java/testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/
DSimpleServiceGrpc.java33 private static volatile io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest,
38 requestType = io.grpc.testing.protobuf.SimpleRequest.class,
41 public static io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest,
43 …io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleRe… in getUnaryRpcMethod()
48 …io.grpc.MethodDescriptor.<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleR… in getUnaryRpcMethod()
54 io.grpc.testing.protobuf.SimpleRequest.getDefaultInstance())) in getUnaryRpcMethod()
65 private static volatile io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest,
70 requestType = io.grpc.testing.protobuf.SimpleRequest.class,
73 public static io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest,
75 …io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleRe… in getClientStreamingRpcMethod()
[all …]
/external/grpc-grpc-java/testing/src/test/java/io/grpc/testing/
DGrpcServerRuleTest.java24 import io.grpc.testing.protobuf.SimpleRequest;
63 SimpleRequest request1 = SimpleRequest.getDefaultInstance(); in serverAllowsServicesToBeAddedViaServiceRegistry_withoutDirectExecutor()
65 SimpleRequest request2 = SimpleRequest.newBuilder().build(); in serverAllowsServicesToBeAddedViaServiceRegistry_withoutDirectExecutor()
82 stub.serverStreamingRpc(SimpleRequest.getDefaultInstance()); in serviceIsNotRunOnSameThreadAsTest_withoutDirectExecutor()
113 SimpleRequest request1 = SimpleRequest.getDefaultInstance(); in serverAllowsServicesToBeAddedViaServiceRegistry_withDirectExecutor()
115 SimpleRequest request2 = SimpleRequest.newBuilder().build(); in serverAllowsServicesToBeAddedViaServiceRegistry_withDirectExecutor()
132 stub.serverStreamingRpc(SimpleRequest.getDefaultInstance()); in serviceIsRunOnSameThreadAsTest_withDirectExecutor()
184 private final Collection<SimpleRequest> unaryCallRequests =
185 new ConcurrentLinkedQueue<SimpleRequest>();
191 SimpleRequest request, StreamObserver<SimpleResponse> responseObserver) { in serverStreamingRpc()
[all …]
/external/golang-protobuf/protoc-gen-go/testdata/grpc/
Dgrpc.pb.go27 type SimpleRequest struct { struct
33 func (m *SimpleRequest) Reset() { *m = SimpleRequest{} } argument
34 func (m *SimpleRequest) String() string { return proto.CompactTextString(m) } argument
35 func (*SimpleRequest) ProtoMessage() {} argument
36 func (*SimpleRequest) Descriptor() ([]byte, []int) { argument
40 func (m *SimpleRequest) XXX_Unmarshal(b []byte) error { argument
43 func (m *SimpleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { argument
46 func (m *SimpleRequest) XXX_Merge(src proto.Message) { argument
49 func (m *SimpleRequest) XXX_Size() int { argument
52 func (m *SimpleRequest) XXX_DiscardUnknown() { argument
[all …]
/external/grpc-grpc/src/ruby/qps/src/proto/grpc/testing/
Dbenchmark_service_services_pb.rb37 rpc :UnaryCall, SimpleRequest, SimpleResponse
41 rpc :StreamingCall, stream(SimpleRequest), stream(SimpleResponse)
44 rpc :StreamingFromClient, stream(SimpleRequest), SimpleResponse
47 rpc :StreamingFromServer, SimpleRequest, stream(SimpleResponse)
50 rpc :StreamingBothWays, stream(SimpleRequest), stream(SimpleResponse)
/external/grpc-grpc/test/cpp/qps/
Dserver_sync.cc39 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()
Dclient_async.cc307 : 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()
503 grpc::ClientAsyncReaderWriter<SimpleRequest, SimpleResponse>>
511 const SimpleRequest& req) { in SetupCtx()
512 return new ClientRpcContextStreamingPingPongImpl<SimpleRequest, in SetupCtx()
[all …]
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/
DAsyncServer.java213 public void unaryCall(Messages.SimpleRequest request, in unaryCall()
220 public StreamObserver<Messages.SimpleRequest> streamingCall( in streamingCall()
225 return new StreamObserver<Messages.SimpleRequest>() { in streamingCall()
227 public void onNext(Messages.SimpleRequest value) { in streamingCall()
250 public StreamObserver<Messages.SimpleRequest> streamingFromClient(
252 return new StreamObserver<Messages.SimpleRequest>() {
253 Messages.SimpleRequest lastSeen = null;
256 public void onNext(Messages.SimpleRequest value) {
286 final Messages.SimpleRequest request,
315 public StreamObserver<Messages.SimpleRequest> streamingBothWays(
[all …]
DAsyncClient.java45 import io.grpc.benchmarks.proto.Messages.SimpleRequest;
75 SimpleRequest req = newRequest(); in run()
100 private SimpleRequest newRequest() { in newRequest()
104 return SimpleRequest.newBuilder() in newRequest()
111 private void warmup(SimpleRequest req, List<? extends Channel> channels) throws Exception { in warmup()
120 private List<Histogram> doBenchmark(SimpleRequest req, in doBenchmark()
140 private Future<Histogram> doRpcs(Channel channel, SimpleRequest request, long endTime) { in doRpcs()
151 private Future<Histogram> doUnaryCalls(Channel channel, final SimpleRequest request, in doUnaryCalls()
191 private static Future<Histogram> doStreamingCalls(Channel channel, final SimpleRequest request, in doStreamingCalls()
200 StreamObserver<SimpleRequest> requestObserver = stub.streamingCall(responseObserver); in doStreamingCalls()
[all …]
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/stub/
DStubConfigTest.java34 import io.grpc.testing.integration.Messages.SimpleRequest;
62 ClientCall<SimpleRequest, SimpleResponse> call = in setUp()
63 new NoopClientCall<SimpleRequest, SimpleResponse>(); in setUp()
65 Mockito.<MethodDescriptor<SimpleRequest, SimpleResponse>>any(), any(CallOptions.class))) in setUp()
87 SimpleRequest request = SimpleRequest.getDefaultInstance(); in testStubCallOptionsPopulatedToNewCall()
/external/grpc-grpc-java/testing-proto/src/main/proto/io/grpc/testing/protobuf/
Dsimpleservice.proto29 rpc UnaryRpc (SimpleRequest) returns (SimpleResponse) {}
32 rpc ClientStreamingRpc (stream SimpleRequest) returns (SimpleResponse) {}
35 rpc ServerStreamingRpc (SimpleRequest) returns (stream SimpleResponse) {}
38 rpc BidiStreamingRpc (stream SimpleRequest) returns (stream SimpleResponse) {}
42 message SimpleRequest { message
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DCascadingTest.java43 import io.grpc.testing.integration.Messages.SimpleRequest;
109 future = futureStub.unaryCall(SimpleRequest.getDefaultInstance()); in testCascadingCancellationViaOuterContextCancellation()
141 Future<SimpleResponse> future = futureStub.unaryCall(SimpleRequest.getDefaultInstance()); in testCascadingCancellationViaRpcCancel()
166 blockingStub.unaryCall(Messages.SimpleRequest.newBuilder().setResponseSize(3).build()); in testCascadingCancellationViaLeafFailure()
190 public void unaryCall(final SimpleRequest request, in testDeadlinePropagation()
216 blockingStub.withDeadline(initialDeadline).unaryCall(SimpleRequest.getDefaultInstance()); in testDeadlinePropagation()
233 public void unaryCall(final SimpleRequest request, in startChainingServer()
292 Messages.SimpleRequest req = (Messages.SimpleRequest) message; in startCallTreeServer()
/external/rust/crates/grpcio-sys/grpc/src/proto/grpc/testing/
Dbenchmark_service.proto26 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);
Decho.proto27 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);
/external/grpc-grpc/src/proto/grpc/testing/
Dbenchmark_service.proto26 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);
/external/grpc-grpc-java/compiler/src/testNano/golden/
DTestDeprecatedService.java.txt38 private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.SimpleRequest,
41 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.SimpleRequest,
43 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.nano.Test.SimpleRequest, io.grpc.testing.compile…
48 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.nano.Test.SimpleRequest, io.grpc.testing.compil…
53 …aller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.SimpleRequest>marshaller(
54 …new NanoFactory<io.grpc.testing.compiler.nano.Test.SimpleRequest>(ARG_IN_METHOD_DEPRECATED_METHOD)…
77 o = new io.grpc.testing.compiler.nano.Test.SimpleRequest();
128 public void deprecatedMethod(io.grpc.testing.compiler.nano.Test.SimpleRequest request,
139 io.grpc.testing.compiler.nano.Test.SimpleRequest,
174 public void deprecatedMethod(io.grpc.testing.compiler.nano.Test.SimpleRequest request,
[all …]
/external/grpc-grpc-java/compiler/src/testLite/golden/
DTestDeprecatedService.java.txt34 private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
39 requestType = io.grpc.testing.compiler.Test.SimpleRequest.class,
42 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
44 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Tes…
49 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Te…
55 io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance()))
102 public void deprecatedMethod(io.grpc.testing.compiler.Test.SimpleRequest request,
113 io.grpc.testing.compiler.Test.SimpleRequest,
148 public void deprecatedMethod(io.grpc.testing.compiler.Test.SimpleRequest request,
183 …ompiler.Test.SimpleResponse deprecatedMethod(io.grpc.testing.compiler.Test.SimpleRequest request) {
[all …]
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
DTestServiceGrpc.java66 …rivate static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest,
71 requestType = io.grpc.testing.integration.Messages.SimpleRequest.class,
74 public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest,
76 …io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest, io.grpc.testing.integ… in getUnaryCallMethod()
81 …io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.SimpleRequest, io.grpc.testing.inte… in getUnaryCallMethod()
87 io.grpc.testing.integration.Messages.SimpleRequest.getDefaultInstance())) in getUnaryCallMethod()
98 …rivate static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest,
103 requestType = io.grpc.testing.integration.Messages.SimpleRequest.class,
106 public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest,
108 …io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest, io.grpc.testing.integ… in getCacheableUnaryCallMethod()
[all …]
/external/grpc-grpc-java/compiler/src/test/golden/
DTestDeprecatedService.java.txt34 private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
39 requestType = io.grpc.testing.compiler.Test.SimpleRequest.class,
42 public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
44 …io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Tes…
49 …io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Te…
55 io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance()))
103 public void deprecatedMethod(io.grpc.testing.compiler.Test.SimpleRequest request,
114 io.grpc.testing.compiler.Test.SimpleRequest,
149 public void deprecatedMethod(io.grpc.testing.compiler.Test.SimpleRequest request,
184 …ompiler.Test.SimpleResponse deprecatedMethod(io.grpc.testing.compiler.Test.SimpleRequest request) {
[all …]
/external/grpc-grpc/src/php/tests/unit_tests/
DInterceptorTest.php30 class SimpleRequest class
62 * @param SimpleRequest $argument input argument
67 SimpleRequest $argument,
236 $req = new SimpleRequest($req_text);
266 $req = new SimpleRequest($req_text);
292 $req = new SimpleRequest($req_text);
322 $req = new SimpleRequest($req_text);
373 $req = new SimpleRequest($req_text);
/external/grpc-grpc/test/cpp/interop/
Dinterop_client.cc54 const SimpleRequest* request, const SimpleResponse* response) {} in NoopChecks()
57 const SimpleRequest* request, in UnaryCompressionChecks()
170 bool InteropClient::PerformLargeUnary(SimpleRequest* request, in PerformLargeUnary()
175 bool InteropClient::PerformLargeUnary(SimpleRequest* request, in PerformLargeUnary()
209 SimpleRequest request; in DoComputeEngineCreds()
233 SimpleRequest request; in DoOauth2AuthToken()
257 SimpleRequest request; in DoPerRpcCreds()
283 SimpleRequest request; in DoJwtTokenCreds()
299 SimpleRequest request; in DoLargeUnary()
311 SimpleRequest probe_req; in DoClientCompressedUnary()
[all …]
/external/grpc-grpc-java/netty/shaded/src/testShadow/java/io/grpc/netty/shaded/
DShadingTest.java32 import io.grpc.testing.protobuf.SimpleRequest;
85 .isEqualTo(stub.unaryRpc(SimpleRequest.getDefaultInstance())); in basic()
103 .isEqualTo(stub.unaryRpc(SimpleRequest.getDefaultInstance())); in tcnative()
107 @Override public void unaryRpc(SimpleRequest req, StreamObserver<SimpleResponse> obs) { in unaryRpc()

12345