-
Notifications
You must be signed in to change notification settings - Fork 3.8k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[#9601] Fix tests aarch64 compatible
- Loading branch information
Showing
48 changed files
with
4,662 additions
and
193 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
307 changes: 307 additions & 0 deletions
307
plugins-it/google-grpc-it/src/test/java/io/grpc/examples/helloworld/GreeterGrpc.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,307 @@ | ||
| package io.grpc.examples.helloworld; | ||
|
|
||
| import static io.grpc.MethodDescriptor.generateFullMethodName; | ||
| import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall; | ||
| import static io.grpc.stub.ClientCalls.asyncClientStreamingCall; | ||
| import static io.grpc.stub.ClientCalls.asyncServerStreamingCall; | ||
| import static io.grpc.stub.ClientCalls.asyncUnaryCall; | ||
| import static io.grpc.stub.ClientCalls.blockingServerStreamingCall; | ||
| import static io.grpc.stub.ClientCalls.blockingUnaryCall; | ||
| import static io.grpc.stub.ClientCalls.futureUnaryCall; | ||
| import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall; | ||
| import static io.grpc.stub.ServerCalls.asyncClientStreamingCall; | ||
| import static io.grpc.stub.ServerCalls.asyncServerStreamingCall; | ||
| import static io.grpc.stub.ServerCalls.asyncUnaryCall; | ||
| import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall; | ||
| import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall; | ||
|
|
||
| /** | ||
| * <pre> | ||
| * The greeting service definition. | ||
| * </pre> | ||
| */ | ||
| @javax.annotation.Generated( | ||
| value = "by gRPC proto compiler (version 1.14.0)", | ||
| comments = "Source: helloworld.proto") | ||
| public final class GreeterGrpc { | ||
|
|
||
| private GreeterGrpc() {} | ||
|
|
||
| public static final String SERVICE_NAME = "helloworld.Greeter"; | ||
|
|
||
| // Static method descriptors that strictly reflect the proto. | ||
| private static volatile io.grpc.MethodDescriptor<io.grpc.examples.helloworld.HelloRequest, | ||
| io.grpc.examples.helloworld.HelloReply> getSayHelloMethod; | ||
|
|
||
| @io.grpc.stub.annotations.RpcMethod( | ||
| fullMethodName = SERVICE_NAME + '/' + "SayHello", | ||
| requestType = io.grpc.examples.helloworld.HelloRequest.class, | ||
| responseType = io.grpc.examples.helloworld.HelloReply.class, | ||
| methodType = io.grpc.MethodDescriptor.MethodType.UNARY) | ||
| public static io.grpc.MethodDescriptor<io.grpc.examples.helloworld.HelloRequest, | ||
| io.grpc.examples.helloworld.HelloReply> getSayHelloMethod() { | ||
| io.grpc.MethodDescriptor<io.grpc.examples.helloworld.HelloRequest, io.grpc.examples.helloworld.HelloReply> getSayHelloMethod; | ||
| if ((getSayHelloMethod = GreeterGrpc.getSayHelloMethod) == null) { | ||
| synchronized (GreeterGrpc.class) { | ||
| if ((getSayHelloMethod = GreeterGrpc.getSayHelloMethod) == null) { | ||
| GreeterGrpc.getSayHelloMethod = getSayHelloMethod = | ||
| io.grpc.MethodDescriptor.<io.grpc.examples.helloworld.HelloRequest, io.grpc.examples.helloworld.HelloReply>newBuilder() | ||
| .setType(io.grpc.MethodDescriptor.MethodType.UNARY) | ||
| .setFullMethodName(generateFullMethodName( | ||
| "helloworld.Greeter", "SayHello")) | ||
| .setSampledToLocalTracing(true) | ||
| .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( | ||
| io.grpc.examples.helloworld.HelloRequest.getDefaultInstance())) | ||
| .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( | ||
| io.grpc.examples.helloworld.HelloReply.getDefaultInstance())) | ||
| .setSchemaDescriptor(new GreeterMethodDescriptorSupplier("SayHello")) | ||
| .build(); | ||
| } | ||
| } | ||
| } | ||
| return getSayHelloMethod; | ||
| } | ||
|
|
||
| /** | ||
| * Creates a new async stub that supports all call types for the service | ||
| */ | ||
| public static GreeterStub newStub(io.grpc.Channel channel) { | ||
| return new GreeterStub(channel); | ||
| } | ||
|
|
||
| /** | ||
| * Creates a new blocking-style stub that supports unary and streaming output calls on the service | ||
| */ | ||
| public static GreeterBlockingStub newBlockingStub( | ||
| io.grpc.Channel channel) { | ||
| return new GreeterBlockingStub(channel); | ||
| } | ||
|
|
||
| /** | ||
| * Creates a new ListenableFuture-style stub that supports unary calls on the service | ||
| */ | ||
| public static GreeterFutureStub newFutureStub( | ||
| io.grpc.Channel channel) { | ||
| return new GreeterFutureStub(channel); | ||
| } | ||
|
|
||
| /** | ||
| * <pre> | ||
| * The greeting service definition. | ||
| * </pre> | ||
| */ | ||
| public static abstract class GreeterImplBase implements io.grpc.BindableService { | ||
|
|
||
| /** | ||
| * <pre> | ||
| * Sends a greeting | ||
| * </pre> | ||
| */ | ||
| public void sayHello(io.grpc.examples.helloworld.HelloRequest request, | ||
| io.grpc.stub.StreamObserver<io.grpc.examples.helloworld.HelloReply> responseObserver) { | ||
| asyncUnimplementedUnaryCall(getSayHelloMethod(), responseObserver); | ||
| } | ||
|
|
||
| @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { | ||
| return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) | ||
| .addMethod( | ||
| getSayHelloMethod(), | ||
| asyncUnaryCall( | ||
| new MethodHandlers< | ||
| io.grpc.examples.helloworld.HelloRequest, | ||
| io.grpc.examples.helloworld.HelloReply>( | ||
| this, METHODID_SAY_HELLO))) | ||
| .build(); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * <pre> | ||
| * The greeting service definition. | ||
| * </pre> | ||
| */ | ||
| public static final class GreeterStub extends io.grpc.stub.AbstractStub<GreeterStub> { | ||
| private GreeterStub(io.grpc.Channel channel) { | ||
| super(channel); | ||
| } | ||
|
|
||
| private GreeterStub(io.grpc.Channel channel, | ||
| io.grpc.CallOptions callOptions) { | ||
| super(channel, callOptions); | ||
| } | ||
|
|
||
| @java.lang.Override | ||
| protected GreeterStub build(io.grpc.Channel channel, | ||
| io.grpc.CallOptions callOptions) { | ||
| return new GreeterStub(channel, callOptions); | ||
| } | ||
|
|
||
| /** | ||
| * <pre> | ||
| * Sends a greeting | ||
| * </pre> | ||
| */ | ||
| public void sayHello(io.grpc.examples.helloworld.HelloRequest request, | ||
| io.grpc.stub.StreamObserver<io.grpc.examples.helloworld.HelloReply> responseObserver) { | ||
| asyncUnaryCall( | ||
| getChannel().newCall(getSayHelloMethod(), getCallOptions()), request, responseObserver); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * <pre> | ||
| * The greeting service definition. | ||
| * </pre> | ||
| */ | ||
| public static final class GreeterBlockingStub extends io.grpc.stub.AbstractStub<GreeterBlockingStub> { | ||
| private GreeterBlockingStub(io.grpc.Channel channel) { | ||
| super(channel); | ||
| } | ||
|
|
||
| private GreeterBlockingStub(io.grpc.Channel channel, | ||
| io.grpc.CallOptions callOptions) { | ||
| super(channel, callOptions); | ||
| } | ||
|
|
||
| @java.lang.Override | ||
| protected GreeterBlockingStub build(io.grpc.Channel channel, | ||
| io.grpc.CallOptions callOptions) { | ||
| return new GreeterBlockingStub(channel, callOptions); | ||
| } | ||
|
|
||
| /** | ||
| * <pre> | ||
| * Sends a greeting | ||
| * </pre> | ||
| */ | ||
| public io.grpc.examples.helloworld.HelloReply sayHello(io.grpc.examples.helloworld.HelloRequest request) { | ||
| return blockingUnaryCall( | ||
| getChannel(), getSayHelloMethod(), getCallOptions(), request); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * <pre> | ||
| * The greeting service definition. | ||
| * </pre> | ||
| */ | ||
| public static final class GreeterFutureStub extends io.grpc.stub.AbstractStub<GreeterFutureStub> { | ||
| private GreeterFutureStub(io.grpc.Channel channel) { | ||
| super(channel); | ||
| } | ||
|
|
||
| private GreeterFutureStub(io.grpc.Channel channel, | ||
| io.grpc.CallOptions callOptions) { | ||
| super(channel, callOptions); | ||
| } | ||
|
|
||
| @java.lang.Override | ||
| protected GreeterFutureStub build(io.grpc.Channel channel, | ||
| io.grpc.CallOptions callOptions) { | ||
| return new GreeterFutureStub(channel, callOptions); | ||
| } | ||
|
|
||
| /** | ||
| * <pre> | ||
| * Sends a greeting | ||
| * </pre> | ||
| */ | ||
| public com.google.common.util.concurrent.ListenableFuture<io.grpc.examples.helloworld.HelloReply> sayHello( | ||
| io.grpc.examples.helloworld.HelloRequest request) { | ||
| return futureUnaryCall( | ||
| getChannel().newCall(getSayHelloMethod(), getCallOptions()), request); | ||
| } | ||
| } | ||
|
|
||
| private static final int METHODID_SAY_HELLO = 0; | ||
|
|
||
| private static final class MethodHandlers<Req, Resp> implements | ||
| io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>, | ||
| io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>, | ||
| io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>, | ||
| io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> { | ||
| private final GreeterImplBase serviceImpl; | ||
| private final int methodId; | ||
|
|
||
| MethodHandlers(GreeterImplBase serviceImpl, int methodId) { | ||
| this.serviceImpl = serviceImpl; | ||
| this.methodId = methodId; | ||
| } | ||
|
|
||
| @java.lang.Override | ||
| @java.lang.SuppressWarnings("unchecked") | ||
| public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { | ||
| switch (methodId) { | ||
| case METHODID_SAY_HELLO: | ||
| serviceImpl.sayHello((io.grpc.examples.helloworld.HelloRequest) request, | ||
| (io.grpc.stub.StreamObserver<io.grpc.examples.helloworld.HelloReply>) responseObserver); | ||
| break; | ||
| default: | ||
| throw new AssertionError(); | ||
| } | ||
| } | ||
|
|
||
| @java.lang.Override | ||
| @java.lang.SuppressWarnings("unchecked") | ||
| public io.grpc.stub.StreamObserver<Req> invoke( | ||
| io.grpc.stub.StreamObserver<Resp> responseObserver) { | ||
| switch (methodId) { | ||
| default: | ||
| throw new AssertionError(); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| private static abstract class GreeterBaseDescriptorSupplier | ||
| implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier { | ||
| GreeterBaseDescriptorSupplier() {} | ||
|
|
||
| @java.lang.Override | ||
| public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() { | ||
| return io.grpc.examples.helloworld.HelloWorldProto.getDescriptor(); | ||
| } | ||
|
|
||
| @java.lang.Override | ||
| public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() { | ||
| return getFileDescriptor().findServiceByName("Greeter"); | ||
| } | ||
| } | ||
|
|
||
| private static final class GreeterFileDescriptorSupplier | ||
| extends GreeterBaseDescriptorSupplier { | ||
| GreeterFileDescriptorSupplier() {} | ||
| } | ||
|
|
||
| private static final class GreeterMethodDescriptorSupplier | ||
| extends GreeterBaseDescriptorSupplier | ||
| implements io.grpc.protobuf.ProtoMethodDescriptorSupplier { | ||
| private final String methodName; | ||
|
|
||
| GreeterMethodDescriptorSupplier(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; | ||
|
|
||
| public static io.grpc.ServiceDescriptor getServiceDescriptor() { | ||
| io.grpc.ServiceDescriptor result = serviceDescriptor; | ||
| if (result == null) { | ||
| synchronized (GreeterGrpc.class) { | ||
| result = serviceDescriptor; | ||
| if (result == null) { | ||
| serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) | ||
| .setSchemaDescriptor(new GreeterFileDescriptorSupplier()) | ||
| .addMethod(getSayHelloMethod()) | ||
| .build(); | ||
| } | ||
| } | ||
| } | ||
| return result; | ||
| } | ||
| } |
Oops, something went wrong.