grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

compiler: set safe and idempotent bits on method descriptors

This commit is contained in:
Carl Mastrangelo 2019-09-25 20:10:06 -07:00 committed by Eric Anderson
parent 4503a233f4
commit f2d0f87d2e
5 changed files with 382 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
compiler/src/java_plugin/cpp/java_generator.cpp
View File

@ -426,7 +426,22 @@ static void PrintMethodFields(
" $service_class_name$.$method_new_field_name$ = $method_new_field_name$ =\n"
" $MethodDescriptor$.<$input_type$, $output_type$>newBuilder()\n"
" .setType($MethodType$.$method_type$)\n"
" .setFullMethodName(generateFullMethodName(SERVICE_NAME, \"$method_name$\"))\n"
" .setFullMethodName(generateFullMethodName(SERVICE_NAME, \"$method_name$\"))\n");
bool safe = method->options().idempotency_level()
== google::protobuf::MethodOptions_IdempotencyLevel_NO_SIDE_EFFECTS;
if (safe) {
p->Print(*vars, " .setSafe(true)\n");
} else {
bool idempotent = method->options().idempotency_level()
== google::protobuf::MethodOptions_IdempotencyLevel_IDEMPOTENT;
if (idempotent) {
p->Print(*vars, " .setIdempotent(true)\n");
}
}
p->Print(
*vars,
" .setSampledToLocalTracing(true)\n"
" .setRequestMarshaller($ProtoUtils$.marshaller(\n"
" $input_type$.getDefaultInstance()))\n"

182
compiler/src/test/golden/TestService.java.txt
View File

@ -216,6 +216,70 @@ public final class TestServiceGrpc {
return getImportMethod;
}
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.compiler.Test.SimpleResponse> getSafeCallMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "SafeCall",
requestType = io.grpc.testing.compiler.Test.SimpleRequest.class,
responseType = io.grpc.testing.compiler.Test.SimpleResponse.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.compiler.Test.SimpleResponse> getSafeCallMethod() {
io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse> getSafeCallMethod;
if ((getSafeCallMethod = TestServiceGrpc.getSafeCallMethod) == null) {
synchronized (TestServiceGrpc.class) {
if ((getSafeCallMethod = TestServiceGrpc.getSafeCallMethod) == null) {
TestServiceGrpc.getSafeCallMethod = getSafeCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName(SERVICE_NAME, "SafeCall"))
.setSafe(true)
.setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("SafeCall"))
.build();
}
}
}
return getSafeCallMethod;
}
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.compiler.Test.SimpleResponse> getIdempotentCallMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "IdempotentCall",
requestType = io.grpc.testing.compiler.Test.SimpleRequest.class,
responseType = io.grpc.testing.compiler.Test.SimpleResponse.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.compiler.Test.SimpleResponse> getIdempotentCallMethod() {
io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse> getIdempotentCallMethod;
if ((getIdempotentCallMethod = TestServiceGrpc.getIdempotentCallMethod) == null) {
synchronized (TestServiceGrpc.class) {
if ((getIdempotentCallMethod = TestServiceGrpc.getIdempotentCallMethod) == null) {
TestServiceGrpc.getIdempotentCallMethod = getIdempotentCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName(SERVICE_NAME, "IdempotentCall"))
.setIdempotent(true)
.setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("IdempotentCall"))
.build();
}
}
}
return getIdempotentCallMethod;
}
/**
* Creates a new async stub that supports all call types for the service
*/
@ -336,6 +400,26 @@ public final class TestServiceGrpc {
return asyncUnimplementedStreamingCall(getImportMethod(), responseObserver);
}
/**
* <pre>
* A unary call that is Safe.
* </pre>
*/
public void safeCall(io.grpc.testing.compiler.Test.SimpleRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
asyncUnimplementedUnaryCall(getSafeCallMethod(), responseObserver);
}
/**
* <pre>
* A unary call that is Idempotent.
* </pre>
*/
public void idempotentCall(io.grpc.testing.compiler.Test.SimpleRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
asyncUnimplementedUnaryCall(getIdempotentCallMethod(), responseObserver);
}
@java.lang.Override public final io.grpc.ServerServiceDefinition bindService() {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
@ -380,6 +464,20 @@ public final class TestServiceGrpc {
io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.compiler.Test.StreamingInputCallResponse>(
this, METHODID_IMPORT)))
.addMethod(
getSafeCallMethod(),
asyncUnaryCall(
new MethodHandlers<
io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.compiler.Test.SimpleResponse>(
this, METHODID_SAFE_CALL)))
.addMethod(
getIdempotentCallMethod(),
asyncUnaryCall(
new MethodHandlers<
io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.compiler.Test.SimpleResponse>(
this, METHODID_IDEMPOTENT_CALL)))
.build();
}
}
@ -475,6 +573,28 @@ public final class TestServiceGrpc {
return asyncBidiStreamingCall(
getChannel().newCall(getImportMethod(), getCallOptions()), responseObserver);
}
/**
* <pre>
* A unary call that is Safe.
* </pre>
*/
public void safeCall(io.grpc.testing.compiler.Test.SimpleRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
asyncUnaryCall(
getChannel().newCall(getSafeCallMethod(), getCallOptions()), request, responseObserver);
}
/**
* <pre>
* A unary call that is Idempotent.
* </pre>
*/
public void idempotentCall(io.grpc.testing.compiler.Test.SimpleRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
asyncUnaryCall(
getChannel().newCall(getIdempotentCallMethod(), getCallOptions()), request, responseObserver);
}
}
/**
@ -516,6 +636,26 @@ public final class TestServiceGrpc {
return blockingServerStreamingCall(
getChannel(), getStreamingOutputCallMethod(), getCallOptions(), request);
}
/**
* <pre>
* A unary call that is Safe.
* </pre>
*/
public io.grpc.testing.compiler.Test.SimpleResponse safeCall(io.grpc.testing.compiler.Test.SimpleRequest request) {
return blockingUnaryCall(
getChannel(), getSafeCallMethod(), getCallOptions(), request);
}
/**
* <pre>
* A unary call that is Idempotent.
* </pre>
*/
public io.grpc.testing.compiler.Test.SimpleResponse idempotentCall(io.grpc.testing.compiler.Test.SimpleRequest request) {
return blockingUnaryCall(
getChannel(), getIdempotentCallMethod(), getCallOptions(), request);
}
}
/**
@ -546,14 +686,38 @@ public final class TestServiceGrpc {
return futureUnaryCall(
getChannel().newCall(getUnaryCallMethod(), getCallOptions()), request);
}
/**
* <pre>
* A unary call that is Safe.
* </pre>
*/
public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.compiler.Test.SimpleResponse> safeCall(
io.grpc.testing.compiler.Test.SimpleRequest request) {
return futureUnaryCall(
getChannel().newCall(getSafeCallMethod(), getCallOptions()), request);
}
/**
* <pre>
* A unary call that is Idempotent.
* </pre>
*/
public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.compiler.Test.SimpleResponse> idempotentCall(
io.grpc.testing.compiler.Test.SimpleRequest request) {
return futureUnaryCall(
getChannel().newCall(getIdempotentCallMethod(), getCallOptions()), request);
}
}
private static final int METHODID_UNARY_CALL = 0;
private static final int METHODID_STREAMING_OUTPUT_CALL = 1;
private static final int METHODID_STREAMING_INPUT_CALL = 2;
private static final int METHODID_FULL_BIDI_CALL = 3;
private static final int METHODID_HALF_BIDI_CALL = 4;
private static final int METHODID_IMPORT = 5;
private static final int METHODID_SAFE_CALL = 2;
private static final int METHODID_IDEMPOTENT_CALL = 3;
private static final int METHODID_STREAMING_INPUT_CALL = 4;
private static final int METHODID_FULL_BIDI_CALL = 5;
private static final int METHODID_HALF_BIDI_CALL = 6;
private static final int METHODID_IMPORT = 7;
private static final class MethodHandlers<Req, Resp> implements
io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
@ -580,6 +744,14 @@ public final class TestServiceGrpc {
serviceImpl.streamingOutputCall((io.grpc.testing.compiler.Test.StreamingOutputCallRequest) request,
(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse>) responseObserver);
break;
case METHODID_SAFE_CALL:
serviceImpl.safeCall((io.grpc.testing.compiler.Test.SimpleRequest) request,
(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse>) responseObserver);
break;
case METHODID_IDEMPOTENT_CALL:
serviceImpl.idempotentCall((io.grpc.testing.compiler.Test.SimpleRequest) request,
(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse>) responseObserver);
break;
default:
throw new AssertionError();
}
@ -659,6 +831,8 @@ public final class TestServiceGrpc {
.addMethod(getFullBidiCallMethod())
.addMethod(getHalfBidiCallMethod())
.addMethod(getImportMethod())
.addMethod(getSafeCallMethod())
.addMethod(getIdempotentCallMethod())
.build();
}
}

