|
@@ -83,7 +83,7 @@ func BagRecord(nodeName string) {
|
|
|
select {
|
|
|
case signal := <-ChannelKillRosRecord:
|
|
|
if signal == 1 {
|
|
|
- if err := util.KillProcessByPid(recordSubProcessPid); err != nil {
|
|
|
+ if err = util.KillProcessByPid(recordSubProcessPid); err != nil {
|
|
|
c_log.GlobalLogger.Errorf("程序阻塞,杀死record命令子进程出错,【pid】=%v,【err】=%v。", recordSubProcessPid, err)
|
|
|
select {} // 此处阻塞防止record命令一直录包占满存储
|
|
|
}
|
|
@@ -99,8 +99,14 @@ func BagRecord(nodeName string) {
|
|
|
}
|
|
|
if signal == 3 { // 这个关闭是等待数据处理时的关闭
|
|
|
c_log.GlobalLogger.Error("采集数据,暂时关闭record命令进程")
|
|
|
- _ = util.KillProcessByPid(recordSubProcessPid)
|
|
|
- _ = cmd.Process.Kill()
|
|
|
+ if err = util.KillProcessByPid(recordSubProcessPid); err != nil {
|
|
|
+ c_log.GlobalLogger.Errorf("程序阻塞,杀死record命令子进程出错,【pid】=%v,【err】=%v。", recordSubProcessPid, err)
|
|
|
+ select {} // 此处阻塞防止record命令一直录包占满存储
|
|
|
+ }
|
|
|
+ if err = cmd.Process.Kill(); err != nil {
|
|
|
+ c_log.GlobalLogger.Error("程序阻塞,杀死record命令进程", recordProcessPid, "出错:", err)
|
|
|
+ select {} // 此处阻塞防止record命令一直录包占满存储
|
|
|
+ }
|
|
|
continue
|
|
|
}
|
|
|
}
|