• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java NfsFileType类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.hadoop.nfs.NfsFileType的典型用法代码示例。如果您正苦于以下问题:Java NfsFileType类的具体用法?Java NfsFileType怎么用?Java NfsFileType使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



NfsFileType类属于org.apache.hadoop.nfs包,在下文中一共展示了NfsFileType类的14个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: getFileAttr

import org.apache.hadoop.nfs.NfsFileType; //导入依赖的package包/类
Nfs3FileAttributes getFileAttr(DFSClient client, FileHandle dirHandle,
    String fileName) throws IOException {
  String fileIdPath = Nfs3Utils.getFileIdPath(dirHandle) + "/" + fileName;
  Nfs3FileAttributes attr = Nfs3Utils.getFileAttr(client, fileIdPath, iug);

  if ((attr != null) && (attr.getType() == NfsFileType.NFSREG.toValue())) {
    OpenFileCtx openFileCtx = fileContextCache.get(new FileHandle(attr
        .getFileId()));

    if (openFileCtx != null) {
      attr.setSize(openFileCtx.getNextOffset());
      attr.setUsed(openFileCtx.getNextOffset());
    }
  }
  return attr;
}
 
开发者ID:naver,项目名称:hadoop,代码行数:17,代码来源:WriteManager.java


示例2: getNfs3FileAttrFromFileStatus

import org.apache.hadoop.nfs.NfsFileType; //导入依赖的package包/类
public static Nfs3FileAttributes getNfs3FileAttrFromFileStatus(
    HdfsFileStatus fs, IdMappingServiceProvider iug) {
  /**
   * Some 32bit Linux client has problem with 64bit fileId: it seems the 32bit
   * client takes only the lower 32bit of the fileId and treats it as signed
   * int. When the 32th bit is 1, the client considers it invalid.
   */
  NfsFileType fileType = fs.isDir() ? NfsFileType.NFSDIR : NfsFileType.NFSREG;
  fileType = fs.isSymlink() ? NfsFileType.NFSLNK : fileType;
  int nlink = (fileType == NfsFileType.NFSDIR) ? fs.getChildrenNum() + 2 : 1;
  long size = (fileType == NfsFileType.NFSDIR) ? getDirSize(fs
      .getChildrenNum()) : fs.getLen();
  return new Nfs3FileAttributes(fileType, nlink,
      fs.getPermission().toShort(), iug.getUidAllowingUnknown(fs.getOwner()),
      iug.getGidAllowingUnknown(fs.getGroup()), size, 0 /* fsid */,
      fs.getFileId(), fs.getModificationTime(), fs.getAccessTime(),
      new Nfs3FileAttributes.Specdata3());
}
 
开发者ID:naver,项目名称:hadoop,代码行数:19,代码来源:Nfs3Utils.java


示例3: getAccessRights

import org.apache.hadoop.nfs.NfsFileType; //导入依赖的package包/类
public static int getAccessRights(int mode, int type) {
  int rtn = 0;
  if (isSet(mode, Nfs3Constant.ACCESS_MODE_READ)) {
    rtn |= Nfs3Constant.ACCESS3_READ;
    // LOOKUP is only meaningful for dir
    if (type == NfsFileType.NFSDIR.toValue()) {
      rtn |= Nfs3Constant.ACCESS3_LOOKUP;
    }
  }
  if (isSet(mode, Nfs3Constant.ACCESS_MODE_WRITE)) {
    rtn |= Nfs3Constant.ACCESS3_MODIFY;
    rtn |= Nfs3Constant.ACCESS3_EXTEND;
    // Set delete bit, UNIX may ignore it for regular file since it's up to
    // parent dir op permission
    rtn |= Nfs3Constant.ACCESS3_DELETE;
  }
  if (isSet(mode, Nfs3Constant.ACCESS_MODE_EXECUTE)) {
    if (type == NfsFileType.NFSREG.toValue()) {
      rtn |= Nfs3Constant.ACCESS3_EXECUTE;
    } else {
      rtn |= Nfs3Constant.ACCESS3_LOOKUP;
    }
  }
  return rtn;
}
 
开发者ID:naver,项目名称:hadoop,代码行数:26,代码来源:Nfs3Utils.java


示例4: Nfs3FileAttributes

import org.apache.hadoop.nfs.NfsFileType; //导入依赖的package包/类
public Nfs3FileAttributes(NfsFileType nfsType, int nlink, short mode, int uid,
    int gid, long size, long fsid, long fileId, long mtime, long atime, Specdata3 rdev) {
  this.type = nfsType.toValue();
  this.mode = mode;
  this.nlink = nlink;
  this.uid = uid;
  this.gid = gid;
  this.size = size;
  this.used = this.size;
  this.rdev = new Specdata3();
  this.fsid = fsid;
  this.fileId = fileId;
  this.mtime = new NfsTime(mtime);
  this.atime = atime != 0 ? new NfsTime(atime) : this.mtime;
  this.ctime = this.mtime;
  this.rdev = rdev;
}
 
