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
113
114
115
116
117
118
119
120
121
|
// --------------------------------------------------------------------------
//
// 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>
#include "BackupStoreRefCountDatabase.h"
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();
bool DoHousekeeping(bool KeepTryingForever = false);
int GetErrorCount() { return mErrorCount; }
private:
// utility functions
void MakeObjectFilename(int64_t ObjectID, std::string &rFilenameOut);
bool ScanDirectory(int64_t ObjectID, BackupStoreInfo& rBackupStoreInfo);
bool DeleteFiles(BackupStoreInfo& rBackupStoreInfo);
bool DeleteEmptyDirectories(BackupStoreInfo& rBackupStoreInfo);
void DeleteEmptyDirectory(int64_t dirId, std::vector<int64_t>& rToExamine,
BackupStoreInfo& rBackupStoreInfo);
BackupStoreRefCountDatabase::refcount_t DeleteFile(int64_t InDirectory,
int64_t ObjectID,
BackupStoreDirectory &rDirectory,
const std::string &rDirectoryFilename,
BackupStoreInfo& rBackupStoreInfo);
void UpdateDirectorySize(BackupStoreDirectory &rDirectory,
IOStream::pos_type new_size_in_blocks);
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;
// Count of errors found and fixed
int64_t mErrorCount;
// 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::auto_ptr<BackupStoreRefCountDatabase> mapNewRefs;
// Poll frequency
int mCountUntilNextInterprocessMsgCheck;
Logging::Tagger mTagWithClientID;
};
#endif // HOUSEKEEPSTOREACCOUNT__H
|
