X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=bacula%2Fsrc%2Fdird%2Fnewvol.c;h=4a57019e0171c5a00efbc56dfdbe1eff9d0d00c1;hb=70c8aeccacb2b0fe1eb110d4f4a4c0d8f97a940d;hp=0b66a86a2bd2a1acd7efb162c23b769b71a5070f;hpb=6a41e15944691f6428fdf667afd80ffb0e63e1c5;p=bacula%2Fbacula diff --git a/bacula/src/dird/newvol.c b/bacula/src/dird/newvol.c index 0b66a86a2b..4a57019e01 100644 --- a/bacula/src/dird/newvol.c +++ b/bacula/src/dird/newvol.c @@ -1,3 +1,30 @@ +/* + Bacula® - The Network Backup Solution + + Copyright (C) 2000-2008 Free Software Foundation Europe e.V. + + 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 + License as published by the Free Software Foundation and included + in the file LICENSE. + + This program is distributed in the hope that it will be useful, but + WITHOUT ANY WARRANTY; without even the implied warranty of + 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 + along with this program; if not, write to the Free Software + Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + 02110-1301, USA. + + Bacula® is a registered trademark of John Walker. + The licensor of Bacula is the Free Software Foundation Europe + (FSFE), Fiduciary Program, Sumatrastrasse 25, 8006 Zürich, + Switzerland, email:ftf@fsfeurope.org. +*/ /* * * Bacula Director -- newvol.c -- creates new Volumes in @@ -8,74 +35,136 @@ * This routine runs as a thread and must be thread reentrant. * * Basic tasks done here: - * If possible create a new Media entry + * If possible create a new Media entry * * Version $Id$ */ -/* - Copyright (C) 2000-2003 Kern Sibbald and John Walker - - This program is free software; you can redistribute it and/or - modify it under the terms of the GNU General Public License as - published by the Free Software Foundation; either version 2 of - the License, or (at your option) any later version. - - This program is distributed in the hope that it will be useful, - but WITHOUT ANY WARRANTY; without even the implied warranty of - 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 along with this program; if not, write to the Free - Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, - MA 02111-1307, USA. - - */ #include "bacula.h" #include "dird.h" +/* Forward referenced functions */ +static bool create_simple_name(JCR *jcr, MEDIA_DBR *mr, POOL_DBR *pr); +static bool perform_full_name_substitution(JCR *jcr, MEDIA_DBR *mr, POOL_DBR *pr); + + /* - * Really crude automatic Volume name creation using - * LabelFormat. We assume that if this routine is being - * called the Volume will be labeled, so we set the LabelDate. + * Automatic Volume name creation using the LabelFormat + * + * The media record must have the PoolId filled in when + * calling this routine. */ -int newVolume(JCR *jcr, MEDIA_DBR *mr) +bool newVolume(JCR *jcr, MEDIA_DBR *mr) { POOL_DBR pr; - char name[MAXSTRING]; - char num[20]; memset(&pr, 0, sizeof(pr)); /* See if we can create a new Volume */ db_lock(jcr->db); - pr.PoolId = jcr->PoolId; - if (db_get_pool_record(jcr, jcr->db, &pr) && pr.LabelFormat[0] && - pr.LabelFormat[0] != '*') { - if (pr.MaxVols == 0 || pr.NumVols < pr.MaxVols) { - set_pool_dbr_defaults_in_media_dbr(mr, &pr); - mr->LabelDate = time(NULL); - bstrncpy(mr->MediaType, jcr->store->media_type, sizeof(mr->MediaType)); - bstrncpy(name, pr.LabelFormat, sizeof(name)); - if (strchr(name, (int)'%') != NULL) { - db_unlock(jcr->db); - Jmsg(jcr, M_ERROR, 0, _("Illegal character in Label Format\n")); - return 0; - } - sprintf(num, "%04d", ++pr.NumVols); - bstrncpy(mr->VolumeName, name, sizeof(mr->VolumeName)); - bstrncat(mr->VolumeName, num, sizeof(mr->VolumeName)); - if (db_create_media_record(jcr, jcr->db, mr) && - db_update_pool_record(jcr, jcr->db, &pr)) { - db_unlock(jcr->db); - Dmsg1(90, "Created new Volume=%s\n", mr->VolumeName); - return 1; - } else { - Jmsg(jcr, M_ERROR, 0, "%s", db_strerror(jcr->db)); - } + pr.PoolId = mr->PoolId; + if (!db_get_pool_record(jcr, jcr->db, &pr)) { + goto bail_out; + } + if (pr.MaxVols == 0 || pr.NumVols < pr.MaxVols) { + memset(mr, 0, sizeof(MEDIA_DBR)); + set_pool_dbr_defaults_in_media_dbr(mr, &pr); + jcr->VolumeName[0] = 0; + bstrncpy(mr->MediaType, jcr->wstore->media_type, sizeof(mr->MediaType)); + if (generate_job_event(jcr, "NewVolume") == 1 && jcr->VolumeName[0] && + is_volume_name_legal(NULL, jcr->VolumeName)) { + bstrncpy(mr->VolumeName, jcr->VolumeName, sizeof(mr->VolumeName)); + /* Check for special characters */ + } else if (pr.LabelFormat[0] && pr.LabelFormat[0] != '*') { + if (is_volume_name_legal(NULL, pr.LabelFormat)) { + /* No special characters, so apply simple algorithm */ + if (!create_simple_name(jcr, mr, &pr)) { + goto bail_out; + } + } else { /* try full substitution */ + /* Found special characters, so try substitution */ + if (!perform_full_name_substitution(jcr, mr, &pr)) { + goto bail_out; + } + if (!is_volume_name_legal(NULL, mr->VolumeName)) { + Jmsg(jcr, M_ERROR, 0, _("Illegal character in Volume name \"%s\"\n"), + mr->VolumeName); + goto bail_out; + } + } + } else { + goto bail_out; + } + pr.NumVols++; + mr->Enabled = 1; + if (db_create_media_record(jcr, jcr->db, mr) && + db_update_pool_record(jcr, jcr->db, &pr)) { + db_unlock(jcr->db); + Jmsg(jcr, M_INFO, 0, _("Created new Volume \"%s\" in catalog.\n"), mr->VolumeName); + Dmsg1(90, "Created new Volume=%s\n", mr->VolumeName); + return true; + } else { + Jmsg(jcr, M_ERROR, 0, "%s", db_strerror(jcr->db)); } } +bail_out: db_unlock(jcr->db); - return 0; + return false; +} + +static bool create_simple_name(JCR *jcr, MEDIA_DBR *mr, POOL_DBR *pr) +{ + char name[MAXSTRING]; + char num[20]; + db_int64_ctx ctx; + POOL_MEM query(PM_MESSAGE); + char ed1[50]; + + /* See if volume already exists */ + mr->VolumeName[0] = 0; + bstrncpy(name, pr->LabelFormat, sizeof(name)); + ctx.value = 0; + Mmsg(query, "SELECT MAX(MediaId) FROM Media,Pool WHERE Pool.PoolId=%s", + edit_int64(pr->PoolId, ed1)); + if (!db_sql_query(jcr->db, query.c_str(), db_int64_handler, (void *)&ctx)) { + Jmsg(jcr, M_WARNING, 0, _("SQL failed, but ignored. ERR=%s\n"), db_strerror(jcr->db)); + ctx.value = pr->NumVols+1; + } + for (int i=(int)ctx.value+1; i<(int)ctx.value+100; i++) { + MEDIA_DBR tmr; + memset(&tmr, 0, sizeof(tmr)); + sprintf(num, "%04d", i); + bstrncpy(tmr.VolumeName, name, sizeof(tmr.VolumeName)); + bstrncat(tmr.VolumeName, num, sizeof(tmr.VolumeName)); + if (db_get_media_record(jcr, jcr->db, &tmr)) { + Jmsg(jcr, M_WARNING, 0, + _("Wanted to create Volume \"%s\", but it already exists. Trying again.\n"), + tmr.VolumeName); + continue; + } + bstrncpy(mr->VolumeName, name, sizeof(mr->VolumeName)); + bstrncat(mr->VolumeName, num, sizeof(mr->VolumeName)); + break; /* Got good name */ + } + if (mr->VolumeName[0] == 0) { + Jmsg(jcr, M_ERROR, 0, _("Too many failures. Giving up creating Volume name.\n")); + return false; + } + return true; +} + +/* + * Perform full substitution on Label + */ +static bool perform_full_name_substitution(JCR *jcr, MEDIA_DBR *mr, POOL_DBR *pr) +{ + bool ok = false; + POOLMEM *label = get_pool_memory(PM_FNAME); + jcr->NumVols = pr->NumVols; + if (variable_expansion(jcr, pr->LabelFormat, &label)) { + bstrncpy(mr->VolumeName, label, sizeof(mr->VolumeName)); + ok = true; + } + free_pool_memory(label); + return ok; }