Method AcquireLock

phxqueue_phxrpc/consumer/consumer.cpp:98–107

}

phxqueue::comm::RetCode
Consumer::AcquireLock(const phxqueue::comm::proto::AcquireLockRequest &req,
                      phxqueue::comm::proto::AcquireLockResponse &resp) {
    static __thread LockClient lock_client;
    auto ret = lock_client.ProtoAcquireLock(req, resp);
    if (phxqueue::comm::RetCode::RET_OK != ret) {
        QLErr("ProtoAcquireLock ret %d", phxqueue::comm::as_integer(ret));
    }
    return ret;
}


}  // namespace consumer