HomeSort by relevance Sort by last modified time
    Searched refs:SimpleResponse (Results 1 - 25 of 56) sorted by null

1 2 3

  /external/grpc-grpc/src/ruby/qps/src/proto/grpc/testing/
benchmark_service_services_pb.rb 37 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-java/testing-proto/src/generated/main/java/io/grpc/testing/protobuf/
SimpleResponse.java 11 * Protobuf type {@code grpc.testing.SimpleResponse}
13 public final class SimpleResponse extends
15 // @@protoc_insertion_point(message_implements:grpc.testing.SimpleResponse)
18 // Use SimpleResponse.newBuilder() to construct.
19 private SimpleResponse(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
22 private SimpleResponse() {
31 private SimpleResponse(
84 io.grpc.testing.protobuf.SimpleResponse.class, io.grpc.testing.protobuf.SimpleResponse.Builder.class);
165 if (!(obj instanceof io.grpc.testing.protobuf.SimpleResponse)) {
    [all...]
  /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/
AsyncServer.java 197 private static final Messages.SimpleResponse BIDI_RESPONSE = Messages.SimpleResponse
214 StreamObserver<Messages.SimpleResponse> responseObserver) {
221 final StreamObserver<Messages.SimpleResponse> observer) {
222 final ServerCallStreamObserver<Messages.SimpleResponse> responseObserver =
223 (ServerCallStreamObserver<Messages.SimpleResponse>) observer;
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
    [all...]
  /external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
BenchmarkServiceGrpc.java 31 io.grpc.benchmarks.proto.Messages.SimpleResponse> getUnaryCallMethod;
36 responseType = io.grpc.benchmarks.proto.Messages.SimpleResponse.class,
39 io.grpc.benchmarks.proto.Messages.SimpleResponse> getUnaryCallMethod() {
40 io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getUnaryCallMethod;
45 io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>newBuilder()
53 io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance()))
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() {
72 io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingCallMethod
    [all...]
  /external/grpc-grpc/src/python/grpcio_tests/tests/qps/
benchmark_server.py 24 return messages_pb2.SimpleResponse(payload=payload)
29 yield messages_pb2.SimpleResponse(payload=payload)
  /external/grpc-grpc/test/cpp/qps/
server_sync.cc 40 SimpleResponse* response) override {
49 ServerReaderWriter<SimpleResponse, SimpleRequest>* stream) override {
52 SimpleResponse response;
65 SimpleResponse* response) override {
74 ServerWriter<SimpleResponse>* stream) override {
75 SimpleResponse response;
84 ServerReaderWriter<SimpleResponse, SimpleRequest>* stream) override {
90 SimpleResponse response;
102 SimpleResponse dummy;
118 SimpleResponse* response)
    [all...]
  /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/stub/
StubConfigTest.java 35 import io.grpc.testing.integration.Messages.SimpleResponse;
55 private StreamObserver<SimpleResponse> responseObserver;
62 ClientCall<SimpleRequest, SimpleResponse> call =
63 new NoopClientCall<SimpleRequest, SimpleResponse>();
65 Mockito.<MethodDescriptor<SimpleRequest, SimpleResponse>>any(), any(CallOptions.class)))
  /external/grpc-grpc-java/testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/
