metaplugin: Add large packet (>64k) tests.

diff --git a/bacula/src/plugins/fd/pluginlib/test_metaplugin_backend.c b/bacula/src/plugins/fd/pluginlib/test_metaplugin_backend.c
index dd1d2ae97741a01c1296a9f0dc594a989fc1791a..88ed8765f47e53f381671dc0b6c43538f3d4b833 100644 (file)
--- a/bacula/src/plugins/fd/pluginlib/test_metaplugin_backend.c
+++ b/bacula/src/plugins/fd/pluginlib/test_metaplugin_backend.c
@@ -193,6 +193,29 @@ void write_plugin(const char cmd, const char *str)
    LOG(buflog);
 }
 
+/**
+ * @brief Sends/writes the binary data to plugin with assembling the raw packet.
+ *
+ * @param cmd the packet type to sent
+ * @param str the text to write
+ */
+void write_plugin_bin(const char *str, int len = 0)
+{
+   const char * out;
+
+   if (str) {
+      out = str;
+   } else {
+      out = "";
+   }
+
+   printf("D%06d\n", len);
+   int status = fwrite(out, len, 1, stdout);
+   fflush(stdout);
+   snprintf(buflog, BUFLEN, "<< D%06d:%d:<bindata>", len ,status);
+   LOG(buflog);
+}
+
 /**
  * @brief Sends the EOD packet to plugin.
  */
@@ -398,7 +421,6 @@ void perform_backup()
 
    snprintf(buf, BIGBUFLEN, "FNAME:%s/bucket/%d/vmsnap.iso\n", PLUGINPREFIX, mypid);
    write_plugin('C', buf);
-   // write_plugin('C', "STAT:S 1048576 0 0 0120777 1\n");
    write_plugin('C', "STAT:S 1048576 0 0 100640 1\n");
    write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
    snprintf(buf, BIGBUFLEN, "LSTAT:bucket/%d/vm1.iso/1508502750.495885/69312986/10485760/\n", mypid);
@@ -413,6 +435,26 @@ void perform_backup()
    write_plugin('D', "/* here comes another file line    */");
    signal_eod();
 
+   const int bigfileblock = 100000;
+   const int bigfilesize = bigfileblock * 5;
+   snprintf(buf, BIGBUFLEN, "FNAME:%s/bucket/%d/bigfile.raw\n", PLUGINPREFIX, mypid);
+   write_plugin('C', buf);
+   snprintf(buf, BIGBUFLEN, "STAT:F %d 0 0 100640 1\n", bigfilesize);
+   write_plugin('C', buf);
+   write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+   signal_eod();
+   write_plugin('I', "TEST17 - big file block");
+   write_plugin('C', "DATA\n");
+   {
+      char *bigfileblock_ptr = (char*)malloc(bigfileblock);
+      memset(bigfileblock_ptr, 0xA1, bigfileblock);
+      for (int s = bigfilesize; s > 0; s -= bigfileblock) {
+         write_plugin_bin(bigfileblock_ptr, bigfileblock);
+      }
+      free(bigfileblock_ptr);
+   }
+   signal_eod();
+
    if (regress_error_backup_abort)
    {
       snprintf(buf, BIGBUFLEN, "FNAME:%s/bucket/%d/file on error\n", PLUGINPREFIX, mypid);