开发者ID:naver,项目名称:hadoop,代码行数:18,代码来源:Nfs3FileAttributes.java


示例5: Nfs3FileAttributes

import org.apache.hadoop.nfs.NfsFileType; //导入依赖的package包/类
public Nfs3FileAttributes(NfsFileType nfsType, int nlink, short mode, int uid,
    int gid, long size, long fsid, long fileId, long mtime, long atime) {
  this.type = nfsType.toValue();
  this.mode = mode;
  this.nlink = (type == NfsFileType.NFSDIR.toValue()) ? (nlink + 2) : 1;
  this.uid = uid;
  this.gid = gid;
  this.size = size;
  if(type == NfsFileType.NFSDIR.toValue()) {
    this.size = getDirSize(nlink);
  }
  this.used = this.size;
  this.rdev = new Specdata3();
  this.fsid = fsid;
  this.fileId = fileId;
  this.mtime = new NfsTime(mtime);
  this.atime = atime != 0 ? new NfsTime(atime) : this.mtime;
  this.ctime = this.mtime;
}
 
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:20,代码来源:Nfs3FileAttributes.java


示例6: getFileAttr

import org.apache.hadoop.nfs.NfsFileType; //导入依赖的package包/类
Nfs3FileAttributes getFileAttr(DFSClient client, FileHandle dirHandle,
    String fileName) throws IOException {
  String fileIdPath = Nfs3Utils.getFileIdPath(dirHandle) + "/" + fileName;
  Nfs3FileAttributes attr = Nfs3Utils.getFileAttr(client, fileIdPath, iug);

  if ((attr != null) && (attr.getType() == NfsFileType.NFSREG.toValue())) {
    OpenFileCtx openFileCtx = openFileMap
        .get(new FileHandle(attr.getFileId()));

    if (openFileCtx != null) {
      attr.setSize(openFileCtx.getNextOffset());
      attr.setUsed(openFileCtx.getNextOffset());
    }
  }
  return attr;
}
 
开发者ID:ict-carch,项目名称:hadoop-plus,代码行数:17,代码来源:WriteManager.java


示例7: getAccessRights

import org.apache.hadoop.nfs.NfsFileType; //导入依赖的package包/类
public static int getAccessRights(int mode, int type) {
  int rtn = 0;
  if (isSet(mode, Nfs3Constant.ACCESS_MODE_READ)) {
    rtn |= Nfs3Constant.ACCESS3_READ;
    // LOOKUP is only meaningful for dir
    if (type == NfsFileType.NFSDIR.toValue()) {
      rtn |= Nfs3Constant.ACCESS3_LOOKUP;
    }
  }
  if (isSet(mode, Nfs3Constant.ACCESS_MODE_WRITE)) {
    rtn |= Nfs3Constant.ACCESS3_MODIFY;
    rtn |= Nfs3Constant.ACCESS3_EXTEND;
    // Set delete bit, UNIX may ignore it for regular file since it's up to
    // parent dir op permission
    rtn |= Nfs3Constant.ACCESS3_DELETE;
  }
  if (isSet(mode, Nfs3Constant.ACCESS_MODE_EXECUTE)) {
    if (type == NfsFileType.NFSREG.toValue()) {
      rtn |= Nfs3Constant.ACCESS3_EXECUTE;
    }
  }
  return rtn;
}
 
开发者ID:ict-carch,项目名称:hadoop-plus,代码行数:24,代码来源:Nfs3Utils.java


示例8: Nfs3FileAttributes

import org.apache.hadoop.nfs.NfsFileType; //导入依赖的package包/类
public Nfs3FileAttributes(boolean isDir, int nlink, short mode, int uid,
    int gid, long size, long fsid, long fileid, long mtime, long atime) {
  this.type = isDir ? NfsFileType.NFSDIR.toValue() : NfsFileType.NFSREG
      .toValue();
  this.mode = mode;
  this.nlink = isDir ? (nlink + 2) : 1;
  this.uid = uid;
  this.gid = gid;
  this.size = size;
  if(isDir) {
    this.size = getDirSize(nlink);
  }
  this.used = this.size;
  this.rdev = new Specdata3();
  this.fsid = fsid;
  this.fileid = fileid;
  this.mtime = new NfsTime(mtime);
  this.atime = atime != 0 ? new NfsTime(atime) : this.mtime;
  this.ctime = this.mtime;
}
 
开发者ID:ict-carch,项目名称:hadoop-plus,代码行数:21,代码来源:Nfs3FileAttributes.java


示例9: getFileAttr

