/*
Bacula® - The Network Backup Solution
- Copyright (C) 2008-2009 Free Software Foundation Europe e.V.
+ Copyright (C) 2010-2011 Bacula Systems(R) SA
The main author of Bacula is Kern Sibbald, with contributions from
many others, a complete list can be found in the file AUTHORS.
This program is Free Software; you can redistribute it and/or
- modify it under the terms of version two of the GNU General Public
+ modify it under the terms of version three of the GNU Affero General Public
License as published by the Free Software Foundation, which is
listed in the file LICENSE.
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
General Public License for more details.
- You should have received a copy of the GNU General Public License
+ You should have received a copy of the GNU Affero General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
02110-1301, USA.
bFuncs *bfuncs = NULL;
bInfo *binfo = NULL;
-#define PLUGIN_LICENSE "Bacula GPLv2"
+#define PLUGIN_LICENSE "Bacula AGPLv3"
#define PLUGIN_AUTHOR "James Harper"
#define PLUGIN_DATE "September 2008"
#define PLUGIN_VERSION "1"
*pinfo = &pluginInfo;
*pfuncs = &pluginFuncs;
retval = loadExchangeApi();
- if (retval != bRC_OK)
- {
+ if (retval != bRC_OK) {
printf("Cannot load Exchange DLL\n");
return retval;
}
context->bpContext = ctx;
context->job_since = 0;
context->notrunconfull_option = false;
+ context->plugin_active = false;
bfuncs->getBaculaValue(ctx, bVarJobId, (void *)&JobId);
_DebugMessage(0, "newPlugin JobId=%d\n", JobId);
bfuncs->registerBaculaEvents(ctx, 1, 2, 0);
char *name;
int i, intval;
int accurate;
+ char *command;
+ char *plugin_name;
switch (event->eventType) {
case bEventJobStart:
_DebugMessage(0, "JobStart=%s\n", (char *)value);
+ context->plugin_active = false;
break;
case bEventJobEnd:
_DebugMessage(0, "JobEnd\n");
break;
+ case bEventPluginCommand:
+ _DebugMessage(0, "bEventPluginCommand %s\n", value);
+ command = bstrdup((char *)value);
+ /* this isn't really unused */
+ plugin_name = strtok((char *)command, ":");
+ if (strcmp(plugin_name, "exchange") != 0) {
+ context->plugin_active = false;
+ } else {
+ context->plugin_active = true;
+ }
+ free(command);
+ break;
case bEventStartBackupJob:
+ if (!context->plugin_active) {
+ break;
+ }
_DebugMessage(0, "BackupStart\n");
bfuncs->getBaculaValue(ctx, bVarAccurate, (void *)&accurate);
context->accurate = accurate;
context->job_type = JOB_TYPE_BACKUP;
// level should have been specified by now - check it
// if level is D or I, since should have been specified too
- switch (context->job_level)
- {
+ switch (context->job_level) {
case 'F':
if (context->notrunconfull_option) {
context->truncate_logs = false;
break;
case bEventEndBackupJob:
_DebugMessage(0, "BackupEnd\n");
+ if (!context->plugin_active) {
+ break;
+ }
break;
case bEventLevel:
+ if (!context->plugin_active) {
+ break;
+ }
intval = (intptr_t)value;
_DebugMessage(0, "JobLevel=%c %d\n", intval, intval);
context->job_level = intval;
break;
case bEventSince:
+ if (!context->plugin_active) {
+ break;
+ }
intval = (intptr_t)value;
_DebugMessage(0, "since=%d\n", intval);
context->job_since = (time_t)value;
case bEventStartRestoreJob:
_DebugMessage(0, "StartRestoreJob\n");
context->job_type = JOB_TYPE_RESTORE;
+ context->plugin_active = true;
break;
case bEventEndRestoreJob:
+ if (!context->plugin_active) {
+ break;
+ }
_DebugMessage(0, "EndRestoreJob\n");
+ context->plugin_active = false;
break;
/* Plugin command e.g. plugin = <plugin-name>:<name-space>:command */
case bEventRestoreCommand:
_DebugMessage(0, "restore\n"); // command=%s\n", (char *)value);
+ if (!context->plugin_active) {
+ break;
+ }
break;
case bEventBackupCommand:
+ if (!context->plugin_active) {
+ break;
+ }
{
_DebugMessage(0, "backup command=%s\n", (char *)value);
char *command = new char[strlen((char *)value)];
char *plugin_name = strtok((char *)command, ":");
char *path = strtok(NULL, ":");
char *option;
- while ((option = strtok(NULL, ":")) != NULL)
- {
+ while ((option = strtok(NULL, ":")) != NULL) {
_DebugMessage(100, "option %s\n", option);
- if (stricmp(option, "notrunconfull") == 0)
- {
+ if (stricmp(option, "notrunconfull") == 0) {
context->notrunconfull_option = true;
- }
- else
- {
+ } else {
_JobMessage(M_WARNING, "Unknown plugin option '%s'\n", option);
}
}
_DebugMessage(0, "name = %s\n", plugin_name);
_DebugMessage(0, "path = %s\n", path);
- if (*path != '/')
- {
- _JobMessage(M_ERROR, "Path does not begin with a '/'\n");
+ if (*path != '/') {
+ _JobMessage(M_FATAL, "Path does not begin with a '/'\n");
return bRC_Error;
}
- for (i = 0; i < 6; i++)
+ for (i = 0; i < 6; i++) {
context->path_bits[i] = NULL;
+ }
char *path_bit = strtok(path, "/");
- for (i = 0; path_bit != NULL && i < 6; i++)
- {
+ for (i = 0; path_bit != NULL && i < 6; i++) {
context->path_bits[i] = new char[strlen(path_bit) + 1];
strcpy(context->path_bits[i], path_bit);
path_bit = strtok(NULL, "/");
}
- if (i < 2 || i > 4)
- {
- _JobMessage(M_ERROR, "Invalid plugin backup path\n");
+ if (i < 2 || i > 4) {
+ _JobMessage(M_FATAL, "Invalid plugin backup path\n");
return bRC_Error;
}
context->root_node = new root_node_t(context->path_bits[0]);
break;
default:
- _JobMessage(M_ERROR, "unknown event=%d\n", event->eventType);
+ _JobMessage(M_FATAL, "unknown event=%d\n", event->eventType);
}
bfuncs->getBaculaValue(ctx, bVarFDName, (void *)&name);
return bRC_OK;
node_t *current_node;
_DebugMessage(100, "startBackupFile, cmd = %s\n", sp->cmd);
- if (sp->pkt_size != sizeof(struct save_pkt) || sp->pkt_end != sizeof(struct save_pkt))
- {
+ if (sp->pkt_size != sizeof(struct save_pkt) || sp->pkt_end != sizeof(struct save_pkt)) {
_JobMessage(M_FATAL, "save_pkt size mismatch - sizeof(struct save_pkt) = %d, pkt_size = %d, pkt_end = %d\n", sizeof(struct save_pkt), sp->pkt_size, sp->pkt_end);
return bRC_Error;
}
if (io->pkt_size != sizeof(struct io_pkt) || io->pkt_end != sizeof(struct io_pkt))
{
- _JobMessage(M_ERROR, "io_pkt size mismatch - sizeof(struct io_pkt) = %d, pkt_size = %d, pkt_end = %d\n", sizeof(struct io_pkt), io->pkt_size, io->pkt_end);
+ _JobMessage(M_FATAL, "io_pkt size mismatch - sizeof(struct io_pkt) = %d, pkt_size = %d, pkt_end = %d\n", sizeof(struct io_pkt), io->pkt_size, io->pkt_end);
}
switch(io->func) {
_DebugMessage(100, "createFile - type = %d, ofname = %s\n", rp->type, rp->ofname);
if (rp->pkt_size != sizeof(struct restore_pkt) || rp->pkt_end != sizeof(struct restore_pkt))
{
- _JobMessage(M_ERROR, "restore_pkt size mismatch - sizeof(struct restore_pkt) = %d, pkt_size = %d, pkt_end = %d\n", sizeof(struct restore_pkt), rp->pkt_size, rp->pkt_end);
+ _JobMessage(M_FATAL, "restore_pkt size mismatch - sizeof(struct restore_pkt) = %d, pkt_size = %d, pkt_end = %d\n", sizeof(struct restore_pkt), rp->pkt_size, rp->pkt_end);
+ return bRC_Error;
}
for (i = 0; i < 6; i++)
projects / bacula / bacula / blobdiff