[thirdparty/squid.git] / src / fs / ufs / RebuildState.h

/*
 * Copyright (C) 1996-2017 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_FS_UFS_REBUILDSTATE_H
#define SQUID_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(RefCount<UFSSwapDir> sd);
    virtual ~RebuildState();

    virtual bool error() const;
    virtual bool isDone() const;
    virtual StoreEntry *currentItem();

    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;
    char fullpath[MAXPATHLEN];
    char fullfilename[MAXPATHLEN];

    StoreRebuildData counts;

private:
    void rebuildFromDirectory();
    void rebuildFromSwapLog();
    void rebuildStep();
    void undoAdd();
    int getNextFile(sfileno *, int *size);
    StoreEntry *currentEntry() const;
    void currentEntry(StoreEntry *);
    StoreEntry *e;
    bool fromLog;
    bool _done;
    /// \bug (callback) should be hidden behind a proper human readable name
    void (callback)(void *cbdata);
    void *cbdata;
};

} /* namespace Ufs */
} /* namespace Fs */

#endif /* SQUID_FS_UFS_REBUILDSTATE_H */
Commit	Line	Data
	1	/*
	2	* Copyright (C) 1996-2017 The Squid Software Foundation and contributors
	3	*
	4	* Squid software is distributed under GPLv2+ license and includes
	5	* contributions from numerous individuals and organizations.
	6	* Please see the COPYING and CONTRIBUTORS files for details.
	7	*/
	8
	9	#ifndef SQUID_FS_UFS_REBUILDSTATE_H
	10	#define SQUID_FS_UFS_REBUILDSTATE_H
	11
	12	#include "base/RefCount.h"
	13	#include "store_rebuild.h"
	14	#include "UFSSwapDir.h"
	15	#include "UFSSwapLogParser.h"
	16
	17	class StoreEntry;
	18
	19	namespace Fs
	20	{
	21	namespace Ufs
	22	{
	23
	24	class RebuildState
	25	{
	26	CBDATA_CLASS(RebuildState);
	27
	28	public:
	29	static EVH RebuildStep;
	30
	31	RebuildState(RefCount<UFSSwapDir> sd);
	32	virtual ~RebuildState();
	33
	34	virtual bool error() const;
	35	virtual bool isDone() const;
	36	virtual StoreEntry *currentItem();
	37
	38	RefCount<UFSSwapDir> sd;
	39	int n_read;
	40	/* FILE log;/
	41	Fs::Ufs::UFSSwapLogParser *LogParser;
	42	int curlvl1;
	43	int curlvl2;
	44
	45	struct Flags {
	46	Flags() : need_to_validate(false), clean(false), init(false) {}
	47	bool need_to_validate;
	48	bool clean;
	49	bool init;
	50	} flags;
	51	int in_dir;
	52	int done;
	53	int fn;
	54
	55	dirent_t *entry;
	56	DIR *td;
	57	char fullpath[MAXPATHLEN];
	58	char fullfilename[MAXPATHLEN];
	59
	60	StoreRebuildData counts;
	61
	62	private:
	63	void rebuildFromDirectory();
	64	void rebuildFromSwapLog();
	65	void rebuildStep();
	66	void undoAdd();
	67	int getNextFile(sfileno , int size);
	68	StoreEntry *currentEntry() const;
	69	void currentEntry(StoreEntry *);
	70	StoreEntry *e;
	71	bool fromLog;
	72	bool _done;
	73	/// \bug (callback) should be hidden behind a proper human readable name
	74	void (callback)(void *cbdata);
	75	void *cbdata;
	76	};
	77
	78	} /* namespace Ufs */
	79	} /* namespace Fs */
	80
	81	#endif /* SQUID_FS_UFS_REBUILDSTATE_H */
	82