char *cfg_opt = NULL;
int dumper_setuid;
+ if (argc > 1 && argv && argv[1] && g_str_equal(argv[1], "--version")) {
+ printf("dumper-%s\n", VERSION);
+ return (0);
+ }
+
/*
* Configure program for internationalization:
* 1) Only set the message locale for now.
if (!errstr) errstr = stralloc(_("got no data"));
}
+ if (indexfile_tmp) {
+ amwait_t index_status;
+
+ /*@i@*/ aclose(indexout);
+ waitpid(indexpid,&index_status,0);
+ log_add(L_INFO, "pid-done %ld", (long)indexpid);
+ if (rename(indexfile_tmp, indexfile_real) != 0) {
+ log_add(L_WARNING, _("could not rename \"%s\" to \"%s\": %s"),
+ indexfile_tmp, indexfile_real, strerror(errno));
+ }
+ amfree(indexfile_tmp);
+ amfree(indexfile_real);
+ }
+
+ /* copy the header in a file on the index dir */
+ {
+ FILE *a;
+ char *s;
+ char *f = getheaderfname(hostname, diskname, dumper_timestamp, level);
+ a = fopen(f,"w");
+ if (a) {
+ s = build_header(&file, NULL, DISK_BLOCK_BYTES);
+ fprintf(a,"%s", s);
+ g_free(s);
+ fclose(a);
+ }
+ g_free(f);
+ }
+
+ if (db->compresspid != -1 && dump_result < 2) {
+ amwait_t wait_status;
+ char *errmsg = NULL;
+
+ waitpid(db->compresspid, &wait_status, 0);
+ if (WIFSIGNALED(wait_status)) {
+ errmsg = g_strdup_printf(_("%s terminated with signal %d"),
+ "compress", WTERMSIG(wait_status));
+ } else if (WIFEXITED(wait_status)) {
+ if (WEXITSTATUS(wait_status) != 0) {
+ errmsg = g_strdup_printf(_("%s exited with status %d"),
+ "compress", WEXITSTATUS(wait_status));
+ }
+ } else {
+ errmsg = g_strdup_printf(_("%s got bad exit"),
+ "compress");
+ }
+ if (errmsg) {
+ g_fprintf(errf, _("? %s\n"), errmsg);
+ g_debug("%s", errmsg);
+ dump_result = max(dump_result, 2);
+ if (!errstr)
+ errstr = errmsg;
+ else
+ g_free(errmsg);
+ }
+ log_add(L_INFO, "pid-done %ld", (long)db->compresspid);
+ db->compresspid = -1;
+ }
+
+ if (db->encryptpid != -1 && dump_result < 2) {
+ amwait_t wait_status;
+ char *errmsg = NULL;
+
+ waitpid(db->encryptpid, &wait_status, 0);
+ if (WIFSIGNALED(wait_status)) {
+ errmsg = g_strdup_printf(_("%s terminated with signal %d"),
+ "encrypt", WTERMSIG(wait_status));
+ } else if (WIFEXITED(wait_status)) {
+ if (WEXITSTATUS(wait_status) != 0) {
+ errmsg = g_strdup_printf(_("%s exited with status %d"),
+ "encrypt", WEXITSTATUS(wait_status));
+ }
+ } else {
+ errmsg = g_strdup_printf(_("%s got bad exit"),
+ "encrypt");
+ }
+ if (errmsg) {
+ g_fprintf(errf, _("? %s\n"), errmsg);
+ g_debug("%s", errmsg);
+ dump_result = max(dump_result, 2);
+ if (!errstr)
+ errstr = errmsg;
+ else
+ g_free(errmsg);
+ }
+ log_add(L_INFO, "pid-done %ld", (long)db->encryptpid);
+ db->encryptpid = -1;
+ }
+
if (dump_result > 1)
goto failed;
if (data_path == DATA_PATH_AMANDA)
aclose(db->fd);
- if (indexfile_tmp) {
- amwait_t index_status;
-
- /*@i@*/ aclose(indexout);
- waitpid(indexpid,&index_status,0);
- log_add(L_INFO, "pid-done %ld", (long)indexpid);
- if (rename(indexfile_tmp, indexfile_real) != 0) {
- log_add(L_WARNING, _("could not rename \"%s\" to \"%s\": %s"),
- indexfile_tmp, indexfile_real, strerror(errno));
- }
- amfree(indexfile_tmp);
- amfree(indexfile_real);
- }
-
- if(db->compresspid != -1) {
- waitpid(db->compresspid,NULL,0);
- log_add(L_INFO, "pid-done %ld", (long)db->compresspid);
- }
- if(db->encryptpid != -1) {
- waitpid(db->encryptpid,NULL,0);
- log_add(L_INFO, "pid-done %ld", (long)db->encryptpid);
- }
-
amfree(errstr);
dumpfile_free_data(&file);
amfree(indexfile_real);
}
+ amfree(errstr);
+ dumpfile_free_data(&file);
+
return 0;
}
strerror(errno));
dump_result = 2;
stop_dump();
- dumpfile_free_data(&file);
return;
}
- dumpfile_free_data(&file);
aclose(db->fd);
if (data_path == DATA_PATH_AMANDA) {
g_debug(_("Sending data to %s:%d\n"), data_host, data_port);
nread = read(filter->fd, filter->buffer + filter->first + filter->size,
filter->allocated_size - filter->first - filter->size - 2);
- if (nread != 0) {
- dump_result = max(dump_result, 2);
- }
-
if (nread <= 0) {
aclose(filter->fd);
if (filter->size > 0 && filter->buffer[filter->first + filter->size - 1] != '\n') {
filter->first += len;
filter->size -= len;
b = p + 1;
+ dump_result = max(dump_result, 1);
}
if (nread <= 0) {
aclose(errpipe[0]);
aclose(errpipe[1]);
return (-1);
- default:
+ default: {
+ char *base;
rval = dup2(outpipe[1], outfd);
if (rval < 0)
errstr = newvstrallocf(errstr, _("couldn't dup2: %s"), strerror(errno));
aclose(errpipe[1]);
filter = g_new0(filter_t, 1);
filter->fd = errpipe[0];
- filter->name = "encrypt";
+ base = g_strdup(srv_encrypt);
+ filter->name = g_strdup(basename(base));
+ amfree(base);
filter->buffer = NULL;
filter->size = 0;
filter->allocated_size = 0;
handle_filter_stderr, filter);
g_debug("event register %s %d", "encrypt data", filter->fd);
return (rval);
+ }
case 0: {
char *base;
if (dup2(outpipe[0], 0) < 0) {
*p++ = '\0';
if(strncmp_const_skip(tok, "features=", tok, ch) == 0) {
char *u = strchr(tok, ';');
+ ch = ch;
if (u)
*u = '\0';
am_release_feature_set(their_features);
{
char level_string[NUM_STR_SIZE];
char *req = NULL;
- char *authopt;
int response_error;
const security_driver_t *secdrv;
char *application_api;
}
vstrextend(&p, " <level>", level_string, "</level>\n", NULL);
vstrextend(&p, options+1, "</dle>\n", NULL);
- pclean = clean_dle_str_for_client(p);
+ pclean = clean_dle_str_for_client(p, their_features);
vstrextend(&req, pclean, NULL);
amfree(pclean);
dle_str = p;
amfree(req);
return 2;
} else {
- authopt = strstr(options, "auth=");
if (auth == NULL) {
auth = "BSD";
}
projects / debian / amanda / blobdiff