Home
last modified time | relevance | path

Searched refs:SchedulerNode (Results 1 – 17 of 17) sorted by relevance

/dports/audio/linuxsampler/linuxsampler-2.2.0/src/engines/common/
H A DEvent.h46 class SchedulerNode; variable
380 class SchedulerNode : public RTAVLNode {
387 inline bool operator==(const SchedulerNode& other) const {
392 inline bool operator<(const SchedulerNode& other) const {
405 class ScheduledEvent : public SchedulerNode {
432 class ScriptEvent : public SchedulerNode {
/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/
H A DSchedulerNode.java51 public abstract class SchedulerNode { class
53 private static final Log LOG = LogFactory.getLog(SchedulerNode.class);
71 public SchedulerNode(RMNode node, boolean usePortForNodeName, in SchedulerNode() method in SchedulerNode
84 public SchedulerNode(RMNode node, boolean usePortForNodeName) { in SchedulerNode() method in SchedulerNode
H A DAppSchedulingInfo.java265 SchedulerNode node, Priority priority, ResourceRequest request, in allocate()
301 synchronized private void allocateNodeLocal(SchedulerNode node, in allocateNodeLocal()
336 synchronized private void allocateRackLocal(SchedulerNode node, in allocateRackLocal()
358 synchronized private void allocateOffSwitch(SchedulerNode node, in allocateOffSwitch()
H A DSchedulerAppUtils.java26 SchedulerNode node, Log LOG) { in isBlacklisted()
H A DSchedulerNodeReport.java35 public SchedulerNodeReport(SchedulerNode node) { in SchedulerNodeReport()
H A DAbstractYarnScheduler.java76 <T extends SchedulerApplicationAttempt, N extends SchedulerNode>
214 ContainerId containerId, SchedulerNode node) { in containerLaunchedOnNode()
504 public SchedulerNode getSchedulerNode(NodeId nodeId) { in getSchedulerNode()
561 SchedulerNode node = getSchedulerNode(nm.getNodeID()); in updateNodeResource()
601 protected void updateMaximumAllocation(SchedulerNode node, boolean add) { in updateMaximumAllocation()
H A DSchedulerApplicationAttempt.java307 public synchronized RMContainer reserve(SchedulerNode node, Priority priority, in reserve()
352 public synchronized boolean isReserved(SchedulerNode node, Priority priority) { in isReserved()
/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/
H A DTestSchedulerApplicationAttempt.java84 SchedulerNode node = createNode(); in testMove()
122 private SchedulerNode createNode() { in createNode()
123 SchedulerNode node = mock(SchedulerNode.class); in createNode()
H A DTestAbstractYarnScheduler.java272 SchedulerNode mockNode1 = mock(SchedulerNode.class); in testUpdateMaxAllocationUsesTotal()
277 SchedulerNode mockNode2 = mock(SchedulerNode.class); in testUpdateMaxAllocationUsesTotal()
284 scheduler.nodes = new HashMap<NodeId, SchedulerNode>(); in testUpdateMaxAllocationUsesTotal()
/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/
H A DFSSchedulerNode.java30 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerNode;
34 public class FSSchedulerNode extends SchedulerNode {
/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/common/fica/
H A DFiCaSchedulerNode.java32 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerNode;
34 public class FiCaSchedulerNode extends SchedulerNode {
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/
H A DResourceSchedulerWrapper.java73 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerNode;
102 extends AbstractYarnScheduler<SchedulerApplicationAttempt, SchedulerNode>
813 ((AbstractYarnScheduler<SchedulerApplicationAttempt, SchedulerNode>) in serviceInit()
821 ((AbstractYarnScheduler<SchedulerApplicationAttempt, SchedulerNode>) in serviceStart()
829 ((AbstractYarnScheduler<SchedulerApplicationAttempt, SchedulerNode>) in serviceStop()
/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/fifo/
H A DTestFifoScheduler.java70 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerNode;
635 AbstractYarnScheduler<SchedulerApplicationAttempt, SchedulerNode> fs = in testAddAndRemoveAppFromFiFoScheduler()
636 (AbstractYarnScheduler<SchedulerApplicationAttempt, SchedulerNode>) rm in testAddAndRemoveAppFromFiFoScheduler()
/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 DMockRM.java81 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerNode;
703 ((AbstractYarnScheduler<SchedulerApplicationAttempt, SchedulerNode>) getResourceScheduler())
H A DTestWorkPreservingRMRestart.java76 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerNode;
210 SchedulerNode schedulerNode1 = scheduler.getSchedulerNode(nm1.getNodeId()); in testSchedulerRecovery()
/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 DTestCapacityScheduler.java118 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerNode;
841 AbstractYarnScheduler<SchedulerApplicationAttempt, SchedulerNode> cs =
842 (AbstractYarnScheduler<SchedulerApplicationAttempt, SchedulerNode>) rm
/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 DTestFairScheduler.java93 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerNode;
4280 AbstractYarnScheduler<SchedulerApplicationAttempt, SchedulerNode> scheduler = in testAddAndRemoveAppFromFairScheduler()
4281 (AbstractYarnScheduler<SchedulerApplicationAttempt, SchedulerNode>) resourceManager in testAddAndRemoveAppFromFairScheduler()