X-Git-Url: https://git.gag.com/?a=blobdiff_plain;f=server-src%2Famindexd.c;h=29ef093282c0ad4a51b344a67fdbee8332eaad84;hb=94a044f90357edefa6f4ae9f0b1d5885b0e34aee;hp=951151bfd42bd39ac716cac90fb1522d8fae0f67;hpb=d3b2175e084f88c8736ad7073eacbf4670147aec;p=debian%2Famanda

diff --git a/server-src/amindexd.c b/server-src/amindexd.c
index 951151b..29ef093 100644
--- a/server-src/amindexd.c
+++ b/server-src/amindexd.c
@@ -56,6 +56,7 @@
 #include "util.h"
 #include "amandad.h"
 #include "pipespawn.h"
+#include "sockaddr-util.h"
 
 #include <grp.h>
 
@@ -100,15 +101,12 @@ static char *amandad_auth = NULL;
 static FILE *cmdin;
 static FILE *cmdout;
 
-static void reply(int, char *, ...)
-    __attribute__ ((format (printf, 2, 3)));
-static void lreply(int, char *, ...)
-    __attribute__ ((format (printf, 2, 3)));
-static void fast_lreply(int, char *, ...)
-    __attribute__ ((format (printf, 2, 3)));
+static void reply(int, char *, ...) G_GNUC_PRINTF(2, 3);
+static void lreply(int, char *, ...) G_GNUC_PRINTF(2, 3);
+static void fast_lreply(int, char *, ...) G_GNUC_PRINTF(2, 3);
 static am_host_t *is_dump_host_valid(char *);
 static int is_disk_valid(char *);
-static int is_config_valid(char *);
+static int check_and_load_config(char *);
 static int build_disk_table(void);
 static int disk_history_list(void);
 static int is_dir_valid_opaque(char *);
