public abstract class org.apache.drill.exec.rpc.BasicServer$ServerHandshakeHandler extends org.apache.drill.exec.rpc.AbstractHandshakeHandler
{
public void <init>(com.google.protobuf.Internal$EnumLite, com.google.protobuf.Parser)
{
org.apache.drill.exec.rpc.BasicServer$ServerHandshakeHandler v;
com.google.protobuf.Internal$EnumLite v;
com.google.protobuf.Parser v;
v := @this: org.apache.drill.exec.rpc.BasicServer$ServerHandshakeHandler;
v := @parameter: com.google.protobuf.Internal$EnumLite;
v := @parameter: com.google.protobuf.Parser;
specialinvoke v.<org.apache.drill.exec.rpc.AbstractHandshakeHandler: void <init>(com.google.protobuf.Internal$EnumLite,com.google.protobuf.Parser)>(v, v);
return;
}
protected void consumeHandshake(io.netty.channel.ChannelHandlerContext, com.google.protobuf.MessageLite) throws java.lang.Exception
{
io.netty.buffer.ByteBuf[] v;
org.apache.drill.exec.rpc.BasicServer$ServerHandshakeHandler v;
org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode v;
com.google.protobuf.MessageLite v, v;
io.netty.channel.ChannelHandlerContext v;
com.google.protobuf.Internal$EnumLite v;
org.apache.drill.exec.rpc.OutboundRpcMessage v;
int v;
v := @this: org.apache.drill.exec.rpc.BasicServer$ServerHandshakeHandler;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: com.google.protobuf.MessageLite;
v = new org.apache.drill.exec.rpc.OutboundRpcMessage;
v = <org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode: org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode RESPONSE>;
v = v.<org.apache.drill.exec.rpc.BasicServer$ServerHandshakeHandler: com.google.protobuf.Internal$EnumLite handshakeType>;
v = v.<org.apache.drill.exec.rpc.BasicServer$ServerHandshakeHandler: int coordinationId>;
v = virtualinvoke v.<org.apache.drill.exec.rpc.BasicServer$ServerHandshakeHandler: com.google.protobuf.MessageLite getHandshakeResponse(com.google.protobuf.MessageLite)>(v);
v = newarray (io.netty.buffer.ByteBuf)[0];
specialinvoke v.<org.apache.drill.exec.rpc.OutboundRpcMessage: void <init>(org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode,com.google.protobuf.Internal$EnumLite,int,com.google.protobuf.MessageLite,io.netty.buffer.ByteBuf[])>(v, v, v, v, v);
interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)>(v);
return;
}
public abstract com.google.protobuf.MessageLite getHandshakeResponse(com.google.protobuf.MessageLite) throws java.lang.Exception;
}