2 Bacula® - The Network Backup Solution
4 Copyright (C) 2006-2007 Free Software Foundation Europe e.V.
6 The main author of Bacula is Kern Sibbald, with contributions from
7 many others, a complete list can be found in the file AUTHORS.
8 This program is Free Software; you can redistribute it and/or
9 modify it under the terms of version two of the GNU General Public
10 License as published by the Free Software Foundation and included
13 This program is distributed in the hope that it will be useful, but
14 WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16 General Public License for more details.
18 You should have received a copy of the GNU General Public License
19 along with this program; if not, write to the Free Software
20 Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
23 Bacula® is a registered trademark of John Walker.
24 The licensor of Bacula is the Free Software Foundation Europe
25 (FSFE), Fiduciary Program, Sumatrastrasse 25, 8006 Zürich,
26 Switzerland, email:ftf@fsfeurope.org.
29 * Manipulation routines for RunScript list
31 * Eric Bollengier, May 2006
41 #include "runscript.h"
43 RUNSCRIPT *new_runscript()
45 Dmsg0(500, "runscript: creating new RUNSCRIPT object\n");
46 RUNSCRIPT *cmd = (RUNSCRIPT *)malloc(sizeof(RUNSCRIPT));
47 memset(cmd, 0, sizeof(RUNSCRIPT));
53 void RUNSCRIPT::reset_default(bool free_strings)
55 if (free_strings && command) {
56 free_pool_memory(command);
58 if (free_strings && target) {
59 free_pool_memory(target);
68 old_proto = false; /* TODO: drop this with bacula 1.42 */
69 job_code_callback = NULL;
72 RUNSCRIPT *copy_runscript(RUNSCRIPT *src)
74 Dmsg0(500, "runscript: creating new RUNSCRIPT object from other\n");
76 RUNSCRIPT *dst = (RUNSCRIPT *)malloc(sizeof(RUNSCRIPT));
77 memcpy(dst, src, sizeof(RUNSCRIPT));
82 dst->set_command(src->command);
83 dst->set_target(src->target);
88 void free_runscript(RUNSCRIPT *script)
90 Dmsg0(500, "runscript: freeing RUNSCRIPT object\n");
92 if (script->command) {
93 free_pool_memory(script->command);
96 free_pool_memory(script->target);
101 int run_scripts(JCR *jcr, alist *runscripts, const char *label)
103 Dmsg2(200, "runscript: running all RUNSCRIPT object (%s) JobStatus=%c\n", label, jcr->JobStatus);
110 if (strstr(label, NT_("Before"))) {
111 when = SCRIPT_Before;
116 if (runscripts == NULL) {
117 Dmsg0(100, "runscript: WARNING RUNSCRIPTS list is NULL\n");
121 foreach_alist(script, runscripts) {
122 Dmsg2(200, "runscript: try to run %s:%s\n", NPRT(script->target), NPRT(script->command));
125 if ((script->when & SCRIPT_Before) && (when & SCRIPT_Before)) {
126 if ((script->on_success
127 && (jcr->JobStatus == JS_Running || jcr->JobStatus == JS_Created))
128 || (script->on_failure && job_canceled(jcr))
131 Dmsg4(200, "runscript: Run it because SCRIPT_Before (%s,%i,%i,%c)\n",
132 script->command, script->on_success, script->on_failure,
138 if ((script->when & SCRIPT_After) && (when & SCRIPT_After)) {
139 if ((script->on_success && (jcr->JobStatus == JS_Terminated))
140 || (script->on_failure && job_canceled(jcr))
143 Dmsg4(200, "runscript: Run it because SCRIPT_After (%s,%i,%i,%c)\n",
144 script->command, script->on_success, script->on_failure,
150 if (!script->is_local()) {
156 script->run(jcr, label);
162 bool RUNSCRIPT::is_local()
164 if (!target || (strcmp(target, "") == 0)) {
171 /* set this->command to cmd */
172 void RUNSCRIPT::set_command(const POOLMEM *cmd)
174 Dmsg1(500, "runscript: setting command = %s\n", NPRT(cmd));
181 command = get_pool_memory(PM_FNAME);
184 pm_strcpy(command, cmd);
187 /* set this->target to client_name */
188 void RUNSCRIPT::set_target(const POOLMEM *client_name)
190 Dmsg1(500, "runscript: setting target = %s\n", NPRT(client_name));
197 target = get_pool_memory(PM_FNAME);
200 pm_strcpy(target, client_name);
203 bool RUNSCRIPT::run(JCR *jcr, const char *name)
205 Dmsg0(200, "runscript: running a RUNSCRIPT object\n");
206 POOLMEM *ecmd = get_pool_memory(PM_FNAME);
209 char line[MAXSTRING];
211 ecmd = edit_job_codes(jcr, ecmd, this->command, "", this->job_code_callback);
212 ecmd = edit_job_codes(jcr, ecmd, this->command, "");
213 Dmsg1(100, "runscript: running '%s'...\n", ecmd);
214 Jmsg(jcr, M_INFO, 0, _("%s: run command \"%s\"\n"), name, ecmd);
216 bpipe = open_bpipe(ecmd, 0, "r");
217 free_pool_memory(ecmd);
220 Jmsg(jcr, M_ERROR, 0, _("Runscript: %s could not execute. ERR=%s\n"), name,
224 while (fgets(line, sizeof(line), bpipe->rfd)) {
225 int len = strlen(line);
226 if (len > 0 && line[len-1] == '\n') {
229 Jmsg(jcr, M_INFO, 0, _("%s: %s\n"), name, line);
231 status = close_bpipe(bpipe);
234 Jmsg(jcr, M_ERROR, 0, _("Runscript: %s returned non-zero status=%d. ERR=%s\n"), name,
235 be.code(status), be.bstrerror(status));
238 Dmsg0(100, "runscript OK\n");
242 /* cancel running job properly */
244 set_jcr_job_status(jcr, JS_ErrorTerminated);
246 Dmsg1(100, "runscript failed. fail_on_error=%d\n", fail_on_error);
250 void free_runscripts(alist *runscripts)
252 Dmsg0(500, "runscript: freeing all RUNSCRIPTS object\n");
255 foreach_alist(elt, runscripts) {
260 void RUNSCRIPT::debug()
262 Dmsg0(200, "runscript: debug\n");
263 Dmsg0(200, _(" --> RunScript\n"));
264 Dmsg1(200, _(" --> Command=%s\n"), NPRT(command));
265 Dmsg1(200, _(" --> Target=%s\n"), NPRT(target));
266 Dmsg1(200, _(" --> RunOnSuccess=%u\n"), on_success);
267 Dmsg1(200, _(" --> RunOnFailure=%u\n"), on_failure);
268 Dmsg1(200, _(" --> FailJobOnError=%u\n"), fail_on_error);
269 Dmsg1(200, _(" --> RunWhen=%u\n"), when);
272 void RUNSCRIPT::set_job_code_callback(job_code_callback_t arg_job_code_callback)
275 this->job_code_callback = arg_job_code_callback;