]> git.sur5r.net Git - bacula/bacula/blobdiff - bacula/src/stored/mount.c
Back out changes apparently crashing system
[bacula/bacula] / bacula / src / stored / mount.c
index bcfb36da6ffcdad38551202bfb366824c5899600..ddc2b5d58f4a4dd42a7f5a5c6bf0b752b6ec541b 100644 (file)
@@ -8,11 +8,11 @@
  *   Version $Id$
  */
 /*
  *   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
 
    This program is free software; you can redistribute it and/or
    modify it under the terms of the GNU General Public License
-   version 2 as ammended with additional clauses defined in the
+   version 2 as amended with additional clauses defined in the
    file LICENSE in the main source directory.
 
    This program is distributed in the hope that it will be useful,
    file LICENSE in the main source directory.
 
    This program is distributed in the hope that it will be useful,
 #include "stored.h"                   /* pull in Storage Deamon headers */
 
 static void mark_volume_not_inchanger(DCR *dcr);
 #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,
 
 /*
  * If release is set, we rewind the current volume,
@@ -47,8 +55,10 @@ bool mount_next_write_volume(DCR *dcr, bool release)
    DEVICE *dev = dcr->dev;
    JCR *jcr = dcr->jcr;
    DEV_BLOCK *block = dcr->block;
    DEVICE *dev = dcr->dev;
    JCR *jcr = dcr->jcr;
    DEV_BLOCK *block = dcr->block;
+   int mode;
 
 
-   Dmsg0(100, "Enter mount_next_volume()\n");
+   Dmsg2(150, "Enter mount_next_volume(release=%d) dev=%s\n", release,
+      dev->print_name());
 
    init_device_wait_timers(dcr);
 
 
    init_device_wait_timers(dcr);
 
@@ -58,6 +68,7 @@ bool mount_next_write_volume(DCR *dcr, bool release)
     *  Volume, ...)
     */
 mount_next_vol:
     *  Volume, ...)
     */
 mount_next_vol:
+   Dmsg1(150, "mount_next_vol retry=%d\n", retry);
    /* Ignore retry if this is poll request */
    if (!dev->poll && retry++ > 4) {
       /* Last ditch effort before giving up, force operator to respond */
    /* Ignore retry if this is poll request */
    if (!dev->poll && retry++ > 4) {
       /* Last ditch effort before giving up, force operator to respond */
@@ -74,7 +85,7 @@ mount_next_vol:
    }
    recycle = false;
    if (release) {
    }
    recycle = false;
    if (release) {
-      Dmsg0(100, "mount_next_volume release=1\n");
+      Dmsg0(150, "mount_next_volume release=1\n");
       release_volume(dcr);
       ask = true;                     /* ask operator to mount tape */
    }
       release_volume(dcr);
       ask = true;                     /* ask operator to mount tape */
    }
@@ -94,11 +105,9 @@ mount_next_vol:
    if (job_canceled(jcr)) {
       return false;
    }
    if (job_canceled(jcr)) {
       return false;
    }
-   Dmsg3(100, "After find_next_append. Vol=%s Slot=%d Parts=%d\n",
+   Dmsg3(150, "After find_next_append. Vol=%s Slot=%d Parts=%d\n",
          dcr->VolCatInfo.VolCatName, dcr->VolCatInfo.Slot, dcr->VolCatInfo.VolCatParts);
    
          dcr->VolCatInfo.VolCatName, dcr->VolCatInfo.Slot, dcr->VolCatInfo.VolCatParts);
    
