]> git.sur5r.net Git - bacula/bacula/blobdiff - bacula/src/stored/mount.c
- Lock autochanger script when running.
[bacula/bacula] / bacula / src / stored / mount.c
index 1b0cd6b52dc27cdcf8261c6ad3a128adacf7a28f..27d1ecebe38b93618addf85e6e4a2321f50c131c 100644 (file)
@@ -8,7 +8,7 @@
  *   Version $Id$
  */
 /*
-   Copyright (C) 2000-2004 Kern Sibbald and John Walker
+   Copyright (C) 2000-2005 Kern Sibbald
 
    This program is free software; you can redistribute it and/or
    modify it under the terms of the GNU General Public License as
@@ -30,8 +30,6 @@
 #include "bacula.h"                   /* pull in global headers */
 #include "stored.h"                   /* pull in Storage Deamon headers */
 
-static bool rewrite_volume_label(DCR *dcr, bool recycle);
-
 
 /*
  * If release is set, we rewind the current volume,
@@ -69,7 +67,7 @@ mount_next_vol:
       /* Last ditch effort before giving up, force operator to respond */
       dcr->VolCatInfo.Slot = 0;
       if (!dir_ask_sysop_to_mount_volume(dcr)) {
-        Jmsg(jcr, M_FATAL, 0, _("Too many errors trying to mount device %s.\n"),
+         Jmsg(jcr, M_FATAL, 0, _("Too many errors trying to mount device %s.\n"),
              dev_name(dev));
         return false;
       }
@@ -100,8 +98,10 @@ mount_next_vol:
    if (job_canceled(jcr)) {
       return false;
    }
-   Dmsg2(100, "After find_next_append. Vol=%s Slot=%d\n",
-        dcr->VolCatInfo.VolCatName, dcr->VolCatInfo.Slot);
+   Dmsg3(100, "After find_next_append. Vol=%s Slot=%d Parts=%d\n",
+        dcr->VolCatInfo.VolCatName, dcr->VolCatInfo.Slot, dcr->VolCatInfo.VolCatParts);
+   
+   dev->num_parts = dcr->VolCatInfo.VolCatParts;
 
    /*
     * Get next volume and ready it for append
@@ -154,12 +154,25 @@ mount_next_vol:
    }
 
    /* Ensure the device is open */
-   if (!open_device(dcr)) {
-      if (dev->poll) {
-        goto mount_next_vol;
-      } else {
-        return false;
+   /* If we have a dvd that requires mount, we first want to guess
+    * which Volume is loaded, so we continue (if the wrong device is
+    * loaded, open_device just below would fail. 
+    */
+   if (!dev->is_dvd()) {
+      if (!open_device(dcr)) {
+        if (dev->poll) {
+           goto mount_next_vol;
+        } else {
+           return false;
+        }
       }
+   } else {
+      /*
+       * Just copy the VolCatName in the device resource 
+       *   (usually done by open_dev).
+       * It is necessary so we can open the real files later.  
+       */
+      bstrncpy(dev->VolCatInfo.VolCatName, dcr->VolCatInfo.VolCatName, sizeof(dev->VolCatInfo.VolCatName));
    }
 
    /*
@@ -174,6 +187,8 @@ read_volume:
       vol_label_status = VOL_OK;
       create_volume_label(dev, dcr->VolumeName, "Default");
       dev->VolHdr.LabelType = PRE_LABEL;
+   } else if (dev->is_dvd()) {
+      vol_label_status = read_dev_volume_label_guess(dcr, 1);
    } else {
       vol_label_status = read_dev_volume_label(dcr);
    }
@@ -198,7 +213,7 @@ read_volume:
 
       /* If not removable, Volume is broken */
       if (!dev_cap(dev, CAP_REM)) {
-        Jmsg(jcr, M_WARNING, 0, _("Volume \"%s\" not on device %s.\n"),
+         Jmsg(jcr, M_WARNING, 0, _("Volume \"%s\" not on device %s.\n"),
            dcr->VolumeName, dev_name(dev));
         mark_volume_in_error(dcr);
         goto mount_next_vol;
@@ -208,7 +223,7 @@ read_volume:
       /* If polling and got a previous bad name, ignore it */
       if (dev->poll && strcmp(dev->BadVolName, dev->VolHdr.VolName) == 0) {
         ask = true;
-        Dmsg1(200, "Vol Name error supress due to poll. Name=%s\n",
+         Dmsg1(200, "Vol Name error supress due to poll. Name=%s\n",
            dcr->VolumeName);
         goto mount_next_vol;
       }
@@ -223,9 +238,9 @@ read_volume:
       bstrncpy(dcr->VolumeName, dev->VolHdr.VolName, sizeof(dcr->VolumeName));
       if (!dir_get_volume_info(dcr, GET_VOL_INFO_FOR_WRITE)) {
         bstrncpy(dev->BadVolName, dev->VolHdr.VolName, sizeof(dev->BadVolName));
-        Jmsg(jcr, M_WARNING, 0, _("Director wanted Volume \"%s\".\n"
-             "    Current Volume \"%s\" not acceptable because:\n"
-             "    %s"),
+         Jmsg(jcr, M_WARNING, 0, _("Director wanted Volume \"%s\".\n"
+              "    Current Volume \"%s\" not acceptable because:\n"
+              "    %s"),
             VolCatInfo.VolCatName, dev->VolHdr.VolName,
             jcr->dir_bsock->msg);
         /* Restore desired volume name, note device info out of sync */
@@ -254,30 +269,33 @@ read_volume:
        *   previous tape (or nothing).
        */
       if (dev_cap(dev, CAP_LABEL) && (dcr->VolCatInfo.VolCatBytes == 0 ||
-           (!dev_is_tape(dev) && strcmp(dcr->VolCatInfo.VolCatStatus,
-                                  "Recycle") == 0))) {
-        Dmsg0(100, "Create volume label\n");
+           (!dev->is_tape() && strcmp(dcr->VolCatInfo.VolCatStatus,
+                                   "Recycle") == 0))) {
+         Dmsg0(100, "Create volume label\n");
         /* Create a new Volume label and write it to the device */
         if (!write_new_volume_label_to_dev(dcr, dcr->VolumeName,
                dcr->pool_name)) {
-           Dmsg0(100, "!write_vol_label\n");
+            Dmsg0(100, "!write_vol_label\n");
            goto mount_next_vol;
         }
-        Dmsg0(100, "dir_update_vol_info. Set Append\n");
-        /* Copy Director's info into the device info */
+         Dmsg0(100, "dir_update_vol_info. Set Append\n");
+         /* Copy Director's info into the device info */
         memcpy(&dev->VolCatInfo, &dcr->VolCatInfo, sizeof(dev->VolCatInfo));
         if (!dir_update_volume_info(dcr, true)) {  /* indicate tape labeled */
            return false;
         }
-        Jmsg(jcr, M_INFO, 0, _("Labeled new Volume \"%s\" on device %s.\n"),
+         Jmsg(jcr, M_INFO, 0, _("Labeled new Volume \"%s\" on device %s.\n"),
            dcr->VolumeName, dev_name(dev));
         goto read_volume;      /* read label we just wrote */
       }
       /* If not removable, Volume is broken */
       if (!dev_cap(dev, CAP_REM)) {
-        Jmsg(jcr, M_WARNING, 0, _("Volume \"%s\" not on device %s.\n"),
+         Jmsg(jcr, M_WARNING, 0, _("Volume \"%s\" not on device %s.\n"),
            dcr->VolumeName, dev_name(dev));
         mark_volume_in_error(dcr);
+        if (autochanger) {
+           mark_volume_not_inchanger(dcr);
+        }
         goto mount_next_vol;
       }
       /* NOTE! Fall-through wanted. */
@@ -285,11 +303,15 @@ read_volume:
    default:
       /* Send error message */
       if (!dev->poll) {
-        Jmsg(jcr, M_WARNING, 0, "%s", jcr->errmsg);
+         Jmsg(jcr, M_WARNING, 0, "%s", jcr->errmsg);
       } else {
-        Dmsg1(200, "Msg suppressed by poll: %s\n", jcr->errmsg);
+         Dmsg1(200, "Msg suppressed by poll: %s\n", jcr->errmsg);
       }
       ask = true;
+      /* Needed, so the medium can be changed */
+      if (dev_cap(dev, CAP_REQMOUNT)) {
+        close_dev(dev);  
+      }
       goto mount_next_vol;
    }
 
@@ -320,7 +342,7 @@ read_volume:
       Jmsg(jcr, M_INFO, 0, _("Volume \"%s\" previously written, moving to end of data.\n"),
         dcr->VolumeName);
       if (!eod_dev(dev)) {
-        Jmsg(jcr, M_ERROR, 0, _("Unable to position to end of data on device \"%s\". ERR=%s\n"),
+         Jmsg(jcr, M_ERROR, 0, _("Unable to position to end of data on device \"%s\". ERR=%s\n"),
            dev_name(dev), strerror_dev(dev));
         mark_volume_in_error(dcr);
         goto mount_next_vol;
@@ -332,10 +354,10 @@ read_volume:
          * that the database says we should be.
          */
         if (dev->VolCatInfo.VolCatFiles == dev_file(dev)) {
-           Jmsg(jcr, M_INFO, 0, _("Ready to append to end of Volume \"%s\" at file=%d.\n"),
+            Jmsg(jcr, M_INFO, 0, _("Ready to append to end of Volume \"%s\" at file=%d.\n"),
                 dcr->VolumeName, dev_file(dev));
         } else {
-           Jmsg(jcr, M_ERROR, 0, _("I canot write on Volume \"%s\" because:\n"
+            Jmsg(jcr, M_ERROR, 0, _("I canot write on Volume \"%s\" because:\n"
 "The number of files mismatch! Volume=%u Catalog=%u\n"),
                 dcr->VolumeName, dev_file(dev), dev->VolCatInfo.VolCatFiles);
            mark_volume_in_error(dcr);
@@ -355,83 +377,6 @@ read_volume:
    return true;
 }
 
-/*
- * Write a volume label.
- *  Returns: true if OK
- *          false if unable to write it
- */
-static bool rewrite_volume_label(DCR *dcr, bool recycle)
-{
-   DEVICE *dev = dcr->dev;
-   JCR *jcr = dcr->jcr;
-
-   Dmsg1(190, "set append found freshly labeled volume. dev=%x\n", dev);
-   dev->VolHdr.LabelType = VOL_LABEL; /* set Volume label */
-   dev->state |= ST_APPEND;
-   if (!write_volume_label_to_block(dcr)) {
-      Dmsg0(200, "Error from write volume label.\n");
-      return false;
-   }
-   /*
-    * If we are not dealing with a streaming device,
-    *  write the block now to ensure we have write permission.
-    *  It is better to find out now rather than later.
-    */
-   if (!dev_cap(dev, CAP_STREAM)) {
-      if (!rewind_dev(dev)) {
-        Jmsg2(jcr, M_WARNING, 0, _("Rewind error on device \"%s\". ERR=%s\n"),
-              dev_name(dev), strerror_dev(dev));
-      }
-      if (recycle) {
-        if (!truncate_dev(dev)) {
-           Jmsg2(jcr, M_WARNING, 0, _("Truncate error on device \"%s\". ERR=%s\n"),
-                 dev_name(dev), strerror_dev(dev));
-        }
-      }
-      /* Attempt write to check write permission */
-      Dmsg0(200, "Attempt to write to device.\n");
-      if (!write_block_to_dev(dcr)) {
-        Jmsg2(jcr, M_ERROR, 0, _("Unable to write device \"%s\". ERR=%s\n"),
-           dev_name(dev), strerror_dev(dev));
-        Dmsg0(200, "===ERROR write block to dev\n");
-        return false;
-      }
-   }
-   /* Set or reset Volume statistics */
-   dev->VolCatInfo.VolCatJobs = 0;
-   dev->VolCatInfo.VolCatFiles = 0;
-   dev->VolCatInfo.VolCatBytes = 1;
-   dev->VolCatInfo.VolCatErrors = 0;
-   dev->VolCatInfo.VolCatBlocks = 0;
-   dev->VolCatInfo.VolCatRBytes = 0;
-   if (recycle) {
-      dev->VolCatInfo.VolCatMounts++;
-      dev->VolCatInfo.VolCatRecycles++;
-   } else {
-      dev->VolCatInfo.VolCatMounts = 1;
-      dev->VolCatInfo.VolCatRecycles = 0;
-      dev->VolCatInfo.VolCatWrites = 1;
-      dev->VolCatInfo.VolCatReads = 1;
-   }
-   Dmsg0(100, "dir_update_vol_info. Set Append\n");
-   bstrncpy(dev->VolCatInfo.VolCatStatus, "Append", sizeof(dev->VolCatInfo.VolCatStatus));
-   if (!dir_update_volume_info(dcr, true)) {  /* indicate doing relabel */
-      return false;
-   }
-   if (recycle) {
-      Jmsg(jcr, M_INFO, 0, _("Recycled volume \"%s\" on device \"%s\", all previous data lost.\n"),
-        dcr->VolumeName, dev_name(dev));
-   } else {
-      Jmsg(jcr, M_INFO, 0, _("Wrote label to prelabeled Volume \"%s\" on device \"%s\"\n"),
-        dcr->VolumeName, dev_name(dev));
-   }
-   /*
-    * End writing real Volume label (from pre-labeled tape), or recycling
-    *  the volume.
-    */
-   Dmsg0(200, "OK from rewite vol label.\n");
-   return true;
-}
 
 
 /*
@@ -462,8 +407,8 @@ bool mount_next_read_volume(DCR *dcr)
    if (jcr->NumVolumes > 1 && jcr->CurVolume < jcr->NumVolumes) {
       close_dev(dev);
       dev->state &= ~ST_READ;
-      if (!acquire_device_for_read(jcr)) {
-        Jmsg2(jcr, M_FATAL, 0, "Cannot open Dev=%s, Vol=%s\n", dev_name(dev),
+      if (!acquire_device_for_read(jcr, dev)) {
+         Jmsg2(jcr, M_FATAL, 0, "Cannot open Dev=%s, Vol=%s\n", dev_name(dev),
               dcr->VolumeName);
         return false;
       }
@@ -495,16 +440,16 @@ void release_volume(DCR *dcr)
    memset(&dev->VolHdr, 0, sizeof(dev->VolHdr));
    /* Force re-read of label */
    dev->state &= ~(ST_LABEL|ST_READ|ST_APPEND);
+   dev->label_type = B_BACULA_LABEL;
    dcr->VolumeName[0] = 0;
 
-   if ((dev->state & ST_OPENED) &&
-       (!dev_is_tape(dev) || !dev_cap(dev, CAP_ALWAYSOPEN))) {
+   if (dev->is_open() && (!dev->is_tape() || !dev_cap(dev, CAP_ALWAYSOPEN))) {
       offline_or_rewind_dev(dev);
       close_dev(dev);
    }
 
    /* If we have not closed the device, then at least rewind the tape */
-   if (dev->state & ST_OPENED) {
+   if (dev->is_open()) {
       offline_or_rewind_dev(dev);
    }
    Dmsg0(190, "===== release_volume ---");