/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());
|