Method Init

phxqueue/store/checkpointstat.cpp:67–102

}

comm::RetCode CheckPointStat::Init(const string &dir, const string &file) {
    if (dir.empty() || file.empty())
        return comm::RetCode::RET_ERR_ARG;

    impl_->dir = dir;
    impl_->file = file;
    string path{impl_->dir + impl_->file};

    impl_->buf = nullptr;
    impl_->len = sizeof(CheckPointStatItem_t);

    int fd = open(path.c_str(), O_RDWR | O_CREAT, S_IRUSR | S_IWUSR);
    if (fd < 0) {
        QLErr("open err path %s %s", path.c_str(), strerror(errno));
        return comm::RetCode::RET_ERR_SYS;
    }

    if (ftruncate(fd, (off_t)impl_->len) < 0) {
        QLErr("ftruncate err %s", strerror(errno));
        close(fd);
        return comm::RetCode::RET_ERR_SYS;
    }

    void *pa{mmap(nullptr, impl_->len, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0)};

    close(fd);

    if ((char *)pa == MAP_FAILED) {
        QLErr("mmap err %s", strerror(errno));
        return comm::RetCode::RET_ERR_SYS;
    }

    impl_->buf = (CheckPointStatItem_t*)pa;

    return comm::RetCode::RET_OK;
}

comm::RetCode CheckPointStat::GetCheckPoint(uint64_t &cp) {
    cp = -1;