Clean up some SD message nos.

[bacula/bacula] / bacula / src / stored / read_record.c

diff --git a/bacula/src/stored/read_record.c b/bacula/src/stored/read_record.c
index f747da67c20e22cfddad114a64f45d380894747b..7e25a43ebedf6ea004375c27ddefbc6104c4ad23 100644 (file)
--- a/bacula/src/stored/read_record.c
+++ b/bacula/src/stored/read_record.c
@@ -9,7 +9,7 @@
  *   Version $Id$
  */
 /*
-   Copyright (C) 2000, 2001, 2002 Kern Sibbald and John Walker
+   Copyright (C) 2000-2003 Kern Sibbald and John Walker
 
    This program is free software; you can redistribute it and/or
    modify it under the terms of the GNU General Public License as
@@ -32,8 +32,9 @@
 #include "stored.h"
 
 static void get_session_record(DEVICE *dev, DEV_RECORD *rec, SESSION_LABEL *sessrec);
+#ifdef DEBUG
 static char *rec_state_to_str(DEV_RECORD *rec);
-
+#endif
 
 int read_records(JCR *jcr,  DEVICE *dev, 
        void record_cb(JCR *jcr, DEVICE *dev, DEV_BLOCK *block, DEV_RECORD *rec),
@@ -42,21 +43,21 @@ int read_records(JCR *jcr,  DEVICE *dev,
    DEV_BLOCK *block;
    DEV_RECORD *rec;
    uint32_t record, num_files = 0;
-   int verbose = FALSE;
    int ok = TRUE;
+   int done = FALSE;
    SESSION_LABEL sessrec;
 
    block = new_block(dev);
    rec = new_record();
-   for ( ;ok; ) {
-      if (job_cancelled(jcr)) {
+   for ( ;ok && !done; ) {
+      if (job_canceled(jcr)) {
         ok = FALSE;
         break;
       }
       if (!read_block_from_device(dev, block)) {
          Dmsg0(20, "!read_record()\n");
         if (dev->state & ST_EOT) {
-           DEV_RECORD *record = new_record();
+           DEV_RECORD *trec = new_record();
 
             Dmsg3(100, "EOT. stat=%s blk=%d rem=%d\n", rec_state_to_str(rec), 
                  block->BlockNumber, rec->remainder);
@@ -69,11 +70,11 @@ int read_records(JCR *jcr,  DEVICE *dev,
                *  be properly updated because this is the last
                *  tape.
                */
-              record->FileIndex = EOT_LABEL;
-              record->File = dev->file;
-              record->Block = rec->Block; /* return block last read */
-              record_cb(jcr, dev, block, record);
-              free_record(record);
+              trec->FileIndex = EOT_LABEL;
+              trec->File = dev->file;
+              trec->Block = rec->Block; /* return block last read */
+              record_cb(jcr, dev, block, trec);
+              free_record(trec);
               break;
            }
             Dmsg3(100, "After mount next vol. stat=%s blk=%d rem=%d\n", rec_state_to_str(rec), 
@@ -84,15 +85,15 @@ int read_records(JCR *jcr,  DEVICE *dev,
             *  most likely reading the previous record.
             */
            read_block_from_device(dev, block);
-           read_record_from_block(block, record);
-           get_session_record(dev, record, &sessrec);
-           record->File = dev->file;
-           record_cb(jcr, dev, block, record);
-           free_record(record);
+           read_record_from_block(block, trec);
+           get_session_record(dev, trec, &sessrec);
+           record_cb(jcr, dev, block, trec);
+           free_record(trec);
            goto next_record;
         }
         if (dev->state & ST_EOF) {
-            Emsg1(M_INFO, 0, "Got EOF on device %s\n", dev_name(dev));
+            Emsg2(M_INFO, 0, "Got EOF on device %s, Volume \"%s\"\n", 
+                 dev_name(dev), jcr->VolumeName);
             Dmsg0(20, "read_record got eof. try again\n");
            continue;
         }
@@ -116,7 +117,6 @@ next_record:
                  block->BlockNumber, rec->remainder);
            break;
         }
-        rec->File = dev->file;
          Dmsg3(10, "read-OK. stat=%s blk=%d rem=%d\n", rec_state_to_str(rec), 
                  block->BlockNumber, rec->remainder);
         /*
@@ -154,14 +154,20 @@ next_record:
         /* 
          * Apply BSR filter
          */
-        if (jcr->bsr && !match_bsr(jcr->bsr, rec, &dev->VolHdr, &sessrec)) {
-           if (verbose) {
-               Dmsg5(10, "BSR no match rec=%d block=%d SessId=%d SessTime=%d FI=%d\n",
-                 record, block->BlockNumber, rec->VolSessionId, rec->VolSessionTime, 
-                 rec->FileIndex);
+        if (jcr->bsr) {
+           int stat = match_bsr(jcr->bsr, rec, &dev->VolHdr, &sessrec);
+           if (stat == -1) { /* no more possible matches */
+              done = TRUE;   /* all items found, stop */
+              break;
+           } else if (stat == 0) {  /* no match */
+              if (verbose) {
+                  Dmsg5(10, "BSR no match rec=%d block=%d SessId=%d SessTime=%d FI=%d\n",
+                    record, block->BlockNumber, rec->VolSessionId, rec->VolSessionTime, 
+                    rec->FileIndex);
+              }
+              rec->remainder = 0;
+               continue;              /* we don't want record, read next one */
            }
-           rec->remainder = 0;
-            continue;              /* we don't want record, read next one */
         }
         if (is_partial_record(rec)) {
             Dmsg6(10, "Partial, break. recno=%d state=%s blk=%d SI=%d ST=%d FI=%d\n", record,
@@ -211,6 +217,7 @@ static void get_session_record(DEVICE *dev, DEV_RECORD *rec, SESSION_LABEL *sess
         rtype, rec->VolSessionId, rec->VolSessionTime, rec->Stream, rec->data_len);
 }
 
+#ifdef DEBUG
 static char *rec_state_to_str(DEV_RECORD *rec)
 {
    static char buf[200]; 
@@ -235,3 +242,4 @@ static char *rec_state_to_str(DEV_RECORD *rec)
    }
    return buf;
 }
+#endif