]> git.sur5r.net Git - bacula/bacula/blobdiff - bacula/src/stored/bcopy.c
projects / bacula / bacula / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
add PostgreSQL support
[bacula/bacula] / bacula / src / stored / bcopy.c
diff --git a/bacula/src/stored/bcopy.c b/bacula/src/stored/bcopy.c
index 9da6927c026b6d25ca800a5761a314125630b996..9efa2a796503d7b98dee654daa37afe120b821fe 100644 (file)
--- a/bacula/src/stored/bcopy.c
+++ b/bacula/src/stored/bcopy.c
@@ -31,7 +31,7 @@
 #include "stored.h"
 
 /* Forward referenced functions */
-static void record_cb(JCR *jcr, DEVICE *dev, DEV_BLOCK *block, DEV_RECORD *rec);
+static int record_cb(JCR *jcr, DEVICE *dev, DEV_BLOCK *block, DEV_RECORD *rec);
 
 
 /* Global variables */
@@ -41,7 +41,6 @@ static JCR *in_jcr;                  /* input jcr */
 static JCR *out_jcr;                  /* output jcr */
 static BSR *bsr = NULL;
 static char *wd = "/tmp";
-static int verbose = 0;
 static int list_records = 0;
 static uint32_t records = 0;
 static uint32_t jobs = 0;
@@ -54,13 +53,15 @@ char *configfile;
 static void usage()
 {
    fprintf(stderr, _(
-"\nVersion: " VERSION " (" DATE ")\n\n"
+"\nVersion: " VERSION " (" BDATE ")\n\n"
 "Usage: bcopy [-d debug_level] <input-archive> <output-archive>\n"
 "       -b bootstrap      specify a bootstrap file\n"
 "       -c <file>         specify configuration file\n"
-"       -dnn              set debug level to nn\n"
+"       -d <nn>           set debug level to nn\n"
 "       -v                verbose\n"
-"       -w dir            specify working directory (default /tmp)\n"
+"       -i                specify input Volume names (separated by |)\n"
+"       -o                specify output Volume names (separated by |)\n"
+"       -w <dir>          specify working directory (default /tmp)\n"
 "       -?                print this message\n\n"));
    exit(1);
 }
