/*
* Amanda, The Advanced Maryland Automatic Network Disk Archiver
* Copyright (c) 1991-1998 University of Maryland at College Park
+ * Copyright (c) 2007-2012 Zmanda, Inc. All Rights Reserved.
* All Rights Reserved.
*
* Permission to use, copy, modify, distribute, and sell this software and its
#include "diskfile.h"
#include "arglist.h"
#include "clock.h"
-#include "version.h"
+#include "match.h"
#include "amindex.h"
#include "disk_history.h"
#include "list_dir.h"
#include "logfile.h"
-#include "token.h"
#include "find.h"
#include "tapefile.h"
#include "util.h"
#include "amandad.h"
#include "pipespawn.h"
#include "sockaddr-util.h"
+#include "amxml.h"
#include <grp.h>
-#define amindexd_debug(i,x) do { \
+#define DBG(i, ...) do { \
if ((i) <= debug_amindexd) { \
- dbprintf(x); \
+ g_debug(__VA_ARGS__); \
} \
} while (0)
static am_feature_t *our_features = NULL;
static am_feature_t *their_features = NULL;
+static int get_pid_status(int pid, char *program, GPtrArray **emsg);
static REMOVE_ITEM *remove_files(REMOVE_ITEM *);
-static char *uncompress_file(char *, char **);
-static int process_ls_dump(char *, DUMP_ITEM *, int, char **);
+static char *uncompress_file(char *, GPtrArray **);
+static int process_ls_dump(char *, DUMP_ITEM *, int, GPtrArray **);
static size_t reply_buffer_size = 1;
static char *reply_buffer = NULL;
static FILE *cmdin;
static FILE *cmdout;
+static void reply_ptr_array(int, GPtrArray *);
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 int are_dumps_compressed(void);
static char *amindexd_nicedate (char *datestamp);
static int cmp_date (const char *date1, const char *date2);
-static char *clean_backslash(char *line);
static char *get_index_name(char *dump_hostname, char *hostname,
char *diskname, char *timestamps, int level);
static int get_index_dir(char *dump_hostname, char *hostname, char *diskname);
int main(int, char **);
+
+static int
+get_pid_status(
+ int pid,
+ char *program,
+ GPtrArray **emsg)
+{
+ int status;
+ amwait_t wait_status;
+ char *msg;
+ int result = 1;
+
+ status = waitpid(pid, &wait_status, 0);
+ if (status < 0) {
+ msg = vstrallocf(
+ _("%s (%d) returned negative value: %s"),
+ program, pid, strerror(errno));
+ dbprintf("%s\n", msg);
+ g_ptr_array_add(*emsg, msg);
+ result = 0;
+ } else {
+ if (!WIFEXITED(wait_status)) {
+ msg = vstrallocf(
+ _("%s exited with signal %d"),
+ program, WTERMSIG(wait_status));
+ dbprintf("%s\n", msg);
+ g_ptr_array_add(*emsg, msg);
+ result = 0;
+ } else if (WEXITSTATUS(wait_status) != 0) {
+ msg = vstrallocf(
+ _("%s exited with status %d"),
+ program, WEXITSTATUS(wait_status));
+ dbprintf("%s\n", msg);
+ g_ptr_array_add(*emsg, msg);
+ result = 0;
+ }
+ }
+ return result;
+}
+
static REMOVE_ITEM *
remove_files(
REMOVE_ITEM *remove)
static char *
uncompress_file(
- char * filename_gz,
- char ** emsg)
+ char *filename_gz,
+ GPtrArray **emsg)
{
char *cmd = NULL;
char *filename = NULL;
int pipe_to_sort;
int indexfd;
int nullfd;
- int debugfd;
+ int uncompress_errfd;
+ int sort_errfd;
char line[STR_SIZE];
FILE *pipe_stream;
pid_t pid_gzip;
pid_t pid_sort;
- amwait_t wait_status;
-
+ pid_t pid_index;
+ int status;
+ char *msg;
+ gpointer *p;
+ gpointer *p_last;
+ GPtrArray *uncompress_err;
+ GPtrArray *sort_err;
+ FILE *uncompress_err_stream;
+ FILE *sort_err_stream;
filename = stralloc(filename_gz);
len = strlen(filename);
* Check that compressed file exists manually.
*/
if (stat(filename_gz, &statbuf) < 0) {
- *emsg = newvstrallocf(*emsg,
- _("Compressed file '%s' is inaccessable: %s"),
- filename_gz, strerror(errno));
- dbprintf("%s\n",*emsg);
+ msg = vstrallocf(_("Compressed file '%s' is inaccessable: %s"),
+ filename_gz, strerror(errno));
+ dbprintf("%s\n", msg);
+ g_ptr_array_add(*emsg, msg);
amfree(filename);
return NULL;
}
indexfd = open(filename,O_WRONLY|O_CREAT, 0600);
if (indexfd == -1) {
- *emsg = newvstrallocf(*emsg, _("Can't open '%s' for writting: %s"),
- filename, strerror(errno));
- dbprintf("%s\n",*emsg);
+ msg = vstrallocf(_("Can't open '%s' for writting: %s"),
+ filename, strerror(errno));
+ dbprintf("%s\n", msg);
+ g_ptr_array_add(*emsg, msg);
amfree(filename);
+ aclose(nullfd);
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,
- &nullfd, &pipe_from_gzip, &debugfd,
+ pid_gzip = pipespawn(UNCOMPRESS_PATH, STDOUT_PIPE|STDERR_PIPE, 0,
+ &nullfd, &pipe_from_gzip, &uncompress_errfd,
UNCOMPRESS_PATH, PARAM_UNCOMPRESS_OPT,
filename_gz, NULL);
aclose(nullfd);
pipe_stream = fdopen(pipe_from_gzip,"r");
if(pipe_stream == NULL) {
- *emsg = newvstrallocf(*emsg, _("Can't fdopen pipe from gzip: %s"),
- strerror(errno));
- dbprintf("%s\n",*emsg);
+ msg = vstrallocf(_("Can't fdopen pipe from gzip: %s"),
+ strerror(errno));
+ dbprintf("%s\n", msg);
+ g_ptr_array_add(*emsg, msg);
amfree(filename);
+ aclose(indexfd);
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 (getconf_seen(CNF_TMPDIR)) {
+ gchar *tmpdir = getconf_str(CNF_TMPDIR);
+ pid_sort = pipespawn(SORT_PATH, STDIN_PIPE|STDERR_PIPE, 0,
+ &pipe_to_sort, &indexfd, &sort_errfd,
+ SORT_PATH, "-T", tmpdir, NULL);
+ } else {
+ pid_sort = pipespawn(SORT_PATH, STDIN_PIPE|STDERR_PIPE, 0,
+ &pipe_to_sort, &indexfd, &sort_errfd,
+ SORT_PATH, NULL);
+ }
aclose(indexfd);
+ /* start a subprocess */
/* send all ouput from uncompress process to sort process */
- /* clean the data with clean_backslash */
- while (fgets(line, STR_SIZE, pipe_stream) != NULL) {
- if (line[0] != '\0') {
- if (index(line,'/')) {
- clean_backslash(line);
- fullwrite(pipe_to_sort,line,strlen(line));
+ pid_index = fork();
+ switch (pid_index) {
+ case -1:
+ msg = vstrallocf(
+ _("fork error: %s"),
+ strerror(errno));
+ dbprintf("%s\n", msg);
+ g_ptr_array_add(*emsg, msg);
+ unlink(filename);
+ amfree(filename);
+ default: break;
+ case 0:
+ while (fgets(line, STR_SIZE, pipe_stream) != NULL) {
+ if (line[0] != '\0') {
+ if (strchr(line,'/')) {
+ full_write(pipe_to_sort,line,strlen(line));
+ }
}
}
+ exit(0);
}
fclose(pipe_stream);
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));
- } else if (WEXITSTATUS(wait_status) != 0) {
- dbprintf(_("Uncompress exited with status %d"),
- WEXITSTATUS(wait_status));
- } else {
- dbprintf(_("Uncompres returned negative value: %s"),
- strerror(errno));
+
+ uncompress_err_stream = fdopen(uncompress_errfd, "r");
+ uncompress_err = g_ptr_array_new();
+ while (fgets(line, sizeof(line), uncompress_err_stream) != NULL) {
+ if (line[strlen(line)-1] == '\n')
+ line[strlen(line)-1] = '\0';
+ g_ptr_array_add(uncompress_err, vstrallocf(" %s", line));
+ dbprintf("Uncompress: %s\n", line);
+ }
+ fclose(uncompress_err_stream);
+
+ sort_err_stream = fdopen(sort_errfd, "r");
+ sort_err = g_ptr_array_new();
+ while (fgets(line, sizeof(line), sort_err_stream) != NULL) {
+ if (line[strlen(line)-1] == '\n')
+ line[strlen(line)-1] = '\0';
+ g_ptr_array_add(sort_err, vstrallocf(" %s", line));
+ dbprintf("Sort: %s\n", line);
+ }
+ fclose(sort_err_stream);
+
+ status = get_pid_status(pid_gzip, UNCOMPRESS_PATH, emsg);
+ if (status == 0 && filename) {
+ unlink(filename);
+ amfree(filename);
+ }
+ if (uncompress_err->len > 0) {
+ p_last = uncompress_err->pdata + uncompress_err->len;
+ for (p = uncompress_err->pdata; p < p_last ;p++) {
+ g_ptr_array_add(*emsg, (char *)*p);
}
}
- if (waitpid(pid_sort, &wait_status, 0) < 0) {
- if (!WIFEXITED(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));
- } else {
- dbprintf(_("Sort returned negative value: %s"),
- strerror(errno));
+ g_ptr_array_free(uncompress_err, TRUE);
+
+ status = get_pid_status(pid_index, "index", emsg);
+ if (status == 0 && filename) {
+ unlink(filename);
+ amfree(filename);
+ }
+
+ status = get_pid_status(pid_sort, SORT_PATH, emsg);
+ if (status == 0 && filename) {
+ unlink(filename);
+ amfree(filename);
+ }
+ if (sort_err->len > 0) {
+ p_last = sort_err->pdata + sort_err->len;
+ for (p = sort_err->pdata; p < p_last ;p++) {
+ g_ptr_array_add(*emsg, (char *)*p);
}
}
+ g_ptr_array_free(sort_err, TRUE);
/* add at beginning */
- remove_file = (REMOVE_ITEM *)alloc(SIZEOF(REMOVE_ITEM));
- remove_file->filename = stralloc(filename);
- remove_file->next = uncompress_remove;
- uncompress_remove = remove_file;
+ if (filename) {
+ remove_file = (REMOVE_ITEM *)alloc(SIZEOF(REMOVE_ITEM));
+ remove_file->filename = stralloc(filename);
+ remove_file->next = uncompress_remove;
+ uncompress_remove = remove_file;
+ }
+
} else if(!S_ISREG((stat_filename.st_mode))) {
- amfree(*emsg);
- *emsg = vstrallocf(_("\"%s\" is not a regular file"), filename);
+ msg = vstrallocf(_("\"%s\" is not a regular file"), filename);
+ dbprintf("%s\n", msg);
+ g_ptr_array_add(*emsg, msg);
errno = -1;
amfree(filename);
amfree(cmd);
char * dir,
DUMP_ITEM * dump_item,
int recursive,
- char ** emsg)
+ GPtrArray **emsg)
{
- char line[STR_SIZE];
- char *old_line = NULL;
+ char line[STR_SIZE], old_line[STR_SIZE];
char *filename = NULL;
char *filename_gz;
char *dir_slash = NULL;
int ch;
size_t len_dir_slash;
+ old_line[0] = '\0';
if (strcmp(dir, "/") == 0) {
dir_slash = stralloc(dir);
} else {
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"));
+ g_ptr_array_add(*emsg, stralloc(_("index file not found")));
amfree(filename_gz);
return -1;
}
- if((filename = uncompress_file(filename_gz, emsg)) == NULL) {
+ filename = uncompress_file(filename_gz, emsg);
+ if(filename == NULL) {
amfree(filename_gz);
amfree(dir_slash);
return -1;
amfree(filename_gz);
if((fp = fopen(filename,"r"))==0) {
- amfree(*emsg);
- *emsg = vstrallocf("%s", strerror(errno));
+ g_ptr_array_add(*emsg, vstrallocf("%s", strerror(errno)));
amfree(dir_slash);
+ amfree(filename);
return -1;
}
}
s[-1] = '\0';
}
- if(old_line == NULL || strcmp(line, old_line) != 0) {
+ if(strcmp(line, old_line) != 0) {
add_dir_list_item(dump_item, line);
- amfree(old_line);
- old_line = stralloc(line);
+ strcpy(old_line, line);
}
}
}
}
afclose(fp);
- /*@i@*/ amfree(old_line);
amfree(filename);
amfree(dir_slash);
return 0;
}
+static void
+reply_ptr_array(
+ int n,
+ GPtrArray *emsg)
+{
+ gpointer *p;
+
+ if (emsg->len == 0)
+ return;
+
+ p = emsg->pdata;
+ while (p != emsg->pdata + emsg->len -1) {
+ fast_lreply(n, "%s", (char *)*p);
+ p++;
+ }
+ reply(n, "%s", (char *)*p);
+}
+
/* send a 1 line reply to the client */
printf_arglist_function1(static void reply, int, n, char *, fmt)
{
exit(1);
}
- dbprintf("< %03d-%s\n", n, reply_buffer);
+ DBG(2, "< %03d-%s", n, reply_buffer);
}
/* see if hostname is valid */
am_host_t *ihost;
disk_t *diskp;
- if (config_name == NULL) {
+ if (get_config_name() == NULL) {
reply(501, _("Must set config before setting host."));
return NULL;
}
}
+static gboolean
+is_disk_allowed(
+ disk_t *disk)
+{
+ dumptype_t *dt = disk->config;
+ host_limit_t *rl = NULL;
+ char *peer;
+ char *dle_hostname;
+ GSList *iter;
+
+ /* get the config: either for the DLE or the global config */
+ if (dt) {
+ if (dumptype_seen(dt, DUMPTYPE_RECOVERY_LIMIT)) {
+ g_debug("using recovery limit from DLE");
+ rl = dumptype_get_recovery_limit(dt);
+ }
+ }
+ if (!rl) {
+ if (getconf_seen(CNF_RECOVERY_LIMIT)) {
+ g_debug("using global recovery limit");
+ rl = getconf_recovery_limit(CNF_RECOVERY_LIMIT);
+ }
+ }
+ if (!rl) {
+ g_debug("no recovery limit found; allowing access");
+ return TRUE;
+ }
+
+ peer = getenv("AMANDA_AUTHENTICATED_PEER");
+ if (!peer || !*peer) {
+ g_warning("DLE has a recovery-limit, but no authenticated peer name is "
+ "available; rejecting");
+ return FALSE;
+ }
+
+ /* check same-host */
+ dle_hostname = disk->host? disk->host->hostname : NULL;
+ if (rl->same_host && dle_hostname) {
+ if (0 == g_ascii_strcasecmp(peer, dle_hostname)) {
+ g_debug("peer matched same-host ('%s')", dle_hostname);
+ return TRUE;
+ }
+ }
+
+ /* check server */
+ if (rl->server) {
+ char myhostname[MAX_HOSTNAME_LENGTH+1];
+ if (gethostname(myhostname, MAX_HOSTNAME_LENGTH) == 0) {
+ myhostname[MAX_HOSTNAME_LENGTH] = '\0';
+ g_debug("server hostname: %s", myhostname);
+ if (0 == g_ascii_strcasecmp(peer, myhostname)) {
+ g_debug("peer matched server ('%s')", myhostname);
+ return TRUE;
+ }
+ }
+ }
+
+ /* check the match list */
+ for (iter = rl->match_pats; iter; iter = iter->next) {
+ char *pat = iter->data;
+ if (match_host(pat, peer))
+ return TRUE;
+ }
+
+ g_warning("peer '%s' does not match any of the recovery-limit restrictions; rejecting",
+ peer);
+
+ return FALSE;
+}
+
static int
is_disk_valid(
char *disk)
disk_t *idisk;
char *qdisk;
- if (config_name == NULL) {
+ if (get_config_name() == NULL) {
reply(501, _("Must set config,host before setting disk."));
return -1;
}
return -1;
}
- /* check that the config actually handles that disk */
+ /* check that the config actually handles that disk, and that recovery-limit allows it */
idisk = lookup_disk(dump_hostname, disk);
- if(idisk == NULL) {
+ if(idisk == NULL || !is_disk_allowed(idisk)) {
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 the server's disklist."), dump_hostname, qdisk);
amfree(qdisk);
return -1;
}
}
/* (re-)initialize configuration with the new config name */
- if (!config_init(CONFIG_INIT_EXPLICIT_NAME, config)) {
+ config_init(CONFIG_INIT_EXPLICIT_NAME, config);
+ if (config_errors(NULL) >= CFGERR_ERRORS) {
reply(501, _("Could not read config file for %s!"), config);
return -1;
}
check_running_as(RUNNING_AS_DUMPUSER_PREFERRED);
conf_diskfile = config_dir_relative(getconf_str(CNF_DISKFILE));
- if (read_diskfile(conf_diskfile, &disk_list) < 0) {
+ read_diskfile(conf_diskfile, &disk_list);
+ amfree(conf_diskfile);
+ if (config_errors(NULL) >= CFGERR_ERRORS) {
reply(501, _("Could not read disk file %s!"), conf_diskfile);
- amfree(conf_diskfile);
return -1;
}
- amfree(conf_diskfile);
conf_tapelist = config_dir_relative(getconf_str(CNF_TAPELIST));
if(read_tapelist(conf_tapelist)) {
}
amfree(conf_tapelist);
- dbrename(config_name, DBG_SUBDIR_SERVER);
+ dbrename(get_config_name(), DBG_SUBDIR_SERVER);
output_find = find_dump(&disk_list);
- sort_find_result("DLKHpB", &output_find);
+ /* the 'w' here sorts by write timestamp, so that the first instance of
+ * any particular datestamp/host/disk/level/part that we see is the one
+ * written earlier */
+ sort_find_result("DLKHpwB", &output_find);
conf_indexdir = config_dir_relative(getconf_str(CNF_INDEXDIR));
if (stat (conf_indexdir, &dir_stat) != 0 || !S_ISDIR(dir_stat.st_mode)) {
int last_partnum;
find_result_t *find_output;
- if (config_name == NULL) {
+ if (get_config_name() == NULL) {
reply(590, _("Must set config,host,disk before building disk table"));
return -1;
}
find_output != NULL;
find_output = find_output->next) {
if(strcasecmp(dump_hostname, find_output->hostname) == 0 &&
- strcmp(disk_name , find_output->diskname) == 0 &&
- strcmp("OK" , find_output->status) == 0) {
- int partnum = -1;
- 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;
- }
+ strcmp(disk_name , find_output->diskname) == 0 &&
+ strcmp("OK" , find_output->status) == 0 &&
+ strcmp("OK" , find_output->dump_status) == 0) {
/*
* The sort order puts holding disk entries first. We want to
* use them if at all possible, so ignore any other entries
if(last_timestamp &&
strcmp(find_output->timestamp, last_timestamp) == 0 &&
find_output->level == last_level &&
- partnum == last_partnum && last_filenum == 0) {
+ 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) {
+ find_output->partnum == last_partnum) {
continue;
}
last_timestamp = find_output->timestamp;
last_filenum = find_output->filenum;
last_level = find_output->level;
- last_partnum = partnum;
+ last_partnum = find_output->partnum;
date = amindexd_nicedate(find_output->timestamp);
add_dump(find_output->hostname, date, find_output->level,
- find_output->label, find_output->filenum, partnum,
- maxpart);
+ find_output->label, find_output->filenum,
+ find_output->partnum, find_output->totalparts);
dbprintf("- %s %d %s %lld %d %d\n",
date, find_output->level,
find_output->label,
(long long)find_output->filenum,
- partnum, maxpart);
+ find_output->partnum, find_output->totalparts);
}
}
DUMP_ITEM *item;
char date[20];
- if (config_name == NULL) {
+ if (get_config_name() == NULL) {
reply(502, _("Must set config,host,disk before listing history"));
return -1;
}
}
lreply(200, _(" Dump history for config \"%s\" host \"%s\" disk %s"),
- config_name, dump_hostname, qdisk_name);
+ get_config_name(), dump_hostname, qdisk_name);
for (item=first_dump(); item!=NULL; item=next_dump(item)){
char *tapelist_str = marshal_tapelist(item->tapes, 1);
}
reply(200, _("Dump history for config \"%s\" host \"%s\" disk %s"),
- config_name, dump_hostname, qdisk_name);
+ get_config_name(), dump_hostname, qdisk_name);
return 0;
}
char *filename_gz = NULL;
char *filename = NULL;
size_t ldir_len;
- static char *emsg = NULL;
+ GPtrArray *emsg = NULL;
- if (config_name == NULL || dump_hostname == NULL || disk_name == NULL) {
+ if (get_config_name() == NULL || dump_hostname == NULL || disk_name == NULL) {
reply(502, _("Must set config,host,disk before asking about directories"));
return -1;
}
amfree(ldir);
return -1;
}
+ emsg = g_ptr_array_new();
if((filename = uncompress_file(filename_gz, &emsg)) == NULL) {
- reply(599, _("System error %s"), emsg);
+ reply_ptr_array(599, emsg);
amfree(filename_gz);
- amfree(emsg);
+ g_ptr_array_free_full(emsg);
amfree(ldir);
return -1;
}
+ g_ptr_array_free_full(emsg);
amfree(filename_gz);
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;
DUMP_ITEM *dump_item;
DIR_ITEM *dir_item;
int level, last_level;
- static char *emsg = NULL;
+ GPtrArray *emsg = NULL;
am_feature_e marshall_feature;
if (recursive) {
clear_dir_list();
- if (config_name == NULL) {
+ if (get_config_name() == NULL) {
reply(502, _("Must set config,host,disk before listing a directory"));
return -1;
}
}
/* get data from that dump */
+ emsg = g_ptr_array_new();
if (process_ls_dump(dir, dump_item, recursive, &emsg) == -1) {
- reply(599, _("System error %s"), emsg);
- amfree(emsg);
+ reply_ptr_array(599, emsg);
+ g_ptr_array_free_full(emsg);
return -1;
}
{
last_level = dump_item->level;
if (process_ls_dump(dir, dump_item, recursive, &emsg) == -1) {
- reply(599, _("System error %s"), emsg);
- amfree(emsg);
+ reply_ptr_array(599, emsg);
+ g_ptr_array_free_full(emsg);
return -1;
}
}
}
+ g_ptr_array_free_full(emsg);
/* return the information to the caller */
lreply(200, _(" Opaque list of %s"), dir);
- for(level=0; level<=9; level++) {
+ for(level=0; level < DUMP_LEVELS; level++) {
for (dir_item = get_dir_list(); dir_item != NULL;
dir_item = dir_item->next) {
am_feature_e marshall_feature,
int recursive)
{
- char date[20];
- char *tapelist_str;
+ char date[20];
+ char *tapelist_str;
+ char *qtapelist_str;
char *qpath;
if (am_has_feature(their_features, marshall_feature)) {
tapelist_str = dir_item->dump->tapes->label;
}
+ if (am_has_feature(their_features, fe_amindexd_quote_label)) {
+ qtapelist_str = quote_string(tapelist_str);
+ } else {
+ qtapelist_str = stralloc(tapelist_str);
+ }
strncpy(date, dir_item->dump->date, 20);
date[19] = '\0';
if(!am_has_feature(their_features,fe_amrecover_timestamp))
fast_lreply(201, " %s %d %s %lld %s",
date,
dir_item->dump->level,
- tapelist_str,
+ qtapelist_str,
(long long)dir_item->dump->file,
qpath);
}
fast_lreply(201, " %s %d %s %s",
date, dir_item->dump->level,
- tapelist_str, qpath);
+ qtapelist_str, qpath);
}
amfree(qpath);
if(am_has_feature(their_features, marshall_feature)) {
amfree(tapelist_str);
}
+ amfree(qtapelist_str);
}
/*
char *result;
/* check state okay to do this */
- if (config_name == NULL) {
+ if (get_config_name() == NULL) {
reply(501, _("Must set config before asking about tapedev."));
return -1;
}
if ((result = getconf_str(CNF_AMRECOVER_CHANGER)) != NULL &&
*result != '\0') {
dbprintf(_("tapedev_is amrecover_changer: %s\n"), result);
- reply(200, result);
+ reply(200, "%s", result);
return 0;
}
/* use changer if possible */
if ((result = getconf_str(CNF_TPCHANGER)) != NULL && *result != '\0') {
dbprintf(_("tapedev_is tpchanger: %s\n"), result);
- reply(200, result);
+ reply(200, "%s", result);
return 0;
}
/* get tapedev value */
if ((result = getconf_str(CNF_TAPEDEV)) != NULL && *result != '\0') {
dbprintf(_("tapedev_is tapedev: %s\n"), result);
- reply(200, result);
+ reply(200, "%s", result);
return 0;
}
disk_t *diskp;
/* check state okay to do this */
- if (config_name == NULL) {
+ if (get_config_name() == NULL) {
reply(501, _("Must set config,host,disk name before asking about dumps."));
return -1;
}
char his_hostname[MAX_HOSTNAME_LENGTH];
char *cfg_opt = NULL;
+ if (argc > 1 && argv && argv[1] && g_str_equal(argv[1], "--version")) {
+ printf("amindexd-%s\n", VERSION);
+ return (0);
+ }
+
/*
* Configure program for internationalization:
* 1) Only set the message locale for now.
textdomain("amanda");
safe_fd(DATA_FD_OFFSET, 2);
+ openbsd_fd_inform();
safe_cd();
/*
signal(SIGPIPE, SIG_IGN);
dbopen(DBG_SUBDIR_SERVER);
- dbprintf(_("version %s\n"), version());
+ dbprintf(_("version %s\n"), VERSION);
if(argv == NULL) {
error("argv == NULL\n");
/* read the REQ packet */
for(; (line = agets(stdin)) != NULL; free(line)) {
if(strncmp_const(line, "OPTIONS ") == 0) {
+ if (g_options != NULL) {
+ dbprintf(_("REQ packet specified multiple OPTIONS.\n"));
+ free_g_options(g_options);
+ }
g_options = parse_g_options(line+8, 1);
if(!g_options->hostname) {
g_options->hostname = alloc(MAX_HOSTNAME_LENGTH+1);
}
reply(220, _("%s AMANDA index server (%s) ready."), local_hostname,
- version());
+ VERSION);
user_validated = from_amandad;
int nbhost = 0,
found = 0;
s[-1] = '\0';
- if (config_name == NULL) {
+ if (get_config_name() == NULL) {
reply(501, _("Must set config before listhost"));
}
else {
- lreply(200, _(" List hosts for config %s"), config_name);
+ lreply(200, _(" List hosts for config %s"), get_config_name());
for (disk = disk_list.head; disk!=NULL; disk = disk->next) {
found = 0;
for (diskdup = disk_list.head; diskdup!=disk; diskdup = diskdup->next) {
}
}
if(nbhost > 0) {
- reply(200, _(" List hosts for config %s"), config_name);
+ reply(200, _(" List hosts for config %s"), get_config_name());
}
else {
- reply(200, _("No hosts for config %s"), config_name);
+ reply(200, _("No hosts for config %s"), get_config_name());
}
}
s[-1] = (char)ch;
}
}
s[-1] = (char)ch;
+ } else if (strcmp(cmd, "DLE") == 0) {
+ disk_t *dp;
+ char *optionstr;
+ char *b64disk;
+ char *l, *ql;
+
+ dp = lookup_disk(dump_hostname, disk_name);
+ if (dp->line == 0) {
+ reply(200, "NODLE");
+ } else {
+ GPtrArray *errarray;
+ guint i;
+
+ b64disk = amxml_format_tag("disk", dp->name);
+ dp->host->features = their_features;
+ errarray = validate_optionstr(dp);
+ if (errarray->len > 0) {
+ for (i=0; i < errarray->len; i++) {
+ g_debug(_("ERROR: %s:%s %s"),
+ dump_hostname, disk_name,
+ (char *)g_ptr_array_index(errarray, i));
+ }
+ g_ptr_array_free(errarray, TRUE);
+ reply(200, "NODLE");
+ } else {
+ optionstr = xml_optionstr(dp, 0);
+ l = vstralloc("<dle>\n",
+ " <program>", dp->program, "</program>\n", NULL);
+ if (dp->application) {
+ application_t *application;
+ char *xml_app;
+
+ application = lookup_application(dp->application);
+ g_assert(application != NULL);
+ xml_app = xml_application(dp, application,
+ their_features);
+ vstrextend(&l, xml_app, NULL);
+ amfree(xml_app);
+ }
+ vstrextend(&l, " ", b64disk, "\n", NULL);
+ if (dp->device) {
+ char *b64device = amxml_format_tag("diskdevice",
+ dp->device);
+ vstrextend(&l, " ", b64device, "\n", NULL);
+ amfree(b64device);
+ }
+ vstrextend(&l, optionstr, "</dle>\n", NULL);
+ ql = quote_string(l);
+ reply(200, "%s", ql);
+ amfree(optionstr);
+ amfree(l);
+ amfree(ql);
+ amfree(b64disk);
+ }
+ }
} else if (strcmp(cmd, "LISTDISK") == 0) {
char *qname;
disk_t *disk;
int nbdisk = 0;
s[-1] = '\0';
- if (config_name == NULL) {
+ if (get_config_name() == NULL) {
reply(501, _("Must set config, host before listdisk"));
}
else if (dump_hostname == NULL) {
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);
+ reply(200, _("Config set to %s."), get_config_name());
} /* check_and_load_config replies with any failure messages */
s[-1] = (char)ch;
} else if (strcmp(cmd, "FEATURES") == 0 && arg) {
our_feature_string = am_feature_to_string(our_features);
their_feature_string = newstralloc(their_feature_string, arg);
their_features = am_string_to_feature(their_feature_string);
+ if (!their_features) {
+ g_warning("Invalid client feature set '%s'", their_feature_string);
+ their_features = am_set_default_feature_set();
+ }
reply(200, "FEATURES %s", our_feature_string);
amfree(our_feature_string);
amfree(their_feature_string);
return strncmp(date1, date2, strlen(date2));
}
-static char *
-clean_backslash(
- char *line)
-{
- char *s = line, *s1, *s2;
- char *p = line;
- int i;
-
- while(*s != '\0') {
- if (*s == '\\') {
- s++;
- s1 = s+1;
- s2 = s+2;
- 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;
- s += 3;
- } else if (*s == '\\') { /* we remove one / */
- *p++ = *s++;
- } else { /* we keep the / */
- *p++ = '\\';
- *p++ = *s++;
- }
- } else {
- *p++ = *s++;
- }
- }
- *p = '\0';
-
- return line;
-}
-
-
static int
get_index_dir(
char *dump_hostname,
projects / debian / amanda / blobdiff