X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=bacula%2Fsrc%2Fstored%2Fautochanger.c;h=ea79fcc778b07a236c2a51fcfb89eb8232c3299f;hb=ecf33f65329d2ac71403eb26962800c9c2f4664e;hp=35127d4a3ac8160b81fd0a833524c2aa126030fd;hpb=8597190cb7d59d08ea317e28145b74f1d21b8fd5;p=bacula%2Fbacula diff --git a/bacula/src/stored/autochanger.c b/bacula/src/stored/autochanger.c index 35127d4a3a..ea79fcc778 100644 --- a/bacula/src/stored/autochanger.c +++ b/bacula/src/stored/autochanger.c @@ -1,3 +1,30 @@ +/* + Bacula® - The Network Backup Solution + + Copyright (C) 2002-2007 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. + This program is Free Software; you can redistribute it and/or + modify it under the terms of version two of the GNU General Public + License as published by the Free Software Foundation plus additions + that are listed in the file LICENSE. + + This program is distributed in the hope that it will be useful, but + WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + 02110-1301, USA. + + Bacula® is a registered trademark of John Walker. + The licensor of Bacula is the Free Software Foundation Europe + (FSFE), Fiduciary Program, Sumatrastrasse 25, 8006 Zürich, + Switzerland, email:ftf@fsfeurope.org. +*/ /* * * Routines for handling the autochanger. @@ -6,20 +33,6 @@ * * Version $Id$ */ -/* - Copyright (C) 2002-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 - 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, - but WITHOUT ANY WARRANTY; without even the implied warranty of - MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - the file LICENSE for additional details. - - */ #include "bacula.h" /* pull in global headers */ #include "stored.h" /* pull in Storage Deamon headers */ @@ -104,12 +117,22 @@ int autoload_device(DCR *dcr, int writing, BSOCK *dir) int rtn_stat = -1; /* error status */ POOLMEM *changer; + if (!dev->is_autochanger()) { + Dmsg1(200, "Device %s is not an autochanger\n", dev->print_name()); + return 0; + } + + /* An empty ChangerCommand => virtual disk autochanger */ + if (dcr->device->changer_command && dcr->device->changer_command[0] == 0) { + return 1; /* nothing to load */ + } + slot = dcr->VolCatInfo.InChanger ? dcr->VolCatInfo.Slot : 0; /* * Handle autoloaders here. If we cannot autoload it, we * will return 0 so that the sysop will be asked to load it. */ - if (writing && dev->is_autochanger() && slot <= 0) { + if (writing && slot <= 0) { if (dir) { return 0; /* For user, bail out right now */ } @@ -122,13 +145,25 @@ int autoload_device(DCR *dcr, int writing, BSOCK *dir) Dmsg1(400, "Want changer slot=%d\n", slot); changer = get_pool_memory(PM_FNAME); - if (slot > 0 && dcr->device->changer_name && dcr->device->changer_command) { + if (slot <= 0) { + Jmsg(jcr, M_INFO, 0, _("Invalid slot=%d defined in catalog. Manual load my be required.\n"), slot); + rtn_stat = 0; + } else if (!dcr->device->changer_name) { + Jmsg(jcr, M_INFO, 0, _("No \"Changer Device\" manual load of Volume may be required.\n")); + rtn_stat = 0; + } else if (!dcr->device->changer_command) { + Jmsg(jcr, M_INFO, 0, _("No \"Changer Command\" manual load of Volume may be requird.\n")); + rtn_stat = 0; + } else { + /* Attempt to load the Volume */ + uint32_t timeout = dcr->device->max_changer_wait; int loaded, status; loaded = get_autochanger_loaded_slot(dcr); if (loaded != slot) { + POOL_MEM results(PM_MESSAGE); /* Unload anything in our drive */ if (!unload_autochanger(dcr, loaded)) { @@ -144,37 +179,41 @@ int autoload_device(DCR *dcr, int writing, BSOCK *dir) * Load the desired cassette */ lock_changer(dcr); - Dmsg1(400, "Doing changer load slot %d\n", slot); + Dmsg1(100, "Doing changer load slot %d\n", slot); Jmsg(jcr, M_INFO, 0, _("3304 Issuing autochanger \"load slot %d, drive %d\" command.\n"), slot, drive); dcr->VolCatInfo.Slot = slot; /* slot to be loaded */ - changer = edit_device_codes(dcr, changer, - dcr->device->changer_command, "load"); - status = run_program(changer, timeout, NULL); + changer = edit_device_codes(dcr, changer, dcr->device->changer_command, "load"); + dev->close(); + Dmsg1(200, "Run program=%s\n", changer); + status = run_program_full_output(changer, timeout, results.c_str()); if (status == 0) { Jmsg(jcr, M_INFO, 0, _("3305 Autochanger \"load slot %d, drive %d\", status is OK.\n"), slot, drive); + Dmsg2(100, "load slot %d, drive %d, status is OK.\n", slot, drive); dev->Slot = slot; /* set currently loaded slot */ } else { - berrno be; - be.set_errno(status); - Jmsg(jcr, M_FATAL, 0, _("3992 Bad autochanger \"load slot %d, drive %d\": ERR=%s.\n"), - slot, drive, be.strerror()); + berrno be; + be.set_errno(status); + Dmsg3(100, "load slot %d, drive %d, bad stats=%s.\n", slot, drive, + be.bstrerror()); + Jmsg(jcr, M_FATAL, 0, _("3992 Bad autochanger \"load slot %d, drive %d\": " + "ERR=%s.\nResults=%s\n"), + slot, drive, be.bstrerror(), results.c_str()); rtn_stat = -1; /* hard error */ + dev->Slot = -1; /* mark unknown */ } - Dmsg2(400, "load slot %d status=%d\n", slot, status); + Dmsg2(100, "load slot %d status=%d\n", slot, status); unlock_changer(dcr); } else { status = 0; /* we got what we want */ dev->Slot = slot; /* set currently loaded slot */ } - Dmsg1(400, "After changer, status=%d\n", status); + Dmsg1(100, "After changer, status=%d\n", status); if (status == 0) { /* did we succeed? */ rtn_stat = 1; /* tape loaded by changer */ } - } else { - rtn_stat = 0; /* no changer found */ } free_pool_memory(changer); return rtn_stat; @@ -194,49 +233,58 @@ bail_out: int get_autochanger_loaded_slot(DCR *dcr) { JCR *jcr = dcr->jcr; - POOLMEM *changer, *results; + DEVICE *dev = dcr->dev; int status, loaded; uint32_t timeout = dcr->device->max_changer_wait; int drive = dcr->dev->drive_index; + POOL_MEM results(PM_MESSAGE); + POOLMEM *changer; + if (!dev->is_autochanger()) { + return -1; + } if (!dcr->device->changer_command) { Jmsg(jcr, M_FATAL, 0, _("3992 Missing Changer command.\n")); return -1; } - - results = get_pool_memory(PM_MESSAGE); - changer = get_pool_memory(PM_FNAME); - + if (dev->Slot > 0) { + return dev->Slot; + } + /* Virtual disk autochanger */ + if (dcr->device->changer_command[0] ==0) { + return 1; + } /* Find out what is loaded, zero means device is unloaded */ + changer = get_pool_memory(PM_FNAME); lock_changer(dcr); - Jmsg(jcr, M_INFO, 0, _("3301 Issuing autochanger \"loaded drive %d\" command.\n"), + Jmsg(jcr, M_INFO, 0, _("3301 Issuing autochanger \"loaded? drive %d\" command.\n"), drive); changer = edit_device_codes(dcr, changer, dcr->device->changer_command, "loaded"); - *results = 0; - status = run_program(changer, timeout, results); - Dmsg3(50, "run_prog: %s stat=%d result=%s\n", changer, status, results); + *results.c_str() = 0; + Dmsg1(100, "Run program=%s\n", changer); + status = run_program_full_output(changer, timeout, results.c_str()); + Dmsg3(100, "run_prog: %s stat=%d result=%s", changer, status, results.c_str()); if (status == 0) { - loaded = atoi(results); + loaded = str_to_int32(results.c_str()); if (loaded > 0) { - Jmsg(jcr, M_INFO, 0, _("3302 Autochanger \"loaded drive %d\", result is Slot %d.\n"), + Jmsg(jcr, M_INFO, 0, _("3302 Autochanger \"loaded? drive %d\", result is Slot %d.\n"), drive, loaded); - dcr->dev->Slot = loaded; + dev->Slot = loaded; } else { - Jmsg(jcr, M_INFO, 0, _("3302 Autochanger \"loaded drive %d\", result: nothing loaded.\n"), + Jmsg(jcr, M_INFO, 0, _("3302 Autochanger \"loaded? drive %d\", result: nothing loaded.\n"), drive); - dcr->dev->Slot = 0; + dev->Slot = -1; /* unknown */ } } else { berrno be; be.set_errno(status); - Jmsg(jcr, M_INFO, 0, _("3991 Bad autochanger \"loaded drive %d\" command: ERR=%s.\n"), - drive, be.strerror()); + Jmsg(jcr, M_INFO, 0, _("3991 Bad autochanger \"loaded? drive %d\" command: " + "ERR=%s.\nResults=%s\n"), drive, be.bstrerror(), results.c_str()); loaded = -1; /* force unload */ } unlock_changer(dcr); free_pool_memory(changer); - free_pool_memory(results); return loaded; } @@ -244,7 +292,7 @@ static void lock_changer(DCR *dcr) { AUTOCHANGER *changer_res = dcr->device->changer_res; if (changer_res) { - Dmsg1(100, "Locking changer %s\n", changer_res->hdr.name); + Dmsg1(200, "Locking changer %s\n", changer_res->hdr.name); P(changer_res->changer_mutex); /* Lock changer script */ } } @@ -253,7 +301,7 @@ static void unlock_changer(DCR *dcr) { AUTOCHANGER *changer_res = dcr->device->changer_res; if (changer_res) { - Dmsg1(100, "Unlocking changer %s\n", changer_res->hdr.name); + Dmsg1(200, "Unlocking changer %s\n", changer_res->hdr.name); V(changer_res->changer_mutex); /* Unlock changer script */ } } @@ -285,11 +333,8 @@ bool unload_autochanger(DCR *dcr, int loaded) loaded = get_autochanger_loaded_slot(dcr); } - /* We are going to load a new tape, so close the device */ - offline_or_rewind_dev(dev); - force_close_device(dev); - if (loaded > 0) { + POOL_MEM results(PM_MESSAGE); POOLMEM *changer = get_pool_memory(PM_FNAME); lock_changer(dcr); Jmsg(jcr, M_INFO, 0, @@ -299,14 +344,19 @@ bool unload_autochanger(DCR *dcr, int loaded) dcr->VolCatInfo.Slot = loaded; changer = edit_device_codes(dcr, changer, dcr->device->changer_command, "unload"); - int stat = run_program(changer, timeout, NULL); + dev->close(); + Dmsg1(100, "Run program=%s\n", changer); + *results.c_str() = 0; + int stat = run_program_full_output(changer, timeout, results.c_str()); dcr->VolCatInfo.Slot = slot; if (stat != 0) { berrno be; be.set_errno(stat); - Jmsg(jcr, M_INFO, 0, _("3995 Bad autochanger \"unload slot %d, drive %d\": ERR=%s.\n"), - slot, dev->drive_index, be.strerror()); + Jmsg(jcr, M_INFO, 0, _("3995 Bad autochanger \"unload slot %d, drive %d\": " + "ERR=%s\nResults=%s\n"), + loaded, dev->drive_index, be.bstrerror(), results.c_str()); ok = false; + dev->Slot = -1; /* unknown */ } else { dev->Slot = 0; /* nothing loaded */ } @@ -330,6 +380,7 @@ static bool unload_other_drive(DCR *dcr, int slot) AUTOCHANGER *changer = dcr->dev->device->changer_res; DEVRES *device; bool found = false; + int retries = 0; /* wait for device retries */ if (!changer) { return false; @@ -348,52 +399,70 @@ static bool unload_other_drive(DCR *dcr, int slot) if (!found) { return true; } + + /* The Volume we want is on another device. */ if (dev->is_busy()) { - Jmsg(jcr, M_WARNING, 0, _("Volume %s is in use by device %s\n"), - dcr->VolumeName, dev->print_name()); - Dmsg2(200, "Volume %s is in use by device %s\n", + Dmsg4(100, "Vol %s for dev=%s in use dev=%s slot=%d\n", + dcr->VolumeName, dcr->dev->print_name(), + dev->print_name(), slot); + } + for (int i=0; i < 3; i++) { + if (dev->is_busy()) { + wait_for_device(dcr->jcr, retries); + continue; + } + break; + } + dev->dlock(); + if (dev->is_busy()) { + Jmsg(jcr, M_WARNING, 0, _("Volume \"%s\" is in use by device %s\n"), dcr->VolumeName, dev->print_name()); - + Dmsg4(100, "Vol %s for dev=%s is busy dev=%s slot=%d\n", + dcr->VolumeName, dcr->dev->print_name(), dev->print_name(), slot); + Dmsg2(100, "num_writ=%d reserv=%d\n", dev->num_writers, dev->reserved_device); + dev->dunlock(); return false; } - /* We are going to unload a tape, so close the device */ - offline_or_rewind_dev(dev); - force_close_device(dev); - POOLMEM *changer_cmd = get_pool_memory(PM_FNAME); + POOL_MEM results(PM_MESSAGE); lock_changer(dcr); Jmsg(jcr, M_INFO, 0, _("3307 Issuing autochanger \"unload slot %d, drive %d\" command.\n"), slot, dev->drive_index); - Dmsg2(200, "Issuing autochanger \"unload slot %d, drive %d\" command.\n", + Dmsg2(100, "Issuing autochanger \"unload slot %d, drive %d\" command.\n", slot, dev->drive_index); - save_slot = dcr->VolCatInfo.Slot; save_dev = dcr->dev; dcr->dev = dev; + save_slot = dcr->VolCatInfo.Slot; dcr->VolCatInfo.Slot = slot; changer_cmd = edit_device_codes(dcr, changer_cmd, dcr->device->changer_command, "unload"); - Dmsg1(200, "Run program=%s\n", changer_cmd); - int stat = run_program(changer_cmd, timeout, NULL); + dev->close(); + Dmsg2(200, "close dev=%s reserve=%d\n", dev->print_name(), + dev->reserved_device); + Dmsg1(100, "Run program=%s\n", changer_cmd); + int stat = run_program_full_output(changer_cmd, timeout, results.c_str()); dcr->VolCatInfo.Slot = save_slot; dcr->dev = save_dev; if (stat != 0) { berrno be; be.set_errno(stat); Jmsg(jcr, M_INFO, 0, _("3995 Bad autochanger \"unload slot %d, drive %d\": ERR=%s.\n"), - slot, dev->drive_index, be.strerror()); + slot, dev->drive_index, be.bstrerror()); - Dmsg3(200, "Bad autochanger \"unload slot %d, drive %d\": ERR=%s.\n", - slot, dev->drive_index, be.strerror()); + Dmsg3(100, "Bad autochanger \"unload slot %d, drive %d\": ERR=%s.\n", + slot, dev->drive_index, be.bstrerror()); ok = false; + dev->Slot = -1; /* unknown */ } else { - dev->Slot = 0; /* nothing loaded */ - Dmsg0(200, "Slot unloaded\n"); + dev->Slot = 0; /* nothing loaded */ + Dmsg0(100, "Slot unloaded\n"); } unlock_changer(dcr); + dev->dunlock(); free_pool_memory(changer_cmd); return ok; } @@ -425,10 +494,6 @@ bool autochanger_cmd(DCR *dcr, BSOCK *dir, const char *cmd) return false; } - /* List command? */ - if (strcmp(cmd, "list") == 0) { - unload_autochanger(dcr, -1); - } if (strcmp(cmd, "drives") == 0) { AUTOCHANGER *changer_res = dcr->device->changer_res; int drives = 1; @@ -459,19 +524,23 @@ bool autochanger_cmd(DCR *dcr, BSOCK *dir, const char *cmd) bnet_send(dir); } } else if (strcmp(cmd, "slots") == 0 ) { + char buf[100], *p; /* For slots command, read a single line */ - bstrncpy(dir->msg, "slots=", len); - fgets(dir->msg+6, len-6, bpipe->rfd); - dir->msglen = strlen(dir->msg); + buf[0] = 0; + fgets(buf, sizeof(buf)-1, bpipe->rfd); + buf[sizeof(buf)-1] = 0; + /* Strip any leading space in front of # of slots */ + for (p=buf; B_ISSPACE(*p); p++) + { } + bnet_fsend(dir, "slots=%s", p); Dmsg1(100, "msg); - bnet_send(dir); } stat = close_bpipe(bpipe); if (stat != 0) { berrno be; be.set_errno(stat); - bnet_fsend(dir, _("Autochanger error: ERR=%s\n"), be.strerror()); + bnet_fsend(dir, _("Autochanger error: ERR=%s\n"), be.bstrerror()); } bnet_sig(dir, BNET_EOD); ok = true;