@@ -133,8 +131,7 @@ remove_files(
     REMOVE_ITEM *prev;
 
     while(remove) {
-	dbprintf(("%s: removing index file: %s\n",
-		  debug_prefix_time(NULL), remove->filename));
+	dbprintf(_("removing index file: %s\n"), remove->filename);
 	unlink(remove->filename);
 	amfree(remove->filename);
 	prev = remove;
@@ -159,7 +156,6 @@ uncompress_file(
     int indexfd;
     int nullfd;
     int debugfd;
-    int debugnullfd;
     char line[STR_SIZE];
     FILE *pipe_stream;
     pid_t pid_gzip;
@@ -185,12 +181,10 @@ uncompress_file(
 	 * Check that compressed file exists manually.
 	 */
 	if (stat(filename_gz, &statbuf) < 0) {
-	    *emsg = newvstralloc(*emsg, "Compressed file '",
-				filename_gz,
-				"' is inaccessable: ",
-				strerror(errno),
-				NULL);
-	    dbprintf(("%s\n",*emsg));
+	    *emsg = newvstrallocf(*emsg,
+				_("Compressed file '%s' is inaccessable: %s"),
+				filename_gz, strerror(errno));
+	    dbprintf("%s\n",*emsg);
 	    amfree(filename);
 	    return NULL;
  	}
@@ -201,25 +195,22 @@ uncompress_file(
 #  define PARAM_UNCOMPRESS_OPT skip_argument
 #endif
 
-	debugfd = dbfd();
-	debugnullfd = 0;
-	if(debugfd < 0) {
-	    debugfd = open("/dev/null", O_WRONLY);
-	    debugnullfd = 1;
-	}
-
 	nullfd = open("/dev/null", O_RDONLY);
+
 	indexfd = open(filename,O_WRONLY|O_CREAT, 0600);
 	if (indexfd == -1) {
-	    *emsg = newvstralloc(*emsg, "Can't open '",
-				 filename, "' for writting: ",
-				 strerror(errno),
-				 NULL);
-	    dbprintf(("%s\n",*emsg));
+	    *emsg = newvstrallocf(*emsg, _("Can't open '%s' for writting: %s"),
+				 filename, strerror(errno));
+	    dbprintf("%s\n",*emsg);
 	    amfree(filename);
 	    return NULL;
 	}
 
+	/* just use our stderr directly for the pipe's stderr; in 
+	 * main() we send stderr to the debug file, or /dev/null
+	 * if debugging is disabled */
+	debugfd = STDERR_FILENO;
+
 	/* start the uncompress process */
 	putenv(stralloc("LC_ALL=C"));
 	pid_gzip = pipespawn(UNCOMPRESS_PATH, STDOUT_PIPE,
@@ -230,20 +221,18 @@ uncompress_file(
 
 	pipe_stream = fdopen(pipe_from_gzip,"r");
 	if(pipe_stream == NULL) {
-	    *emsg = newvstralloc(*emsg, "Can't fdopen pipe from gzip: ",
-				 strerror(errno),
-				 NULL);
-	    dbprintf(("%s\n",*emsg));
+	    *emsg = newvstrallocf(*emsg, _("Can't fdopen pipe from gzip: %s"),
+				 strerror(errno));
+	    dbprintf("%s\n",*emsg);
 	    amfree(filename);
 	    return NULL;
 	}
 
 	/* start the sort process */
+	putenv(stralloc("LC_ALL=C"));
 	pid_sort = pipespawn(SORT_PATH, STDIN_PIPE,
 			     &pipe_to_sort, &indexfd, &debugfd,
 			     SORT_PATH, NULL);
-	if (debugnullfd == 1)
-	    aclose(debugfd);
 	aclose(indexfd);
 
 	/* send all ouput from uncompress process to sort process */
@@ -261,26 +250,26 @@ uncompress_file(
 	aclose(pipe_to_sort);
 	if (waitpid(pid_gzip, &wait_status, 0) < 0) {
 	    if (!WIFEXITED(wait_status)) {
-		dbprintf(("Uncompress exited with signal %d",
-			  WTERMSIG(wait_status)));
+		dbprintf(_("Uncompress exited with signal %d"),
+			  WTERMSIG(wait_status));
 	    } else if (WEXITSTATUS(wait_status) != 0) {
-		dbprintf(("Uncompress exited with status %d",
-			  WEXITSTATUS(wait_status)));
+		dbprintf(_("Uncompress exited with status %d"),
+			  WEXITSTATUS(wait_status));
 	    } else {
-		dbprintf(("Uncompres returned negative value: %s",
-			  strerror(errno)));
+		dbprintf(_("Uncompres returned negative value: %s"),
+			  strerror(errno));
 	    }
 	}
-	if (waitpid(pid_sort, &wait_status, 0)) {
+	if (waitpid(pid_sort, &wait_status, 0) < 0) {
 	    if (!WIFEXITED(wait_status)) {
-		dbprintf(("Sort exited with signal %d",
-			  WTERMSIG(wait_status)));
+		dbprintf(_("Sort exited with signal %d"),
+			  WTERMSIG(wait_status));
 	    } else if (WEXITSTATUS(wait_status) != 0) {
-		dbprintf(("Sort exited with status %d",
-			  WEXITSTATUS(wait_status)));
+		dbprintf(_("Sort exited with status %d"),
+			  WEXITSTATUS(wait_status));
 	    } else {
-		dbprintf(("Sort returned negative value: %s",
-			  strerror(errno)));
+		dbprintf(_("Sort returned negative value: %s"),
+			  strerror(errno));
 	    }
 	}
 
@@ -291,7 +280,7 @@ uncompress_file(
 	uncompress_remove = remove_file;
     } else if(!S_ISREG((stat_filename.st_mode))) {
 	    amfree(*emsg);
-	    *emsg = vstralloc("\"", filename, "\" is not a regular file", NULL);
+	    *emsg = vstrallocf(_("\"%s\" is not a regular file"), filename);
 	    errno = -1;
 	    amfree(filename);
 	    amfree(cmd);
@@ -329,7 +318,7 @@ process_ls_dump(
     filename_gz = get_index_name(dump_hostname, dump_item->hostname, disk_name,
 				 dump_item->date, dump_item->level);
     if (filename_gz == NULL) {
-	*emsg = stralloc("index file not found");
+	*emsg = stralloc(_("index file not found"));
 	amfree(filename_gz);
 	return -1;
     }
@@ -342,7 +331,7 @@ process_ls_dump(
 
     if((fp = fopen(filename,"r"))==0) {
 	amfree(*emsg);
-	*emsg = stralloc(strerror(errno));
+	*emsg = vstrallocf("%s", strerror(errno));
 	amfree(dir_slash);
 	return -1;
     }
@@ -390,7 +379,7 @@ printf_arglist_function1(static void reply, int, n, char *, fmt)
 
     while(1) {
 	arglist_start(args, fmt);
-	len = vsnprintf(reply_buffer, reply_buffer_size, fmt, args);
+	len = g_vsnprintf(reply_buffer, reply_buffer_size, fmt, args);
 	arglist_end(args);
 
 	if (len > -1 && (size_t)len < reply_buffer_size-1)
@@ -401,21 +390,19 @@ printf_arglist_function1(static void reply, int, n, char *, fmt)
 	reply_buffer = alloc(reply_buffer_size);
     }
 
-    if (fprintf(cmdout,"%03d %s\r\n", n, reply_buffer) < 0)
+    if (g_fprintf(cmdout,"%03d %s\r\n", n, reply_buffer) < 0)
     {
-	dbprintf(("%s: ! error %d (%s) in printf\n",
-		  debug_prefix_time(NULL), errno, strerror(errno)));
+	dbprintf(_("! error %d (%s) in printf\n"), errno, strerror(errno));
 	uncompress_remove = remove_files(uncompress_remove);
 	exit(1);
     }
     if (fflush(cmdout) != 0)
     {
-	dbprintf(("%s: ! error %d (%s) in fflush\n",
-		  debug_prefix_time(NULL), errno, strerror(errno)));
+	dbprintf(_("! error %d (%s) in fflush\n"), errno, strerror(errno));
 	uncompress_remove = remove_files(uncompress_remove);
 	exit(1);
     }
-    dbprintf(("%s: < %03d %s\n", debug_prefix_time(NULL), n, reply_buffer));
+    dbprintf(_("< %03d %s\n"), n, reply_buffer);
 }
 
 /* send one line of a multi-line response */
@@ -429,7 +416,7 @@ printf_arglist_function1(static void lreply, int, n, char *, fmt)
 
     while(1) {
 	arglist_start(args, fmt);
-	len = vsnprintf(reply_buffer, reply_buffer_size, fmt, args);
+	len = g_vsnprintf(reply_buffer, reply_buffer_size, fmt, args);
 	arglist_end(args);
 
 	if (len > -1 && (size_t)len < reply_buffer_size-1)
@@ -440,22 +427,22 @@ printf_arglist_function1(static void lreply, int, n, char *, fmt)
 	reply_buffer = alloc(reply_buffer_size);
     }
 
-    if (fprintf(cmdout,"%03d-%s\r\n", n, reply_buffer) < 0)
+    if (g_fprintf(cmdout,"%03d-%s\r\n", n, reply_buffer) < 0)
     {
-	dbprintf(("%s: ! error %d (%s) in printf\n",
-		  debug_prefix_time(NULL), errno, strerror(errno)));
+	dbprintf(_("! error %d (%s) in printf\n"),
+		  errno, strerror(errno));
 	uncompress_remove = remove_files(uncompress_remove);
 	exit(1);
     }
     if (fflush(cmdout) != 0)
     {
-	dbprintf(("%s: ! error %d (%s) in fflush\n",
-		  debug_prefix_time(NULL), errno, strerror(errno)));
+	dbprintf(_("! error %d (%s) in fflush\n"),
+		  errno, strerror(errno));
 	uncompress_remove = remove_files(uncompress_remove);
 	exit(1);
     }
 
-    dbprintf(("%s: < %03d-%s\n", debug_prefix_time(NULL), n, reply_buffer));
+    dbprintf("< %03d-%s\n", n, reply_buffer);
 
 }
 
@@ -470,7 +457,7 @@ printf_arglist_function1(static void fast_lreply, int, n, char *, fmt)
 
     while(1) {
 	arglist_start(args, fmt);
-	len = vsnprintf(reply_buffer, reply_buffer_size, fmt, args);
+	len = g_vsnprintf(reply_buffer, reply_buffer_size, fmt, args);
 	arglist_end(args);
 
 	if (len > -1 && (size_t)len < reply_buffer_size-1)
@@ -481,15 +468,15 @@ printf_arglist_function1(static void fast_lreply, int, n, char *, fmt)
 	reply_buffer = alloc(reply_buffer_size);
     }
 
-    if (fprintf(cmdout,"%03d-%s\r\n", n, reply_buffer) < 0)
+    if (g_fprintf(cmdout,"%03d-%s\r\n", n, reply_buffer) < 0)
     {
-	dbprintf(("%s: ! error %d (%s) in printf\n",
-		  debug_prefix_time(NULL), errno, strerror(errno)));
+	dbprintf(_("! error %d (%s) in printf\n"),
+		  errno, strerror(errno));
 	uncompress_remove = remove_files(uncompress_remove);
 	exit(1);
     }
 
-    dbprintf(("%s: < %03d-%s\n", debug_prefix_time(NULL), n, reply_buffer));
+    dbprintf("< %03d-%s\n", n, reply_buffer);
 }
 
 /* see if hostname is valid */
@@ -505,14 +492,14 @@ is_dump_host_valid(
     disk_t      *diskp;
 
     if (config_name == NULL) {
-	reply(501, "Must set config before setting host.");
+	reply(501, _("Must set config before setting host."));
 	return NULL;
     }
 
     /* check that the config actually handles that host */
     ihost = lookup_host(host);
     if(ihost == NULL) {
-	reply(501, "Host %s is not in your disklist.", host);
+	reply(501, _("Host %s is not in your disklist."), host);
 	return NULL;
     }
 
@@ -528,7 +515,8 @@ is_dump_host_valid(
 	}
     }
 
-    reply(501, "No index records for host: %s. Have you enabled indexing?", host);
+    reply(501, _("No index records for host: %s. Have you enabled indexing?"),
+	  host);
     return NULL;
 }
 
@@ -541,11 +529,11 @@ is_disk_valid(
     char *qdisk;
 
     if (config_name == NULL) {
-	reply(501, "Must set config,host before setting disk.");
+	reply(501, _("Must set config,host before setting disk."));
 	return -1;
     }
     else if (dump_hostname == NULL) {
-	reply(501, "Must set host before setting disk.");
+	reply(501, _("Must set host before setting disk."));
 	return -1;
     }
 
@@ -553,7 +541,7 @@ is_disk_valid(
     idisk = lookup_disk(dump_hostname, disk);
     if(idisk == NULL) {
 	qdisk = quote_string(disk);
-	reply(501, "Disk %s:%s is not in your disklist.", dump_hostname, qdisk);
+	reply(501, _("Disk %s:%s is not in your disklist."), dump_hostname, qdisk);
 	amfree(qdisk);
 	return -1;
     }
@@ -561,7 +549,7 @@ is_disk_valid(
     /* assume an index dir already */
     if (get_index_dir(dump_hostname, idisk->hostname, disk) == 0) {
 	qdisk = quote_string(disk);
-	reply(501, "No index records for disk: %s. Invalid?", qdisk);
+	reply(501, _("No index records for disk: %s. Invalid?"), qdisk);
 	amfree(qdisk);
 	return -1;
     }
@@ -571,10 +559,9 @@ is_disk_valid(
 
 
 static int
-is_config_valid(
+check_and_load_config(
     char *	config)
 {
-    char *conffile;
     char *conf_diskfile;
     char *conf_tapelist;
     char *conf_indexdir;
@@ -582,58 +569,42 @@ is_config_valid(
 
     /* check that the config actually exists */
     if (config == NULL) {
-	reply(501, "Must set config first.");
+	reply(501, _("Must set config first."));
 	return -1;
     }
 
-    /* read conffile */
-    conffile = stralloc2(config_dir, CONFFILE_NAME);
-    if (read_conffile(conffile)) {
-	reply(501, "Could not read config file %s!", conffile);
-	amfree(conffile);
+    /* (re-)initialize configuration with the new config name */
+    if (!config_init(CONFIG_INIT_EXPLICIT_NAME, config)) {
+	reply(501, _("Could not read config file for %s!"), config);
 	return -1;
     }
-    amfree(conffile);
 
-    conf_diskfile = getconf_str(CNF_DISKFILE);
-    if (*conf_diskfile == '/') {
-	conf_diskfile = stralloc(conf_diskfile);
-    } else {
-	conf_diskfile = stralloc2(config_dir, conf_diskfile);
-    }
+    check_running_as(RUNNING_AS_DUMPUSER_PREFERRED);
+
+    conf_diskfile = config_dir_relative(getconf_str(CNF_DISKFILE));
     if (read_diskfile(conf_diskfile, &disk_list) < 0) {
-	reply(501, "Could not read disk file %s!", conf_diskfile);
+	reply(501, _("Could not read disk file %s!"), conf_diskfile);
 	amfree(conf_diskfile);
 	return -1;
     }
     amfree(conf_diskfile);
 
-    conf_tapelist = getconf_str(CNF_TAPELIST);
-    if (*conf_tapelist == '/') {
-	conf_tapelist = stralloc(conf_tapelist);
-    } else {
-	conf_tapelist = stralloc2(config_dir, conf_tapelist);
-    }
+    conf_tapelist = config_dir_relative(getconf_str(CNF_TAPELIST));
     if(read_tapelist(conf_tapelist)) {
-	reply(501, "Could not read tapelist file %s!", conf_tapelist);
+	reply(501, _("Could not read tapelist file %s!"), conf_tapelist);
 	amfree(conf_tapelist);
 	return -1;
     }
     amfree(conf_tapelist);
 
-    dbrename(config, DBG_SUBDIR_SERVER);
+    dbrename(config_name, DBG_SUBDIR_SERVER);
 
-    output_find = find_dump(1, &disk_list);
+    output_find = find_dump(&disk_list);
     sort_find_result("DLKHpB", &output_find);
 
-    conf_indexdir = getconf_str(CNF_INDEXDIR);
-    if(*conf_indexdir == '/') {
-	conf_indexdir = stralloc(conf_indexdir);
-    } else {
-	conf_indexdir = stralloc2(config_dir, conf_indexdir);
-    }
+    conf_indexdir = config_dir_relative(getconf_str(CNF_INDEXDIR));
     if (stat (conf_indexdir, &dir_stat) != 0 || !S_ISDIR(dir_stat.st_mode)) {
-	reply(501, "Index directory %s does not exist", conf_indexdir);
+	reply(501, _("Index directory %s does not exist"), conf_indexdir);
 	amfree(conf_indexdir);
 	return -1;
     }
@@ -654,15 +625,15 @@ build_disk_table(void)
     find_result_t *find_output;
 
     if (config_name == NULL) {
-	reply(590, "Must set config,host,disk before building disk table");
+	reply(590, _("Must set config,host,disk before building disk table"));
 	return -1;
     }
     else if (dump_hostname == NULL) {
-	reply(590, "Must set host,disk before building disk table");
+	reply(590, _("Must set host,disk before building disk table"));
 	return -1;
     }
     else if (disk_name == NULL) {
-	reply(590, "Must set disk before building disk table");
+	reply(590, _("Must set disk before building disk table"));
 	return -1;
     }
 
@@ -678,8 +649,30 @@ build_disk_table(void)
 	   strcmp(disk_name    , find_output->diskname) == 0 &&
 	   strcmp("OK"         , find_output->status)   == 0) {
 	    int partnum = -1;
-	    if(strcmp("--", find_output->partnum)){
+	    int maxpart = -1;
+	    if (strcmp("1/1", find_output->partnum) == 0) {
+		partnum = -1;
+	    } else if (strcmp("1/-1", find_output->partnum) == 0) {
+		if (find_output->next &&
+		    strcmp(dump_hostname, find_output->next->hostname) == 0 &&
+		    strcmp(disk_name, find_output->next->diskname) == 0 &&
+		    strcmp(find_output->timestamp,
+			   find_output->next->timestamp) == 0 &&
+		    strcmp("OK", find_output->next->status) == 0 &&
+		    strcmp("2/-1", find_output->next->partnum) == 0) {
+		    partnum = 1;
+		}
+		else {
+		    partnum = -1;
+		}
+	    } else if (strcmp("--", find_output->partnum)) {
+		char *c;
 		partnum = atoi(find_output->partnum);
+		c = strchr(find_output->partnum,'/');
+		if (c)
+		    maxpart = atoi(c+1);
+		else
+		    maxpart = -1;
 	    }
 	    /*
 	     * The sort order puts holding disk entries first.  We want to
@@ -693,20 +686,31 @@ build_disk_table(void)
 	       partnum == last_partnum && last_filenum == 0) {
 		continue;
 	    }
+	    /* ignore duplicate partnum */
+	    if(last_timestamp &&
+	       strcmp(find_output->timestamp, last_timestamp) == 0 &&
+	       find_output->level == last_level && 
+	       partnum == last_partnum) {
+		continue;
+	    }
 	    last_timestamp = find_output->timestamp;
 	    last_filenum = find_output->filenum;
 	    last_level = find_output->level;
 	    last_partnum = partnum;
 	    date = amindexd_nicedate(find_output->timestamp);
 	    add_dump(find_output->hostname, date, find_output->level,
-		     find_output->label, find_output->filenum, partnum);
-	    dbprintf(("%s: - %s %d %s " OFF_T_FMT " %d\n",
-		     debug_prefix_time(NULL), date, find_output->level, 
+		     find_output->label, find_output->filenum, partnum,
+		     maxpart);
+	    dbprintf("- %s %d %s %lld %d %d\n",
+		     date, find_output->level, 
 		     find_output->label,
-		     (OFF_T_FMT_TYPE)find_output->filenum,
-		     partnum));
+		     (long long)find_output->filenum,
+		     partnum, maxpart);
 	}
     }
+
+    clean_dump();
+
     return 0;
 }
 
@@ -718,19 +722,19 @@ disk_history_list(void)
     char date[20];
 
     if (config_name == NULL) {
-	reply(502, "Must set config,host,disk before listing history");
+	reply(502, _("Must set config,host,disk before listing history"));
 	return -1;
     }
     else if (dump_hostname == NULL) {
-	reply(502, "Must set host,disk before listing history");
+	reply(502, _("Must set host,disk before listing history"));
 	return -1;
     }
     else if (disk_name == NULL) {
-	reply(502, "Must set disk before listing history");
+	reply(502, _("Must set disk before listing history"));
 	return -1;
     }
 
-    lreply(200, " Dump history for config \"%s\" host \"%s\" disk %s",
+    lreply(200, _(" Dump history for config \"%s\" host \"%s\" disk %s"),
 	  config_name, dump_hostname, qdisk_name);
 
     for (item=first_dump(); item!=NULL; item=next_dump(item)){
@@ -745,13 +749,13 @@ disk_history_list(void)
 	    lreply(201, " %s %d %s", date, item->level, tapelist_str);
 	}
 	else{
-	    lreply(201, " %s %d %s " OFF_T_FMT, date, item->level,
-		tapelist_str, (OFF_T_FMT_TYPE)item->file);
+	    lreply(201, " %s %d %s %lld", date, item->level,
+		tapelist_str, (long long)item->file);
 	}
 	amfree(tapelist_str);
     }
 
-    reply(200, "Dump history for config \"%s\" host \"%s\" disk %s",
+    reply(200, _("Dump history for config \"%s\" host \"%s\" disk %s"),
 	  config_name, dump_hostname, qdisk_name);
 
     return 0;
@@ -778,19 +782,19 @@ is_dir_valid_opaque(
     static char *emsg = NULL;
 
     if (config_name == NULL || dump_hostname == NULL || disk_name == NULL) {
-	reply(502, "Must set config,host,disk before asking about directories");
+	reply(502, _("Must set config,host,disk before asking about directories"));
 	return -1;
     }
     else if (dump_hostname == NULL) {
-	reply(502, "Must set host,disk before asking about directories");
+	reply(502, _("Must set host,disk before asking about directories"));
 	return -1;
     }
     else if (disk_name == NULL) {
-	reply(502, "Must set disk before asking about directories");
+	reply(502, _("Must set disk before asking about directories"));
 	return -1;
     }
     else if (target_date == NULL) {
-	reply(502, "Must set date before asking about directories");
+	reply(502, _("Must set date before asking about directories"));
 	return -1;
     }
     /* scan through till we find first dump on or before date */
@@ -801,7 +805,7 @@ is_dir_valid_opaque(
     if (item == NULL)
     {
 	/* no dump for given date */
-	reply(500, "No dumps available on or before date \"%s\"", target_date);
+	reply(500, _("No dumps available on or before date \"%s\""), target_date);
 	return -1;
     }
 
@@ -824,16 +828,16 @@ is_dir_valid_opaque(
 	    return -1;
 	}
 	if((filename = uncompress_file(filename_gz, &emsg)) == NULL) {
-	    reply(599, "System error %s", emsg);
+	    reply(599, _("System error %s"), emsg);
 	    amfree(filename_gz);
 	    amfree(emsg);
 	    amfree(ldir);
 	    return -1;
 	}
 	amfree(filename_gz);
-	dbprintf(("%s: f %s\n", debug_prefix_time(NULL), filename));
+	dbprintf("f %s\n", filename);
 	if ((fp = fopen(filename, "r")) == NULL) {
-	    reply(599, "System error %s", strerror(errno));
+	    reply(599, _("System error %s"), strerror(errno));
 	    amfree(filename);
 	    amfree(ldir);
 	    return -1;
@@ -862,7 +866,7 @@ is_dir_valid_opaque(
 
     amfree(filename);
     amfree(ldir);
-    reply(500, "\"%s\" is an invalid directory", dir);
+    reply(500, _("\"%s\" is an invalid directory"), dir);
     return -1;
 }
 
@@ -886,19 +890,19 @@ opaque_ls(
     clear_dir_list();
 
     if (config_name == NULL) {
-	reply(502, "Must set config,host,disk before listing a directory");
+	reply(502, _("Must set config,host,disk before listing a directory"));
 	return -1;
     }
     else if (dump_hostname == NULL) {
-	reply(502, "Must set host,disk before listing a directory");
+	reply(502, _("Must set host,disk before listing a directory"));
 	return -1;
     }
     else if (disk_name == NULL) {
-	reply(502, "Must set disk before listing a directory");
+	reply(502, _("Must set disk before listing a directory"));
 	return -1;
     }
     else if (target_date == NULL) {
-	reply(502, "Must set date before listing a directory");
+	reply(502, _("Must set date before listing a directory"));
 	return -1;
     }
 
@@ -910,13 +914,13 @@ opaque_ls(
     if (dump_item == NULL)
     {
 	/* no dump for given date */
-	reply(500, "No dumps available on or before date \"%s\"", target_date);
+	reply(500, _("No dumps available on or before date \"%s\""), target_date);
 	return -1;
     }
 
     /* get data from that dump */
     if (process_ls_dump(dir, dump_item, recursive, &emsg) == -1) {
-	reply(599, "System error %s", emsg);
+	reply(599, _("System error %s"), emsg);
 	amfree(emsg);
 	return -1;
     }
@@ -929,7 +933,7 @@ opaque_ls(
 	{
 	    last_level = dump_item->level;
 	    if (process_ls_dump(dir, dump_item, recursive, &emsg) == -1) {
-		reply(599, "System error %s", emsg);
+		reply(599, _("System error %s"), emsg);
 		amfree(emsg);
 		return -1;
 	    }
@@ -937,7 +941,7 @@ opaque_ls(
     }
 
     /* return the information to the caller */
-    lreply(200, " Opaque list of %s", dir);
+    lreply(200, _(" Opaque list of %s"), dir);
     for(level=0; level<=9; level++) {
 	for (dir_item = get_dir_list(); dir_item != NULL; 
 	     dir_item = dir_item->next) {
@@ -946,8 +950,8 @@ opaque_ls(
 		if (!am_has_feature(their_features, marshall_feature) &&
 	            (num_entries(dir_item->dump->tapes) > 1 ||
 	            dir_item->dump->tapes->numfiles > 1)) {
-	            fast_lreply(501, " ERROR: Split dumps not supported"
-				" with old version of amrecover.");
+	            fast_lreply(501, _(" ERROR: Split dumps not supported"
+				" with old version of amrecover."));
 		    break;
 		}
 		else {
@@ -956,7 +960,7 @@ opaque_ls(
 	    }
 	}
     }
-    reply(200, " Opaque list of %s", dir);
+    reply(200, _(" Opaque list of %s"), dir);
 
     clear_dir_list();
     return 0;
@@ -987,11 +991,11 @@ void opaque_ls_one(
 				     fe_amindexd_fileno_in_OLSD)) ||
        (recursive && am_has_feature(their_features,
 				    fe_amindexd_fileno_in_ORLD))) {
-	fast_lreply(201, " %s %d %s " OFF_T_FMT " %s",
+	fast_lreply(201, " %s %d %s %lld %s",
 		    date,
 		    dir_item->dump->level,
 		    tapelist_str,
-		    (OFF_T_FMT_TYPE)dir_item->dump->file,
+		    (long long)dir_item->dump->file,
 		    qpath);
     }
     else {
@@ -1018,38 +1022,35 @@ tapedev_is(void)
 
     /* check state okay to do this */
     if (config_name == NULL) {
-	reply(501, "Must set config before asking about tapedev.");
+	reply(501, _("Must set config before asking about tapedev."));
 	return -1;
     }
 
     /* use amrecover_changer if possible */
     if ((result = getconf_str(CNF_AMRECOVER_CHANGER)) != NULL  &&
         *result != '\0') {
-	dbprintf(("%s: tapedev_is amrecover_changer: %s\n",
-                  debug_prefix_time(NULL), result));
+	dbprintf(_("tapedev_is amrecover_changer: %s\n"), result);
 	reply(200, result);
 	return 0;
     }
 
     /* use changer if possible */
     if ((result = getconf_str(CNF_TPCHANGER)) != NULL  &&  *result != '\0') {
-	dbprintf(("%s: tapedev_is tpchanger: %s\n",
-                  debug_prefix_time(NULL), result));
+	dbprintf(_("tapedev_is tpchanger: %s\n"), result);
 	reply(200, result);
 	return 0;
     }
 
     /* get tapedev value */
     if ((result = getconf_str(CNF_TAPEDEV)) != NULL  &&  *result != '\0') {
-	dbprintf(("%s: tapedev_is tapedev: %s\n",
-                  debug_prefix_time(NULL), result));
+	dbprintf(_("tapedev_is tapedev: %s\n"), result);
 	reply(200, result);
 	return 0;
     }
 
-    dbprintf(("%s: No tapedev or tpchanger in config site.\n",
-              debug_prefix_time(NULL)));
-    reply(501, "Tapedev or tpchanger not set in config file.");
+    dbprintf(_("No tapedev or tpchanger in config site.\n"));
+
+    reply(501, _("Tapedev or tpchanger not set in config file."));
     return -1;
 }
 
@@ -1062,15 +1063,15 @@ are_dumps_compressed(void)
 
     /* check state okay to do this */
     if (config_name == NULL) {
-	reply(501, "Must set config,host,disk name before asking about dumps.");
+	reply(501, _("Must set config,host,disk name before asking about dumps."));
 	return -1;
     }
     else if (dump_hostname == NULL) {
-	reply(501, "Must set host,disk name before asking about dumps.");
+	reply(501, _("Must set host,disk name before asking about dumps."));
 	return -1;
     }
     else if (disk_name == NULL) {
-	reply(501, "Must set disk name before asking about dumps.");
+	reply(501, _("Must set disk name before asking about dumps."));
 	return -1;
     }
 
@@ -1083,7 +1084,7 @@ are_dumps_compressed(void)
     }
 
     if (diskp == NULL) {
-	reply(501, "Couldn't find host/disk in disk file.");
+	reply(501, _("Couldn't find host/disk in disk file."));
 	return -1;
     }
 
@@ -1114,6 +1115,16 @@ main(
     char *errstr = NULL;
     char *pgm = "amindexd";		/* in case argv[0] is not set */
     char his_hostname[MAX_HOSTNAME_LENGTH];
+    char *cfg_opt = NULL;
+
+    /*
+     * Configure program for internationalization:
+     *   1) Only set the message locale for now.
+     *   2) Set textdomain for all amanda related programs to "amanda"
+     *      We don't want to be forced to support dozens of message catalogs.
+     */  
+    setlocale(LC_MESSAGES, "C");
+    textdomain("amanda"); 
 
     safe_fd(DATA_FD_OFFSET, 2);
     safe_cd();
@@ -1137,43 +1148,18 @@ main(
     /* Don't die when child closes pipe */
     signal(SIGPIPE, SIG_IGN);
 
-#ifdef FORCE_USERID
-
-    /* we'd rather not run as root */
-
-    if(geteuid() == 0) {
-	if(client_uid == (uid_t) -1) {
-	    error("error [cannot find user %s in passwd file]\n", CLIENT_LOGIN);
-	    /*NOTREACHED*/
-	}
-
-	/*@ignore@*/
-	initgroups(CLIENT_LOGIN, client_gid);
-	/*@end@*/
-	setgid(client_gid);
-	setuid(client_uid);
-    }
-
-#endif	/* FORCE_USERID */
-
     dbopen(DBG_SUBDIR_SERVER);
-    dbprintf(("%s: version %s\n", get_pname(), version()));
+    dbprintf(_("version %s\n"), version());
 
     if(argv == NULL) {
 	error("argv == NULL\n");
     }
 
     if (! (argc >= 1 && argv[0] != NULL)) {
-	dbprintf(("%s: WARNING: argv[0] not defined: check inetd.conf\n",
-		  debug_prefix_time(NULL)));
+	dbprintf(_("WARNING: argv[0] not defined: check inetd.conf\n"));
     }
 
-    {
-	int db_fd = dbfd();
-	if(db_fd != -1) {
-	    dup2(db_fd, 2);
-	}
-    }
+    debug_dup_stderr_to_debug();
 
     /* initialize */
 
@@ -1202,14 +1188,13 @@ main(
     }
 
     if (argc > 0) {
-	config_name = stralloc(*argv);
-	config_dir = vstralloc(CONFIG_DIR, "/", config_name, "/", NULL);
+	cfg_opt = *argv;
 	argc--;
 	argv++;
     }
 
     if(gethostname(local_hostname, SIZEOF(local_hostname)-1) == -1) {
-	error("gethostname: %s", strerror(errno));
+	error(_("gethostname: %s"), strerror(errno));
 	/*NOTREACHED*/
     }
     local_hostname[SIZEOF(local_hostname)-1] = '\0';
@@ -1226,7 +1211,7 @@ main(
 	    /* who are we talking to? */
 	    socklen = sizeof (his_addr);
 	    if (getpeername(0, (struct sockaddr *)&his_addr, &socklen) == -1)
-		error("getpeername: %s", strerror(errno));
+		error(_("getpeername: %s"), strerror(errno));
 
 	    /* Try a reverse (IP->hostname) resolution, and fail if it does
 	     * not work -- this is a basic security check */
@@ -1260,16 +1245,16 @@ main(
 
 	if(amandad_auth && g_options->auth) {
 	    if(strcasecmp(amandad_auth, g_options->auth) != 0) {
-		printf("ERROR recover program ask for auth=%s while amindexd is configured for '%s'\n",
+		g_printf(_("ERROR recover program ask for auth=%s while amindexd is configured for '%s'\n"),
 		       g_options->auth, amandad_auth);
-		error("amindexd: ERROR recover program ask for auth=%s while amindexd is configured for '%s'",
+		error(_("amindexd: ERROR recover program ask for auth=%s while amindexd is configured for '%s'"),
 		      g_options->auth, amandad_auth);
 		/*NOTREACHED*/
 	    }
 	}
 	/* send the REP packet */
-	printf("CONNECT MESG %d\n", DATA_FD_OFFSET);
-	printf("\n");
+	g_printf("CONNECT MESG %d\n", DATA_FD_OFFSET);
+	g_printf("\n");
 	fflush(stdin);
 	fflush(stdout);
 	fclose(stdin);
@@ -1297,11 +1282,11 @@ main(
     our_features = am_init_feature_set();
     their_features = am_set_default_feature_set();
 
-    if (config_name != NULL && is_config_valid(config_name) != -1) {
+    if (cfg_opt != NULL && check_and_load_config(cfg_opt) != -1) { /* load the config */
 	return 1;
     }
 
-    reply(220, "%s AMANDA index server (%s) ready.", local_hostname,
+    reply(220, _("%s AMANDA index server (%s) ready."), local_hostname,
 	  version());
 
     user_validated = from_amandad;
@@ -1313,18 +1298,15 @@ main(
 	while(1) {
 	    if((part = agets(cmdin)) == NULL) {
 		if(errno != 0) {
-		    dbprintf(("%s: ? read error: %s\n",
-			      debug_prefix_time(NULL), strerror(errno)));
+		    dbprintf(_("? read error: %s\n"), strerror(errno));
 		} else {
-		    dbprintf(("%s: ? unexpected EOF\n",
-			      debug_prefix_time(NULL)));
+		    dbprintf(_("? unexpected EOF\n"));
 		}
 		if(line) {
-		    dbprintf(("%s: ? unprocessed input:\n",
-			      debug_prefix_time(NULL)));
-		    dbprintf(("-----\n"));
-		    dbprintf(("? %s\n", line));
-		    dbprintf(("-----\n"));
+		    dbprintf(_("? unprocessed input:\n"));
+		    dbprintf("-----\n");
+		    dbprintf("? %s\n", line);
+		    dbprintf("-----\n");
 		}
 		amfree(line);
 		amfree(part);
@@ -1350,7 +1332,7 @@ main(
 	    strappend(line, "\n");
 	}
 
-	dbprintf(("%s: > %s\n", debug_prefix_time(NULL), line));
+	dbprintf("> %s\n", line);
 
 	if (arg != NULL)
 	    amfree(arg);
@@ -1359,7 +1341,7 @@ main(
 
 	skip_whitespace(s, ch);
 	if(ch == '\0') {
-	    reply(500, "Command not recognised/incorrect: %s", line);
+	    reply(500, _("Command not recognised/incorrect: %s"), line);
 	    amfree(line);
 	    continue;
 	}
@@ -1385,15 +1367,15 @@ main(
 					(struct sockaddr_storage *)&his_addr,
 					arg, 0, &errstr);
 	    if(user_validated) {
-		reply(200, "Access OK");
+		reply(200, _("Access OK"));
 		amfree(line);
 		continue;
 	    }
 	}
 	if (!user_validated) {  /* don't tell client the reason, just log it to debug log */
-	    reply(500, "Access not allowed");
+	    reply(500, _("Access not allowed"));
 	    if (errstr) {   
-		dbprintf(("%s: %s\n", debug_prefix_time(NULL), errstr));
+		dbprintf("%s\n", errstr);
 	    }
 	    break;
 	}
@@ -1408,7 +1390,7 @@ main(
 	    if ((lhost = is_dump_host_valid(arg)) != NULL)
 	    {
 		dump_hostname = newstralloc(dump_hostname, lhost->hostname);
-		reply(200, "Dump host set to %s.", dump_hostname);
+		reply(200, _("Dump host set to %s."), dump_hostname);
 		amfree(qdisk_name);		/* invalidate any value */
 		amfree(disk_name);		/* invalidate any value */
 	    }
@@ -1420,10 +1402,10 @@ main(
                 found = 0;
 	    s[-1] = '\0';
 	    if (config_name == NULL) {
-		reply(501, "Must set config before listhost");
+		reply(501, _("Must set config before listhost"));
 	    }
 	    else {
-		lreply(200, " List hosts for config %s", config_name);
+		lreply(200, _(" List hosts for config %s"), config_name);
 		for (disk = disk_list.head; disk!=NULL; disk = disk->next) {
                     found = 0;
 		    for (diskdup = disk_list.head; diskdup!=disk; diskdup = diskdup->next) {
@@ -1438,10 +1420,10 @@ main(
                     }
 		}
 		if(nbhost > 0) {
-		    reply(200, " List hosts for config %s", config_name);
+		    reply(200, _(" List hosts for config %s"), config_name);
 		}
 		else {
-		    reply(200, "No hosts for config %s", config_name);
+		    reply(200, _("No hosts for config %s"), config_name);
 		}
 	    }
 	    s[-1] = (char)ch;
@@ -1451,7 +1433,7 @@ main(
 		disk_name = newstralloc(disk_name, arg);
 		qdisk_name = quote_string(disk_name);
 		if (build_disk_table() != -1) {
-		    reply(200, "Disk set to %s.", qdisk_name);
+		    reply(200, _("Disk set to %s."), qdisk_name);
 		}
 	    }
 	    s[-1] = (char)ch;
@@ -1461,13 +1443,13 @@ main(
 	    int nbdisk = 0;
 	    s[-1] = '\0';
 	    if (config_name == NULL) {
-		reply(501, "Must set config, host before listdisk");
+		reply(501, _("Must set config, host before listdisk"));
 	    }
 	    else if (dump_hostname == NULL) {
-		reply(501, "Must set host before listdisk");
+		reply(501, _("Must set host before listdisk"));
 	    }
 	    else if(arg) {
-		lreply(200, " List of disk for device %s on host %s", arg,
+		lreply(200, _(" List of disk for device %s on host %s"), arg,
 		       dump_hostname);
 		for (disk = disk_list.head; disk!=NULL; disk = disk->next) {
 
@@ -1481,16 +1463,16 @@ main(
 		    }
 		}
 		if(nbdisk > 0) {
-		    reply(200, "List of disk for device %s on host %s", arg,
+		    reply(200, _("List of disk for device %s on host %s"), arg,
 			  dump_hostname);
 		}
 		else {
-		    reply(200, "No disk for device %s on host %s", arg,
+		    reply(200, _("No disk for device %s on host %s"), arg,
 			  dump_hostname);
 		}
 	    }
 	    else {
-		lreply(200, " List of disk for host %s", dump_hostname);
+		lreply(200, _(" List of disk for host %s"), dump_hostname);
 		for (disk = disk_list.head; disk!=NULL; disk = disk->next) {
 		    if(strcasecmp(disk->host->hostname, dump_hostname) == 0) {
 			qname = quote_string(disk->name);
@@ -1500,28 +1482,21 @@ main(
 		    }
 		}
 		if(nbdisk > 0) {
-		    reply(200, "List of disk for host %s", dump_hostname);
+		    reply(200, _("List of disk for host %s"), dump_hostname);
 		}
 		else {
-		    reply(200, "No disk for host %s", dump_hostname);
+		    reply(200, _("No disk for host %s"), dump_hostname);
 		}
 	    }
 	    s[-1] = (char)ch;
 	} else if (strcmp(cmd, "SCNF") == 0 && arg) {
 	    s[-1] = '\0';
-	    amfree(config_name);
-	    amfree(config_dir);
-	    config_name = newstralloc(config_name, arg);
-	    config_dir = vstralloc(CONFIG_DIR, "/", config_name, "/", NULL);
-	    if (is_config_valid(arg) != -1) {
+	    if (check_and_load_config(arg) != -1) {    /* try to load the new config */
 		amfree(dump_hostname);		/* invalidate any value */
 		amfree(qdisk_name);		/* invalidate any value */
 		amfree(disk_name);		/* invalidate any value */
-		reply(200, "Config set to %s.", config_name);
-	    } else {
-		amfree(config_name);
-		amfree(config_dir);
-	    }
+		reply(200, _("Config set to %s."), config_name);
+	    } /* check_and_load_config replies with any failure messages */
 	    s[-1] = (char)ch;
 	} else if (strcmp(cmd, "FEATURES") == 0 && arg) {
 	    char *our_feature_string = NULL;
@@ -1540,13 +1515,13 @@ main(
 	} else if (strcmp(cmd, "DATE") == 0 && arg) {
 	    s[-1] = '\0';
 	    target_date = newstralloc(target_date, arg);
-	    reply(200, "Working date set to %s.", target_date);
+	    reply(200, _("Working date set to %s."), target_date);
 	    s[-1] = (char)ch;
 	} else if (strcmp(cmd, "DHST") == 0) {
 	    (void)disk_history_list();
 	} else if (strcmp(cmd, "OISD") == 0 && arg) {
 	    if (is_dir_valid_opaque(arg) != -1) {
-		reply(200, "\"%s\" is a valid directory", arg);
+		reply(200, _("\"%s\" is a valid directory"), arg);
 	    }
 	} else if (strcmp(cmd, "OLSD") == 0 && arg) {
 	    (void)opaque_ls(arg,0);
@@ -1558,7 +1533,7 @@ main(
 	    (void)are_dumps_compressed();
 	} else {
 	    *cmd_undo = cmd_undo_ch;	/* restore the command line */
-	    reply(500, "Command not recognised/incorrect: %s", cmd);
+	    reply(500, _("Command not recognised/incorrect: %s"), cmd);
 	}
 	amfree(line);
     }
@@ -1566,7 +1541,7 @@ main(
     
     uncompress_remove = remove_files(uncompress_remove);
     free_find_result(&output_find);
-    reply(200, "Good bye.");
+    reply(200, _("Good bye."));
     dbclose();
     return 0;
 }
@@ -1589,7 +1564,7 @@ amindexd_nicedate(
     day   = numdate % 100;
 
     if(strlen(datestamp) <= 8) {
-	snprintf(nice, SIZEOF(nice), "%4d-%02d-%02d",
+	g_snprintf(nice, SIZEOF(nice), "%4d-%02d-%02d",
 		year, month, day);
     }
     else {
@@ -1600,7 +1575,7 @@ amindexd_nicedate(
 	minutes = (numtime / 100) % 100;
 	seconds = numtime % 100;
 
-	snprintf(nice, SIZEOF(nice), "%4d-%02d-%02d-%02d-%02d-%02d",
+	g_snprintf(nice, SIZEOF(nice), "%4d-%02d-%02d-%02d-%02d-%02d",
 		year, month, day, hours, minutes, seconds);
     }
 
@@ -1628,9 +1603,9 @@ clean_backslash(
 	    s++;
 	    s1 = s+1;
 	    s2 = s+2;
-	    if (*s != '\0' && isdigit(*s) &&
-		*s1 != '\0' && isdigit(*s1) &&
-		*s2 != '\0' &&  isdigit(*s2)) {
+	    if (*s != '\0' && isdigit((int)*s) &&
+		*s1 != '\0' && isdigit((int)*s1) &&
+		*s2 != '\0' &&  isdigit((int)*s2)) {
 		/* this is \000, an octal value */
 		i = ((*s)-'0')*64 + ((*s1)-'0')*8 + ((*s2)-'0');
 		*p++ = i;