Home
last modified time | relevance | path

Searched refs:SimpleResponse (Results 1 – 25 of 84) sorted by relevance

1234

/external/grpc-grpc-java/testing-proto/src/generated/main/java/io/grpc/testing/protobuf/
DSimpleResponse.java13 public final class SimpleResponse extends class
19 private SimpleResponse(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in SimpleResponse() method in SimpleResponse
22 private SimpleResponse() { in SimpleResponse() method in SimpleResponse
31 private SimpleResponse( in SimpleResponse() method in SimpleResponse
84 …io.grpc.testing.protobuf.SimpleResponse.class, io.grpc.testing.protobuf.SimpleResponse.Builder.cla… in internalGetFieldAccessorTable()
165 if (!(obj instanceof io.grpc.testing.protobuf.SimpleResponse)) { in equals()
168 io.grpc.testing.protobuf.SimpleResponse other = (io.grpc.testing.protobuf.SimpleResponse) obj; in equals()
191 public static io.grpc.testing.protobuf.SimpleResponse parseFrom( in parseFrom()
196 public static io.grpc.testing.protobuf.SimpleResponse parseFrom( in parseFrom()
202 public static io.grpc.testing.protobuf.SimpleResponse parseFrom( in parseFrom()
[all …]
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DBenchmarkServiceGrpc.cs33 …SimpleResponse> __Marshaller_grpc_testing_SimpleResponse = grpc::Marshallers.Create((arg) => globa…
35 …:Grpc.Testing.SimpleResponse> __Method_UnaryCall = new grpc::Method<global::Grpc.Testing.SimpleReq…
42 …rpc.Testing.SimpleResponse> __Method_StreamingCall = new grpc::Method<global::Grpc.Testing.SimpleR…
49 ….Testing.SimpleResponse> __Method_StreamingFromClient = new grpc::Method<global::Grpc.Testing.Simp…
56 ….Testing.SimpleResponse> __Method_StreamingFromServer = new grpc::Method<global::Grpc.Testing.Simp…
63 …c.Testing.SimpleResponse> __Method_StreamingBothWays = new grpc::Method<global::Grpc.Testing.Simpl…
86 …public virtual global::System.Threading.Tasks.Task<global::Grpc.Testing.SimpleResponse> UnaryCall(… in UnaryCall()
100 …quest> requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.SimpleResponse> responseStrea… in StreamingCall()
112 …public virtual global::System.Threading.Tasks.Task<global::Grpc.Testing.SimpleResponse> StreamingF… in StreamingFromClient()
125 …impleRequest request, grpc::IServerStreamWriter<global::Grpc.Testing.SimpleResponse> responseStrea… in StreamingFromServer()
[all …]
DBenchmarkServiceImpl.cs38 … public override Task<SimpleResponse> UnaryCall(SimpleRequest request, ServerCallContext context) in UnaryCall()
40 … var response = new SimpleResponse { Payload = CreateZerosPayload(request.ResponseSize) }; in UnaryCall()
44 …IAsyncStreamReader<SimpleRequest> requestStream, IServerStreamWriter<SimpleResponse> responseStrea… in StreamingCall()
48 … var response = new SimpleResponse { Payload = CreateZerosPayload(request.ResponseSize) }; in StreamingCall()
DTestGrpc.cs39 …SimpleResponse> __Marshaller_grpc_testing_SimpleResponse = grpc::Marshallers.Create((arg) => globa…
52 …:Grpc.Testing.SimpleResponse> __Method_UnaryCall = new grpc::Method<global::Grpc.Testing.SimpleReq…
59 ….Testing.SimpleResponse> __Method_CacheableUnaryCall = new grpc::Method<global::Grpc.Testing.Simpl…
127 …public virtual global::System.Threading.Tasks.Task<global::Grpc.Testing.SimpleResponse> UnaryCall(… in UnaryCall()
140 …public virtual global::System.Threading.Tasks.Task<global::Grpc.Testing.SimpleResponse> CacheableU… in CacheableUnaryCall()
288 …public virtual global::Grpc.Testing.SimpleResponse UnaryCall(global::Grpc.Testing.SimpleRequest re… in UnaryCall()
298 …public virtual global::Grpc.Testing.SimpleResponse UnaryCall(global::Grpc.Testing.SimpleRequest re… in UnaryCall()
310 …public virtual grpc::AsyncUnaryCall<global::Grpc.Testing.SimpleResponse> UnaryCallAsync(global::Gr… in UnaryCallAsync()
320 …public virtual grpc::AsyncUnaryCall<global::Grpc.Testing.SimpleResponse> UnaryCallAsync(global::Gr… in UnaryCallAsync()
334 …public virtual global::Grpc.Testing.SimpleResponse CacheableUnaryCall(global::Grpc.Testing.SimpleR… in CacheableUnaryCall()
[all …]
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
DBenchmarkServiceGrpc.java31 io.grpc.benchmarks.proto.Messages.SimpleResponse> getUnaryCallMethod;
36 responseType = io.grpc.benchmarks.proto.Messages.SimpleResponse.class,
39 io.grpc.benchmarks.proto.Messages.SimpleResponse> getUnaryCallMethod() { in getUnaryCallMethod()
40 …arks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getUnaryCallM… in getUnaryCallMethod()
45 …chmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>newBuilder() in getUnaryCallMethod()
53 io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance())) in getUnaryCallMethod()
63 io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingCallMethod;
68 responseType = io.grpc.benchmarks.proto.Messages.SimpleResponse.class,
71 io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingCallMethod() { in getStreamingCallMethod()
72 …arks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingC… in getStreamingCallMethod()
[all …]
/external/grpc-grpc-java/testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/
DSimpleServiceGrpc.java34 io.grpc.testing.protobuf.SimpleResponse> getUnaryRpcMethod;
39 responseType = io.grpc.testing.protobuf.SimpleResponse.class,
42 io.grpc.testing.protobuf.SimpleResponse> getUnaryRpcMethod() { in getUnaryRpcMethod()
43 …tor<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse> getUnaryRpcMe… in getUnaryRpcMethod()
48 …iptor.<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse>newBuilder() in getUnaryRpcMethod()
56 io.grpc.testing.protobuf.SimpleResponse.getDefaultInstance())) in getUnaryRpcMethod()
66 io.grpc.testing.protobuf.SimpleResponse> getClientStreamingRpcMethod;
71 responseType = io.grpc.testing.protobuf.SimpleResponse.class,
74 io.grpc.testing.protobuf.SimpleResponse> getClientStreamingRpcMethod() { in getClientStreamingRpcMethod()
75 …tor<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse> getClientStre… in getClientStreamingRpcMethod()
[all …]
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/
DAsyncServer.java197 private static final Messages.SimpleResponse BIDI_RESPONSE = Messages.SimpleResponse
214 StreamObserver<Messages.SimpleResponse> responseObserver) { in unaryCall()
221 final StreamObserver<Messages.SimpleResponse> observer) { in streamingCall()
222 final ServerCallStreamObserver<Messages.SimpleResponse> responseObserver = in streamingCall()
223 (ServerCallStreamObserver<Messages.SimpleResponse>) observer; in streamingCall()
251 final StreamObserver<Messages.SimpleResponse> responseObserver) {
287 final StreamObserver<Messages.SimpleResponse> observer) {
289 final Messages.SimpleResponse response = Utils.makeResponse(request);
290 final ServerCallStreamObserver<Messages.SimpleResponse> responseObserver =
291 (ServerCallStreamObserver<Messages.SimpleResponse>) observer;
[all …]
/external/grpc-grpc/test/cpp/qps/
Dserver_sync.cc40 SimpleResponse* response) override { in UnaryCall()
49 ServerReaderWriter<SimpleResponse, SimpleRequest>* stream) override { in StreamingCall() argument
52 SimpleResponse response; in StreamingCall()
65 SimpleResponse* response) override { in StreamingFromClient()
74 ServerWriter<SimpleResponse>* stream) override { in StreamingFromServer()
75 SimpleResponse response; in StreamingFromServer()
84 ServerReaderWriter<SimpleResponse, SimpleRequest>* stream) override { in StreamingBothWays() argument
90 SimpleResponse response; in StreamingBothWays()
102 SimpleResponse dummy; in StreamingBothWays()
118 SimpleResponse* response) { in ClientPull()
[all …]
/external/golang-protobuf/protoc-gen-go/testdata/grpc/
Dgrpc.pb.go58 type SimpleResponse struct { struct
64 func (m *SimpleResponse) Reset() { *m = SimpleResponse{} } argument
65 func (m *SimpleResponse) String() string { return proto.CompactTextString(m) } argument
66 func (*SimpleResponse) ProtoMessage() {} argument
67 func (*SimpleResponse) Descriptor() ([]byte, []int) { argument
71 func (m *SimpleResponse) XXX_Unmarshal(b []byte) error { argument
74 func (m *SimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { argument
77 func (m *SimpleResponse) XXX_Merge(src proto.Message) { argument
80 func (m *SimpleResponse) XXX_Size() int { argument
83 func (m *SimpleResponse) 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/interop/
Dhttp2_client.cc67 Status Http2Client::SendUnaryCall(SimpleResponse* response) { in SendUnaryCall()
83 SimpleResponse response; in DoRstAfterHeader()
94 SimpleResponse response; in DoRstAfterData()
105 SimpleResponse response; in DoRstDuringData()
115 SimpleResponse response; in DoGoaway()
135 SimpleResponse response; in DoPing()
145 SimpleResponse response; in MaxStreamsWorker()
156 SimpleResponse response; in DoMaxStreams()
Dinterop_client.cc54 const SimpleRequest* request, const SimpleResponse* response) {} in NoopChecks()
58 const SimpleResponse* response) { in UnaryCompressionChecks()
171 SimpleResponse* response) { in PerformLargeUnary()
176 SimpleResponse* response, in PerformLargeUnary()
210 SimpleResponse response; in DoComputeEngineCreds()
234 SimpleResponse response; in DoOauth2AuthToken()
258 SimpleResponse response; in DoPerRpcCreds()
284 SimpleResponse response; in DoJwtTokenCreds()
300 SimpleResponse response; in DoLargeUnary()
312 SimpleResponse probe_res; in DoClientCompressedUnary()
[all …]
Dinterop_client.h34 const SimpleRequest*, const SimpleResponse*)>
116 bool PerformLargeUnary(SimpleRequest* request, SimpleResponse* response);
119 bool PerformLargeUnary(SimpleRequest* request, SimpleResponse* response,
/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) {}
48 message SimpleResponse { message
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/stub/
DStubConfigTest.java35 import io.grpc.testing.integration.Messages.SimpleResponse;
55 private StreamObserver<SimpleResponse> responseObserver;
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()
/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);
/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/interop-testing/src/main/java/io/grpc/testing/integration/
DHttp2Client.java35 import io.grpc.testing.integration.Messages.SimpleResponse;
211 final SimpleResponse goldenResponse = SimpleResponse.newBuilder()
283 private class RstStreamObserver implements StreamObserver<SimpleResponse> {
285 private final List<SimpleResponse> responses = new ArrayList<>();
289 public void onNext(SimpleResponse value) { in onNext()
304 public List<SimpleResponse> getResponses() { in getResponses()
352 private void assertResponseEquals(SimpleResponse response, SimpleResponse goldenResponse) { in assertResponseEquals()
/external/grpc-grpc-java/netty/shaded/src/testShadow/java/io/grpc/netty/shaded/
DShadingTest.java33 import io.grpc.testing.protobuf.SimpleResponse;
84 assertThat(SimpleResponse.getDefaultInstance()) in basic()
102 assertThat(SimpleResponse.getDefaultInstance()) in tcnative()
107 @Override public void unaryRpc(SimpleRequest req, StreamObserver<SimpleResponse> obs) { in unaryRpc()
108 obs.onNext(SimpleResponse.getDefaultInstance()); in unaryRpc()
/external/grpc-grpc-java/compiler/src/testNano/golden/
DTestDeprecatedService.java.txt39 io.grpc.testing.compiler.nano.Test.SimpleResponse> getDeprecatedMethodMethod;
42 io.grpc.testing.compiler.nano.Test.SimpleResponse> getDeprecatedMethodMethod() {
43 …compiler.nano.Test.SimpleRequest, io.grpc.testing.compiler.nano.Test.SimpleResponse> getDeprecated…
48 …ng.compiler.nano.Test.SimpleRequest, io.grpc.testing.compiler.nano.Test.SimpleResponse>newBuilder()
55 …ller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.SimpleResponse>marshaller(
56 …new NanoFactory<io.grpc.testing.compiler.nano.Test.SimpleResponse>(ARG_OUT_METHOD_DEPRECATED_METHO…
80 o = new io.grpc.testing.compiler.nano.Test.SimpleResponse();
129 … io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.SimpleResponse> responseObserver) {
140 io.grpc.testing.compiler.nano.Test.SimpleResponse>(
175 … io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.SimpleResponse> responseObserver) {
[all …]
/external/grpc-grpc-java/compiler/src/testLite/golden/
DTestDeprecatedService.java.txt35 io.grpc.testing.compiler.Test.SimpleResponse> getDeprecatedMethodMethod;
40 responseType = io.grpc.testing.compiler.Test.SimpleResponse.class,
43 io.grpc.testing.compiler.Test.SimpleResponse> getDeprecatedMethodMethod() {
44 …c.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse> getDeprecated…
49 …grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder()
57 io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance()))
103 … io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
114 io.grpc.testing.compiler.Test.SimpleResponse>(
149 … io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
183 …public io.grpc.testing.compiler.Test.SimpleResponse deprecatedMethod(io.grpc.testing.compiler.Test…
[all …]
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DCascadingTest.java44 import io.grpc.testing.integration.Messages.SimpleResponse;
106 Future<SimpleResponse> future; in testCascadingCancellationViaOuterContextCancellation()
141 Future<SimpleResponse> future = futureStub.unaryCall(SimpleRequest.getDefaultInstance()); in testCascadingCancellationViaRpcCancel()
191 final StreamObserver<SimpleResponse> responseObserver) { in testDeadlinePropagation()
198 responseObserver.onNext(SimpleResponse.getDefaultInstance()); in testDeadlinePropagation()
234 final StreamObserver<SimpleResponse> responseObserver) { in startChainingServer()
306 new StreamObserver<Messages.SimpleResponse>() { in startCallTreeServer()
308 public void onNext(Messages.SimpleResponse value) { in startCallTreeServer()
/external/grpc-grpc-java/compiler/src/test/golden/
DTestDeprecatedService.java.txt35 io.grpc.testing.compiler.Test.SimpleResponse> getDeprecatedMethodMethod;
40 responseType = io.grpc.testing.compiler.Test.SimpleResponse.class,
43 io.grpc.testing.compiler.Test.SimpleResponse> getDeprecatedMethodMethod() {
44 …c.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse> getDeprecated…
49 …grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder()
57 io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance()))
104 … io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
115 io.grpc.testing.compiler.Test.SimpleResponse>(
150 … io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
184 …public io.grpc.testing.compiler.Test.SimpleResponse deprecatedMethod(io.grpc.testing.compiler.Test…
[all …]
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
DTestServiceGrpc.java67 io.grpc.testing.integration.Messages.SimpleResponse> getUnaryCallMethod;
72 responseType = io.grpc.testing.integration.Messages.SimpleResponse.class,
75 io.grpc.testing.integration.Messages.SimpleResponse> getUnaryCallMethod() { in getUnaryCallMethod()
76 …gration.Messages.SimpleRequest, io.grpc.testing.integration.Messages.SimpleResponse> getUnaryCallM… in getUnaryCallMethod()
81 …ntegration.Messages.SimpleRequest, io.grpc.testing.integration.Messages.SimpleResponse>newBuilder() in getUnaryCallMethod()
89 io.grpc.testing.integration.Messages.SimpleResponse.getDefaultInstance())) in getUnaryCallMethod()
99 io.grpc.testing.integration.Messages.SimpleResponse> getCacheableUnaryCallMethod;
104 responseType = io.grpc.testing.integration.Messages.SimpleResponse.class,
107 io.grpc.testing.integration.Messages.SimpleResponse> getCacheableUnaryCallMethod() { in getCacheableUnaryCallMethod()
108 …gration.Messages.SimpleRequest, io.grpc.testing.integration.Messages.SimpleResponse> getCacheableU… in getCacheableUnaryCallMethod()
[all …]
/external/grpc-grpc-java/testing/src/test/java/io/grpc/testing/
DGrpcServerRuleTest.java25 import io.grpc.testing.protobuf.SimpleResponse;
191 SimpleRequest request, StreamObserver<SimpleResponse> responseObserver) { in serverStreamingRpc()
195 responseObserver.onNext(SimpleResponse.getDefaultInstance()); in serverStreamingRpc()
202 SimpleRequest request, StreamObserver<SimpleResponse> responseObserver) { in unaryRpc()
206 responseObserver.onNext(SimpleResponse.getDefaultInstance()); in unaryRpc()

1234