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
|
/* SPDX-License-Identifier: GPL-2.0 */
/* The possible states for snapshot creation/removal. */
#define HOOK_STATUS_ARRAY \
HSA_ITEM(HS_READY, "ready for action"), \
HSA_ITEM(HS_PRE_RUNNING, "pre-hook running"), \
HSA_ITEM(HS_PRE_SUCCESS, "pre-hook completed successfully"), \
HSA_ITEM(HS_RUNNING, "in progress"), \
HSA_ITEM(HS_SUCCESS, "process terminated successfully"), \
HSA_ITEM(HS_NEEDS_RESTART, "restart needed"), \
HSA_ITEM(HS_POST_RUNNING, "post-hook running")
#define HSA_ITEM(x, y) x
enum hook_status {HOOK_STATUS_ARRAY};
#undef HSA_ITEM
#define HSA_ITEM(x, y) y
/*
* The status of a snapshot.
*
* The snapshot directories come in four different flavours, depending
* on how the two status flags are set. Examples:
*
* Complete, not being deleted: 1204565370-1204565371.Sun_Mar_02_2008_14_33-Sun_Mar_02_2008_14_43.
* Complete, being deleted: 1204565370-1204565371.being_deleted.
* Incomplete, not being deleted: 1204565370-incomplete.
* incomplete, being deleted: 1204565370-incomplete.being_deleted.
*/
enum snapshot_status_flags {
/* The rsync process terminated successfully. */
SS_COMPLETE = 1,
/* The rm process is running to remove this snapshot. */
SS_BEING_DELETED = 2
};
/* Describes one snapshot. */
struct snapshot {
/* The name of the directory, relative to the destination dir. */
char *name;
/* Seconds after the epoch when this snapshot was created. */
int64_t creation_time;
/*
* Seconds after the epoch when creation of this snapshot completed.
* Only meaningful if the SS_COMPLETE bit is set.
*/
int64_t completion_time;
/* See snapshot_status_flags. */
enum snapshot_status_flags flags;
/* The interval this snapshot belongs to. */
unsigned interval;
};
struct snapshot_list {
int64_t now;
unsigned num_snapshots;
unsigned array_size;
struct snapshot **snapshots;
/*
* Array of size num_intervals + 1
*
* It contains the number of snapshots in each interval.
* interval_count[num_intervals] is the number of snapshots which
* belong to any interval greater than num_intervals.
*/
unsigned *interval_count;
};
/* Iterate over all snapshots in a snapshot list. */
#define FOR_EACH_SNAPSHOT(s, i, sl) \
for ((i) = 0; (i) < (sl)->num_snapshots && ((s) = (sl)->snapshots[(i)]); (i)++)
/* Iterate backwards over all snapshots in a snapshot list. */
#define FOR_EACH_SNAPSHOT_REVERSE(s, i, sl) \
for ((i) = (sl)->num_snapshots; (i) > 0 && ((s) = (sl)->snapshots[(i - 1)]); (i)--)
unsigned desired_number_of_snapshots(int interval_num, int num_intervals);
void get_snapshot_list(struct snapshot_list *sl, int unit_interval,
int num_intervals);
void free_snapshot_list(struct snapshot_list *sl);
__malloc char *incomplete_name(int64_t start);
__malloc char *being_deleted_name(struct snapshot *s);
int complete_name(int64_t start, int64_t end, char **result);
__malloc char *name_of_newest_complete_snapshot(struct snapshot_list *sl);
int num_complete_snapshots(struct snapshot_list *sl);
/*
* Get the newest snapshot in a snapshot list.
*/
static inline struct snapshot *get_newest_snapshot(struct snapshot_list *sl)
{
if (!sl->num_snapshots)
return NULL;
return sl->snapshots[sl->num_snapshots - 1];
}
|
