|
@@ -28,7 +28,6 @@ import io.netty.channel.ChannelHandlerContext;
|
|
import io.netty.channel.ChannelInboundHandlerAdapter;
|
|
import io.netty.channel.ChannelInboundHandlerAdapter;
|
|
import org.apache.hadoop.thirdparty.com.google.common.annotations.VisibleForTesting;
|
|
import org.apache.hadoop.thirdparty.com.google.common.annotations.VisibleForTesting;
|
|
import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState;
|
|
import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState;
|
|
-import org.apache.hadoop.oncrpc.security.Verifier;
|
|
|
|
import org.apache.hadoop.oncrpc.security.VerifierNone;
|
|
import org.apache.hadoop.oncrpc.security.VerifierNone;
|
|
import org.apache.hadoop.portmap.PortmapMapping;
|
|
import org.apache.hadoop.portmap.PortmapMapping;
|
|
import org.apache.hadoop.portmap.PortmapRequest;
|
|
import org.apache.hadoop.portmap.PortmapRequest;
|
|
@@ -213,7 +212,7 @@ public abstract class RpcProgram extends ChannelInboundHandlerAdapter {
|
|
private void sendAcceptedReply(RpcCall call, SocketAddress remoteAddress,
|
|
private void sendAcceptedReply(RpcCall call, SocketAddress remoteAddress,
|
|
AcceptState acceptState, ChannelHandlerContext ctx) {
|
|
AcceptState acceptState, ChannelHandlerContext ctx) {
|
|
RpcAcceptedReply reply = RpcAcceptedReply.getInstance(call.getXid(),
|
|
RpcAcceptedReply reply = RpcAcceptedReply.getInstance(call.getXid(),
|
|
- acceptState, Verifier.VERIFIER_NONE);
|
|
|
|
|
|
+ acceptState, VerifierNone.INSTANCE);
|
|
|
|
|
|
XDR out = new XDR();
|
|
XDR out = new XDR();
|
|
reply.write(out);
|
|
reply.write(out);
|