diff options
author | Carl Mastrangelo <notcarl@google.com> | 2018-06-05 11:19:28 -0700 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-06-05 11:19:28 -0700 |
commit | 4c4fda3e5d4a08972d48f5e1435bdc5f335350ee (patch) | |
tree | 81980fa1f66271db351a33fe6594e21123aa286c /benchmarks | |
parent | 8fd762fb8e6d11de6c09c84967620bdb84b71822 (diff) | |
download | grpc-grpc-java-4c4fda3e5d4a08972d48f5e1435bdc5f335350ee.tar.gz |
stub: remove static Method descriptors and stabilize method accessors
Diffstat (limited to 'benchmarks')
3 files changed, 49 insertions, 152 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 211a2ea0c..82cb5b2b0 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 @@ -27,22 +27,11 @@ public final class BenchmarkServiceGrpc { public static final String SERVICE_NAME = "grpc.testing.BenchmarkService"; // Static method descriptors that strictly reflect the proto. - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") - @java.lang.Deprecated // Use {@link #getUnaryCallMethod()} instead. - public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, - io.grpc.benchmarks.proto.Messages.SimpleResponse> METHOD_UNARY_CALL = getUnaryCallMethodHelper(); - private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getUnaryCallMethod; - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getUnaryCallMethod() { - return getUnaryCallMethodHelper(); - } - - private static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, - io.grpc.benchmarks.proto.Messages.SimpleResponse> getUnaryCallMethodHelper() { io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getUnaryCallMethod; if ((getUnaryCallMethod = BenchmarkServiceGrpc.getUnaryCallMethod) == null) { synchronized (BenchmarkServiceGrpc.class) { @@ -64,22 +53,12 @@ public final class BenchmarkServiceGrpc { } return getUnaryCallMethod; } - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") - @java.lang.Deprecated // Use {@link #getStreamingCallMethod()} instead. - public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, - io.grpc.benchmarks.proto.Messages.SimpleResponse> METHOD_STREAMING_CALL = getStreamingCallMethodHelper(); private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingCallMethod; - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingCallMethod() { - return getStreamingCallMethodHelper(); - } - - private static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, - io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingCallMethodHelper() { io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingCallMethod; if ((getStreamingCallMethod = BenchmarkServiceGrpc.getStreamingCallMethod) == null) { synchronized (BenchmarkServiceGrpc.class) { @@ -101,22 +80,12 @@ public final class BenchmarkServiceGrpc { } return getStreamingCallMethod; } - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") - @java.lang.Deprecated // Use {@link #getStreamingFromClientMethod()} instead. - public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, - io.grpc.benchmarks.proto.Messages.SimpleResponse> METHOD_STREAMING_FROM_CLIENT = getStreamingFromClientMethodHelper(); private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingFromClientMethod; - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingFromClientMethod() { - return getStreamingFromClientMethodHelper(); - } - - private static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, - io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingFromClientMethodHelper() { io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingFromClientMethod; if ((getStreamingFromClientMethod = BenchmarkServiceGrpc.getStreamingFromClientMethod) == null) { synchronized (BenchmarkServiceGrpc.class) { @@ -138,22 +107,12 @@ public final class BenchmarkServiceGrpc { } return getStreamingFromClientMethod; } - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") - @java.lang.Deprecated // Use {@link #getStreamingFromServerMethod()} instead. - public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, - io.grpc.benchmarks.proto.Messages.SimpleResponse> METHOD_STREAMING_FROM_SERVER = getStreamingFromServerMethodHelper(); private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingFromServerMethod; - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingFromServerMethod() { - return getStreamingFromServerMethodHelper(); - } - - private static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, - io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingFromServerMethodHelper() { io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingFromServerMethod; if ((getStreamingFromServerMethod = BenchmarkServiceGrpc.getStreamingFromServerMethod) == null) { synchronized (BenchmarkServiceGrpc.class) { @@ -175,22 +134,12 @@ public final class BenchmarkServiceGrpc { } return getStreamingFromServerMethod; } - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") - @java.lang.Deprecated // Use {@link #getStreamingBothWaysMethod()} instead. - public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, - io.grpc.benchmarks.proto.Messages.SimpleResponse> METHOD_STREAMING_BOTH_WAYS = getStreamingBothWaysMethodHelper(); private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingBothWaysMethod; - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingBothWaysMethod() { - return getStreamingBothWaysMethodHelper(); - } - - private static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, - io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingBothWaysMethodHelper() { io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingBothWaysMethod; if ((getStreamingBothWaysMethod = BenchmarkServiceGrpc.getStreamingBothWaysMethod) == null) { synchronized (BenchmarkServiceGrpc.class) { @@ -248,7 +197,7 @@ public final class BenchmarkServiceGrpc { */ public void unaryCall(io.grpc.benchmarks.proto.Messages.SimpleRequest request, io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { - asyncUnimplementedUnaryCall(getUnaryCallMethodHelper(), responseObserver); + asyncUnimplementedUnaryCall(getUnaryCallMethod(), responseObserver); } /** @@ -260,7 +209,7 @@ public final class BenchmarkServiceGrpc { */ public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleRequest> streamingCall( io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { - return asyncUnimplementedStreamingCall(getStreamingCallMethodHelper(), responseObserver); + return asyncUnimplementedStreamingCall(getStreamingCallMethod(), responseObserver); } /** @@ -271,7 +220,7 @@ public final class BenchmarkServiceGrpc { */ public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleRequest> streamingFromClient( io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { - return asyncUnimplementedStreamingCall(getStreamingFromClientMethodHelper(), responseObserver); + return asyncUnimplementedStreamingCall(getStreamingFromClientMethod(), responseObserver); } /** @@ -282,7 +231,7 @@ public final class BenchmarkServiceGrpc { */ public void streamingFromServer(io.grpc.benchmarks.proto.Messages.SimpleRequest request, io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { - asyncUnimplementedUnaryCall(getStreamingFromServerMethodHelper(), responseObserver); + asyncUnimplementedUnaryCall(getStreamingFromServerMethod(), responseObserver); } /** @@ -293,41 +242,41 @@ public final class BenchmarkServiceGrpc { */ public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleRequest> streamingBothWays( io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { - return asyncUnimplementedStreamingCall(getStreamingBothWaysMethodHelper(), responseObserver); + return asyncUnimplementedStreamingCall(getStreamingBothWaysMethod(), responseObserver); } @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) .addMethod( - getUnaryCallMethodHelper(), + getUnaryCallMethod(), asyncUnaryCall( new MethodHandlers< io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>( this, METHODID_UNARY_CALL))) .addMethod( - getStreamingCallMethodHelper(), + getStreamingCallMethod(), asyncBidiStreamingCall( new MethodHandlers< io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>( this, METHODID_STREAMING_CALL))) .addMethod( - getStreamingFromClientMethodHelper(), + getStreamingFromClientMethod(), asyncClientStreamingCall( new MethodHandlers< io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>( this, METHODID_STREAMING_FROM_CLIENT))) .addMethod( - getStreamingFromServerMethodHelper(), + getStreamingFromServerMethod(), asyncServerStreamingCall( new MethodHandlers< io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>( this, METHODID_STREAMING_FROM_SERVER))) .addMethod( - getStreamingBothWaysMethodHelper(), + getStreamingBothWaysMethod(), asyncBidiStreamingCall( new MethodHandlers< io.grpc.benchmarks.proto.Messages.SimpleRequest, @@ -364,7 +313,7 @@ public final class BenchmarkServiceGrpc { public void unaryCall(io.grpc.benchmarks.proto.Messages.SimpleRequest request, io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { asyncUnaryCall( - getChannel().newCall(getUnaryCallMethodHelper(), getCallOptions()), request, responseObserver); + getChannel().newCall(getUnaryCallMethod(), getCallOptions()), request, responseObserver); } /** @@ -377,7 +326,7 @@ public final class BenchmarkServiceGrpc { public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleRequest> streamingCall( io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { return asyncBidiStreamingCall( - getChannel().newCall(getStreamingCallMethodHelper(), getCallOptions()), responseObserver); + getChannel().newCall(getStreamingCallMethod(), getCallOptions()), responseObserver); } /** @@ -389,7 +338,7 @@ public final class BenchmarkServiceGrpc { public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleRequest> streamingFromClient( io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { return asyncClientStreamingCall( - getChannel().newCall(getStreamingFromClientMethodHelper(), getCallOptions()), responseObserver); + getChannel().newCall(getStreamingFromClientMethod(), getCallOptions()), responseObserver); } /** @@ -401,7 +350,7 @@ public final class BenchmarkServiceGrpc { public void streamingFromServer(io.grpc.benchmarks.proto.Messages.SimpleRequest request, io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { asyncServerStreamingCall( - getChannel().newCall(getStreamingFromServerMethodHelper(), getCallOptions()), request, responseObserver); + getChannel().newCall(getStreamingFromServerMethod(), getCallOptions()), request, responseObserver); } /** @@ -413,7 +362,7 @@ public final class BenchmarkServiceGrpc { public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleRequest> streamingBothWays( io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { return asyncBidiStreamingCall( - getChannel().newCall(getStreamingBothWaysMethodHelper(), getCallOptions()), responseObserver); + getChannel().newCall(getStreamingBothWaysMethod(), getCallOptions()), responseObserver); } } @@ -443,7 +392,7 @@ public final class BenchmarkServiceGrpc { */ public io.grpc.benchmarks.proto.Messages.SimpleResponse unaryCall(io.grpc.benchmarks.proto.Messages.SimpleRequest request) { return blockingUnaryCall( - getChannel(), getUnaryCallMethodHelper(), getCallOptions(), request); + getChannel(), getUnaryCallMethod(), getCallOptions(), request); } /** @@ -455,7 +404,7 @@ public final class BenchmarkServiceGrpc { public java.util.Iterator<io.grpc.benchmarks.proto.Messages.SimpleResponse> streamingFromServer( io.grpc.benchmarks.proto.Messages.SimpleRequest request) { return blockingServerStreamingCall( - getChannel(), getStreamingFromServerMethodHelper(), getCallOptions(), request); + getChannel(), getStreamingFromServerMethod(), getCallOptions(), request); } } @@ -486,7 +435,7 @@ public final class BenchmarkServiceGrpc { public com.google.common.util.concurrent.ListenableFuture<io.grpc.benchmarks.proto.Messages.SimpleResponse> unaryCall( io.grpc.benchmarks.proto.Messages.SimpleRequest request) { return futureUnaryCall( - getChannel().newCall(getUnaryCallMethodHelper(), getCallOptions()), request); + getChannel().newCall(getUnaryCallMethod(), getCallOptions()), request); } } @@ -591,11 +540,11 @@ public final class BenchmarkServiceGrpc { if (result == null) { serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) .setSchemaDescriptor(new BenchmarkServiceFileDescriptorSupplier()) - .addMethod(getUnaryCallMethodHelper()) - .addMethod(getStreamingCallMethodHelper()) - .addMethod(getStreamingFromClientMethodHelper()) - .addMethod(getStreamingFromServerMethodHelper()) - .addMethod(getStreamingBothWaysMethodHelper()) + .addMethod(getUnaryCallMethod()) + .addMethod(getStreamingCallMethod()) + .addMethod(getStreamingFromClientMethod()) + .addMethod(getStreamingFromServerMethod()) + .addMethod(getStreamingBothWaysMethod()) .build(); } } 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 380c9663d..8a0cc45e0 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 @@ -27,22 +27,11 @@ public final class ReportQpsScenarioServiceGrpc { public static final String SERVICE_NAME = "grpc.testing.ReportQpsScenarioService"; // Static method descriptors that strictly reflect the proto. - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") - @java.lang.Deprecated // Use {@link #getReportScenarioMethod()} instead. - public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ScenarioResult, - io.grpc.benchmarks.proto.Control.Void> METHOD_REPORT_SCENARIO = getReportScenarioMethodHelper(); - private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ScenarioResult, io.grpc.benchmarks.proto.Control.Void> getReportScenarioMethod; - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ScenarioResult, io.grpc.benchmarks.proto.Control.Void> getReportScenarioMethod() { - return getReportScenarioMethodHelper(); - } - - private static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ScenarioResult, - io.grpc.benchmarks.proto.Control.Void> getReportScenarioMethodHelper() { io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ScenarioResult, io.grpc.benchmarks.proto.Control.Void> getReportScenarioMethod; if ((getReportScenarioMethod = ReportQpsScenarioServiceGrpc.getReportScenarioMethod) == null) { synchronized (ReportQpsScenarioServiceGrpc.class) { @@ -99,13 +88,13 @@ public final class ReportQpsScenarioServiceGrpc { */ public void reportScenario(io.grpc.benchmarks.proto.Control.ScenarioResult request, io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.Void> responseObserver) { - asyncUnimplementedUnaryCall(getReportScenarioMethodHelper(), responseObserver); + asyncUnimplementedUnaryCall(getReportScenarioMethod(), responseObserver); } @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) .addMethod( - getReportScenarioMethodHelper(), + getReportScenarioMethod(), asyncUnaryCall( new MethodHandlers< io.grpc.benchmarks.proto.Control.ScenarioResult, @@ -141,7 +130,7 @@ public final class ReportQpsScenarioServiceGrpc { public void reportScenario(io.grpc.benchmarks.proto.Control.ScenarioResult request, io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.Void> responseObserver) { asyncUnaryCall( - getChannel().newCall(getReportScenarioMethodHelper(), getCallOptions()), request, responseObserver); + getChannel().newCall(getReportScenarioMethod(), getCallOptions()), request, responseObserver); } } @@ -170,7 +159,7 @@ public final class ReportQpsScenarioServiceGrpc { */ public io.grpc.benchmarks.proto.Control.Void reportScenario(io.grpc.benchmarks.proto.Control.ScenarioResult request) { return blockingUnaryCall( - getChannel(), getReportScenarioMethodHelper(), getCallOptions(), request); + getChannel(), getReportScenarioMethod(), getCallOptions(), request); } } @@ -200,7 +189,7 @@ public final class ReportQpsScenarioServiceGrpc { public com.google.common.util.concurrent.ListenableFuture<io.grpc.benchmarks.proto.Control.Void> reportScenario( io.grpc.benchmarks.proto.Control.ScenarioResult request) { return futureUnaryCall( - getChannel().newCall(getReportScenarioMethodHelper(), getCallOptions()), request); + getChannel().newCall(getReportScenarioMethod(), getCallOptions()), request); } } @@ -288,7 +277,7 @@ public final class ReportQpsScenarioServiceGrpc { if (result == null) { serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) .setSchemaDescriptor(new ReportQpsScenarioServiceFileDescriptorSupplier()) - .addMethod(getReportScenarioMethodHelper()) + .addMethod(getReportScenarioMethod()) .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 66229a3aa..eb83c1882 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 @@ -27,22 +27,11 @@ public final class WorkerServiceGrpc { public static final String SERVICE_NAME = "grpc.testing.WorkerService"; // Static method descriptors that strictly reflect the proto. - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") - @java.lang.Deprecated // Use {@link #getRunServerMethod()} instead. - public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ServerArgs, - io.grpc.benchmarks.proto.Control.ServerStatus> METHOD_RUN_SERVER = getRunServerMethodHelper(); - private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ServerArgs, io.grpc.benchmarks.proto.Control.ServerStatus> getRunServerMethod; - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ServerArgs, io.grpc.benchmarks.proto.Control.ServerStatus> getRunServerMethod() { - return getRunServerMethodHelper(); - } - - private static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ServerArgs, - io.grpc.benchmarks.proto.Control.ServerStatus> getRunServerMethodHelper() { io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ServerArgs, io.grpc.benchmarks.proto.Control.ServerStatus> getRunServerMethod; if ((getRunServerMethod = WorkerServiceGrpc.getRunServerMethod) == null) { synchronized (WorkerServiceGrpc.class) { @@ -64,22 +53,12 @@ public final class WorkerServiceGrpc { } return getRunServerMethod; } - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") - @java.lang.Deprecated // Use {@link #getRunClientMethod()} instead. - public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ClientArgs, - io.grpc.benchmarks.proto.Control.ClientStatus> METHOD_RUN_CLIENT = getRunClientMethodHelper(); private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ClientArgs, io.grpc.benchmarks.proto.Control.ClientStatus> getRunClientMethod; - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ClientArgs, io.grpc.benchmarks.proto.Control.ClientStatus> getRunClientMethod() { - return getRunClientMethodHelper(); - } - - private static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ClientArgs, - io.grpc.benchmarks.proto.Control.ClientStatus> getRunClientMethodHelper() { io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ClientArgs, io.grpc.benchmarks.proto.Control.ClientStatus> getRunClientMethod; if ((getRunClientMethod = WorkerServiceGrpc.getRunClientMethod) == null) { synchronized (WorkerServiceGrpc.class) { @@ -101,22 +80,12 @@ public final class WorkerServiceGrpc { } return getRunClientMethod; } - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") - @java.lang.Deprecated // Use {@link #getCoreCountMethod()} instead. - public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.CoreRequest, - io.grpc.benchmarks.proto.Control.CoreResponse> METHOD_CORE_COUNT = getCoreCountMethodHelper(); private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.CoreRequest, io.grpc.benchmarks.proto.Control.CoreResponse> getCoreCountMethod; - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.CoreRequest, io.grpc.benchmarks.proto.Control.CoreResponse> getCoreCountMethod() { - return getCoreCountMethodHelper(); - } - - private static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.CoreRequest, - io.grpc.benchmarks.proto.Control.CoreResponse> getCoreCountMethodHelper() { io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.CoreRequest, io.grpc.benchmarks.proto.Control.CoreResponse> getCoreCountMethod; if ((getCoreCountMethod = WorkerServiceGrpc.getCoreCountMethod) == null) { synchronized (WorkerServiceGrpc.class) { @@ -138,22 +107,12 @@ public final class WorkerServiceGrpc { } return getCoreCountMethod; } - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") - @java.lang.Deprecated // Use {@link #getQuitWorkerMethod()} instead. - public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.Void, - io.grpc.benchmarks.proto.Control.Void> METHOD_QUIT_WORKER = getQuitWorkerMethodHelper(); private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.Void, io.grpc.benchmarks.proto.Control.Void> getQuitWorkerMethod; - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.Void, io.grpc.benchmarks.proto.Control.Void> getQuitWorkerMethod() { - return getQuitWorkerMethodHelper(); - } - - private static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.Void, - io.grpc.benchmarks.proto.Control.Void> getQuitWorkerMethodHelper() { io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.Void, io.grpc.benchmarks.proto.Control.Void> getQuitWorkerMethod; if ((getQuitWorkerMethod = WorkerServiceGrpc.getQuitWorkerMethod) == null) { synchronized (WorkerServiceGrpc.class) { @@ -215,7 +174,7 @@ public final class WorkerServiceGrpc { */ public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ServerArgs> runServer( io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ServerStatus> responseObserver) { - return asyncUnimplementedStreamingCall(getRunServerMethodHelper(), responseObserver); + return asyncUnimplementedStreamingCall(getRunServerMethod(), responseObserver); } /** @@ -230,7 +189,7 @@ public final class WorkerServiceGrpc { */ public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ClientArgs> runClient( io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ClientStatus> responseObserver) { - return asyncUnimplementedStreamingCall(getRunClientMethodHelper(), responseObserver); + return asyncUnimplementedStreamingCall(getRunClientMethod(), responseObserver); } /** @@ -240,7 +199,7 @@ public final class WorkerServiceGrpc { */ public void coreCount(io.grpc.benchmarks.proto.Control.CoreRequest request, io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.CoreResponse> responseObserver) { - asyncUnimplementedUnaryCall(getCoreCountMethodHelper(), responseObserver); + asyncUnimplementedUnaryCall(getCoreCountMethod(), responseObserver); } /** @@ -250,34 +209,34 @@ public final class WorkerServiceGrpc { */ public void quitWorker(io.grpc.benchmarks.proto.Control.Void request, io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.Void> responseObserver) { - asyncUnimplementedUnaryCall(getQuitWorkerMethodHelper(), responseObserver); + asyncUnimplementedUnaryCall(getQuitWorkerMethod(), responseObserver); } @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) .addMethod( - getRunServerMethodHelper(), + getRunServerMethod(), asyncBidiStreamingCall( new MethodHandlers< io.grpc.benchmarks.proto.Control.ServerArgs, io.grpc.benchmarks.proto.Control.ServerStatus>( this, METHODID_RUN_SERVER))) .addMethod( - getRunClientMethodHelper(), + getRunClientMethod(), asyncBidiStreamingCall( new MethodHandlers< io.grpc.benchmarks.proto.Control.ClientArgs, io.grpc.benchmarks.proto.Control.ClientStatus>( this, METHODID_RUN_CLIENT))) .addMethod( - getCoreCountMethodHelper(), + getCoreCountMethod(), asyncUnaryCall( new MethodHandlers< io.grpc.benchmarks.proto.Control.CoreRequest, io.grpc.benchmarks.proto.Control.CoreResponse>( this, METHODID_CORE_COUNT))) .addMethod( - getQuitWorkerMethodHelper(), + getQuitWorkerMethod(), asyncUnaryCall( new MethodHandlers< io.grpc.benchmarks.proto.Control.Void, @@ -318,7 +277,7 @@ public final class WorkerServiceGrpc { public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ServerArgs> runServer( io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ServerStatus> responseObserver) { return asyncBidiStreamingCall( - getChannel().newCall(getRunServerMethodHelper(), getCallOptions()), responseObserver); + getChannel().newCall(getRunServerMethod(), getCallOptions()), responseObserver); } /** @@ -334,7 +293,7 @@ public final class WorkerServiceGrpc { public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ClientArgs> runClient( io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ClientStatus> responseObserver) { return asyncBidiStreamingCall( - getChannel().newCall(getRunClientMethodHelper(), getCallOptions()), responseObserver); + getChannel().newCall(getRunClientMethod(), getCallOptions()), responseObserver); } /** @@ -345,7 +304,7 @@ public final class WorkerServiceGrpc { public void coreCount(io.grpc.benchmarks.proto.Control.CoreRequest request, io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.CoreResponse> responseObserver) { asyncUnaryCall( - getChannel().newCall(getCoreCountMethodHelper(), getCallOptions()), request, responseObserver); + getChannel().newCall(getCoreCountMethod(), getCallOptions()), request, responseObserver); } /** @@ -356,7 +315,7 @@ public final class WorkerServiceGrpc { public void quitWorker(io.grpc.benchmarks.proto.Control.Void request, io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.Void> responseObserver) { asyncUnaryCall( - getChannel().newCall(getQuitWorkerMethodHelper(), getCallOptions()), request, responseObserver); + getChannel().newCall(getQuitWorkerMethod(), getCallOptions()), request, responseObserver); } } @@ -385,7 +344,7 @@ public final class WorkerServiceGrpc { */ public io.grpc.benchmarks.proto.Control.CoreResponse coreCount(io.grpc.benchmarks.proto.Control.CoreRequest request) { return blockingUnaryCall( - getChannel(), getCoreCountMethodHelper(), getCallOptions(), request); + getChannel(), getCoreCountMethod(), getCallOptions(), request); } /** @@ -395,7 +354,7 @@ public final class WorkerServiceGrpc { */ public io.grpc.benchmarks.proto.Control.Void quitWorker(io.grpc.benchmarks.proto.Control.Void request) { return blockingUnaryCall( - getChannel(), getQuitWorkerMethodHelper(), getCallOptions(), request); + getChannel(), getQuitWorkerMethod(), getCallOptions(), request); } } @@ -425,7 +384,7 @@ public final class WorkerServiceGrpc { public com.google.common.util.concurrent.ListenableFuture<io.grpc.benchmarks.proto.Control.CoreResponse> coreCount( io.grpc.benchmarks.proto.Control.CoreRequest request) { return futureUnaryCall( - getChannel().newCall(getCoreCountMethodHelper(), getCallOptions()), request); + getChannel().newCall(getCoreCountMethod(), getCallOptions()), request); } /** @@ -436,7 +395,7 @@ public final class WorkerServiceGrpc { public com.google.common.util.concurrent.ListenableFuture<io.grpc.benchmarks.proto.Control.Void> quitWorker( io.grpc.benchmarks.proto.Control.Void request) { return futureUnaryCall( - getChannel().newCall(getQuitWorkerMethodHelper(), getCallOptions()), request); + getChannel().newCall(getQuitWorkerMethod(), getCallOptions()), request); } } @@ -537,10 +496,10 @@ public final class WorkerServiceGrpc { if (result == null) { serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) .setSchemaDescriptor(new WorkerServiceFileDescriptorSupplier()) - .addMethod(getRunServerMethodHelper()) - .addMethod(getRunClientMethodHelper()) - .addMethod(getCoreCountMethodHelper()) - .addMethod(getQuitWorkerMethodHelper()) + .addMethod(getRunServerMethod()) + .addMethod(getRunClientMethod()) + .addMethod(getCoreCountMethod()) + .addMethod(getQuitWorkerMethod()) .build(); } } |