diff --git a/aufs/core/dtmem.go b/aufs/core/dtmem.go index 446f3c5..c59ecfc 100644 --- a/aufs/core/dtmem.go +++ b/aufs/core/dtmem.go @@ -37,7 +37,7 @@ func Dtmem(w http.ResponseWriter, r *http.Request) { } // 调用远程方法 var reply string - var args = Args{"/www"} + var args = Args{"."} err = client.Call("FileRpcService.GetFilePath", args, &reply) if err != nil { fmt.Fprintf(w, "jsonrpc call faild %v", err) diff --git a/scagent/app.conf b/scagent/app.conf index 2ac511b..b4b4088 100644 --- a/scagent/app.conf +++ b/scagent/app.conf @@ -1,2 +1,2 @@ [rpc] -port=9099 \ No newline at end of file +port=9098 \ No newline at end of file diff --git a/scagent/core/JsonRpc.go b/scagent/core/JsonRpc.go index 46d581e..74f2374 100644 --- a/scagent/core/JsonRpc.go +++ b/scagent/core/JsonRpc.go @@ -1,6 +1,7 @@ package core import ( + "encoding/json" "os" "path/filepath" "scagnet/util" @@ -71,5 +72,13 @@ func (f *FileRpc) GetFilePath(args *Args, replay *Reply) error { flplist.Flist = append(flplist.Flist, FloopJson{Path: file, Size: d.Size(), Hash: hash}) } + // 将文件列表转换为json字符串 + jsonStr, err := json.Marshal(flplist) + if err != nil { + logger.Error("转换为json字符串出错", zap.Error(err)) + return err + } + replay.FilePath = string(jsonStr) + return nil }