]> git.sur5r.net Git - bacula/bacula/blobdiff - bacula/src/stored/mount.c
- Continue implementing migration.
[bacula/bacula] / bacula / src / stored / mount.c
index 28ce910ab86672abb5053f9681ab9dc3bd4b1ba1..d88181a9c2b48c090e7a56ed62362dcfd2d61cc3 100644 (file)
@@ -8,7 +8,7 @@
  *   Version $Id$
  */
 /*
-   Copyright (C) 2002-2005 Kern Sibbald
+   Copyright (C) 2002-2006 Kern Sibbald
 
    This program is free software; you can redistribute it and/or
    modify it under the terms of the GNU General Public License
 #include "stored.h"                   /* pull in Storage Deamon headers */
 
 static void mark_volume_not_inchanger(DCR *dcr);
+static int try_autolabel(DCR *dcr);
+
+enum {
+   try_next_vol = 1,
+   try_read_vol,
+   try_error,
+   try_default
+};
 
 /*
  * If release is set, we rewind the current volume,
@@ -47,6 +55,7 @@ bool mount_next_write_volume(DCR *dcr, bool release)
    DEVICE *dev = dcr->dev;
    JCR *jcr = dcr->jcr;
    DEV_BLOCK *block = dcr->block;
+   int mode;
 
    Dmsg1(150, "Enter mount_next_volume(release=%d)\n", release);
 
@@ -123,12 +132,12 @@ mount_next_vol:
     *   and read the label. If there is no tape in the drive,
     *   we will err, recurse and ask the operator the next time.
     */
