| | |
| | | #include "center.h" |
| | | #include "center_topic_node.h" |
| | | #include "node_center.h" |
| | | #include "tcp_server.h" |
| | | #include <chrono> |
| | | |
| | | using namespace std::chrono; |
| | |
| | | } |
| | | |
| | | topic_node_.reset(new CenterTopicNode(center_ptr, shm)); |
| | | tcp_server_.reset(new TcpServer(kBHCenterPort, center_ptr)); |
| | | } |
| | | |
| | | BHCenter::~BHCenter() { Stop(); } |
| | |
| | | sockets_[info.name_]->Start(1, info.handler_, info.raw_handler_, info.idle_); |
| | | } |
| | | topic_node_->Start(); |
| | | tcp_server_->Start(); |
| | | return true; |
| | | } |
| | | |
| | | bool BHCenter::Stop() |
| | | { |
| | | tcp_server_->Stop(); |
| | | topic_node_->Stop(); |
| | | for (auto &kv : sockets_) { |
| | | kv.second->Stop(); |