|
@@ -2,7 +2,6 @@ package main
|
|
|
|
|
|
import (
|
|
import (
|
|
"cicv-data-closedloop/common/util"
|
|
"cicv-data-closedloop/common/util"
|
|
- masterConfig "cicv-data-closedloop/kinglong/master/pkg/cfg"
|
|
|
|
"cicv-data-closedloop/kinglong_msgs"
|
|
"cicv-data-closedloop/kinglong_msgs"
|
|
"fmt"
|
|
"fmt"
|
|
"github.com/bluenviron/goroslib/v2"
|
|
"github.com/bluenviron/goroslib/v2"
|
|
@@ -26,7 +25,7 @@ func main() {
|
|
if topic == TopicOfNodeFaultInfo {
|
|
if topic == TopicOfNodeFaultInfo {
|
|
_, _ = goroslib.NewSubscriber(goroslib.SubscriberConf{
|
|
_, _ = goroslib.NewSubscriber(goroslib.SubscriberConf{
|
|
Node: rosNode,
|
|
Node: rosNode,
|
|
- Topic: masterConfig.TopicOfNodeFaultInfo,
|
|
|
|
|
|
+ Topic: TopicOfNodeFaultInfo,
|
|
Callback: func(data *kinglong_msgs.FaultInfo) {
|
|
Callback: func(data *kinglong_msgs.FaultInfo) {
|
|
fmt.Println("收到话题", topic, "的数据", data)
|
|
fmt.Println("收到话题", topic, "的数据", data)
|
|
}})
|
|
}})
|
|
@@ -34,7 +33,7 @@ func main() {
|
|
if topic == TopicOfCicvLocation {
|
|
if topic == TopicOfCicvLocation {
|
|
_, _ = goroslib.NewSubscriber(goroslib.SubscriberConf{
|
|
_, _ = goroslib.NewSubscriber(goroslib.SubscriberConf{
|
|
Node: rosNode,
|
|
Node: rosNode,
|
|
- Topic: masterConfig.TopicOfCicvLocation,
|
|
|
|
|
|
+ Topic: TopicOfCicvLocation,
|
|
Callback: func(data *kinglong_msgs.PerceptionLocalization) {
|
|
Callback: func(data *kinglong_msgs.PerceptionLocalization) {
|
|
fmt.Println("收到话题", topic, "的数据", data)
|
|
fmt.Println("收到话题", topic, "的数据", data)
|
|
}})
|
|
}})
|
|
@@ -42,7 +41,7 @@ func main() {
|
|
if topic == TopicOfTpperception {
|
|
if topic == TopicOfTpperception {
|
|
_, _ = goroslib.NewSubscriber(goroslib.SubscriberConf{
|
|
_, _ = goroslib.NewSubscriber(goroslib.SubscriberConf{
|
|
Node: rosNode,
|
|
Node: rosNode,
|
|
- Topic: masterConfig.TopicOfTpperception,
|
|
|
|
|
|
+ Topic: TopicOfTpperception,
|
|
Callback: func(data *kinglong_msgs.PerceptionObjects) {
|
|
Callback: func(data *kinglong_msgs.PerceptionObjects) {
|
|
fmt.Println("收到话题", topic, "的数据", data)
|
|
fmt.Println("收到话题", topic, "的数据", data)
|
|
}})
|
|
}})
|
|
@@ -50,7 +49,7 @@ func main() {
|
|
if topic == TopicOfFaultInfo {
|
|
if topic == TopicOfFaultInfo {
|
|
_, _ = goroslib.NewSubscriber(goroslib.SubscriberConf{
|
|
_, _ = goroslib.NewSubscriber(goroslib.SubscriberConf{
|
|
Node: rosNode,
|
|
Node: rosNode,
|
|
- Topic: masterConfig.TopicOfFaultInfo,
|
|
|
|
|
|
+ Topic: TopicOfFaultInfo,
|
|
Callback: func(data *kinglong_msgs.FaultVec) {
|
|
Callback: func(data *kinglong_msgs.FaultVec) {
|
|
fmt.Println("收到话题", topic, "的数据", data)
|
|
fmt.Println("收到话题", topic, "的数据", data)
|
|
}})
|
|
}})
|
|
@@ -58,7 +57,7 @@ func main() {
|
|
if topic == TopicOfDataRead {
|
|
if topic == TopicOfDataRead {
|
|
_, _ = goroslib.NewSubscriber(goroslib.SubscriberConf{
|
|
_, _ = goroslib.NewSubscriber(goroslib.SubscriberConf{
|
|
Node: rosNode,
|
|
Node: rosNode,
|
|
- Topic: masterConfig.TopicOfDataRead,
|
|
|
|
|
|
+ Topic: TopicOfDataRead,
|
|
Callback: func(data *kinglong_msgs.Retrieval) {
|
|
Callback: func(data *kinglong_msgs.Retrieval) {
|
|
fmt.Println("收到话题", topic, "的数据", data)
|
|
fmt.Println("收到话题", topic, "的数据", data)
|
|
}})
|
|
}})
|