@@ -68,11 +69,13 @@ static void usage()
 int main (int argc, char *argv[])
 {
    int ch;
+   char *iVolumeName = NULL;
+   char *oVolumeName = NULL;
 
    my_name_is(argc, argv, "bscan");
    init_msg(NULL, NULL);
 
-   while ((ch = getopt(argc, argv, "b:c:d:mn:p:rsu:vw:?")) != -1) {
+   while ((ch = getopt(argc, argv, "b:c:d:mn:p:rsu:vV:w:?")) != -1) {
       switch (ch) {
          case 'b':
            bsr = parse_bsr(NULL, optarg);
@@ -95,6 +98,15 @@ int main (int argc, char *argv[])
            verbose++;
            break;
 
+         case 'i':                    /* input Volume name */
+           iVolumeName = optarg;
+           break;
+
+         case 'o':                    /* output Volume name */
+           oVolumeName = optarg;
+           break;
+
+
          case 'w':
            wd = optarg;
            break;
@@ -122,14 +134,14 @@ int main (int argc, char *argv[])
    parse_config(configfile);
 
    /* Setup and acquire input device for reading */
-   in_jcr = setup_jcr("bcopy", argv[0], bsr);
+   in_jcr = setup_jcr("bcopy", argv[0], bsr, iVolumeName);
    in_dev = setup_to_access_device(in_jcr, 1);  /* read device */
    if (!in_dev) { 
       exit(1);
    }
 
    /* Setup output device for writing */
-   out_jcr = setup_jcr("bcopy", argv[1], bsr);
+   out_jcr = setup_jcr("bcopy", argv[1], bsr, oVolumeName);
    out_dev = setup_to_access_device(out_jcr, 0);   /* no acquire */  
    if (!out_dev) { 
       exit(1);     
@@ -144,7 +156,7 @@ int main (int argc, char *argv[])
       exit(1);
    }
    unlock_device(out_dev);
-   if (!acquire_device_for_append(out_jcr, out_dev, out_block)) {
+   if (!(out_dev=acquire_device_for_append(out_jcr, out_dev, out_block))) {
       free_block(out_block);
       free_jcr(in_jcr);
       exit(1);
@@ -167,7 +179,7 @@ int main (int argc, char *argv[])
   
 
 
-static void record_cb(JCR *in_jcr, DEVICE *dev, DEV_BLOCK *block, DEV_RECORD *rec)
+static int record_cb(JCR *in_jcr, DEVICE *dev, DEV_BLOCK *block, DEV_RECORD *rec)
 {
    if (list_records) {
       Pmsg5(000, _("Record: SessId=%u SessTim=%u FileIndex=%d Stream=%d len=%u\n"),
@@ -184,41 +196,41 @@ static void record_cb(JCR *in_jcr, DEVICE *dev, DEV_BLOCK *block, DEV_RECORD *re
         dump_label_record(dev, rec, 1);
       }
       switch (rec->FileIndex) {
-        case PRE_LABEL:
-            Pmsg0(000, "Volume is prelabeled. This volume cannot be copied.\n");
-           return;
-        case VOL_LABEL:
-            Pmsg0(000, "Volume label not copied.\n");
-           return;
-        case SOS_LABEL:
-           jobs++;
-           break;
-        case EOS_LABEL:
-           while (!write_record_to_block(out_block, rec)) {
-               Dmsg2(150, "!write_record_to_block data_len=%d rem=%d\n", rec->data_len,
-                         rec->remainder);
-              if (!write_block_to_device(out_jcr, out_dev, out_block)) {
-                  Dmsg2(90, "Got write_block_to_dev error on device %s. %s\n",
-                    dev_name(out_dev), strerror_dev(out_dev));
-                  Jmsg(out_jcr, M_FATAL, 0, _("Cannot fixup device error. %s\n"),
-                       strerror_dev(out_dev));
-              }
-           }
+      case PRE_LABEL:
+         Pmsg0(000, "Volume is prelabeled. This volume cannot be copied.\n");
+        return 1;
+      case VOL_LABEL:
+         Pmsg0(000, "Volume label not copied.\n");
+        return 1;
+      case SOS_LABEL:
+        jobs++;
+        break;
+      case EOS_LABEL:
+        while (!write_record_to_block(out_block, rec)) {
+            Dmsg2(150, "!write_record_to_block data_len=%d rem=%d\n", rec->data_len,
+                      rec->remainder);
            if (!write_block_to_device(out_jcr, out_dev, out_block)) {
                Dmsg2(90, "Got write_block_to_dev error on device %s. %s\n",
                  dev_name(out_dev), strerror_dev(out_dev));
                Jmsg(out_jcr, M_FATAL, 0, _("Cannot fixup device error. %s\n"),
                     strerror_dev(out_dev));
            }
-           break;
-        case EOM_LABEL:
-            Pmsg0(000, "EOM label not copied.\n");
-           return;
-        case EOT_LABEL:              /* end of all tapes */
-            Pmsg0(000, "EOT label not copied.\n");
-           return;
-        default:
-           break;
+        }
+        if (!write_block_to_device(out_jcr, out_dev, out_block)) {
+            Dmsg2(90, "Got write_block_to_dev error on device %s. %s\n",
+              dev_name(out_dev), strerror_dev(out_dev));
+            Jmsg(out_jcr, M_FATAL, 0, _("Cannot fixup device error. %s\n"),
+                 strerror_dev(out_dev));
+        }
+        break;
+      case EOM_LABEL:
+         Pmsg0(000, "EOM label not copied.\n");
+        return 1;
+      case EOT_LABEL:             /* end of all tapes */
+         Pmsg0(000, "EOT label not copied.\n");
+        return 1;
+      default:
+        break;
       }
    }
 
@@ -235,14 +247,14 @@ static void record_cb(JCR *in_jcr, DEVICE *dev, DEV_BLOCK *block, DEV_RECORD *re
         break;
       }
    }
-   return;
+   return 1;
 }
 
 
 /* Dummies to replace askdir.c */
-int    dir_get_volume_info(JCR *jcr, int writing) { return 1;}
+int    dir_get_volume_info(JCR *jcr, enum get_vol_info_rw  writing) { return 1;}
 int    dir_find_next_appendable_volume(JCR *jcr) { return 1;}
-int    dir_update_volume_info(JCR *jcr, VOLUME_CAT_INFO *vol, int relabel) { return 1; }
+int    dir_update_volume_info(JCR *jcr, DEVICE *dev, int relabel) { return 1; }
 int    dir_create_jobmedia_record(JCR *jcr) { return 1; }
 int    dir_ask_sysop_to_mount_next_volume(JCR *jcr, DEVICE *dev) { return 1; }
 int    dir_update_file_attributes(JCR *jcr, DEV_RECORD *rec) { return 1;}
Cloned from http://git.bacula.org/bacula