RebuildState.h

Go to the documentation of this file.

/*
 * Copyright (C) 1996-2023 The Squid Software Foundation and contributors
 *
 * Squid software is distributed under GPLv2+ license and includes
 * contributions from numerous individuals and organizations.
 * Please see the COPYING and CONTRIBUTORS files for details.
 */
 
#ifndef SQUID_SRC_FS_UFS_REBUILDSTATE_H
#define SQUID_SRC_FS_UFS_REBUILDSTATE_H
 
#include "base/RefCount.h"
#include "store_rebuild.h"
#include "UFSSwapDir.h"
#include "UFSSwapLogParser.h"
 
class StoreEntry;
 
namespace Fs
{
namespace Ufs
{
 
class RebuildState
{
    CBDATA_CLASS(RebuildState);
 
public:
    static EVH RebuildStep;
 
    RebuildState(const RefCount<UFSSwapDir> &sd);
    virtual ~RebuildState();
 
    virtual bool error() const;
    virtual bool isDone() const;
 
    RefCount<UFSSwapDir> sd;
    int n_read;
    /*    FILE *log;*/
    Fs::Ufs::UFSSwapLogParser *LogParser;
    int curlvl1;
    int curlvl2;
 
    struct Flags {
        Flags() : need_to_validate(false), clean(false), init(false) {}
        bool need_to_validate;
        bool clean;
        bool init;
    } flags;
    int in_dir;
    int done;
    int fn;
 
    dirent_t *entry;
    DIR *td;
    SBuf fullpath;
    SBuf fullfilename;
 
    StoreRebuildData counts;
 
private:
    void rebuildFromDirectory();
    void rebuildFromSwapLog();
    void rebuildStep();
    void addIfFresh(const cache_key *key,
                    sfileno file_number,
                    uint64_t swap_file_sz,
                    time_t expires,
                    time_t timestamp,
                    time_t lastref,
                    time_t lastmod,
                    uint32_t refcount,
                    uint16_t flags);
    bool evictStaleAndContinue(const cache_key *candidateKey, const time_t maxRef, int &staleCount);
    int getNextFile(sfileno *, int *size);
    bool fromLog;
    bool _done;
    // TODO: (callback) should be hidden behind a proper human readable name
    void (callback)(void *cbdata);
    void *cbdata;
};
 
} /* namespace Ufs */
} /* namespace Fs */
 
#endif /* SQUID_SRC_FS_UFS_REBUILDSTATE_H */