| 54 | |
| 55 | |
| 56 | ModuleServiceImpl::~ModuleServiceImpl() { |
| 57 | if (run_serve_task_ && run_serve_task_->joinable()) run_serve_task_->join(); |
| 58 | if (socket_) socket_->close(); |
| 59 | if (inner_cmd_socket_) inner_cmd_socket_->close(); |
| 60 | if (zmq_ctx_) zmq_ctx_->close(); |
| 61 | } |
| 62 | |
| 63 | |
| 64 | void ModuleServiceImpl::Serve(void* module, const std::string& mid, const std::string& service_addr) { |