2 * Copyright (c) 2008 The DragonFly Project. All rights reserved.
4 * This code is derived from software contributed to The DragonFly Project
5 * by Matthew Dillon <dillon@backplane.com>
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted provided that the following conditions
11 * 1. Redistributions of source code must retain the above copyright
12 * notice, this list of conditions and the following disclaimer.
13 * 2. Redistributions in binary form must reproduce the above copyright
14 * notice, this list of conditions and the following disclaimer in
15 * the documentation and/or other materials provided with the
17 * 3. Neither the name of The DragonFly Project nor the names of its
18 * contributors may be used to endorse or promote products derived
19 * from this software without specific, prior written permission.
21 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
22 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
23 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
24 * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
25 * COPYRIGHT HOLDERS OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
26 * INCIDENTAL, SPECIAL, EXEMPLARY OR CONSEQUENTIAL DAMAGES (INCLUDING,
27 * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
28 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
29 * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
30 * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
31 * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
34 * $DragonFly: src/sbin/hammer/cmd_prune.c,v 1.6 2008/05/05 20:34:52 dillon Exp $
39 static void hammer_prune_load_file(hammer_tid_t now_tid
,
40 struct hammer_ioc_prune
*prune
,
41 const char *filesystem
, const char *filename
);
42 static int hammer_prune_parse_line(hammer_tid_t now_tid
,
43 struct hammer_ioc_prune
*prune
,
44 const char *filesystem
, char **av
, int ac
);
45 static void hammer_prune_create_links(const char *filesystem
,
46 struct hammer_ioc_prune
*prune
);
47 static void hammer_prune_make_softlink(const char *filesystem
,
49 static int parse_modulo_time(const char *str
, u_int64_t
*delta
);
50 static char *tid_to_stamp_str(hammer_tid_t tid
);
51 static void prune_usage(int code
);
54 * prune <filesystem> from <modulo_time> to <modulo_time> every <modulo_time>
55 * prune <filesystem> [using <filename>]
58 hammer_cmd_prune(char **av
, int ac
)
60 struct hammer_ioc_prune prune
;
61 const char *filesystem
;
63 hammer_tid_t now_tid
= (hammer_tid_t
)time(NULL
) * 1000000000LL;
65 bzero(&prune
, sizeof(prune
));
67 prune
.beg_obj_id
= HAMMER_MIN_OBJID
;
68 prune
.end_obj_id
= HAMMER_MAX_OBJID
;
69 prune
.cur_obj_id
= prune
.end_obj_id
; /* remove me */
70 prune
.cur_key
= HAMMER_MAX_KEY
; /* remove me */
71 prune
.stat_oldest_tid
= HAMMER_MAX_TID
;
77 hammer_prune_load_file(now_tid
, &prune
, filesystem
,
79 } else if (strcmp(av
[1], "using") == 0) {
82 hammer_prune_load_file(now_tid
, &prune
, filesystem
, av
[2]);
83 } else if (strcmp(av
[1], "everything") == 0) {
84 prune
.head
.flags
|= HAMMER_IOC_PRUNE_ALL
;
88 if (hammer_prune_parse_line(now_tid
, &prune
, filesystem
,
93 fd
= open(filesystem
, O_RDONLY
);
95 err(1, "Unable to open %s", filesystem
);
96 if (ioctl(fd
, HAMMERIOC_PRUNE
, &prune
) < 0) {
97 printf("Prune %s failed: %s\n",
98 filesystem
, strerror(errno
));
99 } else if (prune
.head
.flags
& HAMMER_IOC_HEAD_INTR
) {
100 printf("Prune %s interrupted by timer at %016llx\n",
101 filesystem
, prune
.cur_obj_id
);
103 printf("Prune %s succeeded\n", filesystem
);
107 hammer_prune_create_links(filesystem
, &prune
);
108 printf("Pruned %lld records (%lld directory entries) and %lld bytes\n",
109 prune
.stat_rawrecords
,
110 prune
.stat_dirrecords
,
116 hammer_prune_load_file(hammer_tid_t now_tid
, struct hammer_ioc_prune
*prune
,
117 const char *filesystem
, const char *filename
)
125 if ((fp
= fopen(filename
, "r")) == NULL
)
126 err(1, "Unable to read %s", filename
);
128 while (fgets(buf
, sizeof(buf
), fp
) != NULL
) {
130 if (strncmp(buf
, "prune", 5) != 0)
133 av
[ac
] = strtok(buf
, " \t\r\n");
134 while (av
[ac
] != NULL
) {
138 errx(1, "Malformed prune directive in %s "
139 "line %d\n", filename
, lineno
);
141 av
[ac
] = strtok(NULL
, " \t\r\n");
145 if (strcmp(av
[0], "prune") != 0)
147 if (hammer_prune_parse_line(now_tid
, prune
, filesystem
,
148 av
+ 1, ac
- 1) < 0) {
149 errx(1, "Malformed prune directive in %s line %d\n",
158 plural(int notplural
)
160 return(notplural
? "" : "s");
164 * Parse the following parameters:
166 * <filesystem> from <modulo_time> to <modulo_time> every <modulo_time>
169 hammer_prune_parse_line(hammer_tid_t now_tid
, struct hammer_ioc_prune
*prune
,
170 const char *filesystem
, char **av
, int ac
)
172 struct hammer_ioc_prune_elm
*elm
;
175 u_int64_t every_time
;
176 char *from_stamp_str
;
181 if (strcmp(av
[0], filesystem
) != 0)
183 if (strcmp(av
[1], "from") != 0)
185 if (strcmp(av
[3], "to") != 0)
187 if (strcmp(av
[5], "every") != 0)
189 if (parse_modulo_time(av
[2], &from_time
) < 0)
191 if (parse_modulo_time(av
[4], &to_time
) < 0)
193 if (parse_modulo_time(av
[6], &every_time
) < 0)
195 if (from_time
> to_time
)
197 if (from_time
== 0 || to_time
== 0) {
198 fprintf(stderr
, "Bad from or to time specification.\n");
201 if (to_time
% from_time
!= 0) {
202 fprintf(stderr
, "Bad TO time specification.\n"
203 "It must be an integral multiple of FROM time\n");
206 if (every_time
== 0 ||
207 from_time
% every_time
!= 0 ||
208 to_time
% every_time
!= 0) {
209 fprintf(stderr
, "Bad 'every <modulo_time>' specification.\n"
210 "It must be an integral subdivision of FROM and TO\n");
213 if (prune
->nelms
== HAMMER_MAX_PRUNE_ELMS
) {
214 fprintf(stderr
, "Too many prune specifications in file! "
215 "Max is %d\n", HAMMER_MAX_PRUNE_ELMS
);
220 * Example: from 1m to 60m every 5m
222 elm
= &prune
->elms
[prune
->nelms
++];
223 elm
->beg_tid
= now_tid
- now_tid
% to_time
;
224 if (now_tid
- elm
->beg_tid
< to_time
)
225 elm
->beg_tid
-= to_time
;
227 elm
->end_tid
= now_tid
- now_tid
% from_time
;
228 if (now_tid
- elm
->end_tid
< from_time
)
229 elm
->end_tid
-= from_time
;
231 elm
->mod_tid
= every_time
;
232 assert(elm
->beg_tid
< elm
->end_tid
);
235 * Convert back to local time for pretty printing
237 from_stamp_str
= tid_to_stamp_str(elm
->beg_tid
);
238 to_stamp_str
= tid_to_stamp_str(elm
->end_tid
);
239 printf("Prune %s to %s every ", from_stamp_str
, to_stamp_str
);
241 every_time
/= 1000000000;
243 printf("%lld second%s\n", every_time
, plural(every_time
== 1));
245 if (every_time
&& every_time
< 60)
246 printf("%lld minute%s\n", every_time
, plural(every_time
== 1));
248 if (every_time
&& every_time
< 24)
249 printf("%lld hour%s\n", every_time
, plural(every_time
== 1));
252 printf("%lld day%s\n", every_time
, plural(every_time
== 1));
254 free(from_stamp_str
);
260 * Create softlinks in the form $linkpath/snap_ddmmmyyyy[_hhmmss]
263 hammer_prune_create_links(const char *filesystem
,
264 struct hammer_ioc_prune
*prune
)
266 struct hammer_ioc_prune_elm
*elm
;
272 if ((dir
= opendir(LinkPath
)) == NULL
) {
273 fprintf(stderr
, "Unable to access linkpath %s\n", LinkPath
);
276 while ((den
= readdir(dir
)) != NULL
) {
277 if (strncmp(den
->d_name
, "snap-", 5) == 0) {
278 asprintf(&path
, "%s/%s", LinkPath
, den
->d_name
);
285 for (elm
= &prune
->elms
[0]; elm
< &prune
->elms
[prune
->nelms
]; ++elm
) {
286 for (tid
= elm
->beg_tid
;
288 tid
+= elm
->mod_tid
) {
289 if (tid
< prune
->stat_oldest_tid
)
291 hammer_prune_make_softlink(filesystem
, tid
);
297 hammer_prune_make_softlink(const char *filesystem
, hammer_tid_t tid
)
305 t
= (time_t)(tid
/ 1000000000);
309 * Construct the contents of the softlink.
311 asprintf(&target
, "%s/@@0x%016llx", filesystem
, tid
);
314 * Construct the name of the snap-shot softlink
316 if (tid
% (1000000000ULL * 60 * 60 * 24) == 0) {
317 strftime(buf
, sizeof(buf
), "snap-%d%b%Y", tp
);
318 } else if (tid
% (1000000000ULL * 60 * 60) == 0) {
319 strftime(buf
, sizeof(buf
), "snap-%d%b%Y_%H%M", tp
);
320 } else if (tid
% (1000000000ULL * 60) == 0) {
321 strftime(buf
, sizeof(buf
), "snap-%d%b%Y_%H%M", tp
);
323 strftime(buf
, sizeof(buf
), "snap-%d%b%Y_%H%M%S", tp
);
326 asprintf(&path
, "%s/%s", LinkPath
, buf
);
327 symlink(target
, path
);
334 parse_modulo_time(const char *str
, u_int64_t
*delta
)
338 *delta
= strtoull(str
, &term
, 10);
361 *delta
*= 1000000000LL; /* TID's are in nanoseconds */
366 tid_to_stamp_str(hammer_tid_t tid
)
369 char *buf
= malloc(256);
372 t
= (time_t)(tid
/ 1000000000);
374 strftime(buf
, 256, "%e-%b-%Y %H:%M:%S %Z", tp
);
379 prune_usage(int code
)
381 fprintf(stderr
, "Bad prune directive, specify one of:\n"
382 "prune filesystem [using filename]\n"
383 "prune filesystem from <modulo_time> to <modulo_time> every <modulo_time>\n"
384 "prune filesystem everything\n");