+
+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)0755, (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;
+ }
+ }
+ }
+ amfree(diskdir);
+ amfree(hostinfodir);
+ amfree(infofile);
+ }
+ return 0;
+}
+
+void
+run_server_script(
+ pp_script_t *pp_script,
+ execute_on_t execute_on,
+ char *config,
+ disk_t *dp,
+ int level)
+{
+ pid_t scriptpid;
+ int scriptin, scriptout, scripterr;
+ char *cmd;
+ char **argvchild;
+ int i, k;
+ FILE *streamout;
+ char *line;
+ char *plugin;
+ char level_number[NUM_STR_SIZE];
+
+ if ((pp_script_get_execute_on(pp_script) & execute_on) == 0)
+ return;
+ if (pp_script_get_execute_where(pp_script) != ES_SERVER)
+ return;
+
+ plugin = pp_script_get_plugin(pp_script);
+ k = property_argv_size(pp_script_get_property(pp_script));
+ argvchild = g_new0(char *, 16+k);
+ cmd = vstralloc(APPLICATION_DIR, "/", plugin, NULL);
+ i = 0;
+ argvchild[i++] = plugin;
+
+ switch (execute_on) {
+ case EXECUTE_ON_PRE_DLE_AMCHECK:
+ argvchild[i++] = "PRE-DLE-AMCHECK"; break;
+ case EXECUTE_ON_PRE_HOST_AMCHECK:
+ argvchild[i++] = "PRE-HOST-AMCHECK"; break;
+ case EXECUTE_ON_POST_DLE_AMCHECK:
+ argvchild[i++] = "POST-DLE-AMCHECK"; break;
+ case EXECUTE_ON_POST_HOST_AMCHECK:
+ argvchild[i++] = "POST-HOST-AMCHECK"; break;
+ case EXECUTE_ON_PRE_DLE_ESTIMATE:
+ argvchild[i++] = "PRE-DLE-ESTIMATE"; break;
+ case EXECUTE_ON_PRE_HOST_ESTIMATE:
+ argvchild[i++] = "PRE-HOST-ESTIMATE"; break;
+ case EXECUTE_ON_POST_DLE_ESTIMATE:
+ argvchild[i++] = "POST-DLE-ESTIMATE"; break;
+ case EXECUTE_ON_POST_HOST_ESTIMATE:
+ argvchild[i++] = "POST-HOST-ESTIMATE"; break;
+ case EXECUTE_ON_PRE_DLE_BACKUP:
+ argvchild[i++] = "PRE-DLE-BACKUP"; break;
+ case EXECUTE_ON_PRE_HOST_BACKUP:
+ argvchild[i++] = "PRE-HOST-BACKUP"; break;
+ case EXECUTE_ON_POST_DLE_BACKUP:
+ argvchild[i++] = "POST-DLE-BACKUP"; break;
+ case EXECUTE_ON_POST_HOST_BACKUP:
+ argvchild[i++] = "POST-HOST-BACKUP"; break;
+ case EXECUTE_ON_PRE_RECOVER:
+ case EXECUTE_ON_POST_RECOVER:
+ case EXECUTE_ON_PRE_LEVEL_RECOVER:
+ case EXECUTE_ON_POST_LEVEL_RECOVER:
+ case EXECUTE_ON_INTER_LEVEL_RECOVER:
+ {
+ // ERROR these script can't be executed on server.
+ return;
+ }
+ }
+
+ argvchild[i++] = "--execute-where";
+ argvchild[i++] = "server";
+
+ if (config) {
+ argvchild[i++] = "--config";
+ argvchild[i++] = config;
+ }
+ if (dp->host->hostname) {
+ argvchild[i++] = "--host";
+ argvchild[i++] = dp->host->hostname;
+ }
+ if (dp->name) {
+ argvchild[i++] = "--disk";
+ argvchild[i++] = dp->name;
+ }
+ if (dp->device) {
+ argvchild[i++] = "--device";
+ argvchild[i++] = dp->device;
+ }
+ if (level >= 0) {
+ g_snprintf(level_number, SIZEOF(level_number), "%d", level);
+ argvchild[i++] = "--level";
+ argvchild[i++] = level_number;
+ }
+
+ i += property_add_to_argv(&argvchild[i], pp_script_get_property(pp_script));
+ argvchild[i++] = NULL;
+
+ scripterr = fileno(stderr);
+ scriptpid = pipespawnv(cmd, STDIN_PIPE|STDOUT_PIPE, 0, &scriptin,
+ &scriptout, &scripterr, argvchild);
+ close(scriptin);
+
+ streamout = fdopen(scriptout, "r");
+ if (streamout) {
+ while((line = agets(streamout)) != NULL) {
+ dbprintf("script: %s\n", line);
+ }
+ }
+ fclose(streamout);
+ waitpid(scriptpid, NULL, 0);
+}
+
+
+void
+run_server_scripts(
+ execute_on_t execute_on,
+ char *config,
+ disk_t *dp,
+ int level)
+{
+ GSList *pp_scriptlist;
+
+ for (pp_scriptlist = dp->pp_scriptlist; pp_scriptlist != NULL;
+ pp_scriptlist = pp_scriptlist->next) {
+ run_server_script(pp_scriptlist->data, execute_on, config, dp, level);
+ }
+}
+
+void
+run_amcleanup(
+ char *config_name)
+{
+ pid_t amcleanup_pid;
+ char *amcleanup_program;
+ char *amcleanup_options[4];
+
+ switch(amcleanup_pid = fork()) {
+ case -1:
+ return;
+ break;
+ case 0: /* child process */
+ amcleanup_program = vstralloc(sbindir, "/", "amcleanup", versionsuffix(), NULL);
+ amcleanup_options[0] = amcleanup_program;
+ amcleanup_options[1] = "-p";
+ amcleanup_options[2] = config_name;
+ amcleanup_options[3] = NULL;
+ execve(amcleanup_program, amcleanup_options, safe_env());
+ error("exec %s: %s", amcleanup_program, strerror(errno));
+ /*NOTREACHED*/
+ default:
+ break;
+ }
+ waitpid(amcleanup_pid, NULL, 0);
+}
+
+char *
+get_master_process(
+ char *logfile)
+{
+ FILE *log;
+ char line[1024];
+ char *s, ch;
+ char *process_name;
+
+ log = fopen(logfile, "r");
+ if (!log)
+ return stralloc("UNKNOWN");
+
+ while(fgets(line, 1024, log)) {
+ if (strncmp_const(line, "INFO ") == 0) {
+ s = line+5;
+ ch = *s++;
+ process_name = s-1;
+ skip_non_whitespace(s, ch);
+ s[-1] = '\0';
+ skip_whitespace(s, ch);
+ skip_non_whitespace(s, ch);
+ s[-1] = '\0';
+ skip_whitespace(s, ch);
+ if (strncmp_const(s-1, "pid ") == 0) {
+ process_name = stralloc(process_name);
+ fclose(log);
+ return process_name;
+ }
+ }
+ }
+ fclose(log);
+ return stralloc("UNKNOWN");
+}