|
|
@ -218,6 +218,13 @@ func (vl *VolumeLayout) ensureCorrectWritables(vid needle.VolumeId) { |
|
|
|
vl.setVolumeWritable(vid) |
|
|
|
} |
|
|
|
} else { |
|
|
|
if !vl.enoughCopies(vid) { |
|
|
|
glog.V(0).Infof("volume %d does not have enough copies", vid) |
|
|
|
} |
|
|
|
if !vl.isAllWritable(vid) { |
|
|
|
glog.V(0).Infof("volume %d are not all writable", vid) |
|
|
|
} |
|
|
|
glog.V(0).Infof("volume %d remove from writable", vid) |
|
|
|
vl.removeFromWritable(vid) |
|
|
|
} |
|
|
|
} |
|
|
@ -433,7 +440,7 @@ func (vl *VolumeLayout) SetVolumeCapacityFull(vid needle.VolumeId) bool { |
|
|
|
vl.accessLock.Lock() |
|
|
|
defer vl.accessLock.Unlock() |
|
|
|
|
|
|
|
// glog.V(0).Infoln("Volume", vid, "reaches full capacity.")
|
|
|
|
glog.V(0).Infof("Volume %d reaches full capacity.", vid) |
|
|
|
return vl.removeFromWritable(vid) |
|
|
|
} |
|
|
|
|
|
|
|