MyFavMirrors/minio
1
0
Fork 0
mirror of https://github.com/minio/minio.git synced 2025-04-28 13:48:00 -04:00
Code Issues Packages Projects Releases Wiki Activity

docs/debug: log any corruption and continue debug tool

Browse Source
This commit is contained in:
Harshavardhana 2021-12-13 17:45:06 -08:00
parent de400f3473
commit 109c927dad
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
docs/debugging/s3-check-md5/main.go
View File

@ -121,11 +121,12 @@ func main() {
if p, err := strconv.Atoi(s[1]); err == nil { if p, err := strconv.Atoi(s[1]); err == nil {
parts = p parts = p
} else { } else {
log.Fatalln("ETAG: wrong format:", err) log.Println("ETAG: wrong format:", err)
continue continue
} }
default: default:
log.Fatalln("Unexpected ETAG format", object.ETag) log.Println("Unexpected ETAG format", object.ETag)
continue
} }
var partsMD5Sum [][]byte var partsMD5Sum [][]byte
@ -134,12 +135,12 @@ func main() {
obj, err := s3Client.GetObject(context.Background(), bucket, object.Key, obj, err := s3Client.GetObject(context.Background(), bucket, object.Key,
minio.GetObjectOptions{VersionID: object.VersionID, PartNumber: p}) minio.GetObjectOptions{VersionID: object.VersionID, PartNumber: p})
if err != nil { if err != nil {
log.Fatalln("GET", bucket, object.Key, object.VersionID, "=>", err) log.Println("GET", bucket, object.Key, object.VersionID, "=>", err)
continue continue
} }
h := md5.New() h := md5.New()
if _, err := io.Copy(h, obj); err != nil { if _, err := io.Copy(h, obj); err != nil {
log.Fatalln("MD5 calculation error:", bucket, object.Key, object.VersionID, "=>", err) log.Println("MD5 calculation error:", bucket, object.Key, object.VersionID, "=>", err)
continue continue
} }
partsMD5Sum = append(partsMD5Sum, h.Sum(nil)) partsMD5Sum = append(partsMD5Sum, h.Sum(nil))
@ -165,10 +166,10 @@ func main() {
} }
if corrupted { if corrupted {
log.Fatalln("CORRUPTED object:", bucket, object.Key, object.VersionID) log.Println("CORRUPTED object:", bucket, object.Key, object.VersionID)
} } else {
log.Println("INTACT", bucket, object.Key, object.VersionID) log.Println("INTACT", bucket, object.Key, object.VersionID)
} }
} }
} }
}