diff --git a/fsv2/discovery/discovery.go b/fsv2/discovery/discovery.go index e4551f5..a060a78 100644 --- a/fsv2/discovery/discovery.go +++ b/fsv2/discovery/discovery.go @@ -37,10 +37,10 @@ func Listen() { message := string(buf[:n]) // 对消息进行切割 parts := strings.Split(message, separator) - if len(parts) != 2 { - fmt.Printf("Received malformed message from %s: %s\n", remoteAddr, message) - continue - } + // if len(parts) != 2 { + // fmt.Printf("Received malformed message from %s: %s\n", remoteAddr, message) + // continue + // } // 切割 msgtype := parts[0] @@ -50,9 +50,13 @@ func Listen() { if msgtype == "xdml" { opdir := parts[1] // 查找对应的文件目录 - fmt.Print("opertation directory is :%v", opdir) + err := os.MkdirAll(opdir, os.ModePerm) + if err != nil { + fmt.Printf(" create osdir is error:%s\n", err) + } + } - fmt.Print("parts from udp read :%v", parts) + fmt.Println(" parts from udp read :", parts) } }