org.apache.hadoop.fs.permission.FsPermission#fromShort ( )源码实例Demo

static void saveINode2Image(INode node,
                                    DataOutputStream out) throws IOException {
  byte[] name = node.getLocalNameBytes();
  out.writeShort(name.length);
  out.write(name);
  FsPermission filePerm = TL_DATA.get().FILE_PERM;
  if (!node.isDirectory()) {  // write file inode
    INodeFile fileINode = (INodeFile)node;
    out.writeShort(fileINode.getReplication());
    out.writeLong(fileINode.getModificationTime());
    out.writeLong(fileINode.getAccessTime());
    out.writeLong(fileINode.getPreferredBlockSize());
    Block[] blocks = fileINode.getBlocks();
    out.writeInt(blocks.length);
    for (Block blk : blocks)
      blk.write(out);
    filePerm.fromShort(fileINode.getFsPermissionShort());
    PermissionStatus.write(out, fileINode.getUserName(),
                           fileINode.getGroupName(),
                           filePerm);
  } else {   // write directory inode
    out.writeShort(0);  // replication
    out.writeLong(node.getModificationTime());
    out.writeLong(0);   // access time
    out.writeLong(0);   // preferred block size
    out.writeInt(-1);    // # of blocks
    out.writeLong(node.getNsQuota());
    out.writeLong(node.getDsQuota());
    filePerm.fromShort(node.getFsPermissionShort());
    PermissionStatus.write(out, node.getUserName(),
                           node.getGroupName(),
                           filePerm);
  }
}
 

private static void writePermissionStatus(INodeAttributes inode,
    DataOutput out) throws IOException {
  final FsPermission p = TL_DATA.get().FILE_PERM;
  p.fromShort(inode.getFsPermissionShort());
  PermissionStatus.write(out, inode.getUserName(), inode.getGroupName(), p);
}
 

private static void writePermissionStatus(INodeAttributes inode,
    DataOutput out) throws IOException {
  final FsPermission p = TL_DATA.get().FILE_PERM;
  p.fromShort(inode.getFsPermissionShort());
  PermissionStatus.write(out, inode.getUserName(), inode.getGroupName(), p);
}