Method after_create_locknode

src/zookeeper/lock_struct.cpp:546–588

static*/

}
/*static*/
void lock_struct::after_create_locknode(lock_struct_ptr _this,
                                        int ec,
                                        std::shared_ptr<std::string> path)
{
    // as we create an ephe|seq node, so ZNODEEXISTS is not allowed
    static const int allow_ec[] = {
        ZOK,          // succeed
        ZINVALIDSTATE // operation timeout
    };
    static const int allow_state[] = {
        lock_state::pending, lock_state::cancelled, lock_state::expired};

    _this->_checker.only_one_thread_access();
    __check_code(ec, allow_ec, 2, zerror(ec));
    __check_code(_this->_state, allow_state, 3, string_state(_this->_state));

    LOG_DEBUG("after create seq and ephe node, error({}), path({})", zerror(ec), *path);
    if (_this->_state == lock_state::cancelled || _this->_state == lock_state::expired) {
        LOG_INFO("current state({}), ignore event create lockdir({})",
                 string_state(_this->_state),
                 _this->_lock_dir);
        if (ZOK == ec && _this->_state == lock_state::cancelled) {
            _this->remove_my_locknode(std::move(*path), IGNORE_CALLBACK, REMOVE_FOR_CANCEL);
        }
        return;
    }
    if (ZINVALIDSTATE == ec) {
        LOG_ERROR("create seq/ephe node ({}) in dir({}) got session expired",
                  distributed_lock_service_zookeeper::LOCK_NODE_PREFIX,
                  _this->_lock_dir);
        _this->on_expire();
        return;
    }

    char splitter[] = {'/', 0};
    _this->_myself._node_seq_name = utils::get_last_component(*path, splitter);
    _this->_myself._sequence_id = parse_seq_path(_this->_myself._node_seq_name);
    CHECK_NE_MSG(_this->_myself._sequence_id, -1, "invalid seq path created");
    LOG_INFO("create seq/ephe node in dir({}) ok, my_sequence_id({})",
             _this->_lock_dir,
             _this->_myself._sequence_id);
    _this->get_lockdir_nodes();
}

void lock_struct::create_locknode()
{