-   dev->num_parts = dcr->VolCatInfo.VolCatParts;
-
    /*
     * Get next volume and ready it for append
     * This code ensures that the device is ready for
    /*
     * Get next volume and ready it for append
     * This code ensures that the device is ready for
@@ -117,56 +126,62 @@ mount_next_vol:
       autochanger = false;
       dcr->VolCatInfo.Slot = 0;
    }
       autochanger = false;
       dcr->VolCatInfo.Slot = 0;
    }
-   Dmsg1(100, "autoload_dev returns %d\n", autochanger);
+   Dmsg1(200, "autoload_dev returns %d\n", autochanger);
    /*
     * If we autochanged to correct Volume or (we have not just
     *   released the Volume AND we can automount) we go ahead
     *   and read the label. If there is no tape in the drive,
     *   we will err, recurse and ask the operator the next time.
     */
    /*
     * If we autochanged to correct Volume or (we have not just
     *   released the Volume AND we can automount) we go ahead
     *   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 */
       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;
    }
       ask = false;
    }
-   Dmsg2(100, "Ask=%d autochanger=%d\n", ask, autochanger);
+   Dmsg2(150, "Ask=%d autochanger=%d\n", ask, autochanger);
    release = true;                /* release next time if we "recurse" */
 
    if (ask && !dir_ask_sysop_to_mount_volume(dcr)) {
    release = true;                /* release next time if we "recurse" */
 
    if (ask && !dir_ask_sysop_to_mount_volume(dcr)) {
-      Dmsg0(100, "Error return ask_sysop ...\n");
+      Dmsg0(150, "Error return ask_sysop ...\n");
       return false;          /* error return */
    }
    if (job_canceled(jcr)) {
       return false;
    }
       return false;          /* error return */
    }
    if (job_canceled(jcr)) {
       return false;
    }
-   Dmsg1(100, "want vol=%s\n", dcr->VolumeName);
+   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 */
    }
 
    /* Ensure the device is open */
-   /* 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;
+   if (dev_cap(dev, CAP_STREAM)) {
+      mode = OPEN_WRITE_ONLY;
+   } else {
+      mode = OPEN_READ_WRITE;
+   }
+   while (dev->open(dcr, mode) < 0) {
+      Dmsg1(150, "open_device failed: ERR=%s\n", dev->bstrerror());
+      if (dev->is_file() && dev->is_removable()) {
+         Dmsg0(150, "call scan_dir_for_vol\n");
+         if (dev->scan_dir_for_volume(dcr)) {
+            break;                    /* got a valid volume */
          }
       }
          }
       }
-   } 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));
+      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() || dev->is_removable()) {
+         goto mount_next_vol;
+      } else {
+         return false;
+      }
    }
 
    /*
    }
 
    /*
@@ -177,12 +192,10 @@ read_volume:
     * If we are writing to a stream device, ASSUME the volume label
     *  is correct.
     */
     * 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;
       vol_label_status = VOL_OK;
-      create_volume_label(dev, dcr->VolumeName, "Default");
+      create_volume_label(dev, dcr->VolumeName, "Default", false /* not DVD */);
       dev->VolHdr.LabelType = PRE_LABEL;
       dev->VolHdr.LabelType = PRE_LABEL;
-   } else if (dev->is_dvd()) {
-      vol_label_status = read_dvd_volume_label(dcr, /*write*/true);
    } else {
       vol_label_status = read_dev_volume_label(dcr);
    }
    } else {
       vol_label_status = read_dev_volume_label(dcr);
    }
@@ -190,7 +203,7 @@ read_volume:
       return false;
    }
 
       return false;
    }
 
