|
@@ -14,14 +14,18 @@ import (
|
|
|
|
|
|
|
|
var (
|
|
var (
|
|
|
timeInterval = "5"
|
|
timeInterval = "5"
|
|
|
- dir = "/root/competition"
|
|
|
|
|
|
|
+ dir = "/home/root/competition/"
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
func ForCompetition() {
|
|
func ForCompetition() {
|
|
|
|
|
+ c_log.GlobalLogger.Info("开始采集实车算法比赛全量数据。")
|
|
|
util.CreateDir(dir)
|
|
util.CreateDir(dir)
|
|
|
// 1 打包
|
|
// 1 打包
|
|
|
var commandArgs = []string{"record", "--split", "--duration=" + timeInterval, "/pji_gps", "/data_read"}
|
|
var commandArgs = []string{"record", "--split", "--duration=" + timeInterval, "/pji_gps", "/data_read"}
|
|
|
- _, _ = util.ExecuteWithEnvAndDirAsync(commonConfig.RosbagEnvs, dir, commonConfig.RosbagPath, commandArgs...)
|
|
|
|
|
|
|
+ _, err := util.ExecuteWithEnvAndDirAsync(commonConfig.RosbagEnvs, dir, commonConfig.RosbagPath, commandArgs...)
|
|
|
|
|
+ if err != nil {
|
|
|
|
|
+ c_log.GlobalLogger.Error("执行record命令报错，", commandArgs)
|
|
|
|
|
+ }
|
|
|
// 2 扫描目录文件
|
|
// 2 扫描目录文件
|
|
|
for {
|
|
for {
|
|
|
time.Sleep(time.Duration(2) * time.Second)
|
|
time.Sleep(time.Duration(2) * time.Second)
|
