本文整理汇总了Java中org.apache.hadoop.nfs.nfs3.request.SetAttr3.SetAttrField类的典型用法代码示例。如果您正苦于以下问题:Java SetAttrField类的具体用法?Java SetAttrField怎么用?Java SetAttrField使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SetAttrField类属于org.apache.hadoop.nfs.nfs3.request.SetAttr3包,在下文中一共展示了SetAttrField类的5个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: testSetattr
import org.apache.hadoop.nfs.nfs3.request.SetAttr3.SetAttrField; //导入依赖的package包/类
@Test(timeout = 60000)
public void testSetattr() throws Exception {
HdfsFileStatus status = nn.getRpcServer().getFileInfo(testdir);
long dirId = status.getFileId();
XDR xdr_req = new XDR();
FileHandle handle = new FileHandle(dirId);
SetAttr3 symAttr = new SetAttr3(0, 1, 0, 0, null, null,
EnumSet.of(SetAttrField.UID));
SETATTR3Request req = new SETATTR3Request(handle, symAttr, false, null);
req.serialize(xdr_req);
// Attempt by an unprivileged user should fail.
SETATTR3Response response1 = nfsd.setattr(xdr_req.asReadOnlyWrap(),
securityHandlerUnpriviledged,
new InetSocketAddress("localhost", 1234));
assertEquals("Incorrect return code", Nfs3Status.NFS3ERR_ACCES,
response1.getStatus());
// Attempt by a priviledged user should pass.
SETATTR3Response response2 = nfsd.setattr(xdr_req.asReadOnlyWrap(),
securityHandler, new InetSocketAddress("localhost", 1234));
assertEquals("Incorrect return code", Nfs3Status.NFS3_OK,
response2.getStatus());
}
开发者ID:naver,项目名称:hadoop,代码行数:25,代码来源:TestRpcProgramNfs3.java
示例2: setattrInternal
import org.apache.hadoop.nfs.nfs3.request.SetAttr3.SetAttrField; //导入依赖的package包/类
private void setattrInternal(DFSClient dfsClient, String fileIdPath,
SetAttr3 newAttr, boolean setMode) throws IOException {
EnumSet<SetAttrField> updateFields = newAttr.getUpdateFields();
if (setMode && updateFields.contains(SetAttrField.MODE)) {
if (LOG.isDebugEnabled()) {
LOG.debug("set new mode: " + newAttr.getMode());
}
dfsClient.setPermission(fileIdPath,
new FsPermission((short) (newAttr.getMode())));
}
if (updateFields.contains(SetAttrField.UID)
|| updateFields.contains(SetAttrField.GID)) {
String uname = updateFields.contains(SetAttrField.UID) ? iug.getUserName(
newAttr.getUid(), IdMappingConstant.UNKNOWN_USER) : null;
String gname = updateFields.contains(SetAttrField.GID) ? iug
.getGroupName(newAttr.getGid(), IdMappingConstant.UNKNOWN_GROUP) : null;
dfsClient.setOwner(fileIdPath, uname, gname);
}
long atime = updateFields.contains(SetAttrField.ATIME) ? newAttr.getAtime()
.getMilliSeconds() : -1;
long mtime = updateFields.contains(SetAttrField.MTIME) ? newAttr.getMtime()
.getMilliSeconds() : -1;
if (atime != -1 || mtime != -1) {
if (LOG.isDebugEnabled()) {
LOG.debug("set atime: " + +atime + " mtime: " + mtime);
}
dfsClient.setTimes(fileIdPath, mtime, atime);
}
}
开发者ID:naver,项目名称:hadoop,代码行数:32,代码来源:RpcProgramNfs3.java
示例3: setattrInternal
import org.apache.hadoop.nfs.nfs3.request.SetAttr3.SetAttrField; //导入依赖的package包/类
private void setattrInternal(DFSClient dfsClient, String fileIdPath,
SetAttr3 newAttr, boolean setMode) throws IOException {
EnumSet<SetAttrField> updateFields = newAttr.getUpdateFields();
if (setMode && updateFields.contains(SetAttrField.MODE)) {
if (LOG.isDebugEnabled()) {
LOG.debug("set new mode:" + newAttr.getMode());
}
dfsClient.setPermission(fileIdPath,
new FsPermission((short) (newAttr.getMode())));
}
if (updateFields.contains(SetAttrField.UID)
|| updateFields.contains(SetAttrField.GID)) {
String uname = updateFields.contains(SetAttrField.UID) ? iug.getUserName(
newAttr.getUid(), UNKNOWN_USER) : null;
String gname = updateFields.contains(SetAttrField.GID) ? iug
.getGroupName(newAttr.getGid(), UNKNOWN_GROUP) : null;
dfsClient.setOwner(fileIdPath, uname, gname);
}
long atime = updateFields.contains(SetAttrField.ATIME) ? newAttr.getAtime()
.getMilliSeconds() : -1;
long mtime = updateFields.contains(SetAttrField.MTIME) ? newAttr.getMtime()
.getMilliSeconds() : -1;
if (atime != -1 || mtime != -1) {
if (LOG.isDebugEnabled()) {
LOG.debug("set atime:" + +atime + " mtime:" + mtime);
}
dfsClient.setTimes(fileIdPath, mtime, atime);
}
}
开发者ID:ict-carch,项目名称:hadoop-plus,代码行数:32,代码来源:RpcProgramNfs3.java
示例4: setattrInternal
import org.apache.hadoop.nfs.nfs3.request.SetAttr3.SetAttrField; //导入依赖的package包/类
private void setattrInternal(DFSClient dfsClient, String fileIdPath,
SetAttr3 newAttr, boolean setMode) throws IOException {
EnumSet<SetAttrField> updateFields = newAttr.getUpdateFields();
if (setMode && updateFields.contains(SetAttrField.MODE)) {
if (LOG.isDebugEnabled()) {
LOG.debug("set new mode:" + newAttr.getMode());
}
dfsClient.setPermission(fileIdPath,
new FsPermission((short) (newAttr.getMode())));
}
if (updateFields.contains(SetAttrField.UID) ||
updateFields.contains(SetAttrField.GID)) {
String uname = updateFields.contains(SetAttrField.UID) ?
iug.getUserName(newAttr.getUid(), Nfs3Constant.UNKNOWN_USER) : null;
String gname = updateFields.contains(SetAttrField.GID) ?
iug.getGroupName(newAttr.getGid(), Nfs3Constant.UNKNOWN_GROUP) : null;
dfsClient.setOwner(fileIdPath, uname, gname);
}
long atime = updateFields.contains(SetAttrField.ATIME) ?
newAttr.getAtime().getMilliSeconds() : -1;
long mtime = updateFields.contains(SetAttrField.MTIME) ?
newAttr.getMtime().getMilliSeconds() : -1;
if (atime != -1 || mtime != -1) {
if (LOG.isDebugEnabled()) {
LOG.debug("set atime:" + +atime + " mtime:" + mtime);
}
dfsClient.setTimes(fileIdPath, mtime, atime);
}
}
开发者ID:hopshadoop,项目名称:hops,代码行数:32,代码来源:RpcProgramNfs3.java
示例5: setattrInternal
import org.apache.hadoop.nfs.nfs3.request.SetAttr3.SetAttrField; //导入依赖的package包/类
private void setattrInternal(DFSClient dfsClient, String fileIdPath,
SetAttr3 newAttr, boolean setMode) throws IOException {
EnumSet<SetAttrField> updateFields = newAttr.getUpdateFields();
if (setMode && updateFields.contains(SetAttrField.MODE)) {
if (LOG.isDebugEnabled()) {
LOG.debug("set new mode:" + newAttr.getMode());
}
dfsClient.setPermission(fileIdPath,
new FsPermission((short) (newAttr.getMode())));
}
if (updateFields.contains(SetAttrField.UID)
|| updateFields.contains(SetAttrField.GID)) {
String uname = updateFields.contains(SetAttrField.UID) ? iug.getUserName(
newAttr.getUid(), Nfs3Constant.UNKNOWN_USER) : null;
String gname = updateFields.contains(SetAttrField.GID) ? iug
.getGroupName(newAttr.getGid(), Nfs3Constant.UNKNOWN_GROUP) : null;
dfsClient.setOwner(fileIdPath, uname, gname);
}
long atime = updateFields.contains(SetAttrField.ATIME) ? newAttr.getAtime()
.getMilliSeconds() : -1;
long mtime = updateFields.contains(SetAttrField.MTIME) ? newAttr.getMtime()
.getMilliSeconds() : -1;
if (atime != -1 || mtime != -1) {
if (LOG.isDebugEnabled()) {
LOG.debug("set atime:" + +atime + " mtime:" + mtime);
}
dfsClient.setTimes(fileIdPath, mtime, atime);
}
}
开发者ID:chendave,项目名称:hadoop-TCP,代码行数:32,代码来源:RpcProgramNfs3.java
注:本文中的org.apache.hadoop.nfs.nfs3.request.SetAttr3.SetAttrField类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论