commit

amd64/dpi_boot/main.go

@@ -23,21 +23,21 @@ var mutex sync.Mutex
 func main() {
 	lastTime = time.Now()
 
-	// 1 启动 shell 脚本 dpi_start.sh
-	_, s, err := util.ExecuteWithDirSync("/data", "sh", "dpi_start.sh")
-	if err != nil {
-		fmt.Println("执行启动命令报错，执行结果为：", s, "，错误信息为：", err)
-		os.Exit(1)
-	}
-	fmt.Println("执行启动命令 sh dpi_start.sh 成功，执行结果为：", s)
-
-	time.Sleep(5 * time.Second)
+	//// 1 启动 shell 脚本 dpi_start.sh
+	//_, s, err := util.ExecuteWithDirSync("/data", "sh", "dpi_start.sh")
+	//if err != nil {
+	//	fmt.Println("执行启动命令报错，执行结果为：", s, "，错误信息为：", err)
+	//	os.Exit(1)
+	//}
+	//fmt.Println("执行启动命令 sh dpi_start.sh 成功，执行结果为：", s)
+	//
+	//time.Sleep(5 * time.Second)
 	// 2 监听 ros 话题 /heartbeat_info
 	rosNode, _ := goroslib.NewNode(goroslib.NodeConf{
 		Name:          "dpi_with_heartbeatInfo",
 		MasterAddress: "127.0.0.1:11311",
 	})
-	_, err = goroslib.NewSubscriber(goroslib.SubscriberConf{
+	_, err := goroslib.NewSubscriber(goroslib.SubscriberConf{
 		Node:  rosNode,
 		Topic: "/heartbeat_info",
 		Callback: func(data *HeartBeatInfo) {
@@ -54,7 +54,7 @@ func main() {
 		time.Sleep(1 * time.Second)
 		if time.Since(lastTime).Seconds() > 5.00 {
 			fmt.Println("超过5秒没有监听到/heartbeat_info数据，即将重启dpi。")
-			_, s, err = util.ExecuteWithDirSync("/data", "sh", "dpi_stop.sh")
+			_, s, err := util.ExecuteWithDirSync("/data", "sh", "dpi_stop.sh")
 			if err != nil {
 				fmt.Println("执行停止命令报错，执行结果为：", s, "，错误信息为：", err)
 				continue