lichao
2021-05-27 026bbfaf2b5d73a26b8e2fa49158883ef64c211b
box/center.cpp
@@ -18,6 +18,7 @@
#include "center.h"
#include "center_topic_node.h"
#include "node_center.h"
#include "tcp_server.h"
#include <chrono>
using namespace std::chrono;
@@ -175,6 +176,7 @@
   }
   topic_node_.reset(new CenterTopicNode(center_ptr, shm));
   tcp_server_.reset(new TcpServer(kBHCenterPort, center_ptr));
}
BHCenter::~BHCenter() { Stop(); }
@@ -186,11 +188,13 @@
      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();