|
@ -187,7 +187,7 @@ func (s *Store) CollectHeartbeat() *master_pb.Heartbeat { |
|
|
location.RUnlock() |
|
|
location.RUnlock() |
|
|
|
|
|
|
|
|
if len(deleteVids) > 0 { |
|
|
if len(deleteVids) > 0 { |
|
|
// delete expired volumes.
|
|
|
|
|
|
|
|
|
// delete expired volumes.
|
|
|
location.Lock() |
|
|
location.Lock() |
|
|
for _, vid := range deleteVids { |
|
|
for _, vid := range deleteVids { |
|
|
location.deleteVolumeById(vid) |
|
|
location.deleteVolumeById(vid) |
|
|