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

bugfix CheckFileExistByMd5

Browse Source
This commit is contained in:
s_jqzhang 2019-03-12 14:35:55 +08:00
parent 29694c0e6f
commit ea7873067e
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
fileserver.go
View File

@ -290,14 +290,15 @@ func NewServer() *Server {
server.ldb, err = leveldb.OpenFile(CONST_LEVELDB_FILE_NAME, nil)
if err != nil {
fmt.Println(err)
panic(err)
log.Error(err)
panic(err)
}
server.logDB, err = leveldb.OpenFile(CONST_LOG_LEVELDB_FILE_NAME, nil)
if err != nil {
fmt.Println(err)
panic(err)
log.Error(err)
panic(err)
}
return server
}
@ -1017,6 +1018,8 @@ func (this *Server) CheckFileExistByMd5(md5s string, fileInfo *FileInfo) bool {
if info.OffSet == -1 {
if this.util.FileExists(DOCKER_DIR + info.Path + "/" + fn) {
return true
} else {
return false
}
} else { //small file
if name, offset, _, err = this.ParseSmallFile(fn); err != nil {
@ -1122,6 +1125,7 @@ func (this *Server) DownloadFromPeer(peer string, fileInfo *FileInfo) {
err = this.util.WriteFileByOffSet(fpath, fileInfo.OffSet, data)
if err != nil {
log.Warn(err)
return
}
this.SaveFileMd5Log(fileInfo, CONST_FILE_Md5_FILE_NAME)
return