mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-01-19 02:48:24 +00:00
fix wrong volume count
fix https://github.com/chrislusf/seaweedfs/issues/1013
This commit is contained in:
parent
5b5e443d5b
commit
a7b1b23c58
|
@ -81,7 +81,7 @@ func (shard *EcVolumeShard) Close() {
|
||||||
|
|
||||||
func (shard *EcVolumeShard) Destroy() {
|
func (shard *EcVolumeShard) Destroy() {
|
||||||
os.Remove(shard.FileName() + ToExt(int(shard.ShardId)))
|
os.Remove(shard.FileName() + ToExt(int(shard.ShardId)))
|
||||||
stats.VolumeServerVolumeCounter.WithLabelValues(shard.Collection, "ec_shards").Inc()
|
stats.VolumeServerVolumeCounter.WithLabelValues(shard.Collection, "ec_shards").Dec()
|
||||||
}
|
}
|
||||||
|
|
||||||
func (shard *EcVolumeShard) ReadAt(buf []byte, offset int64) (int, error) {
|
func (shard *EcVolumeShard) ReadAt(buf []byte, offset int64) (int, error) {
|
||||||
|
|
|
@ -53,7 +53,7 @@ func (v *Volume) CommitCompact() error {
|
||||||
glog.V(0).Infof("fail to close volume %d", v.Id)
|
glog.V(0).Infof("fail to close volume %d", v.Id)
|
||||||
}
|
}
|
||||||
v.dataFile = nil
|
v.dataFile = nil
|
||||||
stats.VolumeServerVolumeCounter.WithLabelValues(v.Collection, "volume").Inc()
|
stats.VolumeServerVolumeCounter.WithLabelValues(v.Collection, "volume").Dec()
|
||||||
|
|
||||||
var e error
|
var e error
|
||||||
if e = v.makeupDiff(v.FileName()+".cpd", v.FileName()+".cpx", v.FileName()+".dat", v.FileName()+".idx"); e != nil {
|
if e = v.makeupDiff(v.FileName()+".cpd", v.FileName()+".cpx", v.FileName()+".dat", v.FileName()+".idx"); e != nil {
|
||||||
|
|
Loading…
Reference in a new issue