Package org.apache.hadoop.oncrpc.security

Examples of org.apache.hadoop.oncrpc.security.VerifierNone

174
175
176
177
178
179
180
181
182
183
184
    } else if (portmapProc == PMAPPROC_GETVERSADDR) {
      out = getport(xid, in, out);
    } else {
      LOG.info("PortmapHandler unknown rpc procedure=" + portmapProc);
      RpcAcceptedReply reply = RpcAcceptedReply.getInstance(xid,
          RpcAcceptedReply.AcceptState.PROC_UNAVAIL, new VerifierNone());
      reply.write(out);
    }

    ChannelBuffer buf = ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap()
        .buffer());
View Full Code Here
24
25
26
27
28
29
30
31
/**
* Helper utility for sending portmap response.
*/
public class PortmapResponse {
  public static XDR voidReply(XDR xdr, int xid) {
    RpcAcceptedReply.getAcceptInstance(xid, new VerifierNone()).write(xdr);
    return xdr;
  }
View Full Code Here
29
30
31
32
33
34
35
36
37
    RpcAcceptedReply.getAcceptInstance(xid, new VerifierNone()).write(xdr);
    return xdr;
  }

  public static XDR intReply(XDR xdr, int xid, int value) {
    RpcAcceptedReply.getAcceptInstance(xid, new VerifierNone()).write(xdr);
    xdr.writeInt(value);
    return xdr;
  }
View Full Code Here
35
36
37
38
39
40
41
42
43
    xdr.writeInt(value);
    return xdr;
  }

  public static XDR booleanReply(XDR xdr, int xid, boolean value) {
    RpcAcceptedReply.getAcceptInstance(xid, new VerifierNone()).write(xdr);
    xdr.writeBoolean(value);
    return xdr;
  }
View Full Code Here
41
42
43
44
45
46
47
48
49
50
51
    xdr.writeBoolean(value);
    return xdr;
  }

  public static XDR pmapList(XDR xdr, int xid, PortmapMapping[] list) {
    RpcAcceptedReply.getAcceptInstance(xid, new VerifierNone()).write(xdr);
    for (PortmapMapping mapping : list) {
      xdr.writeBoolean(true); // Value follows
      mapping.serialize(xdr);
    }
    xdr.writeBoolean(false); // No value follows
View Full Code Here
36
37
38
39
40
41
42
43
44
    int procedure = set ? RpcProgramPortmap.PMAPPROC_SET
        : RpcProgramPortmap.PMAPPROC_UNSET;
    RpcCall call = RpcCall.getInstance(
        RpcUtil.getNewXid(String.valueOf(RpcProgramPortmap.PROGRAM)),
        RpcProgramPortmap.PROGRAM, RpcProgramPortmap.VERSION, procedure,
        new CredentialsNone(), new VerifierNone());
    call.write(request);
    return mapping.serialize(request);
  }
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
  }
 
  /** Response for RPC call {@link MountInterface.MNTPROC#MNT} */
  public static XDR writeMNTResponse(int status, XDR xdr, int xid,
      byte[] handle) {
    RpcAcceptedReply.getAcceptInstance(xid, new VerifierNone()).write(xdr);
    xdr.writeInt(status);
    if (status == MNT_OK) {
      xdr.writeVariableOpaque(handle);
      // Only MountV3 returns a list of supported authFlavors
      xdr.writeInt(1);
View Full Code Here
49
50
51
52
53
54
55
56
57
58
59
    return xdr;
  }

  /** Response for RPC call {@link MountInterface.MNTPROC#DUMP} */
  public static XDR writeMountList(XDR xdr, int xid, List<MountEntry> mounts) {
    RpcAcceptedReply.getAcceptInstance(xid, new VerifierNone()).write(xdr);
    for (MountEntry mountEntry : mounts) {
      xdr.writeBoolean(true); // Value follows yes
      xdr.writeString(mountEntry.getHost());
      xdr.writeString(mountEntry.getPath());
    }
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
  /** Response for RPC call {@link MountInterface.MNTPROC#EXPORT} */
  public static XDR writeExportList(XDR xdr, int xid, List<String> exports,
      List<NfsExports> hostMatcher) {
    assert (exports.size() == hostMatcher.size());

    RpcAcceptedReply.getAcceptInstance(xid, new VerifierNone()).write(xdr);
    for (int i = 0; i < exports.size(); i++) {
      xdr.writeBoolean(true); // Value follows - yes
      xdr.writeString(exports.get(i));

      // List host groups
View Full Code Here
96
97
98
99
100
101
102
103
  @Override
  public XDR nullOp(XDR out, int xid, InetAddress client) {
    if (LOG.isDebugEnabled()) {
      LOG.debug("MOUNT NULLOP : " + " client: " + client);
    }
    return RpcAcceptedReply.getAcceptInstance(xid, new VerifierNone()).write(
        out);
  }
View Full Code Here
TOP

Related Classes of org.apache.hadoop.oncrpc.security.VerifierNone

  • org.apache.hadoop.hdfs.nfs.mount.RpcProgramMountd
  • org.apache.hadoop.hdfs.nfs.nfs3.OpenFileCtx
  • org.apache.hadoop.hdfs.nfs.nfs3.RpcProgramNfs3
  • org.apache.hadoop.hdfs.nfs.nfs3.WriteManager
  • org.apache.hadoop.hdfs.nfs.TestOutOfOrderWrite
  • org.apache.hadoop.hdfs.nfs.TestPortmapRegister
  • org.apache.hadoop.hdfs.nfs.TestUdpServer
  • org.apache.hadoop.mount.MountResponse
  • org.apache.hadoop.oncrpc.RpcProgram
  • org.apache.hadoop.oncrpc.TestFrameDecoder
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.