X-Git-Url: https://git.gag.com/?a=blobdiff_plain;f=server-src%2Fserver_util.c;h=b238f1217a6f8bb64d389cf6c5be26cf0dd033f2;hb=310f09c0f55a2fb6f3f3746d6ded20099792b773;hp=fff4e6e03cad6ad77543a777c837bb710a8b398c;hpb=3ab887b9bc819a846c75dd7f2ee5d41fac22b19f;p=debian%2Famanda

diff --git a/server-src/server_util.c b/server-src/server_util.c
index fff4e6e..b238f12 100644
--- a/server-src/server_util.c
+++ b/server-src/server_util.c
@@ -24,7 +24,7 @@
  * file named AUTHORS, in the root directory of this distribution.
  */
 /*
- * $Id: server_util.c,v 1.1.2.1.4.2.2.3 2002/04/13 19:24:17 jrjackson Exp $
+ * $Id: server_util.c,v 1.17.2.1 2006/11/24 18:05:07 martinea Exp $
  *
  */
 
@@ -32,19 +32,26 @@
 #include "server_util.h"
 #include "arglist.h"
 #include "token.h"
+#include "logfile.h"
+#include "util.h"
+#include "conffile.h"
+#include "diskfile.h"
 
 const char *cmdstr[] = {
-    "BOGUS", "QUIT", "QUITTING", "DONE",
-    "FILE-DUMP", "PORT-DUMP", "CONTINUE", "ABORT",	/* dumper cmds */
+    "BOGUS", "QUIT", "QUITTING", "DONE", "PARTIAL", 
+    "START", "FILE-DUMP", "PORT-DUMP", "CONTINUE", "ABORT",/* dumper cmds */
     "FAILED", "TRY-AGAIN", "NO-ROOM", "RQ-MORE-DISK",	/* dumper results */
-    "ABORT-FINISHED", "FATAL-TRYAGAIN", "BAD-COMMAND",	/* dumper results */
+    "ABORT-FINISHED", "BAD-COMMAND",			/* dumper results */
     "START-TAPER", "FILE-WRITE", "PORT-WRITE",		/* taper cmds */
-    "PORT", "TAPE-ERROR", "TAPER-OK",			/* taper results */
+    "PORT", "TAPE-ERROR", "TAPER-OK", "SPLIT-NEEDNEXT", /* taper results */
+    "SPLIT-CONTINUE",
     NULL
 };
 
-cmd_t getcmd(cmdargs)
-struct cmdargs *cmdargs;
+
+cmd_t
+getcmd(
+    struct cmdargs *	cmdargs)
 {
     char *line;
     cmd_t cmd_i;
@@ -54,22 +61,24 @@ struct cmdargs *cmdargs;
     if (isatty(0)) {
 	printf("%s> ", get_pname());
 	fflush(stdout);
+        line = readline(NULL);
+    } else {
+        line = agets(stdin);
     }
-
-    if ((line = agets(stdin)) == NULL) {
+    if (line == NULL) {
 	line = stralloc("QUIT");
     }
 
     cmdargs->argc = split(line, cmdargs->argv,
-	sizeof(cmdargs->argv) / sizeof(cmdargs->argv[0]), " ");
+	(int)(sizeof(cmdargs->argv) / sizeof(cmdargs->argv[0])), " ");
     amfree(line);
 
 #if DEBUG
     {
 	int i;
-	printf("argc = %d\n", cmdargs->argc);
-	for (i = 0; i < cmdargs->argc; i++)
-	    printf("argv[%d] = \"%s\"\n", i, cmdargs->argv[i]);
+	fprintf(stderr,"argc = %d\n", cmdargs->argc);
+	for (i = 0; i < cmdargs->argc+1; i++)
+	    fprintf(stderr,"argv[%d] = \"%s\"\n", i, cmdargs->argv[i]);
     }
 #endif
 
@@ -94,3 +103,84 @@ printf_arglist_function1(void putresult, cmd_t, result, const char *, format)
     arglist_end(argp);
 }
 
+char *
+amhost_get_security_conf(
+    char *	string,
+    void *	arg)
+{
+    if(!string || !*string)
+	return(NULL);
+
+    if(strcmp(string, "krb5principal")==0)
+	return(getconf_str(CNF_KRB5PRINCIPAL));
+    else if(strcmp(string, "krb5keytab")==0)
+	return(getconf_str(CNF_KRB5KEYTAB));
+
+    if(!arg || !((am_host_t *)arg)->disks) return(NULL);
+
+    if(strcmp(string, "amandad_path")==0)
+	return ((am_host_t *)arg)->disks->amandad_path;
+    else if(strcmp(string, "client_username")==0)
+	return ((am_host_t *)arg)->disks->client_username;
+    else if(strcmp(string, "ssh_keys")==0)
+	return ((am_host_t *)arg)->disks->ssh_keys;
+
+    return(NULL);
+}
+
+int check_infofile(
+    char        *infodir,
+    disklist_t  *dl,
+    char       **errmsg)
+{
+    disk_t      *dp, *diskp;
+    char        *hostinfodir, *old_hostinfodir, *Xhostinfodir;
+    char        *diskdir,     *old_diskdir,     *Xdiskdir;
+    char        *infofile,    *old_infofile,    *Xinfofile;
+    struct stat  statbuf;
+    int other_dle_match;
+
+    if (stat(infodir, &statbuf) != 0) {
+	return 0;
+    }
+
+    for (dp = dl->head; dp != NULL; dp = dp->next) {
+	hostinfodir = sanitise_filename(dp->host->hostname);
+	diskdir     = sanitise_filename(dp->name);
+	infofile = vstralloc(infodir, "/", hostinfodir, "/", diskdir,
+			     "/info", NULL);
+	if (stat(infofile, &statbuf) == -1 && errno == ENOENT) {
+	    old_hostinfodir = old_sanitise_filename(dp->host->hostname);
+	    old_diskdir     = old_sanitise_filename(dp->name);
+	    old_infofile    = vstralloc(infodir, old_hostinfodir, "/",
+					old_diskdir, "/info", NULL);
+	    if (stat(old_infofile, &statbuf) == 0) {
+		other_dle_match = 0;
+		diskp = dl->head;
+		while (diskp != NULL) {
+		    Xhostinfodir = sanitise_filename(diskp->host->hostname);
+		    Xdiskdir     = sanitise_filename(diskp->name);
+		    Xinfofile = vstralloc(infodir, "/", Xhostinfodir, "/",
+					  Xdiskdir, "/info", NULL);
+		    if (strcmp(old_infofile, Xinfofile) == 0) {
+			other_dle_match = 1;
+			diskp = NULL;
+		    }
+		    else {
+			diskp = diskp->next;
+		    }
+		}
+		if (other_dle_match == 0) {
+		    if(mkpdir(infofile, (mode_t)02755, (uid_t)-1,
+			      (gid_t)-1) == -1) 
+			*errmsg = vstralloc("Can't create directory for ",
+					    infofile, NULL);
+			return -1;
+		    if(copy_file(infofile, old_infofile, errmsg) == -1) 
+			return -1;
+		}
+	    }
+	}
+    }
+    return 0;
+}