-   Dmsg2(100, "Want dirVol=%s dirStat=%s\n", dcr->VolumeName,
+   Dmsg2(150, "Want dirVol=%s dirStat=%s\n", dcr->VolumeName,
       dcr->VolCatInfo.VolCatStatus);
    /*
     * At this point, dev->VolCatInfo has what is in the drive, if anything,
       dcr->VolCatInfo.VolCatStatus);
    /*
     * At this point, dev->VolCatInfo has what is in the drive, if anything,
@@ -198,27 +211,26 @@ read_volume:
     */
    switch (vol_label_status) {
    case VOL_OK:
     */
    switch (vol_label_status) {
    case VOL_OK:
-      Dmsg1(100, "Vol OK name=%s\n", dcr->VolumeName);
+      Dmsg1(150, "Vol OK name=%s\n", dcr->VolumeName);
       memcpy(&dev->VolCatInfo, &dcr->VolCatInfo, sizeof(dev->VolCatInfo));
       recycle = strcmp(dev->VolCatInfo.VolCatStatus, "Recycle") == 0;
       break;                    /* got a Volume */
    case VOL_NAME_ERROR:
       memcpy(&dev->VolCatInfo, &dcr->VolCatInfo, sizeof(dev->VolCatInfo));
       recycle = strcmp(dev->VolCatInfo.VolCatStatus, "Recycle") == 0;
       break;                    /* got a Volume */
    case VOL_NAME_ERROR:
-      VOLUME_CAT_INFO VolCatInfo, devVolCatInfo;
+      VOLUME_CAT_INFO dcrVolCatInfo, devVolCatInfo;
 
       /* If not removable, Volume is broken */
 
       /* 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);
          goto mount_next_vol;
       }
 
          Jmsg(jcr, M_WARNING, 0, _("Volume \"%s\" not on device %s.\n"),
             dcr->VolumeName, dev->print_name());
          mark_volume_in_error(dcr);
          goto mount_next_vol;
       }
 
-      Dmsg1(100, "Vol NAME Error Name=%s\n", dcr->VolumeName);
+      Dmsg1(150, "Vol NAME Error Name=%s\n", dcr->VolumeName);
       /* If polling and got a previous bad name, ignore it */
       if (dev->poll && strcmp(dev->BadVolName, dev->VolHdr.VolumeName) == 0) {
          ask = true;
       /* 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;
       }
       /*
          goto mount_next_vol;
       }
       /*
@@ -227,7 +239,7 @@ read_volume:
        *  this volume is really OK. If not, put back the desired
        *  volume name, mark it not in changer and continue.
        */
        *  this volume is really OK. If not, put back the desired
        *  volume name, mark it not in changer and continue.
        */
-      memcpy(&VolCatInfo, &dcr->VolCatInfo, sizeof(VolCatInfo));
+      memcpy(&dcrVolCatInfo, &dcr->VolCatInfo, sizeof(dcrVolCatInfo));
       memcpy(&devVolCatInfo, &dev->VolCatInfo, sizeof(devVolCatInfo));
       /* Check if this is a valid Volume in the pool */
       bstrncpy(dcr->VolumeName, dev->VolHdr.VolumeName, sizeof(dcr->VolumeName));
       memcpy(&devVolCatInfo, &dev->VolCatInfo, sizeof(devVolCatInfo));
       /* Check if this is a valid Volume in the pool */
       bstrncpy(dcr->VolumeName, dev->VolHdr.VolumeName, sizeof(dcr->VolumeName));
@@ -235,7 +247,12 @@ read_volume:
          /* Restore desired volume name, note device info out of sync */
          /* This gets the info regardless of the Pool */
          bstrncpy(dcr->VolumeName, dev->VolHdr.VolumeName, sizeof(dcr->VolumeName));
          /* Restore desired volume name, note device info out of sync */
          /* This gets the info regardless of the Pool */
          bstrncpy(dcr->VolumeName, dev->VolHdr.VolumeName, sizeof(dcr->VolumeName));
-         if (autochanger && dir_get_volume_info(dcr, GET_VOL_INFO_FOR_READ)) {
+         if (autochanger && !dir_get_volume_info(dcr, GET_VOL_INFO_FOR_READ)) {
+            /*
+             * If we get here, we know we cannot write on the Volume,
+             *  and we know that we cannot read it either, so it 
+             *  is not in the autochanger.
+             */
             mark_volume_not_inchanger(dcr);
          }
          memcpy(&dev->VolCatInfo, &devVolCatInfo, sizeof(dev->VolCatInfo));
             mark_volume_not_inchanger(dcr);
          }
          memcpy(&dev->VolCatInfo, &devVolCatInfo, sizeof(dev->VolCatInfo));
@@ -243,75 +260,56 @@ read_volume:
          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.VolumeName,
+             dcrVolCatInfo.VolCatName, dev->VolHdr.VolumeName,
              jcr->dir_bsock->msg);
          ask = true;
              jcr->dir_bsock->msg);
          ask = true;
+         /* Restore saved DCR before continuing */
+         memcpy(&dcr->VolCatInfo, &dcrVolCatInfo, sizeof(dcr->VolCatInfo));
          goto mount_next_vol;
       }
          goto mount_next_vol;
       }
