Method Put

phxqueue/lock/lockdb.cpp:323–353

//}

comm::RetCode LockDb::Put(const string &k, const proto::LocalLockInfo &v, const bool sync) {
    if (0 >= k.size()) {
        QLErr("key \"%s\" invalid", k.c_str());

        return comm::RetCode::RET_ERR_KEY;
    }

    if (Type::MAP == type_) {
        // TODO: emplace?
        map_[k] = v;
        QLVerb("key \"%s\" ver %llu", k.c_str(), v.version());
    } else if (Type::LEVELDB == type_) {
        string vstr;
        // TODO: Not copy?
        proto::LocalLockInfo v2 = v;
        v2.clear_expire_time_ms();
        bool succ{v2.SerializeToString(&vstr)};
        if (!succ) {
            QLErr("SerializeToString err");

            return comm::RetCode::RET_ERR_LOGIC;
        }
        QLVerb("key \"%s\" ver %llu", k.c_str(), v.version());

        return Put(k, vstr, sync);
    } else {
        return comm::RetCode::RET_ERR_NO_IMPL;
    }

    return comm::RetCode::RET_OK;
}

comm::RetCode LockDb::Put(const string &k, const string &vstr, const bool sync) {
    if (0 >= k.size()) {