Java 类org.apache.hadoop.hdfs.protocol.proto.AclProtos.AclEditLogProto 实例源码

项目:hadoop    文件:FSEditLogOp.java   
@Override
void readFields(DataInputStream in, int logVersion) throws IOException {
  AclEditLogProto p = AclEditLogProto.parseDelimitedFrom(in);
  if (p == null) {
    throw new IOException("Failed to read fields from SetAclOp");
  }
  src = p.getSrc();
  aclEntries = PBHelper.convertAclEntry(p.getEntriesList());
}
项目:hadoop    文件:FSEditLogOp.java   
@Override
public void writeFields(DataOutputStream out) throws IOException {
  AclEditLogProto.Builder b = AclEditLogProto.newBuilder();
  if (src != null)
    b.setSrc(src);
  b.addAllEntries(PBHelper.convertAclEntryProto(aclEntries));
  b.build().writeDelimitedTo(out);
}
项目:big-c    文件:FSEditLogOp.java   
@Override
void readFields(DataInputStream in, int logVersion) throws IOException {
  AclEditLogProto p = AclEditLogProto.parseDelimitedFrom(in);
  if (p == null) {
    throw new IOException("Failed to read fields from SetAclOp");
  }
  src = p.getSrc();
  aclEntries = PBHelper.convertAclEntry(p.getEntriesList());
}
项目:big-c    文件:FSEditLogOp.java   
@Override
public void writeFields(DataOutputStream out) throws IOException {
  AclEditLogProto.Builder b = AclEditLogProto.newBuilder();
  if (src != null)
    b.setSrc(src);
  b.addAllEntries(PBHelper.convertAclEntryProto(aclEntries));
  b.build().writeDelimitedTo(out);
}
项目:hadoop-2.6.0-cdh5.4.3    文件:FSEditLogOp.java   
@Override
void readFields(DataInputStream in, int logVersion) throws IOException {
  AclEditLogProto p = AclEditLogProto.parseDelimitedFrom(in);
  if (p == null) {
    throw new IOException("Failed to read fields from SetAclOp");
  }
  src = p.getSrc();
  aclEntries = PBHelper.convertAclEntry(p.getEntriesList());
}
项目:hadoop-2.6.0-cdh5.4.3    文件:FSEditLogOp.java   
@Override
public void writeFields(DataOutputStream out) throws IOException {
  AclEditLogProto.Builder b = AclEditLogProto.newBuilder();
  if (src != null)
    b.setSrc(src);
  b.addAllEntries(PBHelper.convertAclEntryProto(aclEntries));
  b.build().writeDelimitedTo(out);
}
项目:FlexMap    文件:FSEditLogOp.java   
@Override
void readFields(DataInputStream in, int logVersion) throws IOException {
  AclEditLogProto p = AclEditLogProto.parseDelimitedFrom(in);
  if (p == null) {
    throw new IOException("Failed to read fields from SetAclOp");
  }
  src = p.getSrc();
  aclEntries = PBHelper.convertAclEntry(p.getEntriesList());
}
项目:FlexMap    文件:FSEditLogOp.java   
@Override
public void writeFields(DataOutputStream out) throws IOException {
  AclEditLogProto.Builder b = AclEditLogProto.newBuilder();
  if (src != null)
    b.setSrc(src);
  b.addAllEntries(PBHelper.convertAclEntryProto(aclEntries));
  b.build().writeDelimitedTo(out);
}
项目:hadoop-on-lustre2    文件:FSEditLogOp.java   
@Override
void readFields(DataInputStream in, int logVersion) throws IOException {
  AclEditLogProto p = AclEditLogProto.parseDelimitedFrom((DataInputStream)in);
  if (p == null) {
    throw new IOException("Failed to read fields from SetAclOp");
  }
  src = p.getSrc();
  aclEntries = PBHelper.convertAclEntry(p.getEntriesList());
}
项目:hadoop-on-lustre2    文件:FSEditLogOp.java   
@Override
public void writeFields(DataOutputStream out) throws IOException {
  AclEditLogProto.Builder b = AclEditLogProto.newBuilder();
  if (src != null)
    b.setSrc(src);
  b.addAllEntries(PBHelper.convertAclEntryProto(aclEntries));
  b.build().writeDelimitedTo(out);
}