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

Show volume server which failed to verify a chunk (#5958)

Browse Source
This commit is contained in:
Eugeniy E. Mikhailov
2024-09-02 00:13:22 -04:00
committed by GitHub
parent 220061573d
commit 282867a71e
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
weed/shell/command_fs_verify.go
View File

@@ -217,8 +217,8 @@ func (c *commandFsVerify) verifyEntry(path string, chunks []*filer_pb.FileChunk,
if *c.concurrency == 0 { if *c.concurrency == 0 {
if err := c.verifyChunk(volumeServer, chunk.Fid); err != nil { if err := c.verifyChunk(volumeServer, chunk.Fid); err != nil {
if !(*c.metadataFromLog && strings.HasSuffix(err.Error(), "not found")) { if !(*c.metadataFromLog && strings.HasSuffix(err.Error(), "not found")) {
fmt.Fprintf(c.writer, "%s failed verify fileId %s: %+v\n", fmt.Fprintf(c.writer, "%s failed verify fileId %s: %+v, at volume server %v\n",
fileMsg, chunk.GetFileIdString(), err) fileMsg, chunk.GetFileIdString(), err, volumeServer)
} }
if itemIsVerifed.Load() { if itemIsVerifed.Load() {
itemIsVerifed.Store(false) itemIsVerifed.Store(false)
@@ -245,8 +245,8 @@ func (c *commandFsVerify) verifyEntry(path string, chunks []*filer_pb.FileChunk,
defer wg.Done() defer wg.Done()
if err := c.verifyChunk(volumeServer, fChunk.Fid); err != nil { if err := c.verifyChunk(volumeServer, fChunk.Fid); err != nil {
if !(*c.metadataFromLog && strings.HasSuffix(err.Error(), "not found")) { if !(*c.metadataFromLog && strings.HasSuffix(err.Error(), "not found")) {
fmt.Fprintf(c.writer, "%s failed verify fileId %s: %+v\n", fmt.Fprintf(c.writer, "%s failed verify fileId %s: %+v, at volume server %v\n",
msg, fChunk.GetFileIdString(), err) msg, fChunk.GetFileIdString(), err, volumeServer)
} }
if itemIsVerifed.Load() { if itemIsVerifed.Load() {
itemIsVerifed.Store(false) itemIsVerifed.Store(false)