专栏算法工具链dataflow tool禁止proc失败，提示send requset failed

dataflow tool禁止proc失败，提示send requset failed

已解决
默认194242024-03-19
85
6

sdk版本：1.7.5

process.json配置如下：

 "dag_information": {

 "enable": false,

 "enable_module": false,

 "topic": "/bole/dataflow/dag"

 }

报错信息如下：


算法工具链
+1
评论6
0/1000
  • TROS.Enid
    Lv.1

    内部分析中

    2024-03-20
    0
    0
  • TROS.Enid
    Lv.1

    下面的红色错误是设置线程属性失败，需要root权限，但是对程序运行没影响.

    send requset failed的错误帮忙提供一下log

    2024-03-20
    0
    0
  • 默认19424
    Lv.1

    附件按钮点击无法弹出选择文件窗口，图片按钮可以弹出，但是选择文本文件不能上传

    2024-03-20
    0
    0
  • TROS.Enid
    Lv.1

    可以上传到网盘，给链接我下载。

    2024-03-20
    0
    0
  • 默认19424
    Lv.1

    [D][215629][demo_tag][14:05:08:923645][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:08:923653][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:08:923655][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:08:923665][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:123601][scheduler_executor.cpp:140][dataflow] Timer schedule add task dag_report

    [D][215629][demo_tag][14:05:09:123691][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:123707][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:09:123720][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:09:123746][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:09:123760][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:09:123800][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:123826][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:123828][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:09:123830][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:09:123838][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:09:123841][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:09:123854][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:322273][shm_manager.cpp:338][communication] SHMManager::start_check_ref after erase dead referencer, map_refs_.size = 2

    [D][215629][demo_tag][14:05:09:322920][scheduler_executor.cpp:140][dataflow] Timer schedule add task dag_report

    [D][215629][demo_tag][14:05:09:323044][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:323057][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:09:323067][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:09:323088][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:09:323102][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:09:323148][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:323189][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:323192][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:09:323194][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:09:323209][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:09:323213][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:09:323229][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:363620][plugin_zmq_data_reader_impl.cpp:519][communication] [ZMQ plugin] zmq read msg fail, reason: Resource temporarily unavailable

    [D][215629][demo_tag][14:05:09:363660][plugin_zmq_data_reader_impl.cpp:459][communication] [ZMQ plugin] read data start ip_and_port_: tcp://172.31.8.52:18579

    [D][215629][demo_tag][14:05:09:522895][scheduler_executor.cpp:140][dataflow] Timer schedule add task dag_report

    [D][215629][demo_tag][14:05:09:523020][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:523032][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:09:523047][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:09:523068][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:09:523085][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:09:523152][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:523194][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:523197][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:09:523200][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:09:523210][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:09:523214][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:09:523227][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:722872][scheduler_executor.cpp:140][dataflow] Timer schedule add task dag_report

    [D][215629][demo_tag][14:05:09:722990][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:723007][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:09:723021][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:09:723039][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:09:723056][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:09:723101][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:723133][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:723136][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:09:723138][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:09:723147][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:09:723150][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:09:723173][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:806281][discovery_manager.cpp:810][communication] OnMsgRecvCallback DIS_MSG_TYPE_INCREASE_DEL uuid ba6808c7-78de-4a07-90c8-4277cffff064 version 4

    [D][215629][demo_tag][14:05:09:922874][scheduler_executor.cpp:140][dataflow] Timer schedule add task dag_report

    [D][215629][demo_tag][14:05:09:922931][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:922938][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:09:922949][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:09:922967][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:09:922980][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:09:923028][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:923057][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:09:923059][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:09:923062][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:09:923070][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:09:923073][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:09:923079][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:122875][scheduler_executor.cpp:140][dataflow] Timer schedule add task dag_report

    [D][215629][demo_tag][14:05:10:122949][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:122957][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:10:122970][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:10:122987][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:10:123002][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:10:123046][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:123077][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:123080][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:10:123083][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:10:123092][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:10:123095][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:10:123103][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:322422][shm_manager.cpp:338][communication] SHMManager::start_check_ref after erase dead referencer, map_refs_.size = 2

    [D][215629][demo_tag][14:05:10:322980][scheduler_executor.cpp:140][dataflow] Timer schedule add task dag_report

    [D][215629][demo_tag][14:05:10:323179][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:323186][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:10:323194][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:10:323209][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:10:323220][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:10:323251][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:323281][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:323285][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:10:323287][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:10:323294][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:10:323297][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:10:323303][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:364730][plugin_zmq_data_reader_impl.cpp:519][communication] [ZMQ plugin] zmq read msg fail, reason: Resource temporarily unavailable

    [D][215629][demo_tag][14:05:10:364755][plugin_zmq_data_reader_impl.cpp:459][communication] [ZMQ plugin] read data start ip_and_port_: tcp://172.31.8.52:18579

    [D][215629][demo_tag][14:05:10:522888][scheduler_executor.cpp:140][dataflow] Timer schedule add task dag_report

    [D][215629][demo_tag][14:05:10:522955][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:522960][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:10:522971][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:10:522987][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:10:522999][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:10:523038][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:523063][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:523065][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:10:523067][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:10:523075][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:10:523077][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:10:523083][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:722890][scheduler_executor.cpp:140][dataflow] Timer schedule add task dag_report

    [D][215629][demo_tag][14:05:10:723037][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:723045][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:10:723057][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:10:723074][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:10:723089][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:10:723139][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:723196][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:723199][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:10:723203][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:10:723214][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:10:723219][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:10:723228][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:838572][reliable_timer.cpp:173][communication] Task:Comm_raw_socket ID:1 count 3000 duration 15570 fps 192.67822736030828

    [D][215629][demo_tag][14:05:10:922882][scheduler_executor.cpp:140][dataflow] Timer schedule add task dag_report

    [D][215629][demo_tag][14:05:10:922957][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:922965][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:10:922982][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:10:923006][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:10:923023][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:10:923088][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:923121][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:10:923124][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:10:923127][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:10:923137][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:10:923140][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:10:923147][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:122887][scheduler_executor.cpp:140][dataflow] Timer schedule add task dag_report

    [D][215629][demo_tag][14:05:11:122961][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:122969][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:11:122981][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:11:123000][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:11:123017][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:11:123065][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:123096][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:123098][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:11:123100][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:11:123109][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:11:123112][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:11:123118][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:322856][scheduler_executor.cpp:140][dataflow] Timer schedule add task dag_report

    [D][215629][demo_tag][14:05:11:322905][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:322913][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:11:322920][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:11:322935][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:11:322946][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:11:322948][shm_manager.cpp:338][communication] SHMManager::start_check_ref after erase dead referencer, map_refs_.size = 2

    [D][215629][demo_tag][14:05:11:322979][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:323003][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:323006][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:11:323008][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:11:323015][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:11:323018][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:11:323030][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:365232][plugin_zmq_data_reader_impl.cpp:519][communication] [ZMQ plugin] zmq read msg fail, reason: Resource temporarily unavailable

    [D][215629][demo_tag][14:05:11:365257][plugin_zmq_data_reader_impl.cpp:459][communication] [ZMQ plugin] read data start ip_and_port_: tcp://172.31.8.52:18579

    [D][215629][demo_tag][14:05:11:522895][scheduler_executor.cpp:140][dataflow] Timer schedule add task dag_report

    [D][215629][demo_tag][14:05:11:522963][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:522972][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:11:522986][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:11:523005][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:11:523022][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:11:523079][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:523115][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:523119][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:11:523123][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:11:523134][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:11:523140][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:11:523188][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:722930][scheduler_executor.cpp:140][dataflow] Timer schedule add task dag_report

    [D][215629][demo_tag][14:05:11:723004][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:723011][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:11:723023][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:11:723038][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:11:723051][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:11:723099][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:723124][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:723129][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:11:723131][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:11:723140][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:11:723142][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:11:723151][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:922880][scheduler_executor.cpp:140][dataflow] Timer schedule add task dag_report

    [D][215629][demo_tag][14:05:11:922944][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:922951][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:11:922962][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:11:922978][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:11:922991][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:11:923045][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:923071][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:11:923074][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:11:923076][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:11:923083][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:11:923086][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:11:923094][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [I][215629][demo_tag][14:05:12:031193][mainboard.cpp:360][dataflow] received signal: 2

    [I][215629][demo_tag][14:05:12:031333][flow_manager.cpp:274][dataflow] FlowManager begin Stop.

    [D][215629][demo_tag][14:05:12:031894][graphlet.cpp:656][dataflow] Graphlet instance_id: _top_graphlet_, ele_deps: DemoSubModule_A: ;

    [D][215629][demo_tag][14:05:12:031904][dependency_executor.cpp:104][dataflow] AddTask task_id: DemoSubModule_A, dep:

    [D][215629][demo_tag][14:05:12:031972][timer_scheduler.cpp:227][dataflow] Timer scheduler starts clear tasks, task_producer 12

    [D][215629][demo_tag][14:05:12:031984][base_condition_filter.cpp:306][dataflow] ClearAllMsgs

    [D][215629][demo_tag][14:05:12:031997][timer_scheduler.cpp:227][dataflow] Timer scheduler starts clear tasks, task_producer 11

    [D][215629][demo_tag][14:05:12:031999][base_condition_filter.cpp:306][dataflow] ClearAllMsgs

    [I][215629][demo_tag][14:05:12:032003][module.cpp:298][dataflow] module DemoSubModule_A Stop successed

    [I][215629][demo_tag][14:05:12:032007][dependency_executor.cpp:58][dataflow] dependency executor done

    [I][215629][demo_tag][14:05:12:032028][graphlet.cpp:170][dataflow] graphlet _top_graphlet_ Stop successed

    [I][215629][demo_tag][14:05:12:032213][flow_manager.cpp:803][dataflow] graphlet stop success, instance id: _top_graphlet_

    [I][215629][demo_tag][14:05:12:032226][flow_manager.cpp:660][dataflow] begin stop scheduler, scheduler name: Simple_sg

    [I][215629][demo_tag][14:05:12:032229][flow_manager.cpp:662][dataflow] end stop scheduler, scheduler name: Simple_sg

    [I][215629][demo_tag][14:05:12:032232][flow_manager.cpp:286][dataflow] FlowManager end Stop.

    [I][215629][demo_tag][14:05:12:032237][flow_manager.cpp:192][dataflow] FlowManager begin DeInitialize.

    [D][215629][demo_tag][14:05:12:032357][graphlet.cpp:656][dataflow] Graphlet instance_id: _top_graphlet_, ele_deps: DemoSubModule_A: ;

    [D][215629][demo_tag][14:05:12:032363][dependency_executor.cpp:104][dataflow] AddTask task_id: DemoSubModule_A, dep:

    [D][215629][demo_tag][14:05:12:032478][proc.cpp:81][dataflow] UnRegister Proc DemoSubProc2 success

    [D][215629][demo_tag][14:05:12:032502][proc.cpp:81][dataflow] UnRegister Proc DemoSubProc1 success

    [D][215629][demo_tag][14:05:12:032576][reader_base.cpp:65][communication] Destroy Reader, topic=0#%^&/gac/acc/planning_feedback, protocol=0

    [D][215629][demo_tag][14:05:12:032597][dispatcher.cpp:305][communication] remove Listener topic: 0#%^&/gac/acc/planning_feedback

    [D][215629][demo_tag][14:05:12:032599][dispatcher.cpp:332][communication] remove Listener topic: 0#%^&/gac/acc/planning_feedback return

    [D][215629][demo_tag][14:05:12:032603][dispatcher.cpp:305][communication] remove Listener topic: 0#%^&/gac/acc/planning_feedback

    [D][215629][demo_tag][14:05:12:032606][dispatcher.cpp:332][communication] remove Listener topic: 0#%^&/gac/acc/planning_feedback return

    [D][215629][demo_tag][14:05:12:032609][dispatcher.cpp:305][communication] remove Listener topic: 0#%^&/gac/acc/planning_feedback

    [D][215629][demo_tag][14:05:12:032610][dispatcher.cpp:332][communication] remove Listener topic: 0#%^&/gac/acc/planning_feedback return

    [D][215629][demo_tag][14:05:12:032619][participant.cpp:294][communication] RemoveReaderEventListener, key=0x7fb2f8019350

    [D][215629][demo_tag][14:05:12:032624][participant.cpp:294][communication] RemoveReaderEventListener, key=0x7fb2f8019350

    [D][215629][demo_tag][14:05:12:032642][participant.cpp:294][communication] RemoveReaderEventListener, key=0x7fb2f8019350

    [D][215629][demo_tag][14:05:12:032682][participant.cpp:580][communication] participant id: 111111 use count: 3

    [D][215629][demo_tag][14:05:12:032686][participant.cpp:580][communication] participant id: 111115 use count: 1

    [D][215629][demo_tag][14:05:12:032692][discovery_manager.cpp:1106][communication] DiscoveryManager::un_regist_reader uuid:85af7376-5401-4532-95cd-27baad8fa522

    [D][215629][demo_tag][14:05:12:032790][subscriber_base.cpp:57][communication] Destroy Subscriber, topic=/gac/acc/planning_feedback, protocol=0, id_=4480332513468177091

    [D][215629][demo_tag][14:05:12:032800][discovery_manager.cpp:1285][communication] DiscoveryManager::un_regist_entity uuid:acb0a4ba-1e66-4d80-9b50-b63399c0e03e

    [I][215629][demo_tag][14:05:12:032865][subscriber_base.cpp:203][dataflow] UnRegister subscriber success: topic=/gac/acc/planning_feedback

    [D][215629][demo_tag][14:05:12:032876][port.cpp:60][dataflow] UnRegister Port input_ACCFbToSM success

    [D][215629][demo_tag][14:05:12:032909][reader_base.cpp:65][communication] Destroy Reader, topic=0#%^&/gac/obstacle_id_infos, protocol=0

    [D][215629][demo_tag][14:05:12:032916][dispatcher.cpp:305][communication] remove Listener topic: 0#%^&/gac/obstacle_id_infos

    [D][215629][demo_tag][14:05:12:032918][dispatcher.cpp:332][communication] remove Listener topic: 0#%^&/gac/obstacle_id_infos return

    [D][215629][demo_tag][14:05:12:032922][dispatcher.cpp:305][communication] remove Listener topic: 0#%^&/gac/obstacle_id_infos

    [D][215629][demo_tag][14:05:12:032924][dispatcher.cpp:332][communication] remove Listener topic: 0#%^&/gac/obstacle_id_infos return

    [D][215629][demo_tag][14:05:12:032926][dispatcher.cpp:305][communication] remove Listener topic: 0#%^&/gac/obstacle_id_infos

    [D][215629][demo_tag][14:05:12:032927][dispatcher.cpp:332][communication] remove Listener topic: 0#%^&/gac/obstacle_id_infos return

    [D][215629][demo_tag][14:05:12:032930][participant.cpp:294][communication] RemoveReaderEventListener, key=0x7fb2f8002450

    [D][215629][demo_tag][14:05:12:032932][participant.cpp:294][communication] RemoveReaderEventListener, key=0x7fb2f8002450

    [D][215629][demo_tag][14:05:12:032936][participant.cpp:294][communication] RemoveReaderEventListener, key=0x7fb2f8002450

    [D][215629][demo_tag][14:05:12:032945][participant.cpp:580][communication] participant id: 111111 use count: 2

    [D][215629][demo_tag][14:05:12:032948][participant.cpp:580][communication] participant id: 111115 use count: 0

    [D][215629][demo_tag][14:05:12:032950][participant.cpp:583][communication] erase participant id: 111115

    [D][215629][demo_tag][14:05:12:032954][discovery_manager.cpp:1106][communication] DiscoveryManager::un_regist_reader uuid:dd1f47fb-6340-449c-badb-30180dc15f04

    [D][215629][demo_tag][14:05:12:032967][participant.cpp:57][communication] Destroy Participant start

    [D][215629][demo_tag][14:05:12:032968][participant.cpp:67][communication] Participant::~Participant data_writer_ = nullptr

    [D][215629][demo_tag][14:05:12:032970][participant.cpp:70][communication] Participant::~Participant destroy data reader

    [D][215629][demo_tag][14:05:12:032974][plugin_manager.cpp:1101][communication] DestroyDataReader, protocol=zmq_tcp, protocol_type=2

    [D][215629][demo_tag][14:05:12:032977][plugin_manager.cpp:1106][communication] Protocol zmq_tcp still has 0 data reader

    [D][215629][demo_tag][14:05:12:032981][plugin_manager.cpp:1113][communication] Erase from one DataReader Info

    [D][215629][demo_tag][14:05:12:032986][participant.cpp:78][communication] Participant::~Participant data_reader_ = nullptr

    [D][215629][demo_tag][14:05:12:032989][plugin_manager.cpp:45][communication] PluginReader::~PluginReader

    [D][215629][demo_tag][14:05:12:032991][plugin_manager.cpp:48][communication] PluginReader::~PluginReader, call plugin API, plug_handle_=0x7fb2f800a340

    [D][215629][demo_tag][14:05:12:032998][plugin_zmq_interface.cpp:1079][communication] [ZMQ plugin] Destroy data reader

    [D][215629][demo_tag][14:05:12:033002][plugin_zmq_data_reader.cpp:249][communication] [ZMQ plugin] ~ZmqReader

    [D][215629][demo_tag][14:05:12:033004][plugin_zmq_data_reader.cpp:427][communication] [ZMQ plugin] zmq reader stop start

    [D][215629][demo_tag][14:05:12:033006][plugin_zmq_data_reader.cpp:431][communication] [ZMQ plugin] waiting for zmq unlink...

    [D][215629][demo_tag][14:05:12:051118][discovery_manager.cpp:325][communication] DiscoveryManager::SendEndpointChangeMsg

    [D][215629][demo_tag][14:05:12:051206][discovery_manager.cpp:402][communication] DiscoveryManager::SendEndpointChangeMsg send DIS_MSG_TYPE_INCREASE_DEL version 4 reader_size 2 writer_size 0 entity size 1

    [D][215629][demo_tag][14:05:12:051217][discovery_manager.cpp:339][communication] DiscoveryManager::SendEndpointChangeMsg GroupSend hash 4271819530586767357

    [D][215629][demo_tag][14:05:12:122898][scheduler_executor.cpp:140][dataflow] Timer schedule add task dag_report

    [D][215629][demo_tag][14:05:12:122973][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:12:122981][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:12:122993][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:12:123010][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:12:123024][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:12:123072][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:12:123088][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:12:123090][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:12:123093][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:12:123099][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:12:123102][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:12:123109][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:12:323093][shm_manager.cpp:338][communication] SHMManager::start_check_ref after erase dead referencer, map_refs_.size = 2

    [D][215629][demo_tag][14:05:12:323259][scheduler_executor.cpp:140][dataflow] Timer schedule add task dag_report

    [D][215629][demo_tag][14:05:12:323305][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:12:323310][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:12:323317][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:12:323333][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:12:323347][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:12:323380][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:12:323394][writer.h:247][communication] begin write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:12:323395][writer.h:198][communication] participants_ size is 2

    [D][215629][demo_tag][14:05:12:323398][dispatcher.cpp:347][communication] Dispatcher receive one message[topic=0#%^&bole/dataflow/demosub_dag].

    [D][215629][demo_tag][14:05:12:323404][writer_base.cpp:238][communication] serial_data Set DataRef from msg

    [D][215629][demo_tag][14:05:12:323407][seg_writer.cpp:666][communication] seg_data is communication inner type SegMsg

    [D][215629][demo_tag][14:05:12:323419][writer.h:239][communication] end write message topic=0#%^&bole/dataflow/demosub_dag ...

    [D][215629][demo_tag][14:05:12:366338][plugin_zmq_data_reader_impl.cpp:519][communication] [ZMQ plugin] zmq read msg fail, reason: Resource temporarily unavailable

    [D][215629][demo_tag][14:05:12:366362][plugin_zmq_data_reader.cpp:412][communication] [ZMQ plugin] zmq read task exit

    [D][215629][demo_tag][14:05:12:366451][plugin_zmq_data_reader_impl.cpp:317][communication] [ZMQ plugin] zmq reader unlink endpoint: tcp://172.31.8.52:18579, link_type_: bind

    [D][215629][demo_tag][14:05:12:366503][plugin_zmq_common.cpp:408][communication] [ZMQ plugin] Delete monitor task, task_id: 1

    [D][215629][demo_tag][14:05:12:366588][plugin_zmq_data_reader_impl.cpp:395][communication] [ZMQ plugin] zmq reader monitor get event: 128

    [D][215629][demo_tag][14:05:12:366604][plugin_zmq_data_reader.cpp:208][communication] [ZMQ plugin] event_listeners_.size(): 0

    2024-03-22
    0
    0
  • TROS.Assist
    Lv.3

    没有看到有==send request failed的log，可以上传完整log吗（提供云盘地址下载）

    2024-03-27
    0
    0