-      /* This was not the volume we expected, but it is OK with
+      /*
+       * This was not the volume we expected, but it is OK with
        * the Director, so use it.
        */
        * the Director, so use it.
        */
-      Dmsg1(100, "want new name=%s\n", dcr->VolumeName);
+      Dmsg1(150, "want new name=%s\n", dcr->VolumeName);
       memcpy(&dev->VolCatInfo, &dcr->VolCatInfo, sizeof(dev->VolCatInfo));
       recycle = strcmp(dev->VolCatInfo.VolCatStatus, "Recycle") == 0;
       break;                /* got a Volume */
    /*
     * At this point, we assume we have a blank tape mounted.
     */
       memcpy(&dev->VolCatInfo, &dcr->VolCatInfo, sizeof(dev->VolCatInfo));
       recycle = strcmp(dev->VolCatInfo.VolCatStatus, "Recycle") == 0;
       break;                /* got a Volume */
    /*
     * At this point, we assume we have a blank tape mounted.
     */
-   case VOL_NO_LABEL:
    case VOL_IO_ERROR:
    case VOL_IO_ERROR:
-      /*
-       * 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(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");
-            mark_volume_in_error(dcr);
-            goto mount_next_vol;
-         }
-         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"),
-            dcr->VolumeName, dev->print_name());
-         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"),
-            dcr->VolumeName, dev->print_name());
+      if (dev->is_dvd()) {
+         Jmsg(jcr, M_FATAL, 0, "%s", jcr->errmsg);
          mark_volume_in_error(dcr);
          mark_volume_in_error(dcr);
+         return false;       /* we could not write on DVD */
+      }
+      /* Fall through wanted */
+   case VOL_NO_LABEL:
+      switch (try_autolabel(dcr)) {
+      case try_next_vol:
          goto mount_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:
       /* NOTE! Fall-through wanted. */
    case VOL_NO_MEDIA:
    default:
+      Dmsg0(200, "VOL_NO_MEDIA or default.\n");
       /* Send error message */
       if (!dev->poll) {
       /* Send error message */
       if (!dev->poll) {
-         Jmsg(jcr, M_WARNING, 0, "%s", jcr->errmsg);
       } else {
          Dmsg1(200, "Msg suppressed by poll: %s\n", jcr->errmsg);
       }
       ask = true;
       /* Needed, so the medium can be changed */
       if (dev->requires_mount()) {
       } else {
          Dmsg1(200, "Msg suppressed by poll: %s\n", jcr->errmsg);
       }
       ask = true;
       /* Needed, so the medium can be changed */
       if (dev->requires_mount()) {
-         close_device(dev);  
+         dev->close();
       }
       goto mount_next_vol;
    }
       }
       goto mount_next_vol;
    }
@@ -343,42 +341,138 @@ 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);
       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(dcr)) {
          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->print_name(), strerror_dev(dev));
+            dev->print_name(), dev->bstrerror());
          mark_volume_in_error(dcr);
          goto mount_next_vol;
       }
          mark_volume_in_error(dcr);
          goto mount_next_vol;
       }
