/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/util/resource/ |
H A D | DominantResourceCalculator.java | 57 if ((lhs.getMemory() < rhs.getMemory() && lhs.getVirtualCores() > rhs in compare() 62 } else if (lhs.getMemory() > rhs.getMemory() in compare() 65 } else if (lhs.getMemory() < rhs.getMemory() in compare() 103 (float)resource.getMemory() / clusterResource.getMemory(), in getResourceAsValue() 108 (float)resource.getMemory() / clusterResource.getMemory(), in getResourceAsValue() 116 available.getMemory() / required.getMemory(), in computeAvailableContainers() 139 (float)a.getMemory()/b.getMemory(), in ratio() 157 Math.max(r.getMemory(), minimumResource.getMemory()), in normalize() 172 roundUp(r.getMemory(), stepFactor.getMemory()), in roundUp() 180 roundDown(r.getMemory(), stepFactor.getMemory()), in roundDown() [all …]
|
H A D | DefaultResourceCalculator.java | 31 return lhs.getMemory() - rhs.getMemory(); in compare() 37 return available.getMemory() / required.getMemory(); in computeAvailableContainers() 47 if (r.getMemory() == 0.0f) { in isInvalidDivisor() 55 return (float)a.getMemory() / b.getMemory(); in ratio() 69 Math.max(r.getMemory(), minimumResource.getMemory()), in normalize() 70 stepFactor.getMemory()), in normalize() 84 roundUp(r.getMemory(), stepFactor.getMemory()) in roundUp() 91 roundDown(r.getMemory(), stepFactor.getMemory())); in roundDown() 98 roundUp((int)(r.getMemory() * by + 0.5), stepFactor.getMemory()) in multiplyAndNormalizeUp() 107 (int)(r.getMemory() * by), in multiplyAndNormalizeDown() [all …]
|
H A D | Resources.java | 34 public int getMemory() { 55 int diff = 0 - o.getMemory(); 67 public int getMemory() { 88 int diff = 0 - o.getMemory(); 121 lhs.setMemory(lhs.getMemory() + rhs.getMemory()); in addTo() 131 lhs.setMemory(lhs.getMemory() - rhs.getMemory()); in subtractFrom() 145 lhs.setMemory((int)(lhs.getMemory() * by)); in multiplyTo() 166 out.setMemory((int)(lhs.getMemory() * by)); in multiplyAndRoundDown() 255 return smaller.getMemory() <= bigger.getMemory() && in fitsIn() 260 return createResource(Math.min(lhs.getMemory(), rhs.getMemory()), in componentwiseMin() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/ |
H A D | TestReservations.java | 272 assertEquals(2 * GB, a.getUsedResources().getMemory()); in testReservation() 284 assertEquals(5 * GB, a.getUsedResources().getMemory()); in testReservation() 318 .getMemory()); in testReservation() 332 assertEquals(6 * GB, app_0.getHeadroom().getMemory()); in testReservation() 334 .getMemory()); in testReservation() 349 assertEquals(6 * GB, app_0.getHeadroom().getMemory()); in testReservation() 474 .getMemory()); in testReservationNoContinueLook() 488 assertEquals(6 * GB, app_0.getHeadroom().getMemory()); in testReservationNoContinueLook() 490 .getMemory()); in testReservationNoContinueLook() 507 .getMemory()); in testReservationNoContinueLook() [all …]
|
H A D | TestLeafQueue.java | 496 assertEquals(1*GB, a.getUsedResources().getMemory()); in testSingleQueueWithOneUser() 507 assertEquals(2*GB, a.getUsedResources().getMemory()); in testSingleQueueWithOneUser() 733 assertEquals(9*GB,app_0.getHeadroom().getMemory()); in testComputeUserLimitAndSetHeadroom() 756 assertEquals(8*GB, app_0.getHeadroom().getMemory()); in testComputeUserLimitAndSetHeadroom() 758 assertEquals(8*GB, app_2.getHeadroom().getMemory()); in testComputeUserLimitAndSetHeadroom() 798 assertEquals(5*GB, app_3.getHeadroom().getMemory()); in testComputeUserLimitAndSetHeadroom() 799 assertEquals(5*GB, app_1.getHeadroom().getMemory()); in testComputeUserLimitAndSetHeadroom() 823 assertEquals(6*GB, app_3.getHeadroom().getMemory()); in testComputeUserLimitAndSetHeadroom() 829 assertEquals(5*GB, app_4.getHeadroom().getMemory()); in testComputeUserLimitAndSetHeadroom() 892 assertEquals(2*GB, app_0.getHeadroom().getMemory()); in testUserHeadroomMultiApp() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/rm/ |
H A D | ResourceCalculatorUtils.java | 38 return Math.min(available.getMemory() / required.getMemory(), in computeAvailableContainers() 41 return available.getMemory() / required.getMemory(); in computeAvailableContainers() 47 return Math.max(divideAndCeil(required.getMemory(), factor.getMemory()), in divideAndCeilContainers() 50 return divideAndCeil(required.getMemory(), factor.getMemory()); in divideAndCeilContainers()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/ |
H A D | TestFairSchedulerFairShare.java | 140 .getMemory() / nodeCapacity * 100, 0.1); in testFairShareOneAppRunning() 145 .getMemory() / nodeCapacity, 0.1); in testFairShareOneAppRunning() 170 .getMemory() in testFairShareMultipleActiveQueuesUnderSameParent() 203 .getMemory() in testFairShareMultipleActiveQueuesUnderDifferentParent() 213 .getMemory() in testFairShareMultipleActiveQueuesUnderDifferentParent() 240 .getMemory() in testFairShareResetsToZeroWhenAppsComplete() 257 .getMemory() in testFairShareResetsToZeroWhenAppsComplete() 263 .getMemory() in testFairShareResetsToZeroWhenAppsComplete() 296 .getMemory() in testFairShareWithDRFMultipleActiveQueuesUnderDifferentParent() 311 .getMemory() in testFairShareWithDRFMultipleActiveQueuesUnderDifferentParent() [all …]
|
H A D | TestFairScheduler.java | 722 getResourceUsage().getMemory()); in testSimpleContainerAllocation() 768 getResourceUsage().getMemory()); in testSimpleContainerReservation() 895 getResourceUsage().getMemory()); in testContainerReservationNotExceedingQueueMax() 1430 .getDemand().getMemory()); in testQueueDemandCalculation() 1433 .getMemory()); in testQueueDemandCalculation() 3512 .getFairShare().getMemory()); in testQueueMaxAMShare() 3705 .getFairShare().getMemory()); in testQueueMaxAMShareDefault() 3709 .getFairShare().getMemory()); in testQueueMaxAMShareDefault() 3713 .getFairShare().getMemory()); in testQueueMaxAMShareDefault() 3717 .getFairShare().getMemory()); in testQueueMaxAMShareDefault() [all …]
|
H A D | TestFSAppAttempt.java | 239 min(queueStarvation.getMemory(), in testHeadroom() 240 clusterAvailable.getMemory(), in testHeadroom() 241 queueMaxResourcesAvailable.getMemory()), in testHeadroom() 251 min(queueStarvation.getMemory(), in testHeadroom() 252 clusterAvailable.getMemory(), in testHeadroom() 253 queueMaxResourcesAvailable.getMemory()), in testHeadroom() 262 min(queueStarvation.getMemory(), in testHeadroom() 263 clusterAvailable.getMemory(), in testHeadroom() 264 queueMaxResourcesAvailable.getMemory()), in testHeadroom() 278 assertEquals(expectedMemory, headroom.getMemory()); in verifyHeadroom()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/policies/ |
H A D | FairSharePolicy.java | 83 minShareRatio1 = (double) s1.getResourceUsage().getMemory() in compare() 84 / Resources.max(RESOURCE_CALCULATOR, null, minShare1, ONE).getMemory(); in compare() 85 minShareRatio2 = (double) s2.getResourceUsage().getMemory() in compare() 86 / Resources.max(RESOURCE_CALCULATOR, null, minShare2, ONE).getMemory(); in compare() 87 useToWeightRatio1 = s1.getResourceUsage().getMemory() / in compare() 89 useToWeightRatio2 = s2.getResourceUsage().getMemory() / in compare() 121 queueFairShare.getMemory() - queueUsage.getMemory(), 0); in getHeadroom() 123 Math.min(maxAvailable.getMemory(), queueAvailableMemory), in getHeadroom() 148 return usage.getMemory() > maxAMResource.getMemory(); in checkIfAMResourceUsageOverLimit()
|
H A D | FifoPolicy.java | 107 return usage.getMemory() > maxAMResource.getMemory(); in checkIfAMResourceUsageOverLimit() 114 queueFairShare.getMemory() - queueUsage.getMemory(), 0); in getHeadroom() 116 Math.min(maxAvailable.getMemory(), queueAvailableMemory), in getHeadroom()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/dao/ |
H A D | FairSchedulerQueueInfo.java | 78 fractionMemUsed = (float)usedResources.getMemory() / in FairSchedulerQueueInfo() 79 clusterResources.getMemory(); in FairSchedulerQueueInfo() 90 (float)steadyFairResources.getMemory() / clusterResources.getMemory(); in FairSchedulerQueueInfo() 91 fractionMemFairShare = (float) fairResources.getMemory() in FairSchedulerQueueInfo() 92 / clusterResources.getMemory(); in FairSchedulerQueueInfo() 93 fractionMemMinShare = (float)minResources.getMemory() / clusterResources.getMemory(); in FairSchedulerQueueInfo() 94 fractionMemMaxShare = (float)maxResources.getMemory() / clusterResources.getMemory(); in FairSchedulerQueueInfo()
|
H A D | FifoSchedulerInfo.java | 70 this.minQueueMemoryCapacity = fs.getMinimumResourceCapability().getMemory(); in FifoSchedulerInfo() 71 this.maxQueueMemoryCapacity = fs.getMaximumResourceCapability().getMemory(); in FifoSchedulerInfo() 82 this.usedNodeCapacity += report.getUsedResource().getMemory(); in FifoSchedulerInfo() 83 this.availNodeCapacity += report.getAvailableResource().getMemory(); in FifoSchedulerInfo() 84 this.totalNodeCapacity += ni.getTotalCapability().getMemory(); in FifoSchedulerInfo()
|
/dports/cad/digital/Digital-0.27/src/test/java/de/neemann/digital/gui/ |
H A D | ProgramMemoryLoaderTest.java | 31 assertEquals(0x55, ram.getMemory().getDataWord(0)); in testSimple() 32 assertEquals(0xAA, ram.getMemory().getDataWord(1)); in testSimple() 33 assertEquals(0x56, ram.getMemory().getDataWord(2)); in testSimple() 34 assertEquals(0xAB, ram.getMemory().getDataWord(3)); in testSimple() 52 assertEquals(0x55, ram0.getMemory().getDataWord(0)); in testSplit() 53 assertEquals(0xAA, ram1.getMemory().getDataWord(0)); in testSplit() 54 assertEquals(0x56, ram0.getMemory().getDataWord(1)); in testSplit() 55 assertEquals(0xAB, ram1.getMemory().getDataWord(1)); in testSplit()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/ |
H A D | FairSchedulerMetrics.java | 73 return app.getDemand().getMemory(); in trackApp() 89 return app.getResourceUsage().getMemory(); in trackApp() 105 return app.getMinShare().getMemory(); in trackApp() 113 return app.getMinShare().getMemory(); in trackApp() 121 return Math.min(app.getMaxShare().getMemory(), totalMemoryMB); in trackApp() 160 return queue.getDemand().getMemory(); in trackQueue() 176 return queue.getResourceUsage().getMemory(); in trackQueue() 192 return queue.getMinShare().getMemory(); in trackQueue() 224 return Math.min(queue.getMaxShare().getMemory(), totalMemoryMB); in trackQueue() 240 return queue.getFairShare().getMemory(); in trackQueue()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/ |
H A D | Resource.java | 69 public abstract int getMemory(); in getMemory() method in Resource 112 result = 939769357 + getMemory(); // prime * result = 939769357 initially in hashCode() 126 if (getMemory() != other.getMemory() || in equals() 135 return "<memory:" + getMemory() + ", vCores:" + getVirtualCores() + ">"; in toString()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/ |
H A D | TestFifoScheduler.java | 158 Assert.assertEquals(2 * GB, report_nm1.getUsedResource().getMemory()); in test() 168 Assert.assertEquals(2 * GB, report_nm2.getUsedResource().getMemory()); in test() 204 Assert.assertEquals(0, report_nm1.getAvailableResource().getMemory()); in test() 207 Assert.assertEquals(6 * GB, report_nm1.getUsedResource().getMemory()); in test() 208 Assert.assertEquals(2 * GB, report_nm2.getUsedResource().getMemory()); in test() 211 Assert.assertEquals(GB, c1.getResource().getMemory()); in test() 225 Assert.assertEquals(5 * GB, report_nm1.getUsedResource().getMemory()); in test() 520 allocation1.getResourceLimit().getMemory()); in testHeadroom() 524 allocation2.getResourceLimit().getMemory()); in testHeadroom() 545 Assert.assertEquals(2 * GB, report_nm1.getUsedResource().getMemory()); in testResourceOverCommit() [all …]
|
/dports/java/openjdk8/jdk8u-jdk8u312-b07.1/hotspot/agent/src/share/classes/sun/jvm/hotspot/memory/ |
H A D | CodeHeap.java | 72 return getMemory().low(); in begin() 76 return getMemory().high(); in end() 106 private VirtualSpace getMemory() { in getMemory() method in CodeHeap 115 return p.minus(getMemory().low()) >> getLog2SegmentSize(); in segmentFor() 142 return getMemory().low().addOffsetTo(i << getLog2SegmentSize()); in blockBase()
|
/dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/hotspot/agent/src/share/classes/sun/jvm/hotspot/memory/ |
H A D | CodeHeap.java | 72 return getMemory().low(); in begin() 76 return getMemory().high(); in end() 106 private VirtualSpace getMemory() { in getMemory() method in CodeHeap 115 return p.minus(getMemory().low()) >> getLog2SegmentSize(); in segmentFor() 142 return getMemory().low().addOffsetTo(i << getLog2SegmentSize()); in blockBase()
|
/dports/sysutils/triton/Triton-0.8.1/src/examples/cpp/ |
H A D | ir.cpp | 59 …std::cout << "\t base : " << inst.operands[op_index].getMemory().getBaseRegister() << std::endl; in main() 60 …std::cout << "\t index : " << inst.operands[op_index].getMemory().getIndexRegister() << std::end… in main() 61 …std::cout << "\t disp : " << inst.operands[op_index].getMemory().getDisplacement() << std::endl; in main() 62 std::cout << "\t scale : " << inst.operands[op_index].getMemory().getScale() << std::endl; in main()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ |
H A D | ResourcePBImpl.java | 59 public int getMemory() { in getMemory() method in ResourcePBImpl 61 return (p.getMemory()); in getMemory() 84 int diff = this.getMemory() - other.getMemory(); in compareTo()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/metrics/ |
H A D | NodeManagerMetrics.java | 100 allocatedMB = allocatedMB + res.getMemory(); in allocateContainer() 102 availableMB = availableMB - res.getMemory(); in allocateContainer() 110 allocatedMB = allocatedMB - res.getMemory(); in releaseContainer() 112 availableMB = availableMB + res.getMemory(); in releaseContainer() 119 availableMB = availableMB + res.getMemory(); in addResource()
|
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/jdk.hotspot.agent/share/classes/sun/jvm/hotspot/memory/ |
H A D | CodeHeap.java | 73 return getMemory().low(); in begin() 77 return getMemory().high(); in end() 132 private VirtualSpace getMemory() { in getMemory() method in CodeHeap 141 return p.minus(getMemory().low()) >> getLog2SegmentSize(); in segmentFor() 168 return getMemory().low().addOffsetTo(i << getLog2SegmentSize()); in blockBase()
|
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/jdk.hotspot.agent/share/classes/sun/jvm/hotspot/memory/ |
H A D | CodeHeap.java | 73 return getMemory().low(); in begin() 77 return getMemory().high(); in end() 132 private VirtualSpace getMemory() { in getMemory() method in CodeHeap 141 return p.minus(getMemory().low()) >> getLog2SegmentSize(); in segmentFor() 168 return getMemory().low().addOffsetTo(i << getLog2SegmentSize()); in blockBase()
|
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/src/jdk.hotspot.agent/share/classes/sun/jvm/hotspot/memory/ |
H A D | CodeHeap.java | 75 return getMemory().low(); in begin() 79 return getMemory().high(); in end() 134 private VirtualSpace getMemory() { in getMemory() method in CodeHeap 143 return p.minus(getMemory().low()) >> getLog2SegmentSize(); in segmentFor() 170 return getMemory().low().addOffsetTo(i << getLog2SegmentSize()); in blockBase()
|