test/go-fastdfs
1
0
Fork 0
mirror of https://gitee.com/sjqzhang/go-fastdfs.git synced 2024-11-29 17:57:41 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

disable repair fileinfo

Browse Source
This commit is contained in:
s_jqzhang 2019-02-23 13:01:21 +08:00
parent c30354e482
commit a4b89b9c11
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
fileserver.go
View File

@ -941,7 +941,7 @@ func (this *Server) RepairStat() {
log.Warn("Lock RepairStat")
return
}
this.lockMap.LockKey("RepairStat")
defer this.lockMap.UnLockKey("RepairStat")
@ -1620,6 +1620,11 @@ func (this *Server) saveFileMd5Log(fileInfo *FileInfo, filename string) {
}
}()
if fileInfo == nil || fileInfo.Md5 == "" || filename == "" {
log.Warn("saveFileMd5Log", fileInfo, filename)
return
}
logDate = this.util.GetDayFromTimeStamp(fileInfo.TimeStamp)
sumKey = fmt.Sprintf("%s_%s", logDate, filename)
@ -2855,6 +2860,7 @@ func (this *Server) RepairStatWeb(w http.ResponseWriter, r *http.Request) {
)
this.RepairStat()
result.Status = "ok"
w.Write([]byte(this.util.JsonEncodePretty(result)))
}
@ -3273,8 +3279,9 @@ func (this *Server) RepairFileInfo(w http.ResponseWriter, r *http.Request) {
return
}
result.Status = "ok"
result.Message = "repair job start,don't try again"
go this.RepairFileInfoFromFile()
//result.Message = "repair job start,don't try again"
result.Message = "very danger , disable by system"
//go this.RepairFileInfoFromFile()
w.Write([]byte(this.util.JsonEncodePretty(result)))
}