+      if (dev->is_dvd()) {
+         char ed1[50], ed2[50];
+         if (dev->VolCatInfo.VolCatBytes == dev->part_start + dev->part_size) {
+            Jmsg(jcr, M_INFO, 0, _("Ready to append to end of Volume \"%s\""
+                 " part=%d size=%s\n"), dcr->VolumeName, 
+                 dev->part, edit_uint64(dev->VolCatInfo.VolCatBytes,ed1));
+         } else {
+            Jmsg(jcr, M_ERROR, 0, _("I cannot write on Volume \"%s\" because: "
+                 "The sizes do not match! Volume=%s Catalog=%s\n"),
+                 dcr->VolumeName,
+                 edit_uint64(dev->part_start + dev->part_size, ed1),
+                 edit_uint64(dev->VolCatInfo.VolCatBytes, ed2));
+            mark_volume_in_error(dcr);
+            goto mount_next_vol;
+         }
+      }
       /* *****FIXME**** we should do some checking for files too */
       if (dev->is_tape()) {
          /*
           * Check if we are positioned on the tape at the same place
           * that the database says we should be.
           */
       /* *****FIXME**** we should do some checking for files too */
       if (dev->is_tape()) {
          /*
           * Check if we are positioned on the tape at the same place
           * that the database says we should be.
           */
-         if (dev->VolCatInfo.VolCatFiles == dev_file(dev)) {
+         if (dev->VolCatInfo.VolCatFiles == dev->get_file()) {
             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));
+                 dcr->VolumeName, dev->get_file());
          } else {
             Jmsg(jcr, M_ERROR, 0, _("I cannot write on Volume \"%s\" because:\n"
          } else {
             Jmsg(jcr, M_ERROR, 0, _("I cannot write on Volume \"%s\" because:\n"
-"The number of files mismatch! Volume=%u Catalog=%u\n"),
-                 dcr->VolumeName, dev_file(dev), dev->VolCatInfo.VolCatFiles);
+                 "The number of files mismatch! Volume=%u Catalog=%u\n"),
+                 dcr->VolumeName, dev->get_file(), dev->VolCatInfo.VolCatFiles);
             mark_volume_in_error(dcr);
             goto mount_next_vol;
          }
       }
       dev->VolCatInfo.VolCatMounts++;      /* Update mounts */
             mark_volume_in_error(dcr);
             goto mount_next_vol;
          }
       }
       dev->VolCatInfo.VolCatMounts++;      /* Update mounts */
-      Dmsg1(100, "update volinfo mounts=%d\n", dev->VolCatInfo.VolCatMounts);
+      Dmsg1(150, "update volinfo mounts=%d\n", dev->VolCatInfo.VolCatMounts);
       if (!dir_update_volume_info(dcr, false)) {
          return false;
       }
       if (!dir_update_volume_info(dcr, false)) {
          return false;
       }
+      
+      /*
+       * DVD : check if the last part was removed or truncated, or if a written
+       * part was overwritten.   
+       * We need to do it after dir_update_volume_info, so we have the EndBlock
+       * info. (nb: I don't understand why VolCatFiles is set (used to check
+       * tape file number), but not EndBlock)
+       * Maybe could it be changed "dev->is_file()" (would remove the fixme above)   
+       *
+       * Disabled: I had problems with this code... 
+       * (maybe is it related to the seek bug ?)   
+       */
+#ifdef xxx
+      if (dev->is_dvd()) {
+         Dmsg2(150, "DVD/File sanity check addr=%u vs endblock=%u\n", (unsigned int)dev->file_addr, (unsigned int)dev->VolCatInfo.EndBlock);
+         if (dev->file_addr == dev->VolCatInfo.EndBlock+1) {
+            Jmsg(jcr, M_INFO, 0, _("Ready to append to end of Volume \"%s\" at file address=%u.\n"),
+                 dcr->VolumeName, (unsigned int)dev->file_addr);
+         }
+         else {
+            Jmsg(jcr, M_ERROR, 0, _("I cannot write on Volume \"%s\" because:\n"
+                                    "The EOD file address is wrong: Volume file address=%u != Catalog Endblock=%u(+1)\n"
+                                    "You probably removed DVD last part in spool directory.\n"),
+                 dcr->VolumeName, (unsigned int)dev->file_addr, (unsigned int)dev->VolCatInfo.EndBlock);
+            mark_volume_in_error(dcr);
+            goto mount_next_vol;
+         }
+      }
+#endif
+      
       /* Return an empty block */
       empty_block(block);             /* we used it for reading so set for write */
    }
    dev->set_append();
       /* Return an empty block */
       empty_block(block);             /* we used it for reading so set for write */
    }
    dev->set_append();
