test/go-fastdfs
1
0
Fork 0
mirror of https://gitee.com/sjqzhang/go-fastdfs.git synced 2024-11-30 02:07:45 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

when migrate file add file metadata to db

Browse Source
This commit is contained in:
s_jqzhang 2019-04-26 09:36:13 +08:00
parent 60e7f650b8
commit 7477f9ed93
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
fileserver.go
View File

@ -1203,7 +1203,9 @@ func (this *Server) DownloadFromPeer(peer string, fileInfo *FileInfo) {
req.SetTimeout(time.Second*30, time.Second*time.Duration(timeout))
if err = req.ToFile(fpath); err != nil {
log.Error(err)
return
}
this.SaveFileInfoToLevelDB(fileInfo.Md5, fileInfo, this.ldb)
return
}
req.SetTimeout(time.Second*30, time.Second*time.Duration(timeout))
@ -3254,15 +3256,15 @@ func (this *Server) Search(w http.ResponseWriter, r *http.Request) {
result.Data = fileInfos
w.Write([]byte(this.util.JsonEncodePretty(result)))
}
func (this *Server) SearchDict(kw string) []FileInfo{
func (this *Server) SearchDict(kw string) []FileInfo {
var (
fileInfos []FileInfo
fileInfo *FileInfo
fileInfo *FileInfo
)
for dict:=range this.searchMap.Iter() {
if strings.Contains( dict.Val.(string),kw) {
if fileInfo,_=this.GetFileInfoFromLevelDB(dict.Key);fileInfo!=nil{
fileInfos=append(fileInfos,*fileInfo)
for dict := range this.searchMap.Iter() {
if strings.Contains(dict.Val.(string), kw) {
if fileInfo, _ = this.GetFileInfoFromLevelDB(dict.Key); fileInfo != nil {
fileInfos = append(fileInfos, *fileInfo)
}
}
}