commit

aarch64/pjibot_guide/common/service/rosbag_record.go

@@ -98,7 +98,7 @@ func BagRecord(nodeName string) {
 					goto startRecord // 收到信号 2 重新 record 命令
 				}
 				if signal == 3 { // 这个关闭是等待数据处理时的关闭
-					c_log.GlobalLogger.Error("采集数据，暂时关闭record命令进程")
+					c_log.GlobalLogger.Error("采集数据，接收record命令进程关闭信号：", signal)
 					if err = util.KillProcessByPid(recordSubProcessPid); err != nil {
 						c_log.GlobalLogger.Errorf("程序阻塞，杀死record命令子进程出错，【pid】=%v,【err】=%v。", recordSubProcessPid, err)
 						select {} // 此处阻塞防止record命令一直录包占满存储

aarch64/pjibot_guide/master/package/service/move_bag_and_send_window.go

@@ -34,6 +34,7 @@ func RunTimeWindowProducerQueue() {
 		time.Sleep(time.Duration(1) * time.Second)
 		if len(entity.TimeWindowProducerQueue) > 0 {
 			// 如果有可处理的，先把record命令杀掉
+			c_log.GlobalLogger.Info("采集数据，发送record命令进程关闭信号。")
 			commonService.ChannelKillRosRecord <- 3
 			// 处理
 			bags, _ := util.ListAbsolutePathWithSuffixAndSort(commonConfig.CloudConfig.BagDataDir, ".bag")