Removed a commented line.
This commit is contained in:
parent
6ae59d4be5
commit
55ea017a9a
2 changed files with 0 additions and 2 deletions
|
@ -193,7 +193,6 @@ func (s *ProactiveClusterwideCapFCFS) startRecapping() {
|
||||||
case <-s.recapTicker.C:
|
case <-s.recapTicker.C:
|
||||||
fcfsMutex.Lock()
|
fcfsMutex.Lock()
|
||||||
// If stopped performing cluster wide capping then we need to explicitly cap the entire cluster.
|
// If stopped performing cluster wide capping then we need to explicitly cap the entire cluster.
|
||||||
//if !s.isCapping && s.isRecapping && fcfsRecapValue > 0.0 {
|
|
||||||
if s.isRecapping && fcfsRecapValue > 0.0 {
|
if s.isRecapping && fcfsRecapValue > 0.0 {
|
||||||
for _, host := range constants.Hosts {
|
for _, host := range constants.Hosts {
|
||||||
// Rounding curreCapValue to the nearest int.
|
// Rounding curreCapValue to the nearest int.
|
||||||
|
|
|
@ -203,7 +203,6 @@ func (s *ProactiveClusterwideCapRanked) startRecapping() {
|
||||||
case <-s.recapTicker.C:
|
case <-s.recapTicker.C:
|
||||||
rankedMutex.Lock()
|
rankedMutex.Lock()
|
||||||
// If stopped performing cluster wide capping then we need to explicitly cap the entire cluster.
|
// If stopped performing cluster wide capping then we need to explicitly cap the entire cluster.
|
||||||
//if !s.isCapping && s.isRecapping && rankedRecapValue > 0.0 {
|
|
||||||
if s.isRecapping && rankedRecapValue > 0.0 {
|
if s.isRecapping && rankedRecapValue > 0.0 {
|
||||||
for _, host := range constants.Hosts {
|
for _, host := range constants.Hosts {
|
||||||
// Rounding curreCapValue to the nearest int.
|
// Rounding curreCapValue to the nearest int.
|
||||||
|
|
Reference in a new issue