lichao
2021-05-18 9f9d05d8cfb8076a4067a0e3c7561781521225ed
trivial.
2个文件已修改
13 ■■■■■ 已修改文件
box/box.cc 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/topic_node.cpp 11 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
box/box.cc
@@ -41,7 +41,7 @@
        }
        return false;
    }
    void Apply(std::function<void(const std::string &id, const std::string &desc)> f) const
    void Apply(std::function<void(const std::string &id, const std::string &desc)> const &f) const
    {
        for (auto &kv : functions_) {
            f(kv.second.id_, kv.second.desc_);
src/topic_node.cpp
@@ -107,14 +107,9 @@
                    }
                    SetProcIndex(reply.proc_index());
                    this->state_ = eStateUnregistered;
                    auto onRequest = [this](ShmSocket &socket, MsgI &msg, BHMsgHead &head) {
                        server_buffer_->Write(std::move(head), msg.body());
                    };
                    SockServer().Start(onRequest);
                    auto onSub = [this](ShmSocket &socket, MsgI &msg, BHMsgHead &head) {
                        sub_buffer_->Write(std::move(head), msg.body());
                    };
                    SockSub().Start(onSub);
                    ServerStart(ServerAsyncCB(), 1);
                    SubscribeStartWorker(SubDataCB(), 1);
                }
            } break;
            default: break;