|
@@ -79,6 +79,8 @@ public class RMContextImpl implements RMContext {
|
|
|
|
|
|
private QueueLimitCalculator queueLimitCalculator;
|
|
private QueueLimitCalculator queueLimitCalculator;
|
|
|
|
|
|
|
|
+ private final Object haServiceStateLock = new Object();
|
|
|
|
+
|
|
/**
|
|
/**
|
|
* Default constructor. To be used in conjunction with setter methods for
|
|
* Default constructor. To be used in conjunction with setter methods for
|
|
* individual fields.
|
|
* individual fields.
|
|
@@ -253,9 +255,9 @@ public class RMContextImpl implements RMContext {
|
|
this.isHAEnabled = isHAEnabled;
|
|
this.isHAEnabled = isHAEnabled;
|
|
}
|
|
}
|
|
|
|
|
|
- void setHAServiceState(HAServiceState haServiceState) {
|
|
|
|
- synchronized (haServiceState) {
|
|
|
|
- this.haServiceState = haServiceState;
|
|
|
|
|
|
+ void setHAServiceState(HAServiceState serviceState) {
|
|
|
|
+ synchronized (haServiceStateLock) {
|
|
|
|
+ this.haServiceState = serviceState;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
@@ -351,7 +353,7 @@ public class RMContextImpl implements RMContext {
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public HAServiceState getHAServiceState() {
|
|
public HAServiceState getHAServiceState() {
|
|
- synchronized (haServiceState) {
|
|
|
|
|
|
+ synchronized (haServiceStateLock) {
|
|
return haServiceState;
|
|
return haServiceState;
|
|
}
|
|
}
|
|
}
|
|
}
|