diff --git a/aufs/core/dtmem.go b/aufs/core/dtmem.go index 2d0f4a4..ec5f8d8 100644 --- a/aufs/core/dtmem.go +++ b/aufs/core/dtmem.go @@ -13,6 +13,16 @@ type Dtm struct { Alloc string `json:"alloc"` } +// for rpc +type Args struct { + FilePath string +} + +// 返回的参数 +type Reply struct { + FilePath string `json:"file_path"` +} + // 获取内存信息 func Dtmem(w http.ResponseWriter, r *http.Request) { var m runtime.MemStats @@ -27,7 +37,8 @@ func Dtmem(w http.ResponseWriter, r *http.Request) { } // 调用远程方法 var reply string - err = client.Call("core.FileRpc.GetFilePath", "/www", &reply) + var args = Args{"/www"} + err = client.Call("FileRpcService.GetFilePath", args, &reply) if err != nil { fmt.Fprintf(w, "jsonrpc call faild %v", err) return diff --git a/scagent/main.go b/scagent/main.go index 6c149b6..a49b65e 100644 --- a/scagent/main.go +++ b/scagent/main.go @@ -46,6 +46,9 @@ func main() { defer logger.Sync() logger.Info("JSON RPC服务端启动") + // 读取配置文件 + util.ReadConfig() + // 检查是否以守护进程方式运行 if isDaemon() { // 以守护进程方式运行 @@ -58,6 +61,7 @@ func main() { } // sport := fmt.Sprintf(":%v", config.G.Port) + logger.Info("Listen port", zap.String("port", sport)) tcpAddr, err := net.ResolveTCPAddr("tcp", sport) if err != nil { logger.Error("ResolveTCPAddr failed", zap.Error(err))