X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=bacula%2Fsrc%2Fstored%2Flabel.c;h=8df3339a464de7ddfbc49de27f27cb5be0155b5f;hb=36b40d5c7f3ff90565ab73ac75f0dc4f6660ff37;hp=db385275393c1b1d80bb60c59929d603f11f852e;hpb=5dfc1f669ea6d5b83c3a32b0ac2bbe5d9d7afe8f;p=bacula%2Fbacula diff --git a/bacula/src/stored/label.c b/bacula/src/stored/label.c index db38527539..8df3339a46 100644 --- a/bacula/src/stored/label.c +++ b/bacula/src/stored/label.c @@ -20,7 +20,7 @@ Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. - Bacula® is a registered trademark of John Walker. + Bacula® is a registered trademark of Kern Sibbald. The licensor of Bacula is the Free Software Foundation Europe (FSFE), Fiduciary Program, Sumatrastrasse 25, 8006 Zürich, Switzerland, email:ftf@fsfeurope.org. @@ -85,25 +85,6 @@ int read_dev_volume_label(DCR *dcr) return VOL_IO_ERROR; } } - if (dev->is_labeled()) { /* did we already read label? */ - /* Compare Volume Names allow special wild card */ - if (VolName && *VolName && *VolName != '*' && strcmp(dev->VolHdr.VolumeName, VolName) != 0) { - Mmsg(jcr->errmsg, _("Wrong Volume mounted on device %s: Wanted %s have %s\n"), - dev->print_name(), VolName, dev->VolHdr.VolumeName); - /* - * Cancel Job if too many label errors - * => we are in a loop - */ - if (!dev->poll && jcr->label_errors++ > 100) { - Jmsg(jcr, M_FATAL, 0, _("Too many tries: %s"), jcr->errmsg); - } - Dmsg0(150, "return VOL_NAME_ERROR\n"); - stat = VOL_NAME_ERROR; - goto bail_out; - } - Dmsg0(130, "Leave read_volume_label() VOL_OK\n"); - return VOL_OK; /* label already read */ - } dev->clear_labeled(); dev->clear_append(); @@ -168,6 +149,10 @@ int read_dev_volume_label(DCR *dcr) } free_record(record); /* finished reading Volume record */ + if (!dev->is_volume_to_unload()) { + dev->clear_unload(); + } + if (!ok) { if (forge_on || jcr->ignore_label_errors) { dev->set_labeled(); /* set has Bacula label */ @@ -212,16 +197,6 @@ int read_dev_volume_label(DCR *dcr) } dev->set_labeled(); /* set has Bacula label */ - Dmsg1(100, "Call reserve_volume=%s\n", dev->VolHdr.VolumeName); - Dmsg2(100, "=== dcr->dev=%p dev=%p\n", dcr->dev, dev); - if (reserve_volume(dcr, dev->VolHdr.VolumeName) == NULL) { - Mmsg2(jcr->errmsg, _("Could not reserve volume %s on %s\n"), - dev->VolHdr.VolumeName, dev->print_name()); - stat = VOL_NAME_ERROR; - goto bail_out; - } - Dmsg2(100, "=== dcr->dev=%p dev=%p\n", dcr->dev, dev); -// dev = dcr->dev; /* may have changed in reserve volume */ /* Compare Volume Names */ Dmsg2(130, "Compare Vol names: VolName=%s hdr=%s\n", VolName?VolName:"*", dev->VolHdr.VolumeName); @@ -238,10 +213,9 @@ int read_dev_volume_label(DCR *dcr) } Dmsg0(150, "return VOL_NAME_ERROR\n"); stat = VOL_NAME_ERROR; - volume_unused(dcr); /* mark volume "released" */ goto bail_out; } - Dmsg1(130, "Copy vol_name=%s\n", dev->VolHdr.VolumeName); + if (debug_level >= 10) { dump_volume_label(dev); @@ -254,11 +228,19 @@ int read_dev_volume_label(DCR *dcr) stat = read_ansi_ibm_label(dcr); /* If we want a label and didn't find it, return error */ if (stat != VOL_OK) { - volume_unused(dcr); /* mark volume "released" */ goto bail_out; } } } + + Dmsg1(100, "Call reserve_volume=%s\n", dev->VolHdr.VolumeName); + if (reserve_volume(dcr, dev->VolHdr.VolumeName) == NULL) { + Mmsg2(jcr->errmsg, _("Could not reserve volume %s on %s\n"), + dev->VolHdr.VolumeName, dev->print_name()); + stat = VOL_NAME_ERROR; + goto bail_out; + } + empty_block(block); return VOL_OK; @@ -296,7 +278,8 @@ bool write_volume_label_to_block(DCR *dcr) dev->print_name()); return false; } else { - Dmsg1(130, "Wrote label of %d bytes to block\n", rec.data_len); + Dmsg2(130, "Wrote label of %d bytes to block. Vol=%s\n", rec.data_len, + dcr->VolumeName); } free_pool_memory(rec.data); return true; @@ -320,6 +303,10 @@ bool write_new_volume_label_to_dev(DCR *dcr, const char *VolName, Dmsg0(150, "write_volume_label()\n"); empty_block(dcr->block); + if (*VolName == 0) { + Pmsg0(0, "=== ERROR: write_new_volume_label_to_dev called with NULL VolName\n"); + goto bail_out; + } if (relabel) { volume_unused(dcr); /* mark current volume unused */ @@ -448,6 +435,7 @@ bool rewrite_volume_label(DCR *dcr, bool recycle) Dmsg0(200, "Error from write volume label.\n"); return false; } + Dmsg1(150, "wrote vol label to block. Vol=%s\n", dcr->VolumeName); dev->VolCatInfo.VolCatBytes = 0; /* reset byte count */ @@ -465,6 +453,7 @@ bool rewrite_volume_label(DCR *dcr, bool recycle) return false; } if (recycle) { + Dmsg1(150, "Doing recycle. Vol=%s\n", dcr->VolumeName); // volume_unused(dcr); /* mark volume unused */ if (!dev->truncate(dcr)) { Jmsg2(jcr, M_FATAL, 0, _("Truncate error on device %s: ERR=%s\n"), @@ -518,8 +507,9 @@ bool rewrite_volume_label(DCR *dcr, bool recycle) dev->VolCatInfo.VolCatWrites = 1; dev->VolCatInfo.VolCatReads = 1; } - Dmsg0(150, "dir_update_vol_info. Set Append\n"); + Dmsg1(150, "dir_update_vol_info. Set Append vol=%s\n", dcr->VolumeName); bstrncpy(dev->VolCatInfo.VolCatStatus, "Append", sizeof(dev->VolCatInfo.VolCatStatus)); + bstrncpy(dev->VolCatInfo.VolCatName, dcr->VolumeName, sizeof(dev->VolCatInfo.VolCatName)); if (!dir_update_volume_info(dcr, true, true)) { /* indicate doing relabel */ return false; } @@ -534,7 +524,7 @@ bool rewrite_volume_label(DCR *dcr, bool recycle) * End writing real Volume label (from pre-labeled tape), or recycling * the volume. */ - Dmsg0(200, "OK from rewrite vol label.\n"); + Dmsg1(150, "OK from rewrite vol label. Vol=%s\n", dcr->VolumeName); return true; } @@ -590,6 +580,7 @@ static void create_volume_label_record(DCR *dcr, DEV_RECORD *rec) ser_string(dev->VolHdr.ProgDate); ser_end(rec->data, SER_LENGTH_Volume_Label); + bstrncpy(dcr->VolumeName, dev->VolHdr.VolumeName, sizeof(dcr->VolumeName)); rec->data_len = ser_length(rec->data); rec->FileIndex = dev->VolHdr.LabelType; rec->VolSessionId = jcr->VolSessionId; @@ -676,8 +667,8 @@ void create_session_label(DCR *dcr, DEV_RECORD *rec, int label) /* Added in VerNum 10 */ ser_string(jcr->Job); /* Unique name of this Job */ ser_string(jcr->fileset_name); - ser_uint32(jcr->JobType); - ser_uint32(jcr->JobLevel); + ser_uint32(jcr->get_JobType()); + ser_uint32(jcr->get_JobLevel()); /* Added in VerNum 11 */ ser_string(jcr->fileset_md5);