-   Dmsg0(100, "set APPEND, normal return from read_dev_for_append\n");
+   Dmsg1(150, "set APPEND, normal return from mount_next_write_volume. dev=%s\n",
+      dev->print_name());
+
    return true;
 }
 
    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, false, /* no relabel */ false /* defer DVD label */)) {
+         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;
+}
 
 
 /*
 
 
 /*
@@ -391,7 +485,7 @@ void mark_volume_in_error(DCR *dcr)
         dcr->VolumeName);
    memcpy(&dev->VolCatInfo, &dcr->VolCatInfo, sizeof(dev->VolCatInfo));
    bstrncpy(dev->VolCatInfo.VolCatStatus, "Error", sizeof(dev->VolCatInfo.VolCatStatus));
         dcr->VolumeName);
    memcpy(&dev->VolCatInfo, &dcr->VolCatInfo, sizeof(dev->VolCatInfo));
    bstrncpy(dev->VolCatInfo.VolCatStatus, "Error", sizeof(dev->VolCatInfo.VolCatStatus));
-   Dmsg0(100, "dir_update_vol_info. Set Error.\n");
+   Dmsg0(150, "dir_update_vol_info. Set Error.\n");
    dir_update_volume_info(dcr, false);
 }
 
    dir_update_volume_info(dcr, false);
 }
 
@@ -422,7 +516,7 @@ void release_volume(DCR *dcr)
    JCR *jcr = dcr->jcr;
    DEVICE *dev = dcr->dev;
    if (dcr->WroteVol) {
    JCR *jcr = dcr->jcr;
    DEVICE *dev = dcr->dev;
    if (dcr->WroteVol) {
-      Jmsg0(jcr, M_ERROR, 0, "Hey!!!!! WroteVol non-zero !!!!!\n");
+      Jmsg0(jcr, M_ERROR, 0, _("Hey!!!!! WroteVol non-zero !!!!!\n"));
       Dmsg0(190, "Hey!!!!! WroteVol non-zero !!!!!\n");
    }
    /*
       Dmsg0(190, "Hey!!!!! WroteVol non-zero !!!!!\n");
    }
    /*
@@ -442,15 +536,14 @@ void release_volume(DCR *dcr)
    dcr->VolumeName[0] = 0;
 
    if (dev->is_open() && (!dev->is_tape() || !dev_cap(dev, CAP_ALWAYSOPEN))) {
    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()) {
    }
 
    /* 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 ---");
+   Dmsg0(190, "release_volume\n");
 }
 
 /*
 }
 
 /*
@@ -466,10 +559,9 @@ bool mount_next_read_volume(DCR *dcr)
     * End Of Tape -- mount next Volume (if another specified)
     */
    if (jcr->NumVolumes > 1 && jcr->CurVolume < jcr->NumVolumes) {
     * 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)) {
       if (!acquire_device_for_read(dcr)) {
-         Jmsg2(jcr, M_FATAL, 0, "Cannot open Dev=%s, Vol=%s\n", dev->print_name(),
+         Jmsg2(jcr, M_FATAL, 0, _("Cannot open Dev=%s, Vol=%s\n"), dev->print_name(),
                dcr->VolumeName);
          return false;
       }
                dcr->VolumeName);
          return false;
       }