X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;ds=sidebyside;f=bacula%2Fsrc%2Fstored%2Fread.c;h=7d50550902977492e368dd333474ad4c0f2d2467;hb=2499795e233e43bd4eb4d99e0473b67e6c6b60d8;hp=9821c9784306038d75629cc53b2a84d8b8c7cd03;hpb=90400dabee92914f71e7846d67aed5e302bbe520;p=bacula%2Fbacula diff --git a/bacula/src/stored/read.c b/bacula/src/stored/read.c index 9821c97843..7d50550902 100644 --- a/bacula/src/stored/read.c +++ b/bacula/src/stored/read.c @@ -1,250 +1,143 @@ /* - * Read code for Storage daemon - * - * Kern Sibbald, November MM - * - * Version $Id$ - */ -/* - Copyright (C) 2000, 2001, 2002 Kern Sibbald and John Walker + Bacula® - The Network Backup Solution - This program is free software; you can redistribute it and/or - modify it under the terms of the GNU General Public License as - published by the Free Software Foundation; either version 2 of - the License, or (at your option) any later version. + Copyright (C) 2000-2009 Free Software Foundation Europe e.V. - This program is distributed in the hope that it will be useful, - but WITHOUT ANY WARRANTY; without even the implied warranty of + 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 and included + 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., 59 Temple Place - Suite 330, Boston, - MA 02111-1307, USA. + 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 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. +*/ +/* + * Read code for Storage daemon + * + * Kern Sibbald, November MM + * + * Version $Id$ */ #include "bacula.h" #include "stored.h" /* Forward referenced subroutines */ - -/* Variables used by Child process */ -/* Global statistics */ -/* Note, these probably should be in shared memory so that - * they are truly global for all processes - */ -extern struct s_shm *shm; /* shared memory structure */ -extern int FiledDataChan; /* File daemon data channel (port) */ +static bool record_cb(DCR *dcr, DEV_RECORD *rec); /* Responses sent to the File daemon */ static char OK_data[] = "3000 OK data\n"; +static char FD_error[] = "3000 error\n"; static char rec_header[] = "rechdr %ld %ld %ld %ld %ld"; - -/* +/* * Read Data and send to File Daemon - * Returns: 0 on failure - * 1 on success + * Returns: false on failure + * true on success */ -int do_read_data(JCR *jcr) +bool do_read_data(JCR *jcr) { - BSOCK *ds; - BSOCK *fd_sock = jcr->file_bsock; - int ok = TRUE; - DEVICE *dev; - DEV_RECORD rec; - DEV_BLOCK *block; - POOLMEM *hdr; - SESSION_LABEL sessrec; /* session record */ - + BSOCK *fd = jcr->file_bsock; + bool ok = true; + DCR *dcr = jcr->read_dcr; + Dmsg0(20, "Start read data.\n"); - dev = jcr->device->dev; - memset(&sessrec, 0, sizeof(sessrec)); + if (!bnet_set_buffer_size(fd, dcr->device->max_network_buffer_size, BNET_SETBUF_WRITE)) { + return false; + } - /* Tell File daemon we will send data */ - bnet_fsend(fd_sock, OK_data); - Dmsg1(10, "bstored>filed: %s\n", fd_sock->msg); + if (jcr->NumReadVolumes == 0) { + Jmsg(jcr, M_FATAL, 0, _("No Volume names found for restore.\n")); + fd->fsend(FD_error); + return false; + } - ds = fd_sock; + Dmsg2(200, "Found %d volumes names to restore. First=%s\n", jcr->NumReadVolumes, + jcr->VolList->VolumeName); - if (!bnet_set_buffer_size(ds, MAX_NETWORK_BUFFER_SIZE, BNET_SETBUF_READ)) { - return 0; + /* Ready device for reading */ + if (!acquire_device_for_read(dcr)) { + fd->fsend(FD_error); + return false; } + /* Tell File daemon we will send data */ + fd->fsend(OK_data); + ok = read_records(dcr, record_cb, mount_next_read_volume); - Dmsg1(20, "Begin read device=%s\n", dev_name(dev)); - - block = new_block(dev); + /* Send end of data to FD */ + fd->signal(BNET_EOD); - create_vol_list(jcr); + if (!release_device(jcr->read_dcr)) { + ok = false; + } - Dmsg1(20, "Found %d volumes names to restore.\n", jcr->NumVolumes); + Dmsg0(30, "Done reading.\n"); + return ok; +} - /* - * Ready device for reading, and read records - */ - if (!acquire_device_for_read(jcr, dev, block)) { - free_block(block); - free_vol_list(jcr); - return 0; +/* + * Called here for each record from read_records() + * Returns: true if OK + * false if error + */ +static bool record_cb(DCR *dcr, DEV_RECORD *rec) +{ + JCR *jcr = dcr->jcr; + BSOCK *fd = jcr->file_bsock; + bool ok = true; + POOLMEM *save_msg; + char ec1[50], ec2[50]; + + if (rec->FileIndex < 0) { + return true; } - - memset(&rec, 0, sizeof(rec)); - rec.data = ds->msg; /* use socket message buffer */ - hdr = get_pool_memory(PM_MESSAGE); - - /* - * Read records, apply BSR filtering, and return any that are - * matched. - */ - for ( ;ok; ) { - DEV_RECORD *record; /* for reading label of multi-volumes */ - - if (job_cancelled(jcr)) { - ok = FALSE; - break; - } - /* Read Record */ - Dmsg1(500, "Main read_record. rem=%d\n", rec.remainder); - if (!read_record(dev, block, &rec)) { - Dmsg1(500, "Main read record failed. rem=%d\n", rec.remainder); - if (dev->state & ST_EOT) { - if (rec.remainder) { - Dmsg0(500, "Not end of record.\n"); - } - Dmsg2(90, "NumVolumes=%d CurVolume=%d\n", jcr->NumVolumes, jcr->CurVolume); - /* - * End Of Tape -- mount next Volume (if another specified) - */ - if (jcr->NumVolumes > 1 && jcr->CurVolume < jcr->NumVolumes) { - VOL_LIST *vol = jcr->VolList; - close_dev(dev); - jcr->CurVolume++; - for (int i=1; iCurVolume; i++) { - vol = vol->next; - } - strcpy(jcr->VolumeName, vol->VolumeName); - Dmsg1(100, "There is another volume %s.\n", jcr->VolumeName); - dev->state &= ~ST_READ; - if (!acquire_device_for_read(jcr, dev, block)) { - Jmsg(jcr, M_FATAL, 0, _("Cannot open Dev=%s, Vol=%s\n"), dev_name(dev), jcr->VolumeName); - ok = FALSE; - break; - } - record = new_record(); - Dmsg1(500, "read record after new tape. rem=%d\n", record->remainder); - read_record(dev, block, record); /* read vol label */ - dump_label_record(dev, record, 0); - free_record(record); - continue; - } - Dmsg0(90, "End of Device reached.\n"); - break; /* End of Tape */ - } - if (dev->state & ST_EOF) { - Dmsg0(90, "Got End of File. Trying again ...\n"); - continue; /* End of File */ - } - - Jmsg2(jcr, M_FATAL, 0, _("Read error on Record Header %s ERR=%s\n"), dev_name(dev), strerror(errno)); - ok = FALSE; - break; - } - - /* Some sort of label? */ - if (rec.FileIndex < 0) { - char *rtype; - memset(&sessrec, 0, sizeof(sessrec)); - switch (rec.FileIndex) { - case PRE_LABEL: - rtype = "Fresh Volume Label"; - break; - case VOL_LABEL: - rtype = "Volume Label"; - unser_volume_label(dev, &rec); - break; - case SOS_LABEL: - rtype = "Begin Session"; - unser_session_label(&sessrec, &rec); - break; - case EOS_LABEL: - rtype = "End Session"; - break; - case EOM_LABEL: - rtype = "End of Media"; - break; - default: - rtype = "Unknown"; - break; - } - if (debug_level > 0) { - printf("%s Record: VolSessionId=%d VolSessionTime=%d JobId=%d DataLen=%d\n", - rtype, rec.VolSessionId, rec.VolSessionTime, rec.Stream, rec.data_len); - } - - Dmsg1(40, "Got label = %d\n", rec.FileIndex); - if (rec.FileIndex == EOM_LABEL) { /* end of tape? */ - Dmsg0(40, "Get EOM LABEL\n"); - break; /* yes, get out */ - } - continue; /* ignore other labels */ - } /* end if label record */ - - if (jcr->bsr) { - /* Match BSR against current record */ - if (!match_bsr(jcr->bsr, &rec, &dev->VolHdr, &sessrec)) { - Dmsg0(50, "BSR rejected record\n"); - continue; - } - } else { - /* Old way, deprecated */ - if (rec.VolSessionId != jcr->read_VolSessionId || - rec.VolSessionTime != jcr->read_VolSessionTime) { - Dmsg0(50, "Ignore record ids not equal\n"); - continue; /* ignore */ - } - } - - /* Generate Header parameters and send to File daemon - * Note, we build header in hdr buffer to avoid wiping - * out the data record - */ - ds->msg = hdr; - if (!bnet_fsend(ds, rec_header, rec.VolSessionId, rec.VolSessionTime, - rec.FileIndex, rec.Stream, rec.data_len)) { - Dmsg1(30, ">filed: Error Hdr=%s\n", ds->msg); - ds->msg = rec.data; - ok = FALSE; - break; - } else { - Dmsg1(30, ">filed: Hdr=%s\n", ds->msg); - } - - ds->msg = rec.data; /* restore data record address */ - - /* Send data record to File daemon */ - ds->msglen = rec.data_len; - Dmsg1(40, ">filed: send %d bytes data.\n", ds->msglen); - if (!bnet_send(ds)) { - Dmsg0(0, "Error sending to FD\n"); - Jmsg1(jcr, M_FATAL, 0, _("Error sending to File daemon. ERR=%s\n"), - bnet_strerror(ds)); - ok = FALSE; - } + Dmsg5(400, "Send to FD: SessId=%u SessTim=%u FI=%s Strm=%s, len=%d\n", + rec->VolSessionId, rec->VolSessionTime, + FI_to_ascii(ec1, rec->FileIndex), + stream_to_ascii(ec2, rec->Stream, rec->FileIndex), + rec->data_len); + + /* Send record header to File daemon */ + if (!fd->fsend(rec_header, rec->VolSessionId, rec->VolSessionTime, + rec->FileIndex, rec->Stream, rec->data_len)) { + Pmsg1(000, _(">filed: Error Hdr=%s\n"), fd->msg); + Jmsg1(jcr, M_FATAL, 0, _("Error sending to File daemon. ERR=%s\n"), + fd->bstrerror()); + return false; + } else { + Dmsg1(400, ">filed: Hdr=%s\n", fd->msg); } - /* Send end of data to FD */ - bnet_sig(ds, BNET_EOD); - if (!release_device(jcr, dev, block)) { - ok = FALSE; + + /* Send data record to File daemon */ + save_msg = fd->msg; /* save fd message pointer */ + fd->msg = rec->data; /* pass data directly to the FD */ + fd->msglen = rec->data_len; + Dmsg1(400, ">filed: send %d bytes data.\n", fd->msglen); + if (!fd->send()) { + Pmsg1(000, _("Error sending to FD. ERR=%s\n"), fd->bstrerror()); + Jmsg1(jcr, M_FATAL, 0, _("Error sending to File daemon. ERR=%s\n"), + fd->bstrerror()); + + ok = false; } - free_pool_memory(hdr); - free_block(block); - free_vol_list(jcr); - Dmsg0(30, "Done reading.\n"); - return ok ? 1 : 0; + fd->msg = save_msg; /* restore fd message pointer */ + return ok; }