commit

aarch64/pjisuv/common/service/rosbag_upload.go

@@ -13,6 +13,7 @@ import (
 	"time"
 )
 
+// RunTimeWindowConsumerQueue 依次上传时间窗口
 func RunTimeWindowConsumerQueue(nodeName string) {
 	c_log.GlobalLogger.Info("处理消费者队列goroutine - 启动")
 outLoop:
@@ -32,7 +33,6 @@ outLoop:
 			}
 		default:
 		}
-		// 每一秒扫一次
 		time.Sleep(time.Duration(1) * time.Second)
 		waitLength := len(entity.TimeWindowConsumerQueue)
 		if waitLength == 0 {