-   if (!release && dev->is_tape() && dev_cap(dev, CAP_AUTOMOUNT)) {
+   if (!release && dev->is_tape() && dev->has_cap(CAP_AUTOMOUNT)) {
       Dmsg0(150, "(1)Ask=0\n");
       ask = false;                 /* don't ask SYSOP this time */
    }
    /* Don't ask if not removable */
-   if (!dev_cap(dev, CAP_REM)) {
+   if (!dev->is_removable()) {
       Dmsg0(150, "(2)Ask=0\n");
       ask = false;
    }
@@ -144,15 +153,30 @@ mount_next_vol:
    }
    Dmsg1(150, "want vol=%s\n", dcr->VolumeName);
 
-   if (dev->poll && dev_cap(dev, CAP_CLOSEONPOLL)) {
-      force_close_device(dev);
+   if (dev->poll && dev->has_cap(CAP_CLOSEONPOLL)) {
+      dev->close();
    }
 
    /* Ensure the device is open */
-   if (!open_device(dcr)) {
+   if (dev_cap(dev, CAP_STREAM)) {
+      mode = OPEN_WRITE_ONLY;
+   } else {
+      mode = OPEN_READ_WRITE;
+   }
+   while (dev->open(dcr, mode) < 0) {
+      Dmsg0(000, "open_device failed\n");
+      if (dev->is_file() && dev->is_removable()) {
+         Dmsg0(000, "call scan_dir_for_vol\n");
+         if (dev->scan_dir_for_volume(dcr)) {
+            break;                    /* got a valid volume */
+         }
+      }
+      if (try_autolabel(dcr) == try_read_vol) {
+         break;                       /* created a new volume label */
+      }
       /* If DVD, ignore the error, very often you cannot open the device
        * (when there is no DVD, or when the one inserted is a wrong one) */
-      if ((dev->poll) || (dev->is_dvd())) {
+      if (dev->poll || dev->is_dvd() || dev->is_removable()) {
          goto mount_next_vol;
       } else {
          return false;
@@ -167,7 +191,7 @@ read_volume:
     * If we are writing to a stream device, ASSUME the volume label
     *  is correct.
     */
-   if (dev_cap(dev, CAP_STREAM)) {
+   if (dev->has_cap(CAP_STREAM)) {
       vol_label_status = VOL_OK;
       create_volume_label(dev, dcr->VolumeName, "Default");
       dev->VolHdr.LabelType = PRE_LABEL;
@@ -194,7 +218,7 @@ read_volume:
       VOLUME_CAT_INFO VolCatInfo, devVolCatInfo;
 
       /* If not removable, Volume is broken */
-      if (!dev_cap(dev, CAP_REM)) {
+      if (!dev->is_removable()) {
          Jmsg(jcr, M_WARNING, 0, _("Volume \"%s\" not on device %s.\n"),
             dcr->VolumeName, dev->print_name());
          mark_volume_in_error(dcr);
@@ -205,8 +229,7 @@ read_volume:
       /* If polling and got a previous bad name, ignore it */
       if (dev->poll && strcmp(dev->BadVolName, dev->VolHdr.VolumeName) == 0) {
          ask = true;
-         Dmsg1(200, "Vol Name error supress due to poll. Name=%s\n",
-            dcr->VolumeName);
+         Dmsg1(200, "Vol Name error supress due to poll. Name=%s\n", dcr->VolumeName);
          goto mount_next_vol;
       }
       /*
@@ -254,49 +277,17 @@ read_volume:
       }
       /* Fall through wanted */
    case VOL_NO_LABEL:
-      /*
-       * If permitted, we label the device, make sure we can do
-       *   it by checking that the VolCatBytes is zero => not labeled,
-       *   once the Volume is labeled we don't want to label another
-       *   blank tape with the same name.  For disk, we go ahead and
-       *   label it anyway, because the OS insures that there is only
-       *   one Volume with that name.
-       * As noted above, at this point dcr->VolCatInfo has what
-       *   the Director wants and dev->VolCatInfo has info on the
-       *   previous tape (or nothing).
-       */
-      if (dev_cap(dev, CAP_LABEL) && (dcr->VolCatInfo.VolCatBytes == 0 ||
-            (!dev->is_tape() && strcmp(dcr->VolCatInfo.VolCatStatus,
-                                   "Recycle") == 0))) {
-         Dmsg0(150, "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(150, "!write_vol_label\n");
-            mark_volume_in_error(dcr);
-            goto mount_next_vol;
-         }
-         Dmsg0(150, "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"),
-            dcr->VolumeName, dev->print_name());
-         goto read_volume;      /* read label we just wrote */
-      }
-      if (!dev_cap(dev, CAP_LABEL) && dcr->VolCatInfo.VolCatBytes == 0) {
-         Jmsg(jcr, M_INFO, 0, _("Warning device %s not configured to autolabel Volumes.\n"), 
-            dev->print_name());
-      }
-      /* If not removable, Volume is broken */
-      if (!dev_cap(dev, CAP_REM)) {
-         Jmsg(jcr, M_WARNING, 0, _("Volume \"%s\" not on device %s.\n"),
-            dcr->VolumeName, dev->print_name());
-         mark_volume_in_error(dcr);
+      switch (try_autolabel(dcr)) {
+      case try_next_vol:
          goto mount_next_vol;
+      case try_read_vol:
+         goto read_volume;
+      case try_error:
+         return false;
+      case try_default:
+         break;
       }
+
       /* NOTE! Fall-through wanted. */
    case VOL_NO_MEDIA:
    default:
@@ -309,7 +300,7 @@ read_volume:
       ask = true;
       /* Needed, so the medium can be changed */
       if (dev->requires_mount()) {
-         close_device(dev);  
+         dev->close();
       }
       goto mount_next_vol;
    }
@@ -341,7 +332,7 @@ read_volume:
       Dmsg0(200, "Device previously written, moving to end of data\n");
       Jmsg(jcr, M_INFO, 0, _("Volume \"%s\" previously written, moving to end of data.\n"),
          dcr->VolumeName);
-      if (!eod_dev(dev)) {
+      if (!dev->eod()) {
          Jmsg(jcr, M_ERROR, 0, _("Unable to position to end of data on device %s: ERR=%s\n"),
             dev->print_name(), strerror_dev(dev));
          mark_volume_in_error(dcr);
@@ -407,6 +398,54 @@ read_volume:
    return true;
 }
 
+/*
+ * If permitted, we label the device, make sure we can do
+ *   it by checking that the VolCatBytes is zero => not labeled,
+ *   once the Volume is labeled we don't want to label another
+ *   blank tape with the same name.  For disk, we go ahead and
+ *   label it anyway, because the OS insures that there is only
+ *   one Volume with that name.
+ * As noted above, at this point dcr->VolCatInfo has what
+ *   the Director wants and dev->VolCatInfo has info on the
+ *   previous tape (or nothing).
+ */
+static int try_autolabel(DCR *dcr)
+{
+   DEVICE *dev = dcr->dev;
+   if (dev->has_cap(CAP_LABEL) && (dcr->VolCatInfo.VolCatBytes == 0 ||
+         (!dev->is_tape() && strcmp(dcr->VolCatInfo.VolCatStatus,
+                                "Recycle") == 0))) {
+      Dmsg0(150, "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(150, "!write_vol_label\n");
+         mark_volume_in_error(dcr);
+         return try_next_vol;
+      }
+      Dmsg0(150, "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 try_error;
+      }
+      Jmsg(dcr->jcr, M_INFO, 0, _("Labeled new Volume \"%s\" on device %s.\n"),
+         dcr->VolumeName, dev->print_name());
+      return try_read_vol;   /* read label we just wrote */
+   }
+   if (!dev->has_cap(CAP_LABEL) && dcr->VolCatInfo.VolCatBytes == 0) {
+      Jmsg(dcr->jcr, M_INFO, 0, _("Warning device %s not configured to autolabel Volumes.\n"), 
+         dev->print_name());
+   }
+   /* If not removable, Volume is broken */
+   if (!dev->is_removable()) {
+      Jmsg(dcr->jcr, M_WARNING, 0, _("Volume \"%s\" not on device %s.\n"),
+         dcr->VolumeName, dev->print_name());
+      mark_volume_in_error(dcr);
+      return try_next_vol;
+   }
+   return try_default;
+}
 
 
 /*
@@ -470,13 +509,12 @@ void release_volume(DCR *dcr)
    dcr->VolumeName[0] = 0;
 
    if (dev->is_open() && (!dev->is_tape() || !dev_cap(dev, CAP_ALWAYSOPEN))) {
-      offline_or_rewind_dev(dev);
-      close_device(dev);
+      dev->close();
    }
 
    /* If we have not closed the device, then at least rewind the tape */
    if (dev->is_open()) {
-      offline_or_rewind_dev(dev);
+      dev->offline_or_rewind();
    }
    Dmsg0(190, "release_volume\n");
 }
@@ -494,8 +532,7 @@ bool mount_next_read_volume(DCR *dcr)
     * End Of Tape -- mount next Volume (if another specified)
     */
    if (jcr->NumVolumes > 1 && jcr->CurVolume < jcr->NumVolumes) {
-      close_device(dev);
-      dev->clear_read();
+      dev->close();
       if (!acquire_device_for_read(dcr)) {
          Jmsg2(jcr, M_FATAL, 0, _("Cannot open Dev=%s, Vol=%s\n"), dev->print_name(),
                dcr->VolumeName);