import org.apache.hadoop.nfs.NfsFileType; //导入依赖的package包/类
Nfs3FileAttributes getFileAttr(DFSClient client, FileHandle dirHandle,
    String fileName) throws IOException {
  String fileIdPath = Nfs3Utils.getFileIdPath(dirHandle) + "/" + fileName;
  Nfs3FileAttributes attr = Nfs3Utils.getFileAttr(client, fileIdPath, iug);

  if ((attr != null) && (attr.getType() == NfsFileType.NFSREG.toValue())) {
    OpenFileCtx openFileCtx =
        fileContextCache.get(new FileHandle(attr.getFileId()));

    if (openFileCtx != null) {
      attr.setSize(openFileCtx.getNextOffset());
      attr.setUsed(openFileCtx.getNextOffset());
    }
  }
  return attr;
}
 
开发者ID:hopshadoop,项目名称:hops,代码行数:17,代码来源:WriteManager.java


示例10: Nfs3FileAttributes

import org.apache.hadoop.nfs.NfsFileType; //导入依赖的package包/类
public Nfs3FileAttributes(NfsFileType nfsType, int nlink, short mode, int uid,
    int gid, long size, long fsid, long fileid, long mtime, long atime) {
  this.type = nfsType.toValue();
  this.mode = mode;
  this.nlink = (type == NfsFileType.NFSDIR.toValue()) ? (nlink + 2) : 1;
  this.uid = uid;
  this.gid = gid;
  this.size = size;
  if(type == NfsFileType.NFSDIR.toValue()) {
    this.size = getDirSize(nlink);
  }
  this.used = this.size;
  this.rdev = new Specdata3();
  this.fsid = fsid;
  this.fileid = fileid;
  this.mtime = new NfsTime(mtime);
  this.atime = atime != 0 ? new NfsTime(atime) : this.mtime;
  this.ctime = this.mtime;
}
 
开发者ID:chendave,项目名称:hadoop-TCP,代码行数:20,代码来源:Nfs3FileAttributes.java


示例11: getNfs3FileAttrFromFileStatus

import org.apache.hadoop.nfs.NfsFileType; //导入依赖的package包/类
public static Nfs3FileAttributes getNfs3FileAttrFromFileStatus(
    HdfsFileStatus fs, IdMappingServiceProvider iug) {
  /**
   * Some 32bit Linux client has problem with 64bit fileId: it seems the 32bit
   * client takes only the lower 32bit of the fileId and treats it as signed
   * int. When the 32th bit is 1, the client considers it invalid.
   */
  NfsFileType fileType = fs.isDir() ? NfsFileType.NFSDIR : NfsFileType.NFSREG;
  fileType = fs.isSymlink() ? NfsFileType.NFSLNK : fileType;
  
  return new Nfs3FileAttributes(fileType, fs.getChildrenNum(), fs
      .getPermission().toShort(), iug.getUidAllowingUnknown(fs.getOwner()),
      iug.getGidAllowingUnknown(fs.getGroup()), fs.getLen(), 0 /* fsid */,
      fs.getFileId(), fs.getModificationTime(), fs.getAccessTime());
}
 
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:16,代码来源:Nfs3Utils.java


示例12: getNfs3FileAttrFromFileStatus

import org.apache.hadoop.nfs.NfsFileType; //导入依赖的package包/类
public static Nfs3FileAttributes getNfs3FileAttrFromFileStatus(
    HdfsFileStatus fs, IdUserGroup iug) {
  /**
   * Some 32bit Linux client has problem with 64bit fileId: it seems the 32bit
   * client takes only the lower 32bit of the fileId and treats it as signed
   * int. When the 32th bit is 1, the client considers it invalid.
   */
  NfsFileType fileType = fs.isDir() ? NfsFileType.NFSDIR : NfsFileType.NFSREG;
  fileType = fs.isSymlink() ? NfsFileType.NFSLNK : fileType;
  
  return new Nfs3FileAttributes(fileType, fs.getChildrenNum(),
      fs.getPermission().toShort(), iug.getUidAllowingUnknown(fs.getOwner()),
      iug.getGidAllowingUnknown(fs.getGroup()), fs.getLen(), 0 /* fsid */,
      fs.getFileId(), fs.getModificationTime(), fs.getAccessTime());
}
 
开发者ID:hopshadoop,项目名称:hops,代码行数:16,代码来源:Nfs3Utils.java


示例13: getNfs3FileAttrFromFileStatus

