gsh-digital-services/seaweedFS
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

report empty volume or ec shards

Browse Source
This commit is contained in:
Chris Lu
2019-06-05 13:32:33 -07:00
parent 7f6fb9ffd0
commit 450f4733ce
5 changed files with 139 additions and 117 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
weed/storage/store.go
View File

@@ -191,6 +191,7 @@ func (s *Store) CollectHeartbeat() *master_pb.Heartbeat {
DataCenter: s.dataCenter,
Rack: s.rack,
Volumes: volumeMessages,
HasNoVolumes: len(volumeMessages) == 0,
}
}

9
weed/storage/store_ec.go
View File

@@ -28,7 +28,8 @@ func (s *Store) CollectErasureCodingHeartbeat() *master_pb.Heartbeat {
}
return &master_pb.Heartbeat{
EcShards: ecShardMessages,
EcShards: ecShardMessages,
HasNoEcShards: len(ecShardMessages) == 0,
}
}
@@ -221,11 +222,11 @@ func (s *Store) cachedLookupEcShardLocations(ctx context.Context, ecVolume *eras
shardCount := len(ecVolume.ShardLocations)
if shardCount < erasure_coding.DataShardsCount &&
ecVolume.ShardLocationsRefreshTime.Add(11*time.Second).After(time.Now()) ||
ecVolume.ShardLocationsRefreshTime.Add(11 * time.Second).After(time.Now()) ||
shardCount == erasure_coding.TotalShardsCount &&
ecVolume.ShardLocationsRefreshTime.Add(37*time.Minute).After(time.Now()) ||
ecVolume.ShardLocationsRefreshTime.Add(37 * time.Minute).After(time.Now()) ||
shardCount >= erasure_coding.DataShardsCount &&
ecVolume.ShardLocationsRefreshTime.Add(7*time.Minute).After(time.Now()) {
ecVolume.ShardLocationsRefreshTime.Add(7 * time.Minute).After(time.Now()) {
// still fresh
return nil
}