Examples of ResourceAggregate

org.apache.aurora.gen.ResourceAggregate

Examples of org.apache.aurora.gen.ResourceAggregate

  public void testGetQuota() throws Exception {
    QuotaInfo infoMock = createMock(QuotaInfo.class);
    expect(quotaManager.getQuotaInfo(ROLE)).andReturn(infoMock);
    expect(infoMock.guota()).andReturn(QUOTA);
    expect(infoMock.getProdConsumption()).andReturn(CONSUMED);
    IResourceAggregate nonProdConsumed = IResourceAggregate.build(new ResourceAggregate(1, 0, 0));
    expect(infoMock.getNonProdConsumption()).andReturn(nonProdConsumed);
    control.replay();


    Response response = assertOkResponse(thrift.getQuota(ROLE));
    assertEquals(QUOTA.newBuilder(), response.getResult().getGetQuotaResult().getQuota());

View Full Code Here

Examples of org.apache.aurora.gen.ResourceAggregate

        cpu += task.getNumCpus();
        ramMb += task.getRamMb();
        diskMb += task.getDiskMb();
      }


      return IResourceAggregate.build(new ResourceAggregate()
          .setNumCpus(cpu)
          .setRamMb(ramMb)
          .setDiskMb(diskMb));
    }

View Full Code Here

Examples of org.apache.aurora.gen.ResourceAggregate

          .setRamMb(ramMb)
          .setDiskMb(diskMb));
    }


    private static IResourceAggregate add(IResourceAggregate a, IResourceAggregate b) {
      return IResourceAggregate.build(new ResourceAggregate()
          .setNumCpus(a.getNumCpus() + b.getNumCpus())
          .setRamMb(a.getRamMb() + b.getRamMb())
          .setDiskMb(a.getDiskMb() + b.getDiskMb()));
    }

View Full Code Here

Examples of org.apache.aurora.gen.ResourceAggregate


  /**
   * a * m.
   */
  public static IResourceAggregate scale(IResourceAggregate a, int m) {
    return IResourceAggregate.build(new ResourceAggregate()
        .setNumCpus(a.getNumCpus() * m)
        .setRamMb(a.getRamMb() * m)
        .setDiskMb(a.getDiskMb() * m));
  }

View Full Code Here

Examples of org.apache.aurora.gen.ResourceAggregate


  @Test
  public void testTinyOffers() {
    expectStatExport();
    expectGetSlots(
        new MachineResource(IResourceAggregate.build(new ResourceAggregate(0.1, 1, 1)), false));


    control.replay();


    slotCounter.run();
    assertEquals(0, smallCounter.get());

View Full Code Here

Examples of org.apache.aurora.gen.ResourceAggregate

  @Test
  public void testStarvedResourceVector() {
    expectStatExport();
    expectGetSlots(
        new MachineResource(
            IResourceAggregate.build(new ResourceAggregate(1000, 16384, 1)), false));


    control.replay();


    slotCounter.run();
    assertEquals(0, smallCounter.get());

View Full Code Here

Examples of org.apache.aurora.gen.ResourceAggregate

    expectGetSlots(
        new MachineResource(SMALL, false),
        new MachineResource(SMALL, false),
        new MachineResource(LARGE, false),
        new MachineResource(ResourceAggregates.scale(LARGE, 4), false),
        new MachineResource(IResourceAggregate.build(new ResourceAggregate(1, 1, 1)), false),
        new MachineResource(SMALL, true),
        new MachineResource(SMALL, true),
        new MachineResource(ResourceAggregates.scale(SMALL, 2), true));


    control.replay();

View Full Code Here

Examples of org.apache.aurora.gen.ResourceAggregate

  public void testComputeQuotaAllocationTotals() {
    storage.write(new Storage.MutateWork.NoResult.Quiet() {
      @Override
      protected void execute(Storage.MutableStoreProvider storeProvider) {
        storeProvider.getQuotaStore()
            .saveQuota("a", IResourceAggregate.build(new ResourceAggregate(1, 1, 1)));
        storeProvider.getQuotaStore()
            .saveQuota("b", IResourceAggregate.build(new ResourceAggregate(2, 3, 4)));
      }
    });


    assertEquals(new Metric(3, 4, 5), resourceCounter.computeQuotaAllocationTotals());
  }

View Full Code Here

Examples of org.apache.aurora.gen.ResourceAggregate

      // Calculate result as max(existing, desired) per resource type.
      return max(initial, desired);
    }


    private static IResourceAggregate add(IResourceAggregate a, IResourceAggregate b) {
      return IResourceAggregate.build(new ResourceAggregate()
          .setNumCpus(a.getNumCpus() + b.getNumCpus())
          .setRamMb(a.getRamMb() + b.getRamMb())
          .setDiskMb(a.getDiskMb() + b.getDiskMb()));
    }

View Full Code Here

Examples of org.apache.aurora.gen.ResourceAggregate

          .setRamMb(a.getRamMb() + b.getRamMb())
          .setDiskMb(a.getDiskMb() + b.getDiskMb()));
    }


    private static IResourceAggregate max(IResourceAggregate a, IResourceAggregate b) {
      return IResourceAggregate.build(new ResourceAggregate()
          .setNumCpus(Math.max(a.getNumCpus(), b.getNumCpus()))
          .setRamMb(Math.max(a.getRamMb(), b.getRamMb()))
          .setDiskMb(Math.max(a.getDiskMb(), b.getDiskMb())));
    }

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.