1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
|
// --------------------------------------------------------------------------
//
// File
// Name: HousekeepStoreAccount.h
// Purpose: Action class to perform housekeeping on a store account
// Created: 11/12/03
//
// --------------------------------------------------------------------------
#ifndef HOUSEKEEPSTOREACCOUNT__H
#define HOUSEKEEPSTOREACCOUNT__H
#include <string>
#include <set>
#include <vector>
class BackupStoreDaemon;
class BackupStoreDirectory;
class HousekeepingCallback
{
public:
virtual ~HousekeepingCallback() {}
virtual bool CheckForInterProcessMsg(int AccountNum = 0, int MaximumWaitTime = 0) = 0;
};
// --------------------------------------------------------------------------
//
// Class
// Name: HousekeepStoreAccount
// Purpose: Action class to perform housekeeping on a store account
// Created: 11/12/03
//
// --------------------------------------------------------------------------
class HousekeepStoreAccount
{
public:
HousekeepStoreAccount(int AccountID, const std::string &rStoreRoot,
int StoreDiscSet, HousekeepingCallback* pHousekeepingCallback);
~HousekeepStoreAccount();
void DoHousekeeping(bool KeepTryingForever = false);
int GetRefCountsAdjusted() { return mRefCountsAdjusted; }
private:
// utility functions
void MakeObjectFilename(int64_t ObjectID, std::string &rFilenameOut);
bool ScanDirectory(int64_t ObjectID);
bool DeleteFiles();
bool DeleteEmptyDirectories();
void DeleteEmptyDirectory(int64_t dirId,
std::vector<int64_t>& rToExamine);
void DeleteFile(int64_t InDirectory, int64_t ObjectID, BackupStoreDirectory &rDirectory, const std::string &rDirectoryFilename, int64_t OriginalDirSizeInBlocks);
private:
typedef struct
{
int64_t mObjectID;
int64_t mInDirectory;
int64_t mSizeInBlocks;
int32_t mMarkNumber;
int32_t mVersionAgeWithinMark; // 0 == current, 1 latest old version, etc
bool mIsFlagDeleted; // false for files flagged "Old"
} DelEn;
struct DelEnCompare
{
bool operator()(const DelEn &x, const DelEn &y);
};
int mAccountID;
std::string mStoreRoot;
int mStoreDiscSet;
HousekeepingCallback* mpHousekeepingCallback;
int64_t mDeletionSizeTarget;
std::set<DelEn, DelEnCompare> mPotentialDeletions;
int64_t mPotentialDeletionsTotalSize;
int64_t mMaxSizeInPotentialDeletions;
// List of directories which are empty, and might be good for deleting
std::vector<int64_t> mEmptyDirectories;
// The re-calculated blocks used stats
int64_t mBlocksUsed;
int64_t mBlocksInOldFiles;
int64_t mBlocksInDeletedFiles;
int64_t mBlocksInDirectories;
// Deltas from deletion
int64_t mBlocksUsedDelta;
int64_t mBlocksInOldFilesDelta;
int64_t mBlocksInDeletedFilesDelta;
int64_t mBlocksInDirectoriesDelta;
// Deletion count
int64_t mFilesDeleted;
int64_t mEmptyDirectoriesDeleted;
// New reference count list
std::vector<uint32_t> mNewRefCounts;
bool mSuppressRefCountChangeWarnings;
int mRefCountsAdjusted;
// Poll frequency
int mCountUntilNextInterprocessMsgCheck;
};
#endif // HOUSEKEEPSTOREACCOUNT__H
|