SimpleServiceGrpc.java 34 io.grpc.testing.protobuf.SimpleResponse> getUnaryRpcMethod;
39 responseType = io.grpc.testing.protobuf.SimpleResponse.class,
42 io.grpc.testing.protobuf.SimpleResponse> getUnaryRpcMethod() {
43 io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse> getUnaryRpcMethod;
48 io.grpc.MethodDescriptor.<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse>newBuilder()
56 io.grpc.testing.protobuf.SimpleResponse.getDefaultInstance()))
66 io.grpc.testing.protobuf.SimpleResponse> getClientStreamingRpcMethod;
71 responseType = io.grpc.testing.protobuf.SimpleResponse.class,
74 io.grpc.testing.protobuf.SimpleResponse> getClientStreamingRpcMethod() {
75 io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse> getClientStreamingRpcMethod
    [all...]
  /external/grpc-grpc/test/cpp/interop/
interop_client.h 34 const SimpleRequest*, const SimpleResponse*)>
116 bool PerformLargeUnary(SimpleRequest* request, SimpleResponse* response);
119 bool PerformLargeUnary(SimpleRequest* request, SimpleResponse* response,
http2_client.cc 67 Status Http2Client::SendUnaryCall(SimpleResponse* response) {
83 SimpleResponse response;
94 SimpleResponse response;
105 SimpleResponse response;
115 SimpleResponse response;
135 SimpleResponse response;
145 SimpleResponse response;
156 SimpleResponse response;
http2_client.h 58 Status SendUnaryCall(SimpleResponse* response);
interop_client.cc 54 const SimpleRequest* request, const SimpleResponse* response) {}
58 const SimpleResponse* response) {
171 SimpleResponse* response) {
176 SimpleResponse* response,
210 SimpleResponse response;
234 SimpleResponse response;
258 SimpleResponse response;
284 SimpleResponse response;
300 SimpleResponse response;
312 SimpleResponse probe_res
    [all...]
  /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
BenchmarkServiceImpl.cs 38 public override Task<SimpleResponse> UnaryCall(SimpleRequest request, ServerCallContext context)
40 var response = new SimpleResponse { Payload = CreateZerosPayload(request.ResponseSize) };
44 public override async Task StreamingCall(IAsyncStreamReader<SimpleRequest> requestStream, IServerStreamWriter<SimpleResponse> responseStream, ServerCallContext context)
48 var response = new SimpleResponse { Payload = CreateZerosPayload(request.ResponseSize) };
BenchmarkServiceGrpc.cs 33 static readonly grpc::Marshaller<global::Grpc.Testing.SimpleResponse> __Marshaller_grpc_testing_SimpleResponse = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.SimpleResponse.Parser.ParseFrom);
35 static readonly grpc::Method<global::Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_UnaryCall = new grpc::Method<global::Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse>(
42 static readonly grpc::Method<global::Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_StreamingCall = new grpc::Method<global::Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse>(
49 static readonly grpc::Method<global::Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_StreamingFromClient = new grpc::Method<global::Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse>(
56 static readonly grpc::Method<global::Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_StreamingFromServer = new grpc::Method<global::Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse>(
    [all...]
  /external/grpc-grpc/src/ruby/pb/src/proto/grpc/testing/
test_services_pb.rb 41 rpc :UnaryCall, SimpleRequest, SimpleResponse
45 rpc :CacheableUnaryCall, SimpleRequest, SimpleResponse
  /external/grpc-grpc-java/gae-interop-testing/gae-jdk8/src/main/java/io/grpc/testing/integration/
LongLivedChannel.java 24 import io.grpc.testing.integration.Messages.SimpleResponse;
66 SimpleResponse simpleResponse = blockingStub.unaryCall(request);
68 if (simpleResponse.getPayload().getBody().size() == responseSize) {
  /external/grpc-grpc-java/netty/shaded/src/testShadow/java/io/grpc/netty/shaded/
ShadingTest.java 33 import io.grpc.testing.protobuf.SimpleResponse;
84 assertThat(SimpleResponse.getDefaultInstance())
102 assertThat(SimpleResponse.getDefaultInstance())
107 @Override public void unaryRpc(SimpleRequest req, StreamObserver<SimpleResponse> obs) {
108 obs.onNext(SimpleResponse.getDefaultInstance());
  /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
Http2Client.java 35 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) {
304 public List<SimpleResponse> getResponses() {
352 private void assertResponseEquals(SimpleResponse response, SimpleResponse goldenResponse) {
  /external/golang-protobuf/protoc-gen-go/testdata/grpc/
grpc.pb.go 56 type SimpleResponse struct {
62 func (m *SimpleResponse) Reset() { *m = SimpleResponse{} }
63 func (m *SimpleResponse) String() string { return proto.CompactTextString(m) }
64 func (*SimpleResponse) ProtoMessage() {}
65 func (*SimpleResponse) Descriptor() ([]byte, []int) {
69 func (m *SimpleResponse) XXX_Unmarshal(b []byte) error {
72 func (m *SimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
75 func (m *SimpleResponse) XXX_Merge(src proto.Message) {
78 func (m *SimpleResponse) XXX_Size() int
    [all...]
  /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
CascadingTest.java 44 import io.grpc.testing.integration.Messages.SimpleResponse;
106 Future<SimpleResponse> future;
141 Future<SimpleResponse> future = futureStub.unaryCall(SimpleRequest.getDefaultInstance());
191 final StreamObserver<SimpleResponse> responseObserver) {
198 responseObserver.onNext(SimpleResponse.getDefaultInstance());
234 final StreamObserver<SimpleResponse> responseObserver) {
306 new StreamObserver<Messages.SimpleResponse>() {
308 public void onNext(Messages.SimpleResponse value) {
  /external/grpc-grpc-java/testing/src/test/java/io/grpc/testing/
GrpcServerRuleTest.java 25 import io.grpc.testing.protobuf.SimpleResponse;
191 SimpleRequest request, StreamObserver<SimpleResponse> responseObserver) {
195 responseObserver.onNext(SimpleResponse.getDefaultInstance());
202 SimpleRequest request, StreamObserver<SimpleResponse> responseObserver) {
206 responseObserver.onNext(SimpleResponse.getDefaultInstance());
  /external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
TestServiceGrpc.java 67 io.grpc.testing.integration.Messages.SimpleResponse> getUnaryCallMethod;
72 responseType = io.grpc.testing.integration.Messages.SimpleResponse.class,
75 io.grpc.testing.integration.Messages.SimpleResponse> getUnaryCallMethod() {
76 io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest, io.grpc.testing.integration.Messages.SimpleResponse> getUnaryCallMethod;
81 io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.SimpleRequest, io.grpc.testing.integration.Messages.SimpleResponse>newBuilder()
89 io.grpc.testing.integration.Messages.SimpleResponse.getDefaultInstance()))
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() {
108 io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest, io.grpc.testing.integration.Messages.SimpleResponse> getCacheableUnaryCallMethod
    [all...]
  /external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/
SimpleResponse.php 14 * Generated from protobuf message <code>grpc.testing.SimpleResponse</code>
16 class SimpleResponse extends \Google\Protobuf\Internal\Message
  /external/grpc-grpc/src/ruby/qps/
qps-common.rb 71 sr = Grpc::Testing::SimpleResponse
  /external/grpc-grpc-java/testing-proto/src/test/java/io/grpc/testing/protobuf/
SimpleServiceTest.java 58 MethodDescriptor<SimpleRequest, SimpleResponse> genericTypeShouldMatchWhenAssigned;
88 MethodDescriptor<SimpleRequest, SimpleResponse> descriptor, RpcMethod annotation) {
100 assertEquals(SimpleResponse.class, annotation.responseType());
102 assertEquals(SimpleResponse.class.getCanonicalName(), e.getTypeMirror().toString());

Completed in 543 milliseconds

1 2 3