lichao
2021-05-18 b4a8d1632c2b4a3d4dc6e03d732fa3e93fd0731e
fix re-register fail.
2个文件已修改
6 ■■■■ 已修改文件
src/topic_node.cpp 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/topic_node.h 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/topic_node.cpp
@@ -155,10 +155,10 @@
    }
    auto end_time = steady_clock::now() + milliseconds(timeout_ms);
    while (state_ != eStateUnregistered && steady_clock::now() < end_time) {
    while (!Valid() && steady_clock::now() < end_time) {
        std::this_thread::yield();
    }
    if (state_ != eStateUnregistered) {
    if (!Valid()) {
        SetLastError(eError, kErrMsgNotInit);
        return false;
    }
src/topic_node.h
@@ -156,7 +156,7 @@
    State state() const { return state_.load(); }
    bool IsOnline() { return state() == eStateOnline; }
    bool Init();
    bool Valid() const { return !sockets_.empty(); }
    bool Valid() const { return state() != eStateUninited; }
    std::mutex mutex_;
    MQId ssn_id_ = 0;
    std::atomic<State> state_;