import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalResourceStatus; //导入依赖的package包/类
@Override
public boolean matches(Object o) {
  LocalizerStatus status = (LocalizerStatus) o;
  for (LocalResourceStatus localized : status.getResources()) {
    switch (localized.getStatus()) {
    case FETCH_SUCCESS:
      if (localized.getLocalPath().getFile().contains(
            rsrc.getResource().getFile())) {
        return true;
      }
      break;
    default:
      fail("Unexpected: " + localized.getStatus());
      break;
    }
  }
  return false;
}
 

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalResourceStatus; //导入依赖的package包/类
static LocalResourceStatus createLocalResourceStatus() {
  LocalResourceStatus ret =
    recordFactory.newRecordInstance(LocalResourceStatus.class);
  assertTrue(ret instanceof LocalResourceStatusPBImpl);
  ret.setResource(createResource());
  ret.setLocalPath(
      ConverterUtils.getYarnUrlFromPath(
        new Path("file:///local/foo/bar")));
  ret.setStatus(ResourceStatusType.FETCH_SUCCESS);
  ret.setLocalSize(4443L);
  Exception e = new Exception("Dingos.");
  e.setStackTrace(new StackTraceElement[] {
      new StackTraceElement("foo", "bar", "baz", 10),
      new StackTraceElement("sbb", "one", "onm", 10) });
  ret.setException(SerializedException.newInstance(e));
  return ret;
}
 

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalResourceStatus; //导入依赖的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.server.nodemanager.api.protocolrecords.LocalResourceStatus; //导入依赖的package包/类
static LocalResourceStatus createLocalResourceStatus() {
  LocalResourceStatus ret =
    recordFactory.newRecordInstance(LocalResourceStatus.class);
  assertTrue(ret instanceof LocalResourceStatusPBImpl);
  ret.setResource(createResource());
  ret.setLocalPath(
      URL.fromPath(
        new Path("file:///local/foo/bar")));
  ret.setStatus(ResourceStatusType.FETCH_SUCCESS);
  ret.setLocalSize(4443L);
  Exception e = new Exception("Dingos.");
  e.setStackTrace(new StackTraceElement[] {
      new StackTraceElement("foo", "bar", "baz", 10),
      new StackTraceElement("sbb", "one", "onm", 10) });
  ret.setException(SerializedException.newInstance(e));
  return ret;
}
 

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalResourceStatus; //导入依赖的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.server.nodemanager.api.protocolrecords.LocalResourceStatus; //导入依赖的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.server.nodemanager.api.protocolrecords.LocalResourceStatus; //导入依赖的package包/类
@Override
public void addAllResources(List<LocalResourceStatus> resources) {
  if (resources == null)
    return;
  initResources();
  this.resources.addAll(resources);
}
 

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalResourceStatus; //导入依赖的package包/类
private LocalizerStatus createLocalizerStatusForFailedResource(
    String localizerId, LocalResourceRequest req) {
  LocalizerStatus status = createLocalizerStatus(localizerId);
  LocalResourceStatus resourceStatus = new LocalResourceStatusPBImpl();
  resourceStatus.setException(SerializedException
    .newInstance(new YarnException("test")));
  resourceStatus.setStatus(ResourceStatusType.FETCH_FAILURE);
  resourceStatus.setResource(req);
  status.addResourceStatus(resourceStatus);
  return status;
}