12
compiler/src/test/proto/grpc/testing/compiler/test.proto
View File

@ -70,6 +70,16 @@ service TestService {
// An RPC method whose Java name collides with a keyword, and whose generated
// method should have a '_' appended.
rpc Import(stream StreamingInputCallRequest) returns (stream StreamingInputCallResponse);
// A unary call that is Safe.
rpc SafeCall(SimpleRequest) returns (SimpleResponse) {
option idempotency_level = NO_SIDE_EFFECTS;
}
// A unary call that is Idempotent.
rpc IdempotentCall(SimpleRequest) returns (SimpleResponse) {
option idempotency_level = IDEMPOTENT;
}
}
// Test service that has been deprecated and should generate with Java's @Deprecated annotation
@ -80,4 +90,4 @@ service TestDeprecatedService {
rpc DeprecatedMethod(SimpleRequest) returns (SimpleResponse) {
option deprecated = true;
}
}
}

180
compiler/src/testLite/golden/TestService.java.txt
View File

@ -210,6 +210,68 @@ public final class TestServiceGrpc {
return getImportMethod;
}
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.compiler.Test.SimpleResponse> getSafeCallMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "SafeCall",
requestType = io.grpc.testing.compiler.Test.SimpleRequest.class,
responseType = io.grpc.testing.compiler.Test.SimpleResponse.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.compiler.Test.SimpleResponse> getSafeCallMethod() {
io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse> getSafeCallMethod;
if ((getSafeCallMethod = TestServiceGrpc.getSafeCallMethod) == null) {
synchronized (TestServiceGrpc.class) {
if ((getSafeCallMethod = TestServiceGrpc.getSafeCallMethod) == null) {
TestServiceGrpc.getSafeCallMethod = getSafeCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName(SERVICE_NAME, "SafeCall"))
.setSafe(true)
.setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance()))
.build();
}
}
}
return getSafeCallMethod;
}
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.compiler.Test.SimpleResponse> getIdempotentCallMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "IdempotentCall",
requestType = io.grpc.testing.compiler.Test.SimpleRequest.class,
responseType = io.grpc.testing.compiler.Test.SimpleResponse.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.compiler.Test.SimpleResponse> getIdempotentCallMethod() {
io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse> getIdempotentCallMethod;
if ((getIdempotentCallMethod = TestServiceGrpc.getIdempotentCallMethod) == null) {
synchronized (TestServiceGrpc.class) {
if ((getIdempotentCallMethod = TestServiceGrpc.getIdempotentCallMethod) == null) {
TestServiceGrpc.getIdempotentCallMethod = getIdempotentCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName(SERVICE_NAME, "IdempotentCall"))
.setIdempotent(true)
.setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance()))
.build();
}
}
}
return getIdempotentCallMethod;
}
/**
* Creates a new async stub that supports all call types for the service
*/
@ -330,6 +392,26 @@ public final class TestServiceGrpc {
return asyncUnimplementedStreamingCall(getImportMethod(), responseObserver);
}
/**
* <pre>
* A unary call that is Safe.
* </pre>
*/
public void safeCall(io.grpc.testing.compiler.Test.SimpleRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
asyncUnimplementedUnaryCall(getSafeCallMethod(), responseObserver);
}
/**
* <pre>
* A unary call that is Idempotent.
* </pre>
*/
public void idempotentCall(io.grpc.testing.compiler.Test.SimpleRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
asyncUnimplementedUnaryCall(getIdempotentCallMethod(), responseObserver);
}
@java.lang.Override public final io.grpc.ServerServiceDefinition bindService() {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
@ -374,6 +456,20 @@ public final class TestServiceGrpc {
io.grpc.testing.compiler.Test.StreamingInputCallRequest,
io.grpc.testing.compiler.Test.StreamingInputCallResponse>(
this, METHODID_IMPORT)))
.addMethod(
getSafeCallMethod(),
asyncUnaryCall(
new MethodHandlers<
io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.compiler.Test.SimpleResponse>(
this, METHODID_SAFE_CALL)))
.addMethod(
getIdempotentCallMethod(),
asyncUnaryCall(
new MethodHandlers<
io.grpc.testing.compiler.Test.SimpleRequest,
io.grpc.testing.compiler.Test.SimpleResponse>(
this, METHODID_IDEMPOTENT_CALL)))
.build();
}
}
@ -469,6 +565,28 @@ public final class TestServiceGrpc {
return asyncBidiStreamingCall(
getChannel().newCall(getImportMethod(), getCallOptions()), responseObserver);
}
/**
* <pre>
* A unary call that is Safe.
* </pre>
*/
public void safeCall(io.grpc.testing.compiler.Test.SimpleRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
asyncUnaryCall(
getChannel().newCall(getSafeCallMethod(), getCallOptions()), request, responseObserver);
}
/**
* <pre>
* A unary call that is Idempotent.
* </pre>
*/
public void idempotentCall(io.grpc.testing.compiler.Test.SimpleRequest request,
io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
asyncUnaryCall(
getChannel().newCall(getIdempotentCallMethod(), getCallOptions()), request, responseObserver);
}
}
/**
@ -510,6 +628,26 @@ public final class TestServiceGrpc {
return blockingServerStreamingCall(
getChannel(), getStreamingOutputCallMethod(), getCallOptions(), request);
}
/**
* <pre>
* A unary call that is Safe.
* </pre>
*/
public io.grpc.testing.compiler.Test.SimpleResponse safeCall(io.grpc.testing.compiler.Test.SimpleRequest request) {
return blockingUnaryCall(
getChannel(), getSafeCallMethod(), getCallOptions(), request);
}
/**
* <pre>
* A unary call that is Idempotent.
* </pre>
*/
public io.grpc.testing.compiler.Test.SimpleResponse idempotentCall(io.grpc.testing.compiler.Test.SimpleRequest request) {
return blockingUnaryCall(
getChannel(), getIdempotentCallMethod(), getCallOptions(), request);
}
}
/**
@ -540,14 +678,38 @@ public final class TestServiceGrpc {
return futureUnaryCall(
getChannel().newCall(getUnaryCallMethod(), getCallOptions()), request);
}
/**
* <pre>
* A unary call that is Safe.
* </pre>
*/
public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.compiler.Test.SimpleResponse> safeCall(
io.grpc.testing.compiler.Test.SimpleRequest request) {
return futureUnaryCall(
getChannel().newCall(getSafeCallMethod(), getCallOptions()), request);
}
/**
* <pre>
* A unary call that is Idempotent.
* </pre>
*/
public com.google.common.util.concurrent.ListenableFuture<io.grpc.testing.compiler.Test.SimpleResponse> idempotentCall(
io.grpc.testing.compiler.Test.SimpleRequest request) {
return futureUnaryCall(
getChannel().newCall(getIdempotentCallMethod(), getCallOptions()), request);
}
}
private static final int METHODID_UNARY_CALL = 0;
private static final int METHODID_STREAMING_OUTPUT_CALL = 1;
private static final int METHODID_STREAMING_INPUT_CALL = 2;
private static final int METHODID_FULL_BIDI_CALL = 3;
private static final int METHODID_HALF_BIDI_CALL = 4;
private static final int METHODID_IMPORT = 5;
private static final int METHODID_SAFE_CALL = 2;
private static final int METHODID_IDEMPOTENT_CALL = 3;
private static final int METHODID_STREAMING_INPUT_CALL = 4;
private static final int METHODID_FULL_BIDI_CALL = 5;
private static final int METHODID_HALF_BIDI_CALL = 6;
private static final int METHODID_IMPORT = 7;
private static final class MethodHandlers<Req, Resp> implements
io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
@ -574,6 +736,14 @@ public final class TestServiceGrpc {
serviceImpl.streamingOutputCall((io.grpc.testing.compiler.Test.StreamingOutputCallRequest) request,
(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse>) responseObserver);
break;
case METHODID_SAFE_CALL:
serviceImpl.safeCall((io.grpc.testing.compiler.Test.SimpleRequest) request,
(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse>) responseObserver);
break;
case METHODID_IDEMPOTENT_CALL:
serviceImpl.idempotentCall((io.grpc.testing.compiler.Test.SimpleRequest) request,
(io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse>) responseObserver);
break;
default:
throw new AssertionError();
}
@ -617,6 +787,8 @@ public final class TestServiceGrpc {
.addMethod(getFullBidiCallMethod())
.addMethod(getHalfBidiCallMethod())
.addMethod(getImportMethod())
.addMethod(getSafeCallMethod())
.addMethod(getIdempotentCallMethod())
.build();
}
}

2
okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelBuilder.java
View File

@ -133,7 +133,7 @@ public class OkHttpChannelBuilder extends
* If true, indicates that the transport may use the GET method for RPCs, and may include the
* request body in the query params.
*/
private final boolean useGetForSafeMethods = true;
private final boolean useGetForSafeMethods = false;
protected OkHttpChannelBuilder(String host, int port) {
this(GrpcUtil.authorityFromHostAndPort(host, port));