/*
Bacula® - The Network Backup Solution
- Copyright (C) 2000-2008 Free Software Foundation Europe e.V.
+ Copyright (C) 2000-2010 Free Software Foundation Europe e.V.
The main author of Bacula is Kern Sibbald, with contributions from
many others, a complete list can be found in the file AUTHORS.
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.
* daemon. More complicated coding (double buffering, writer
* thread, ...) is left for a later version.
*
- * Version $Id$
*/
/*
* Handling I/O errors and end of tape conditions are a bit tricky.
- * This is how it is currently done when writting.
+ * This is how it is currently done when writing.
* On either an I/O error or end of tape,
* we will stop writing on the physical device (no I/O recovery is
* attempted at least in this daemon). The state flag will be sent
device->dev_type = B_TAPE_DEV;
} else if (S_ISFIFO(statp.st_mode)) {
device->dev_type = B_FIFO_DEV;
-#ifdef USE_FAKETAPE
- /* must set DeviceType = Faketape
+#ifdef USE_VTAPE
+ /* must set DeviceType = Vtape
* in normal mode, autodetection is disabled
*/
} else if (S_ISREG(statp.st_mode)) {
- device->dev_type = B_FAKETAPE_DEV;
+ device->dev_type = B_VTAPE_DEV;
#endif
} else if (!(device->cap_bits & CAP_REQMOUNT)) {
Jmsg2(jcr, M_ERROR, 0, _("%s is an unknown device type. Must be tape or directory\n"
dev->max_block_size = device->max_block_size;
dev->max_volume_size = device->max_volume_size;
dev->max_file_size = device->max_file_size;
+ dev->max_concurrent_jobs = device->max_concurrent_jobs;
dev->volume_capacity = device->volume_capacity;
dev->max_rewind_wait = device->max_rewind_wait;
dev->max_open_wait = device->max_open_wait;
Jmsg2(jcr, M_ERROR_TERM, 0, _("Unable to stat mount point %s: ERR=%s\n"),
device->mount_point, be.bstrerror());
}
- }
- if (dev->is_dvd()) {
+
if (!device->mount_command || !device->unmount_command) {
Jmsg0(jcr, M_ERROR_TERM, 0, _("Mount and unmount commands must defined for a device which requires mount.\n"));
}
+ }
+ if (dev->is_dvd()) {
if (!device->write_part_command) {
Jmsg0(jcr, M_ERROR_TERM, 0, _("Write part command must be defined for a device which requires mount.\n"));
}
Jmsg2(jcr, M_WARNING, 0, _("Max block size %u not multiple of device %s block size.\n"),
dev->max_block_size, dev->print_name());
}
+ if (dev->max_volume_size != 0 && dev->max_volume_size < (dev->max_block_size << 4)) {
+ Jmsg(jcr, M_ERROR_TERM, 0, _("Max Vol Size < 8 * Max Block Size on device %s\n"),
+ dev->print_name());
+ }
dev->errmsg = get_pool_memory(PM_EMSG);
*dev->errmsg = 0;
Mmsg1(dev->errmsg, _("Unable to init mutex: ERR=%s\n"), be.bstrerror(errstat));
Jmsg0(jcr, M_ERROR_TERM, 0, dev->errmsg);
}
+ if ((errstat = pthread_mutex_init(&dev->acquire_mutex, NULL)) != 0) {
+ berrno be;
+ dev->dev_errno = errstat;
+ Mmsg1(dev->errmsg, _("Unable to init mutex: ERR=%s\n"), be.bstrerror(errstat));
+ Jmsg0(jcr, M_ERROR_TERM, 0, dev->errmsg);
+ }
+ /* Ensure that we respect this order in P/V operations */
+ bthread_mutex_set_priority(&dev->m_mutex, PRIO_SD_DEV_ACCESS);
+ bthread_mutex_set_priority(&dev->spool_mutex, PRIO_SD_DEV_SPOOL);
+ bthread_mutex_set_priority(&dev->acquire_mutex, PRIO_SD_DEV_ACQUIRE);
#ifdef xxx
if ((errstat = rwl_init(&dev->lock)) != 0) {
berrno be;
/* Choose the right backend */
void DEVICE::init_backend()
{
- if (is_faketape()) {
- d_open = faketape_open;
- d_write = faketape_write;
- d_close = faketape_close;
- d_ioctl = faketape_ioctl;
- d_read = faketape_read;
#ifdef HAVE_WIN32
- } else if (is_tape()) {
+ if (is_tape()) {
d_open = win32_tape_open;
d_write = win32_tape_write;
d_close = win32_tape_close;
d_ioctl = win32_tape_ioctl;
d_read = win32_tape_read;
-#endif
} else {
+ d_open = ::open;
+ d_close = ::close;
+ d_ioctl = win32_ioctl; /* dummy function */
+ d_write = win32_write; /* win32 read/write are not POSIX */
+ d_read = win32_read;
+ }
+
+#else /* POSIX / UNIX Interface */
+ if (is_vtape()) { /* test backend */
+ d_open = vtape_open; /* vtape isn't available for WIN32 or FreeBSD */
+ d_write = vtape_write;
+ d_close = vtape_close;
+ d_ioctl = vtape_ioctl;
+ d_read = vtape_read;
+
+ } else { /* tape and file are using normal io */
d_open = ::open;
d_write = ::write;
d_close = ::close;
d_ioctl = ::ioctl;
d_read = ::read;
}
+#endif
}
/*
}
}
if (dcr) {
- bstrncpy(VolCatInfo.VolCatName, dcr->VolumeName, sizeof(VolCatInfo.VolCatName));
+ dcr->setVolCatName(dcr->VolumeName);
+ VolCatInfo = dcr->VolCatInfo; /* structure assign */
}
Dmsg4(100, "open dev: type=%d dev_name=%s vol=%s mode=%s\n", dev_type,
- print_name(), VolCatInfo.VolCatName, mode_to_str(omode));
+ print_name(), getVolCatName(), mode_to_str(omode));
state &= ~(ST_LABEL|ST_APPEND|ST_READ|ST_EOT|ST_WEOT|ST_EOF);
label_type = B_BACULA_LABEL;
if (is_tape() || is_fifo()) {
utime_t start_time = time(NULL);
#endif
+ mount(1); /* do mount if required */
Dmsg0(100, "Open dev: device is tape\n");
if (!IsPathSeparator(archive_name.c_str()[strlen(archive_name.c_str())-1])) {
pm_strcat(archive_name, "/");
}
- pm_strcat(archive_name, VolCatInfo.VolCatName);
+ pm_strcat(archive_name, getVolCatName());
}
mount(1); /* do mount if required */
Mmsg2(errmsg, _("Could not open: %s, ERR=%s\n"), archive_name.c_str(),
be.bstrerror());
Dmsg1(100, "open failed: %s", errmsg);
- Jmsg1(NULL, M_WARNING, 0, "%s", errmsg);
+// Jmsg1(NULL, M_WARNING, 0, "%s", errmsg);
} else {
dev_errno = 0;
file = 0;
}
/*
- * Open a DVD device. N.B. at this point, dcr->VolCatInfo.VolCatName
- * (NB:??? I think it's VolCatInfo.VolCatName that is right)
+ * Open a DVD device. N.B. at this point, dcr->getVolCatName()
+ * (NB:??? I think it's getVolCatName() that is right)
* has the desired Volume name, but there is NO assurance that
* any other field of VolCatInfo is correct.
*/
* copy here, when opening.
*/
VolCatInfo = dcr->VolCatInfo; /* structure assignment */
- Dmsg1(100, "Volume=%s\n", VolCatInfo.VolCatName);
+ Dmsg1(100, "Volume=%s\n", getVolCatName());
if (VolCatInfo.VolCatName[0] == 0) {
Dmsg1(10, "Could not open DVD device %s. No Volume name given.\n",
return fsf(VolCatInfo.VolCatFiles);
#endif
- Dmsg0(100, "eod\n");
+ Dmsg0(100, "Enter eod\n");
if (at_eot()) {
return true;
}
}
if (!is_tape()) {
pos = lseek(dcr, (boffset_t)0, SEEK_END);
-// Dmsg1(100, "====== Seek to %lld\n", pos);
+ Dmsg1(200, "====== Seek to %lld\n", pos);
if (pos >= 0) {
update_pos(dcr);
set_eot();
berrno be;
Mmsg2(errmsg, _("lseek error on %s. ERR=%s.\n"),
print_name(), be.bstrerror());
+ Dmsg0(100, errmsg);
return false;
}
#ifdef MTEOM
/* If unknown position, rewind */
if (get_os_tape_file() < 0) {
if (!rewind(NULL)) {
+ Dmsg0(100, "Rewind error\n");
return false;
}
}
update_pos(dcr);
Mmsg2(errmsg, _("ioctl MTEOM error on %s. ERR=%s.\n"),
print_name(), be.bstrerror());
+ Dmsg0(100, errmsg);
return false;
}
clrerror(-1);
Mmsg2(errmsg, _("ioctl MTIOCGET error on %s. ERR=%s.\n"),
print_name(), be.bstrerror());
+ Dmsg0(100, errmsg);
return false;
}
Dmsg1(100, "EOD file=%d\n", os_file);
* Rewind then use FSF until EOT reached
*/
if (!rewind(NULL)) {
+ Dmsg0(100, "Rewind error.\n");
return false;
}
/*
for (file_num=file; !at_eot(); file_num++) {
Dmsg0(200, "eod: doing fsf 1\n");
if (!fsf(1)) {
- Dmsg0(200, "fsf error.\n");
+ Dmsg0(100, "fsf error.\n");
return false;
}
/*
{
struct mtop mt_com;
int stat;
- Dmsg0(129, "weof_dev\n");
+ Dmsg1(129, "=== weof_dev=%s\n", print_name());
if (!is_open()) {
dev_errno = EBADF;
}
+/*
+ * Set to unload the current volume in the drive
+ */
+void DEVICE::set_unload()
+{
+ if (!m_unload && VolHdr.VolumeName[0] != 0) {
+ m_unload = true;
+ memcpy(UnloadVolName, VolHdr.VolumeName, sizeof(UnloadVolName));
+ }
+}
+
+
/*
* Clear volume header
*/
{
Dmsg1(100, "Clear volhdr vol=%s\n", VolHdr.VolumeName);
memset(&VolHdr, 0, sizeof(VolHdr));
+ setVolCatInfo(false);
}
void DEVICE::close()
{
Dmsg1(100, "close_dev %s\n", print_name());
- if (has_cap(CAP_OFFLINEUNMOUNT)) {
- offline();
- }
+ offline_or_rewind();
if (!is_open()) {
Dmsg2(100, "device %s already closed vol=%s\n", print_name(),
switch (dev_type) {
case B_VTL_DEV:
- case B_FAKETAPE_DEV:
+ case B_VTAPE_DEV:
case B_TAPE_DEV:
unlock_door();
default:
d_close(m_fd);
+ break;
}
+ unmount(1); /* do unmount if required */
+
/* Clean up device packet so it can be reused */
clear_opened();
/*
#if defined(HAVE_WIN32)
return ::_lseeki64(m_fd, (__int64)offset, whence);
#else
- return ::lseek(m_fd, (off_t)offset, whence);
+ return ::lseek(m_fd, offset, whence);
#endif
}
return -1;
Dmsg1(100, "truncate %s\n", print_name());
switch (dev_type) {
case B_VTL_DEV:
- case B_FAKETAPE_DEV:
+ case B_VTAPE_DEV:
case B_TAPE_DEV:
/* maybe we should rewind and write and eof ???? */
return true; /* we don't really truncate tapes */
return false;
}
-/* Mount the device.
+/*
+ * Mount the device.
* If timeout, wait until the mount command returns 0.
* If !timeout, try to mount the device only once.
*/
bool DEVICE::mount(int timeout)
{
Dmsg0(190, "Enter mount\n");
+
if (is_mounted()) {
return true;
- } else if (requires_mount()) {
- return do_mount(1, timeout);
- }
+ }
+
+ switch (dev_type) {
+ case B_VTL_DEV:
+ case B_VTAPE_DEV:
+ case B_TAPE_DEV:
+ if (device->mount_command) {
+ return do_tape_mount(1, timeout);
+ }
+ break;
+ case B_FILE_DEV:
+ case B_DVD_DEV:
+ if (requires_mount() && device->mount_command) {
+ return do_file_mount(1, timeout);
+ }
+ break;
+ default:
+ break;
+ }
+
return true;
}
-/* Unmount the device
+/*
+ * Unmount the device
* If timeout, wait until the unmount command returns 0.
* If !timeout, try to unmount the device only once.
*/
bool DEVICE::unmount(int timeout)
{
Dmsg0(100, "Enter unmount\n");
- if (is_mounted()) {
- return do_mount(0, timeout);
+
+ if (!is_mounted()) {
+ return true;
}
+
+ switch (dev_type) {
+ case B_VTL_DEV:
+ case B_VTAPE_DEV:
+ case B_TAPE_DEV:
+ if (device->unmount_command) {
+ return do_tape_mount(0, timeout);
+ }
+ break;
+ case B_FILE_DEV:
+ case B_DVD_DEV:
+ if (requires_mount() && device->unmount_command) {
+ return do_file_mount(0, timeout);
+ }
+ break;
+ default:
+ break;
+ }
+
return true;
}
-/* (Un)mount the device */
-bool DEVICE::do_mount(int mount, int dotimeout)
+/*
+ * (Un)mount the device (for tape devices)
+ */
+bool DEVICE::do_tape_mount(int mount, int dotimeout)
{
POOL_MEM ocmd(PM_FNAME);
POOLMEM *results;
char *icmd;
- int status, timeout;
-
+ int status, tries;
+ berrno be;
+
Dsm_check(1);
if (mount) {
- if (is_mounted()) {
- Dmsg0(200, "======= mount=1\n");
- return true;
- }
icmd = device->mount_command;
} else {
- if (!is_mounted()) {
- Dmsg0(200, "======= mount=0\n");
- return true;
+ icmd = device->unmount_command;
+ }
+
+ edit_mount_codes(ocmd, icmd);
+
+ Dmsg2(100, "do_tape_mount: cmd=%s mounted=%d\n", ocmd.c_str(), !!is_mounted());
+
+ if (dotimeout) {
+ /* Try at most 10 times to (un)mount the device. This should perhaps be configurable. */
+ tries = 10;
+ } else {
+ tries = 1;
+ }
+ results = get_memory(4000);
+
+ /* If busy retry each second */
+ Dmsg1(100, "do_tape_mount run_prog=%s\n", ocmd.c_str());
+ while ((status = run_program_full_output(ocmd.c_str(), max_open_wait/2, results)) != 0) {
+ if (tries-- > 0) {
+ continue;
}
+
+ Dmsg5(100, "Device %s cannot be %smounted. stat=%d result=%s ERR=%s\n", print_name(),
+ (mount ? "" : "un"), status, results, be.bstrerror(status));
+ Mmsg(errmsg, _("Device %s cannot be %smounted. ERR=%s\n"),
+ print_name(), (mount ? "" : "un"), be.bstrerror(status));
+
+ set_mounted(false);
+ free_pool_memory(results);
+ Dmsg0(200, "============ mount=0\n");
+ Dsm_check(1);
+ return false;
+ }
+
+ set_mounted(mount); /* set/clear mounted flag */
+ free_pool_memory(results);
+ Dmsg1(200, "============ mount=%d\n", mount);
+ return true;
+}
+
+/*
+ * (Un)mount the device (either a FILE or DVD device)
+ */
+bool DEVICE::do_file_mount(int mount, int dotimeout)
+{
+ POOL_MEM ocmd(PM_FNAME);
+ POOLMEM *results;
+ DIR* dp;
+ char *icmd;
+ struct dirent *entry, *result;
+ int status, tries, name_max, count;
+ berrno be;
+
+ Dsm_check(1);
+ if (mount) {
+ icmd = device->mount_command;
+ } else {
icmd = device->unmount_command;
}
clear_freespace_ok();
edit_mount_codes(ocmd, icmd);
- Dmsg2(100, "do_mount: cmd=%s mounted=%d\n", ocmd.c_str(), !!is_mounted());
+ Dmsg2(100, "do_file_mount: cmd=%s mounted=%d\n", ocmd.c_str(), !!is_mounted());
if (dotimeout) {
- /* Try at most 1 time to (un)mount the device. This should perhaps be configurable. */
- timeout = 1;
+ /* Try at most 10 times to (un)mount the device. This should perhaps be configurable. */
+ tries = 10;
} else {
- timeout = 0;
+ tries = 1;
}
results = get_memory(4000);
/* If busy retry each second */
- Dmsg1(100, "do_mount run_prog=%s\n", ocmd.c_str());
- while ((status = run_program_full_output(ocmd.c_str(),
- max_open_wait/2, results)) != 0) {
+ Dmsg1(100, "do_file_mount run_prog=%s\n", ocmd.c_str());
+ while ((status = run_program_full_output(ocmd.c_str(), max_open_wait/2, results)) != 0) {
/* Doesn't work with internationalization (This is not a problem) */
if (mount && fnmatch("*is already mounted on*", results, 0) == 0) {
break;
if (!mount && fnmatch("* not mounted*", results, 0) == 0) {
break;
}
- if (timeout-- > 0) {
+ if (tries-- > 0) {
/* Sometimes the device cannot be mounted because it is already mounted.
* Try to unmount it, then remount it */
if (mount) {
Dmsg1(400, "Trying to unmount the device %s...\n", print_name());
- do_mount(0, 0);
+ do_file_mount(0, 0);
}
bmicrosleep(1, 0);
continue;
}
- if (status != 0) {
- berrno be;
- Dmsg5(100, "Device %s cannot be %smounted. stat=%d result=%s ERR=%s\n", print_name(),
- (mount ? "" : "un"), status, results, be.bstrerror(status));
- Mmsg(errmsg, _("Device %s cannot be %smounted. ERR=%s\n"),
- print_name(), (mount ? "" : "un"), be.bstrerror(status));
- } else {
- Dmsg4(100, "Device %s cannot be %smounted. stat=%d ERR=%s\n", print_name(),
- (mount ? "" : "un"), status, results);
- Mmsg(errmsg, _("Device %s cannot be %smounted. ERR=%s\n"),
- print_name(), (mount ? "" : "un"), results);
- }
+ Dmsg5(100, "Device %s cannot be %smounted. stat=%d result=%s ERR=%s\n", print_name(),
+ (mount ? "" : "un"), status, results, be.bstrerror(status));
+ Mmsg(errmsg, _("Device %s cannot be %smounted. ERR=%s\n"),
+ print_name(), (mount ? "" : "un"), be.bstrerror(status));
+
/*
- * Now, just to be sure it is not mounted, try to read the
- * filesystem.
+ * Now, just to be sure it is not mounted, try to read the filesystem.
*/
- DIR* dp;
- struct dirent *entry, *result;
- int name_max;
- int count;
-
name_max = pathconf(".", _PC_NAME_MAX);
if (name_max < 1024) {
name_max = 1024;
if (!(dp = opendir(device->mount_point))) {
berrno be;
dev_errno = errno;
- Dmsg3(100, "do_mount: failed to open dir %s (dev=%s), ERR=%s\n",
+ Dmsg3(100, "do_file_mount: failed to open dir %s (dev=%s), ERR=%s\n",
device->mount_point, print_name(), be.bstrerror());
goto get_out;
}
while (1) {
if ((readdir_r(dp, entry, &result) != 0) || (result == NULL)) {
dev_errno = EIO;
- Dmsg2(129, "do_mount: failed to find suitable file in dir %s (dev=%s)\n",
+ Dmsg2(129, "do_file_mount: failed to find suitable file in dir %s (dev=%s)\n",
device->mount_point, print_name());
break;
}
count++; /* result->d_name != ., .. or .keep (Gentoo-specific) */
break;
} else {
- Dmsg2(129, "do_mount: ignoring %s in %s\n", result->d_name, device->mount_point);
+ Dmsg2(129, "do_file_mount: ignoring %s in %s\n", result->d_name, device->mount_point);
}
}
free(entry);
closedir(dp);
- Dmsg1(100, "do_mount: got %d files in the mount point (not counting ., .. and .keep)\n", count);
+ Dmsg1(100, "do_file_mount: got %d files in the mount point (not counting ., .. and .keep)\n", count);
if (count > 0) {
/* If we got more than ., .. and .keep */
char *
dev_vol_name(DEVICE *dev)
{
- return dev->VolCatInfo.VolCatName;
+ return dev->getVolCatName();
}
dev->rem_wait_sec = dev->wait_sec;
dev->num_wait = 0;
dev->poll = false;
- dev->BadVolName[0] = 0;
jcr->min_wait = 60 * 60;
jcr->max_wait = 24 * 60 * 60;