aboutsummaryrefslogtreecommitdiff
path: root/benchmarks
diff options
context:
space:
mode:
authorCarl Mastrangelo <notcarl@google.com>2018-06-05 11:19:28 -0700
committerGitHub <noreply@github.com>2018-06-05 11:19:28 -0700
commit4c4fda3e5d4a08972d48f5e1435bdc5f335350ee (patch)
tree81980fa1f66271db351a33fe6594e21123aa286c /benchmarks
parent8fd762fb8e6d11de6c09c84967620bdb84b71822 (diff)
downloadgrpc-grpc-java-4c4fda3e5d4a08972d48f5e1435bdc5f335350ee.tar.gz
stub: remove static Method descriptors and stabilize method accessors
Diffstat (limited to 'benchmarks')
-rw-r--r--benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/BenchmarkServiceGrpc.java97
-rw-r--r--benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/ReportQpsScenarioServiceGrpc.java23
-rw-r--r--benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/WorkerServiceGrpc.java81
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();
}
}