import org.apache.hadoop.yarn.proto.YarnServerNodemanagerServiceProtos.LocalResourceStatusProto; //导入依赖的package包/类
@Test(timeout=10000)
public void testLocalResourceStatusSerDe() throws Exception {
  LocalResourceStatus rsrcS = createLocalResourceStatus();
  assertTrue(rsrcS instanceof LocalResourceStatusPBImpl);
  LocalResourceStatusPBImpl rsrcPb = (LocalResourceStatusPBImpl) rsrcS;
  DataOutputBuffer out = new DataOutputBuffer();
  rsrcPb.getProto().writeDelimitedTo(out);
  DataInputBuffer in = new DataInputBuffer();
  in.reset(out.getData(), 0, out.getLength());
  LocalResourceStatusProto rsrcPbD =
    LocalResourceStatusProto.parseDelimitedFrom(in);
  assertNotNull(rsrcPbD);
  LocalResourceStatus rsrcD =
    new LocalResourceStatusPBImpl(rsrcPbD);

  assertEquals(rsrcS, rsrcD);
  assertEquals(createResource(), rsrcS.getResource());
  assertEquals(createResource(), rsrcD.getResource());
}
 

import org.apache.hadoop.yarn.proto.YarnServerNodemanagerServiceProtos.LocalResourceStatusProto; //导入依赖的package包/类
private void initResources() {
  if (this.resources != null) {
    return;
  }
  LocalizerStatusProtoOrBuilder p = viaProto ? proto : builder;
  List<LocalResourceStatusProto> list = p.getResourcesList();
  this.resources = new ArrayList<LocalResourceStatus>();

  for (LocalResourceStatusProto c : list) {
    this.resources.add(convertFromProtoFormat(c));
  }
}
 

import org.apache.hadoop.yarn.proto.YarnServerNodemanagerServiceProtos.LocalResourceStatusProto; //导入依赖的package包/类
private void addResourcesToProto() {
  maybeInitBuilder();
  builder.clearResources();
  if (this.resources == null) 
    return;
  Iterable<LocalResourceStatusProto> iterable =
      new Iterable<LocalResourceStatusProto>() {
    @Override
    public Iterator<LocalResourceStatusProto> iterator() {
      return new Iterator<LocalResourceStatusProto>() {

        Iterator<LocalResourceStatus> iter = resources.iterator();

        @Override
        public boolean hasNext() {
          return iter.hasNext();
        }

        @Override
        public LocalResourceStatusProto next() {
          return convertToProtoFormat(iter.next());
        }

        @Override
        public void remove() {
          throw new UnsupportedOperationException();

        }
      };

    }
  };
  builder.addAllResources(iterable);
}
 

import org.apache.hadoop.yarn.proto.YarnServerNodemanagerServiceProtos.LocalResourceStatusProto; //导入依赖的package包/类
private LocalResourceStatus
    convertFromProtoFormat(LocalResourceStatusProto p) {
  return new LocalResourceStatusPBImpl(p);
}
 

import org.apache.hadoop.yarn.proto.YarnServerNodemanagerServiceProtos.LocalResourceStatusProto; //导入依赖的package包/类
private LocalResourceStatusProto convertToProtoFormat(LocalResourceStatus s) {
  return ((LocalResourceStatusPBImpl)s).getProto();
}
 

import org.apache.hadoop.yarn.proto.YarnServerNodemanagerServiceProtos.LocalResourceStatusProto; //导入依赖的package包/类
public LocalResourceStatusPBImpl() {
  builder = LocalResourceStatusProto.newBuilder();
}
 

import org.apache.hadoop.yarn.proto.YarnServerNodemanagerServiceProtos.LocalResourceStatusProto; //导入依赖的package包/类
public LocalResourceStatusProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}
 

import org.apache.hadoop.yarn.proto.YarnServerNodemanagerServiceProtos.LocalResourceStatusProto; //导入依赖的package包/类
private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = LocalResourceStatusProto.newBuilder(proto);
  }
  viaProto = false;
}