diff options
author | Lukasz Strzalkowski <lukasz@squareup.com> | 2017-06-11 22:00:07 -0700 |
---|---|---|
committer | Eric Anderson <ejona@google.com> | 2017-09-11 09:57:03 -0700 |
commit | 731bbefb1774c108bdde718e1c41a4529b2ac723 (patch) | |
tree | 09d8fa04cdd5c3276683e3913a7cdcc4cc6a9b6f /benchmarks | |
parent | 65530bb71b7a89137daad88e67c23585e98c170d (diff) | |
download | grpc-grpc-java-731bbefb1774c108bdde718e1c41a4529b2ac723.tar.gz |
core, compiler, protobuf: introduce MethodDescriptor#setSchemaDescriptor
Diffstat (limited to 'benchmarks')
3 files changed, 100 insertions, 6 deletions
diff --git a/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/BenchmarkServiceGrpc.java b/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/BenchmarkServiceGrpc.java index d0ecea460..12675c763 100644 --- a/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/BenchmarkServiceGrpc.java +++ b/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/BenchmarkServiceGrpc.java @@ -38,6 +38,7 @@ public final class BenchmarkServiceGrpc { io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance())) + .setSchemaDescriptor(new BenchmarkServiceMethodDescriptorSupplier("UnaryCall")) .build(); @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, @@ -50,6 +51,7 @@ public final class BenchmarkServiceGrpc { io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance())) + .setSchemaDescriptor(new BenchmarkServiceMethodDescriptorSupplier("StreamingCall")) .build(); @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, @@ -62,6 +64,7 @@ public final class BenchmarkServiceGrpc { io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance())) + .setSchemaDescriptor(new BenchmarkServiceMethodDescriptorSupplier("StreamingFromClient")) .build(); @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, @@ -74,6 +77,7 @@ public final class BenchmarkServiceGrpc { io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance())) + .setSchemaDescriptor(new BenchmarkServiceMethodDescriptorSupplier("StreamingFromServer")) .build(); @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, @@ -86,6 +90,7 @@ public final class BenchmarkServiceGrpc { io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance())) + .setSchemaDescriptor(new BenchmarkServiceMethodDescriptorSupplier("StreamingBothWays")) .build(); /** @@ -421,11 +426,39 @@ public final class BenchmarkServiceGrpc { } } - private static final class BenchmarkServiceDescriptorSupplier implements io.grpc.protobuf.ProtoFileDescriptorSupplier { + private static abstract class BenchmarkServiceBaseDescriptorSupplier + implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier { + BenchmarkServiceBaseDescriptorSupplier() {} + @java.lang.Override public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() { return io.grpc.benchmarks.proto.Services.getDescriptor(); } + + @java.lang.Override + public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() { + return getFileDescriptor().findServiceByName("BenchmarkService"); + } + } + + private static final class BenchmarkServiceFileDescriptorSupplier + extends BenchmarkServiceBaseDescriptorSupplier { + BenchmarkServiceFileDescriptorSupplier() {} + } + + private static final class BenchmarkServiceMethodDescriptorSupplier + extends BenchmarkServiceBaseDescriptorSupplier + implements io.grpc.protobuf.ProtoMethodDescriptorSupplier { + private final String methodName; + + BenchmarkServiceMethodDescriptorSupplier(String methodName) { + this.methodName = methodName; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() { + return getServiceDescriptor().findMethodByName(methodName); + } } private static volatile io.grpc.ServiceDescriptor serviceDescriptor; @@ -437,7 +470,7 @@ public final class BenchmarkServiceGrpc { result = serviceDescriptor; if (result == null) { serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) - .setSchemaDescriptor(new BenchmarkServiceDescriptorSupplier()) + .setSchemaDescriptor(new BenchmarkServiceFileDescriptorSupplier()) .addMethod(METHOD_UNARY_CALL) .addMethod(METHOD_STREAMING_CALL) .addMethod(METHOD_STREAMING_FROM_CLIENT) diff --git a/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/ReportQpsScenarioServiceGrpc.java b/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/ReportQpsScenarioServiceGrpc.java index 184556ada..4c89fa0bd 100644 --- a/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/ReportQpsScenarioServiceGrpc.java +++ b/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/ReportQpsScenarioServiceGrpc.java @@ -38,6 +38,7 @@ public final class ReportQpsScenarioServiceGrpc { io.grpc.benchmarks.proto.Control.ScenarioResult.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( io.grpc.benchmarks.proto.Control.Void.getDefaultInstance())) + .setSchemaDescriptor(new ReportQpsScenarioServiceMethodDescriptorSupplier("ReportScenario")) .build(); /** @@ -218,11 +219,39 @@ public final class ReportQpsScenarioServiceGrpc { } } - private static final class ReportQpsScenarioServiceDescriptorSupplier implements io.grpc.protobuf.ProtoFileDescriptorSupplier { + private static abstract class ReportQpsScenarioServiceBaseDescriptorSupplier + implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier { + ReportQpsScenarioServiceBaseDescriptorSupplier() {} + @java.lang.Override public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() { return io.grpc.benchmarks.proto.Services.getDescriptor(); } + + @java.lang.Override + public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() { + return getFileDescriptor().findServiceByName("ReportQpsScenarioService"); + } + } + + private static final class ReportQpsScenarioServiceFileDescriptorSupplier + extends ReportQpsScenarioServiceBaseDescriptorSupplier { + ReportQpsScenarioServiceFileDescriptorSupplier() {} + } + + private static final class ReportQpsScenarioServiceMethodDescriptorSupplier + extends ReportQpsScenarioServiceBaseDescriptorSupplier + implements io.grpc.protobuf.ProtoMethodDescriptorSupplier { + private final String methodName; + + ReportQpsScenarioServiceMethodDescriptorSupplier(String methodName) { + this.methodName = methodName; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() { + return getServiceDescriptor().findMethodByName(methodName); + } } private static volatile io.grpc.ServiceDescriptor serviceDescriptor; @@ -234,7 +263,7 @@ public final class ReportQpsScenarioServiceGrpc { result = serviceDescriptor; if (result == null) { serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) - .setSchemaDescriptor(new ReportQpsScenarioServiceDescriptorSupplier()) + .setSchemaDescriptor(new ReportQpsScenarioServiceFileDescriptorSupplier()) .addMethod(METHOD_REPORT_SCENARIO) .build(); } diff --git a/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/WorkerServiceGrpc.java b/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/WorkerServiceGrpc.java index 314e1ba79..c37708eda 100644 --- a/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/WorkerServiceGrpc.java +++ b/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/WorkerServiceGrpc.java @@ -38,6 +38,7 @@ public final class WorkerServiceGrpc { io.grpc.benchmarks.proto.Control.ServerArgs.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( io.grpc.benchmarks.proto.Control.ServerStatus.getDefaultInstance())) + .setSchemaDescriptor(new WorkerServiceMethodDescriptorSupplier("RunServer")) .build(); @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ClientArgs, @@ -50,6 +51,7 @@ public final class WorkerServiceGrpc { io.grpc.benchmarks.proto.Control.ClientArgs.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( io.grpc.benchmarks.proto.Control.ClientStatus.getDefaultInstance())) + .setSchemaDescriptor(new WorkerServiceMethodDescriptorSupplier("RunClient")) .build(); @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.CoreRequest, @@ -62,6 +64,7 @@ public final class WorkerServiceGrpc { io.grpc.benchmarks.proto.Control.CoreRequest.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( io.grpc.benchmarks.proto.Control.CoreResponse.getDefaultInstance())) + .setSchemaDescriptor(new WorkerServiceMethodDescriptorSupplier("CoreCount")) .build(); @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.Void, @@ -74,6 +77,7 @@ public final class WorkerServiceGrpc { io.grpc.benchmarks.proto.Control.Void.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( io.grpc.benchmarks.proto.Control.Void.getDefaultInstance())) + .setSchemaDescriptor(new WorkerServiceMethodDescriptorSupplier("QuitWorker")) .build(); /** @@ -392,11 +396,39 @@ public final class WorkerServiceGrpc { } } - private static final class WorkerServiceDescriptorSupplier implements io.grpc.protobuf.ProtoFileDescriptorSupplier { + private static abstract class WorkerServiceBaseDescriptorSupplier + implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier { + WorkerServiceBaseDescriptorSupplier() {} + @java.lang.Override public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() { return io.grpc.benchmarks.proto.Services.getDescriptor(); } + + @java.lang.Override + public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() { + return getFileDescriptor().findServiceByName("WorkerService"); + } + } + + private static final class WorkerServiceFileDescriptorSupplier + extends WorkerServiceBaseDescriptorSupplier { + WorkerServiceFileDescriptorSupplier() {} + } + + private static final class WorkerServiceMethodDescriptorSupplier + extends WorkerServiceBaseDescriptorSupplier + implements io.grpc.protobuf.ProtoMethodDescriptorSupplier { + private final String methodName; + + WorkerServiceMethodDescriptorSupplier(String methodName) { + this.methodName = methodName; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() { + return getServiceDescriptor().findMethodByName(methodName); + } } private static volatile io.grpc.ServiceDescriptor serviceDescriptor; @@ -408,7 +440,7 @@ public final class WorkerServiceGrpc { result = serviceDescriptor; if (result == null) { serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) - .setSchemaDescriptor(new WorkerServiceDescriptorSupplier()) + .setSchemaDescriptor(new WorkerServiceFileDescriptorSupplier()) .addMethod(METHOD_RUN_SERVER) .addMethod(METHOD_RUN_CLIENT) .addMethod(METHOD_CORE_COUNT) |