#include "bacula.h" /* pull in global headers */
#include "stored.h" /* pull in Storage Deamon headers */
+/* Forward referenced functions */
+static void detach_dcr_from_dev(DCR *dcr);
+
/*********************************************************************
* Acquire device for reading.
* Returns: NULL if failed for any reason
* dcr if successful
*/
-DCR *acquire_device_for_read(DCR *dcr)
+bool acquire_device_for_read(DCR *dcr)
{
DEVICE *dev = dcr->dev;
JCR *jcr = dcr->jcr;
- bool vol_ok = false;
+ bool ok = false;
bool tape_previously_mounted;
bool tape_initially_mounted;
VOL_LIST *vol;
bool try_autochanger = true;
int i;
int vol_label_status;
+ int retry = 0;
+ Dmsg1(50, "jcr->dcr=%p\n", jcr->dcr);
dev->block(BST_DOING_ACQUIRE);
if (dev->num_writers > 0) {
bstrncpy(dcr->VolumeName, vol->VolumeName, sizeof(dcr->VolumeName));
bstrncpy(dcr->media_type, vol->MediaType, sizeof(dcr->media_type));
dcr->VolCatInfo.Slot = vol->Slot;
- Dmsg4(100, "===== Vol=%s MT=%s Slt=%d Dev-MT=%s\n", dcr->VolumeName,
- dcr->media_type, vol->Slot, dev->device->media_type);
-
- if (strcmp(dcr->media_type, dev->device->media_type) != 0) {
- Dmsg2(000, "Wrong MT have=%s want=%s\n", dev->device->media_type,
- dcr->media_type);
- Dmsg1(000, "New storage=%s\n", vol->storage);
+
+ /*
+ * If the MediaType requested for this volume is not the
+ * same as the current drive, we attempt to find the same
+ * device that was used to write the orginal volume. If
+ * found, we switch to using that device.
+ */
+ Dmsg2(100, "MediaType dcr=%s dev=%s\n", dcr->media_type, dev->device->media_type);
+ if (dcr->media_type[0] && strcmp(dcr->media_type, dev->device->media_type) != 0) {
+ RCTX rctx;
+ DIRSTORE *store;
+ int stat;
+ DCR *dcr_save = jcr->dcr;
+
+ lock_reservations();
+ jcr->dcr = NULL;
+ memset(&rctx, 0, sizeof(RCTX));
+ rctx.jcr = jcr;
+ jcr->reserve_msgs = New(alist(10, not_owned_by_alist));
+ rctx.any_drive = true;
+ rctx.device_name = vol->device;
+ store = new DIRSTORE;
+ memset(store, 0, sizeof(DIRSTORE));
+ store->name[0] = 0; /* No dir name */
+ bstrncpy(store->media_type, vol->MediaType, sizeof(store->media_type));
+ bstrncpy(store->pool_name, dcr->pool_name, sizeof(store->pool_name));
+ bstrncpy(store->pool_type, dcr->pool_type, sizeof(store->pool_type));
+ store->append = false;
+ rctx.store = store;
+
+ /*
+ * Note, if search_for_device() succeeds, we get a new_dcr,
+ * which we do not use except for the dev info.
+ */
+ stat = search_res_for_device(rctx);
+ release_msgs(jcr); /* release queued messages */
+ unlock_reservations();
+ if (stat == 1) {
+ DCR *new_dcr = jcr->read_dcr;
+ dev->unblock();
+ detach_dcr_from_dev(dcr); /* release old device */
+ /* Copy important info from the new dcr */
+ dev = dcr->dev = new_dcr->dev;
+ jcr->read_dcr = dcr;
+ dcr->device = new_dcr->device;
+ dcr->max_job_spool_size = dcr->device->max_job_spool_size;
+ if (dev->fd != 0 && jcr && jcr->JobType != JT_SYSTEM) {
+ dev->attached_dcrs->append(dcr); /* attach dcr to device */
+ }
+ new_dcr->VolumeName[0] = 0;
+ free_dcr(new_dcr);
+ dev->block(BST_DOING_ACQUIRE);
+ Jmsg(jcr, M_INFO, 0, _("Media Type change. New device %s chosen.\n"),
+ dev->print_name());
+ bstrncpy(dcr->VolumeName, vol->VolumeName, sizeof(dcr->VolumeName));
+ bstrncpy(dcr->media_type, vol->MediaType, sizeof(dcr->media_type));
+ dcr->VolCatInfo.Slot = vol->Slot;
+ bstrncpy(dcr->pool_name, store->pool_name, sizeof(dcr->pool_name));
+ bstrncpy(dcr->pool_type, store->pool_type, sizeof(dcr->pool_type));
+ } else if (stat == 0) { /* device busy */
+ Dmsg1(000, "Device %s is busy.\n", vol->device);
+ } else {
+ /* error */
+ Jmsg1(jcr, M_FATAL, 0, _("No suitable device found to read Volume \"%s\"\n"),
+ vol->VolumeName);
+ jcr->dcr = dcr_save;
+ goto get_out;
+ }
+ jcr->dcr = dcr_save;
}
+
init_device_wait_timers(dcr);
tape_previously_mounted = dev->can_read() || dev->can_append() ||
Jmsg1(jcr, M_WARNING, 0, "%s", jcr->errmsg);
}
- for (i=0; i<5; i++) {
+ for ( ;; ) {
+ /* If not polling limit retries */
+ if (!dev->poll && retry++ > 10) {
+ break;
+ }
dev->clear_labeled(); /* force reread of label */
if (job_canceled(jcr)) {
Mmsg1(dev->errmsg, _("Job %d canceled.\n"), jcr->JobId);
if (dev->open(dcr, OPEN_READ_ONLY) < 0) {
if (dev->dev_errno == EIO) { /* no tape loaded */
Jmsg3(jcr, M_WARNING, 0, _("Read open device %s Volume \"%s\" failed (EIO): ERR=%s\n"),
- dev->print_name(), dcr->VolumeName, strerror_dev(dev));
+ dev->print_name(), dcr->VolumeName, dev->bstrerror());
goto default_path;
}
Jmsg3(jcr, M_FATAL, 0, _("Read open device %s Volume \"%s\" failed: ERR=%s\n"),
- dev->print_name(), dcr->VolumeName, strerror_dev(dev));
+ dev->print_name(), dcr->VolumeName, dev->bstrerror());
goto get_out;
}
Dmsg1(100, "opened dev %s OK\n", dev->print_name());
vol_label_status = read_dev_volume_label(dcr);
switch (vol_label_status) {
case VOL_OK:
- vol_ok = true;
+ ok = true;
memcpy(&dev->VolCatInfo, &dcr->VolCatInfo, sizeof(dev->VolCatInfo));
break; /* got it */
case VOL_IO_ERROR:
tape_initially_mounted = false;
goto default_path;
}
+ /* If polling and got a previous bad name, ignore it */
+ if (dev->poll && strcmp(dev->BadVolName, dev->VolHdr.VolumeName) == 0) {
+ goto default_path;
+ } else {
+ bstrncpy(dev->BadVolName, dev->VolHdr.VolumeName, sizeof(dev->BadVolName));
+ }
/* Fall through */
default:
Jmsg1(jcr, M_WARNING, 0, "%s", jcr->errmsg);
} /* end switch */
break;
} /* end for loop */
- if (!vol_ok) {
+ if (!ok) {
Jmsg1(jcr, M_FATAL, 0, _("Too many errors trying to mount device %s.\n"),
dev->print_name());
goto get_out;
}
V(dev->mutex);
dev->unblock();
- if (!vol_ok) {
- dcr = NULL;
- }
- return dcr;
+ Dmsg1(50, "jcr->dcr=%p\n", jcr->dcr);
+ return ok;
}
}
goto get_out;
}
+ Dmsg2(190, "Output pos=%u:%u\n", dcr->dev->file, dcr->dev->block_num);
}
dev->num_writers++; /* we are now a writer */
}
/* If no more writers, write an EOF */
if (!dev->num_writers && dev->can_write()) {
- weof_dev(dev, 1);
+ dev->weof(1);
write_ansi_ibm_labels(dcr, ANSI_EOF_LABEL, dev->VolHdr.VolumeName);
}
if (!dev->at_weot()) {
}
#endif
-/*
- * Free up all aspects of the given dcr -- i.e. dechain it,
- * release allocated memory, zap pointers, ...
- */
-void free_dcr(DCR *dcr)
+static void detach_dcr_from_dev(DCR *dcr)
{
- JCR *jcr = dcr->jcr;
DEVICE *dev = dcr->dev;
if (dcr->reserved_device) {
+ dcr->reserved_device = false;
lock_device(dev);
dev->reserved_device--;
Dmsg2(100, "Dec reserve=%d dev=%s\n", dev->reserved_device, dev->print_name());
}
/* Detach this dcr only if the dev is initialized */
- if (dev->fd != 0 && jcr && jcr->JobType != JT_SYSTEM) {
- dev->attached_dcrs->remove(dcr); /* detach dcr from device */
+ if (dcr->dev->fd != 0 && dcr->jcr && dcr->jcr->JobType != JT_SYSTEM) {
+ dcr->dev->attached_dcrs->remove(dcr); /* detach dcr from device */
// remove_dcr_from_dcrs(dcr); /* remove dcr from jcr list */
}
+ free_unused_volume(dcr); /* free unused vols attached to this dcr */
+ pthread_cond_broadcast(&dcr->dev->wait_next_vol);
+ pthread_cond_broadcast(&wait_device_release);
+}
+
+/*
+ * Free up all aspects of the given dcr -- i.e. dechain it,
+ * release allocated memory, zap pointers, ...
+ */
+void free_dcr(DCR *dcr)
+{
+
+ detach_dcr_from_dev(dcr);
+
if (dcr->block) {
free_block(dcr->block);
}
if (dcr->jcr) {
dcr->jcr->dcr = NULL;
}
- free_unused_volume(dcr); /* free unused vols attached to this dcr */
free(dcr);
- pthread_cond_broadcast(&dev->wait_next_vol);
- pthread_cond_broadcast(&wait_device_release);
}
projects / bacula / bacula / blobdiff