import org.apache.hadoop.nfs.NfsFileType; //导入依赖的package包/类
public static Nfs3FileAttributes getNfs3FileAttrFromFileStatus(
    HdfsFileStatus fs, IdUserGroup iug) {
  /**
   * Some 32bit Linux client has problem with 64bit fileId: it seems the 32bit
   * client takes only the lower 32bit of the fileId and treats it as signed
   * int. When the 32th bit is 1, the client considers it invalid.
   */
  NfsFileType fileType = fs.isDir() ? NfsFileType.NFSDIR : NfsFileType.NFSREG;
  fileType = fs.isSymlink() ? NfsFileType.NFSLNK : fileType;
  
  return new Nfs3FileAttributes(fileType, fs.getChildrenNum(), fs
      .getPermission().toShort(), iug.getUidAllowingUnknown(fs.getOwner()),
      iug.getGidAllowingUnknown(fs.getGroup()), fs.getLen(), 0 /* fsid */,
      fs.getFileId(), fs.getModificationTime(), fs.getAccessTime());
}
 
开发者ID:chendave,项目名称:hadoop-TCP,代码行数:16,代码来源:Nfs3Utils.java


示例14: testGetAccessRightsForUserGroup

import org.apache.hadoop.nfs.NfsFileType; //导入依赖的package包/类
@Test
public void testGetAccessRightsForUserGroup() throws IOException {
  Nfs3FileAttributes attr = Mockito.mock(Nfs3FileAttributes.class);
  Mockito.when(attr.getUid()).thenReturn(2);
  Mockito.when(attr.getGid()).thenReturn(3);
  Mockito.when(attr.getMode()).thenReturn(448); // 700
  Mockito.when(attr.getType()).thenReturn(NfsFileType.NFSREG.toValue());
  assertEquals("No access should be allowed as UID does not match attribute over mode 700",
    0, Nfs3Utils.getAccessRightsForUserGroup(3, 3, null, attr));
  Mockito.when(attr.getUid()).thenReturn(2);
  Mockito.when(attr.getGid()).thenReturn(3);
  Mockito.when(attr.getMode()).thenReturn(56); // 070
  Mockito.when(attr.getType()).thenReturn(NfsFileType.NFSREG.toValue());
  assertEquals("No access should be allowed as GID does not match attribute over mode 070",
    0, Nfs3Utils.getAccessRightsForUserGroup(2, 4, null, attr));
  Mockito.when(attr.getUid()).thenReturn(2);
  Mockito.when(attr.getGid()).thenReturn(3);
  Mockito.when(attr.getMode()).thenReturn(7); // 007
  Mockito.when(attr.getType()).thenReturn(NfsFileType.NFSREG.toValue());
  assertEquals("Access should be allowed as mode is 007 and UID/GID do not match",
    61 /* RWX */, Nfs3Utils.getAccessRightsForUserGroup(1, 4, new int[] {5, 6}, attr));
  Mockito.when(attr.getUid()).thenReturn(2);
  Mockito.when(attr.getGid()).thenReturn(10);
  Mockito.when(attr.getMode()).thenReturn(288); // 440
  Mockito.when(attr.getType()).thenReturn(NfsFileType.NFSREG.toValue());
  assertEquals("Access should be allowed as mode is 440 and Aux GID does match",
    1 /* R */, Nfs3Utils.getAccessRightsForUserGroup(3, 4, new int[] {5, 16, 10}, attr));
  Mockito.when(attr.getUid()).thenReturn(2);
  Mockito.when(attr.getGid()).thenReturn(10);
  Mockito.when(attr.getMode()).thenReturn(448); // 700
  Mockito.when(attr.getType()).thenReturn(NfsFileType.NFSDIR.toValue());
  assertEquals("Access should be allowed for dir as mode is 700 and UID does match",
    31 /* Lookup */, Nfs3Utils.getAccessRightsForUserGroup(2, 4, new int[] {5, 16, 10}, attr));
  assertEquals("No access should be allowed for dir as mode is 700 even though GID does match",
    0, Nfs3Utils.getAccessRightsForUserGroup(3, 10, new int[] {5, 16, 4}, attr));
  assertEquals("No access should be allowed for dir as mode is 700 even though AuxGID does match",
    0, Nfs3Utils.getAccessRightsForUserGroup(3, 20, new int[] {5, 10}, attr));
  
  Mockito.when(attr.getUid()).thenReturn(2);
  Mockito.when(attr.getGid()).thenReturn(10);
  Mockito.when(attr.getMode()).thenReturn(457); // 711
  Mockito.when(attr.getType()).thenReturn(NfsFileType.NFSDIR.toValue());
  assertEquals("Access should be allowed for dir as mode is 711 and GID matches",
      2 /* Lookup */, Nfs3Utils.getAccessRightsForUserGroup(3, 10, new int[] {5, 16, 11}, attr));
}
 
开发者ID:naver,项目名称:hadoop,代码行数:46,代码来源:TestNfs3Utils.java



注:本文中的org.apache.hadoop.nfs.NfsFileType类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java Synset类代码示例发布时间:2022-05-22
下一篇:
Java RepositoryModel类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap