2 * Amanda, The Advanced Maryland Automatic Network Disk Archiver
3 * Copyright (c) 1991-1998 University of Maryland at College Park
6 * Permission to use, copy, modify, distribute, and sell this software and its
7 * documentation for any purpose is hereby granted without fee, provided that
8 * the above copyright notice appear in all copies and that both that
9 * copyright notice and this permission notice appear in supporting
10 * documentation, and that the name of U.M. not be used in advertising or
11 * publicity pertaining to distribution of the software without specific,
12 * written prior permission. U.M. makes no representations about the
13 * suitability of this software for any purpose. It is provided "as is"
14 * without express or implied warranty.
16 * U.M. DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE, INCLUDING ALL
17 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS, IN NO EVENT SHALL U.M.
18 * BE LIABLE FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
19 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION
20 * OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN
21 * CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
23 * Authors: the Amanda Development Team. Its members are listed in a
24 * file named AUTHORS, in the root directory of this distribution.
27 * $Id: amtrmidx.c,v 1.42 2006/07/25 18:27:57 martinea Exp $
29 * trims number of index files to only those still in system. Well
30 * actually, it keeps a few extra, plus goes back to the last level 0
36 #ifdef HAVE_NETINET_IN_SYSTM_H
37 #include <netinet/in_systm.h>
46 static int sort_by_name_reversed(const void *a, const void *b);
48 int main(int argc, char **argv);
50 static int sort_by_name_reversed(
54 char **ap = (char **) a;
55 char **bp = (char **) b;
57 return -1 * strcmp(*ap, *bp);
61 int main(int argc, char **argv)
70 find_result_t *output_find;
72 int amtrmidx_debug = 0;
73 int new_argc, my_argc;
74 char **new_argv, **my_argv;
79 set_pname("amtrmidx");
81 /* Don't die when child closes pipe */
82 signal(SIGPIPE, SIG_IGN);
84 dbopen(DBG_SUBDIR_SERVER);
85 dbprintf(("%s: version %s\n", argv[0], version()));
87 parse_conf(argc, argv, &new_argc, &new_argv);
91 if (my_argc > 1 && strcmp(my_argv[1], "-t") == 0) {
98 fprintf(stderr, "Usage: %s [-t] <config> [-o configoption]*\n", my_argv[0]);
102 config_name = my_argv[1];
104 config_dir = vstralloc(CONFIG_DIR, "/", config_name, "/", NULL);
105 conffile = stralloc2(config_dir, CONFFILE_NAME);
106 if (read_conffile(conffile)) {
107 error("errors processing config file \"%s\"", conffile);
112 dbrename(config_name, DBG_SUBDIR_SERVER);
114 report_bad_conf_arg();
116 conf_diskfile = getconf_str(CNF_DISKFILE);
117 if(*conf_diskfile == '/') {
118 conf_diskfile = stralloc(conf_diskfile);
120 conf_diskfile = stralloc2(config_dir, conf_diskfile);
122 if (read_diskfile(conf_diskfile, &diskl) < 0) {
123 error("could not load disklist \"%s\"", conf_diskfile);
126 amfree(conf_diskfile);
128 conf_tapelist = getconf_str(CNF_TAPELIST);
129 if(*conf_tapelist == '/') {
130 conf_tapelist = stralloc(conf_tapelist);
132 conf_tapelist = stralloc2(config_dir, conf_tapelist);
134 if(read_tapelist(conf_tapelist)) {
135 error("could not load tapelist \"%s\"", conf_tapelist);
138 amfree(conf_tapelist);
140 output_find = find_dump(1, &diskl);
142 conf_indexdir = getconf_str(CNF_INDEXDIR);
143 if(*conf_indexdir == '/') {
144 conf_indexdir = stralloc(conf_indexdir);
146 conf_indexdir = stralloc2(config_dir, conf_indexdir);
149 /* now go through the list of disks and find which have indexes */
151 tmp_time -= 7*24*60*60; /* back one week */
152 for (diskp = diskl.head; diskp != NULL; diskp = diskp->next)
156 char *indexdir, *qindexdir;
167 /* get listing of indices, newest first */
168 host = sanitise_filename(diskp->host->hostname);
169 disk = sanitise_filename(diskp->name);
170 qdisk = quote_string(diskp->name);
171 indexdir = vstralloc(conf_indexdir, "/",
175 qindexdir = quote_string(indexdir);
177 dbprintf(("%s %s -> %s\n", diskp->host->hostname,
182 if ((d = opendir(indexdir)) == NULL) {
183 dbprintf(("could not open index directory %s\n", qindexdir));
189 names = (char **)alloc(name_length * SIZEOF(char *));
191 while ((f = readdir(d)) != NULL) {
194 if(is_dot_or_dotdot(f->d_name)) {
197 for(i = 0; i < SIZEOF("YYYYMMDDHHMMSS")-1; i++) {
198 if(! isdigit((int)(f->d_name[i]))) {
203 /* len_date=8 for YYYYMMDD */
204 /* len_date=14 for YYYYMMDDHHMMSS */
205 if((len_date != 8 && len_date != 14)
206 || f->d_name[len_date] != '_'
207 || ! isdigit((int)(f->d_name[len_date+1]))) {
208 continue; /* not an index file */
211 * Clear out old index temp files.
213 l = strlen(f->d_name) - (SIZEOF(".tmp")-1);
214 if ((l > (len_date + 1))
215 && (strcmp(f->d_name + l, ".tmp")==0)) {
219 path = stralloc2(indexdir, f->d_name);
220 qpath = quote_string(path);
221 if(lstat(path, &sbuf) != -1
222 && ((sbuf.st_mode & S_IFMT) == S_IFREG)
223 && ((time_t)sbuf.st_mtime < tmp_time)) {
224 dbprintf(("rm %s\n", qpath));
225 if(amtrmidx_debug == 0 && unlink(path) == -1) {
226 dbprintf(("Error removing %s: %s\n",
227 qpath, strerror(errno)));
234 if(name_count >= name_length) {
237 new_names = alloc((name_length * 2) * SIZEOF(char *));
238 memcpy(new_names, names, name_length * SIZEOF(char *));
243 names[name_count++] = stralloc(f->d_name);
246 qsort(names, name_count, SIZEOF(char *), sort_by_name_reversed);
249 * Search for the first full dump past the minimum number
250 * of index files to keep.
252 for(i = 0; i < name_count; i++) {
257 for(len_date = 0; len_date < SIZEOF("YYYYMMDDHHMMSS")-1; len_date++) {
258 if(! isdigit((int)(names[i][len_date]))) {
263 datestamp = stralloc(names[i]);
264 datestamp[len_date] = '\0';
265 level = names[i][len_date+1] - '0';
266 if(!dump_exist(output_find, diskp->host->hostname,
267 diskp->name, datestamp, level)) {
269 path = stralloc2(indexdir, names[i]);
270 qpath = quote_string(path);
271 dbprintf(("rm %s\n", qpath));
272 if(amtrmidx_debug == 0 && unlink(path) == -1) {
273 dbprintf(("Error removing %s: %s\n",
274 qpath, strerror(errno)));
288 amfree(conf_indexdir);
290 free_find_result(&output_find);
292 free_disklist(&diskl);
293 free_new_argv(new_argc, new_argv);
294 free_server_config();