From 0065d7fe746d0c0b46f7669e51307c28ef89ce09 Mon Sep 17 00:00:00 2001
From: "453530270@qq.com" <aa123456>
Date: Wed, 26 Jun 2024 15:00:37 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E7=9B=AE=E5=BD=95=E5=A4=84?=
 =?UTF-8?q?=E7=90=86=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 fsv2/discovery/discovery.go | 16 ++++++++++------
 1 file changed, 10 insertions(+), 6 deletions(-)

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)
 	}
 }