|
@@ -60,6 +60,7 @@ public abstract class AbstractCSQueue implements CSQueue {
|
|
private static final Log LOG = LogFactory.getLog(AbstractCSQueue.class);
|
|
private static final Log LOG = LogFactory.getLog(AbstractCSQueue.class);
|
|
CSQueue parent;
|
|
CSQueue parent;
|
|
final String queueName;
|
|
final String queueName;
|
|
|
|
+ private final String queuePath;
|
|
volatile int numContainers;
|
|
volatile int numContainers;
|
|
|
|
|
|
final Resource minimumAllocation;
|
|
final Resource minimumAllocation;
|
|
@@ -96,6 +97,8 @@ public abstract class AbstractCSQueue implements CSQueue {
|
|
this.labelManager = cs.getRMContext().getNodeLabelManager();
|
|
this.labelManager = cs.getRMContext().getNodeLabelManager();
|
|
this.parent = parent;
|
|
this.parent = parent;
|
|
this.queueName = queueName;
|
|
this.queueName = queueName;
|
|
|
|
+ this.queuePath =
|
|
|
|
+ ((parent == null) ? "" : (parent.getQueuePath() + ".")) + this.queueName;
|
|
this.resourceCalculator = cs.getResourceCalculator();
|
|
this.resourceCalculator = cs.getResourceCalculator();
|
|
|
|
|
|
// must be called after parent and queueName is set
|
|
// must be called after parent and queueName is set
|
|
@@ -122,6 +125,11 @@ public abstract class AbstractCSQueue implements CSQueue {
|
|
queueCapacities,
|
|
queueCapacities,
|
|
parent == null ? null : parent.getQueueCapacities());
|
|
parent == null ? null : parent.getQueueCapacities());
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public String getQueuePath() {
|
|
|
|
+ return queuePath;
|
|
|
|
+ }
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public synchronized float getCapacity() {
|
|
public synchronized float getCapacity() {
|