import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
public static Resource buildPortRanges(String... ranges) {
  Resource.Builder resources = Resource.newBuilder()
      .setType(Type.RANGES)
      .setName(MesosUtils.PORTS);

  Ranges.Builder rangesBuilder = Ranges.newBuilder();

  for (String range : ranges) {
    String[] split = range.split("\\:");

    rangesBuilder.addRange(
        Range.newBuilder()
        .setBegin(Long.parseLong(split[0]))
        .setEnd(Long.parseLong(split[1])));
  }

  resources.setRanges(rangesBuilder);

  return resources.build();
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
public static long[] getPorts(Resource portsResource, int numPorts) {
  long[] ports = new long[numPorts];
  if (numPorts == 0) {
    return ports;
  }

  int idx = 0;

  for (Range r : portsResource.getRanges().getRangeList()) {
    for (long port = r.getBegin(); port <= r.getEnd(); port++) {
      ports[idx++] = port;

      if (idx >= numPorts) {
        return ports;
      }
    }
  }

  return ports;
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
private void collectPorts(List<Resource> offers, List<Integer> portList, int maxPorts) {
  for (Resource r : offers) {
    if (r.getName().equals("ports")) {
      for (Range range : r.getRanges().getRangeList()) {
        if (portList.size() >= maxPorts) {
          break;
        } else {
          int start = (int) range.getBegin();
          int end = (int) range.getEnd();
          for (int p = start; p <= end; p++) {
            portList.add(p);
            if (portList.size() >= maxPorts) {
              break;
            }
          }
        }
      }
    }
  }
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
protected List<Resource> getResourcesRange(final List<Resource> offerResources,
                                           final long value,
                                           final String name) {
  for (Resource r : offerResources) {
    if (r.hasReservation()) {
      // skip reserved resources
      continue;
    }
    if (r.getType() == Type.RANGES && r.getName().equals(name)) {
      for (Range range : r.getRanges().getRangeList()) {
        if (value >= range.getBegin() && value <= range.getEnd()) {
          return Arrays.asList(r.toBuilder()
              .setRanges(
                  Ranges.newBuilder()
                      .addRange(
                          Range.newBuilder().setBegin(value).setEnd(value).build()
                      ).build()
              )
              .build()
          );
        }
      }
    }
  }
  return new ArrayList<>();
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
@Test
public void testRangeIsInAny() {
    List<Range> r1 = Arrays.asList(getRange(1, 3), getRange(5, 7));
    assertFalse(RangeUtils.isInAny(r1, 0));
    assertTrue(RangeUtils.isInAny(r1, 1));
    assertTrue(RangeUtils.isInAny(r1, 2));
    assertTrue(RangeUtils.isInAny(r1, 3));
    assertFalse(RangeUtils.isInAny(r1, 4));
    assertTrue(RangeUtils.isInAny(r1, 5));
    assertTrue(RangeUtils.isInAny(r1, 6));
    assertTrue(RangeUtils.isInAny(r1, 7));
    assertFalse(RangeUtils.isInAny(r1, 8));

    List<Range> r2 = Arrays.asList(getRange(2, 2));
    assertFalse(RangeUtils.isInAny(r2, 1));
    assertTrue(RangeUtils.isInAny(r2, 2));
    assertFalse(RangeUtils.isInAny(r2, 3));
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
private Iterator<Long> getPortMappingIterator(TaskInfo taskInfo) {
    List<Resource> list = taskInfo.getResourcesList();
    List<Long> ports = new ArrayList<Long>();
    for (Resource resource : list) {
        String name = resource.getName();
        if ("ports".equals(name)) {
            Ranges ranges = resource.getRanges();
            for (Range range : ranges.getRangeList()) {
                long startPort = range.getBegin();
                long endPort = range.getEnd();
                for (int i = 0; i <= endPort - startPort; i++) {
                    ports.add(startPort + i);
                }
            }
        }
    }
    return ports.iterator();
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
private Iterator<Long> getPortMappingIterator(TaskInfo taskInfo){
	List<Resource> list = taskInfo.getResourcesList();
	List<Long> ports = new ArrayList<Long>();
	for(Resource resource:list){
		String name = resource.getName();
		if("ports".equals(name)){
			Ranges ranges = resource.getRanges();
			for(Range range:ranges.getRangeList()){
				long startPort = range.getBegin();
				long endPort = range.getEnd();
				for(int i=0;i<=endPort-startPort;i++){
					ports.add(startPort+i);
				}
			}
		}
	}
	return ports.iterator();
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
private OfferID findOffer(WorkerSlot worker) {
    int port = worker.getPort();
    ArrayList<Offer> offers = new ArrayList(_offers.values());
    Collections.shuffle(offers);
    for (Offer offer : offers) {
        if (offer.getHostname().equals(worker.getNodeId())) {
            for (Resource r : offer.getResourcesList()) {
                if (r.getName().equals("ports")) {
                    for (Range range : r.getRanges().getRangeList()) {
                        if (port >= range.getBegin() && port <= range.getEnd()) {
                            return offer.getId();
                        }
                    }
                }
            }
        }
    }
    return null;
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
/**
 * Creates string out an offer in a nice format.
 * @param resource - mesos resource to make into string.
 * @return string representing a resource.
 */
public static String getResourceMessage(Resource resource) {
    Type type = resource.getType();
    String ret = resource.getName() +" "+resource.getRole()+ ": ";
    switch (type) {
        case SCALAR:
            ret += resource.getScalar().getValue();
            break;
        case RANGES:
            for (Range range : resource.getRanges().getRangeList())
                ret += range.getBegin() + " - "+range.getEnd()+",";
            break;
        case TEXT:
            ret += " TEXT type...cannot find.";
            break;
        case SET:
            for (String string : resource.getSet().getItemList())
                ret += string + ",";
            break;
    }
    return ret;
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
private static int getNumRanges(List<Resource> resources, String name) {
  int totalRanges = 0;

  for (Range range : getRanges(resources, name).getRangeList()) {
    totalRanges += (range.getEnd() - range.getBegin()) + 1;
  }

  return totalRanges;
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
public static List<Long> getAllPorts(List<Resource> resources) {
  Ranges ranges = getRanges(resources, PORTS);

  final List<Long> ports = Lists.newArrayList();
  if (ranges != null) {
    for (Range range : ranges.getRangeList()) {
      for (long port = range.getBegin(); port <= range.getEnd(); port++) {
        ports.add(port);
      }
    }
  }

  return ports;
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
private int getNumAvailablePorts() {
  int offeredPorts = 0;
  for (Range range : getPortRanges()) {
    offeredPorts += 1 + range.getEnd() - range.getBegin();
  }
  return offeredPorts;
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
private Iterable<Range> getPortRanges() {
  ImmutableList.Builder<Range> ranges = ImmutableList.builder();
  for (Resource r : getResources(PORTS.getMesosName())) {
    ranges.addAll(r.getRanges().getRangeList().iterator());
  }

  return ranges.build();
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
private Resource createPortRanges(Set<Pair<Integer, Integer>> ports) {
  Ranges.Builder ranges = Ranges.newBuilder();
  for (Pair<Integer, Integer> range : ports) {
    ranges.addRange(Range.newBuilder().setBegin(range.getFirst()).setEnd(range.getSecond()));
  }

  return Resource.newBuilder()
      .setName(PORTS.getMesosName())
      .setType(RANGES)
      .setRanges(ranges)
      .build();
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
public static Offer createOffer(
    double cpu,
    double ramMb,
    double diskMb,
    Pair<Integer, Integer> portRange) {

  Ranges portRanges = Ranges.newBuilder()
      .addRange(Range
          .newBuilder().setBegin(portRange.getFirst()).setEnd(portRange.getSecond()).build())
      .build();

  return Offer.newBuilder()
      .addResources(Resource.newBuilder().setType(Type.SCALAR).setName(CPUS.getMesosName())
          .setScalar(Scalar.newBuilder().setValue(cpu)))
      .addResources(Resource.newBuilder().setType(Type.SCALAR).setName(RAM_MB.getMesosName())
          .setScalar(Scalar.newBuilder().setValue(ramMb)))
      .addResources(Resource.newBuilder().setType(Type.SCALAR).setName(DISK_MB.getMesosName())
          .setScalar(Scalar.newBuilder().setValue(diskMb)))
      .addResources(Resource.newBuilder().setType(Type.RANGES).setName(PORTS.getMesosName())
          .setRanges(portRanges))
      .addAttributes(Protos.Attribute.newBuilder().setType(Type.TEXT)
          .setName("host")
          .setText(Protos.Value.Text.newBuilder().setValue("slavehost")))
      .setSlaveId(SlaveID.newBuilder().setValue("SlaveId").build())
      .setHostname("slavehost")
      .setFrameworkId(Protos.FrameworkID.newBuilder().setValue("framework-id").build())
      .setId(OfferID.newBuilder().setValue("OfferId").build())
      .build();
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
/**
 * Create String representation of mesos protobuf Range type.
 */
private static String rangeToString(Range range) {
  String beginStr = String.valueOf(range.getBegin());
  String endStr = String.valueOf(range.getEnd());
  /*
   * A Range representing a single number still has both Range.begin
   * and Range.end populated, but they are set to the same value.
   * In that case we just return "N" instead of "N-N".
   */
  if (range.getBegin() == range.getEnd()) {
    return beginStr;
  } else {
    return beginStr + "-" + endStr;
  }
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
/**
 * Removes the range intervals listed in {@code subtrahend} from {@code minuend}.
 */
public static List<Range> subtractRanges(List<Range> minuend, List<Range> subtrahend) {
    IntervalSet iMinuend = intervalsToIntervalSet(rangesToIntervals(minuend));
    IntervalSet iSubtrahend = intervalsToIntervalSet(rangesToIntervals(subtrahend));
    IntervalSet iDifference = IntervalSet.subtract(iMinuend, iSubtrahend);
    return intervalSetToRanges(iDifference);
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
/**
 * Returns whether the provided value is encompassed by any of the provided ranges.
 */
public static boolean isInAny(List<Range> ranges, long value) {
    for (Interval interval : rangesToIntervals(ranges)) {
        if (interval.a <= value && value <= interval.b) {
            return true;
        }
    }
    return false;
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
private static List<Interval> rangesToIntervals(List<Range> ranges) {
    List<Interval> intervals = new ArrayList<Interval>();
    for (Range range : ranges) {
        intervals.add(rangeToInterval(range));
    }
    return intervals;
}
 

import org.apache.mesos.Protos.Value.Range; //导入依赖的package包/类
private static List<Range> intervalsToRanges(List<Interval> intervals) {
    List<Range> ranges = new ArrayList<Range>();
    for (Interval interval : intervals) {
        ranges.add(Range.newBuilder().setBegin(interval.a).setEnd(interval.b).build());
    }
    return ranges;
}