--- /dev/null
+/*
+ Bacula® - The Network Backup Solution
+
+ Copyright (C) 2007-2017 Bacula Systems SA
+ All rights reserved.
+
+ The main author of Bacula is Kern Sibbald, with contributions from many
+ others, a complete list can be found in the file AUTHORS.
+
+ Licensees holding a valid Bacula Systems SA license may use this file
+ and others of this release in accordance with the proprietary license
+ agreement provided in the LICENSE file. Redistribution of any part of
+ this release is not permitted.
+
+ Bacula® is a registered trademark of Kern Sibbald.
+*/
+/*
+ * File: test_rhv_backend.c
+ * Author: radekk
+ *
+ * Copyright (c) 2017 by Inteos sp. z o.o.
+ * All rights reserved. IP transferred to Bacula Systems according to agreement.
+ * This is a dumb and extremely simple backend simulator used for test swift Plugin.
+ *
+ * Created on 18 September 2017, 13:13
+ */
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <fcntl.h>
+#include <string.h>
+#include <errno.h>
+
+
+#ifndef LOGDIR
+#define LOGDIR "/tmp"
+#endif
+
+extern const char *PLUGINPREFIX;
+extern const char *PLUGINNAME;
+
+int logfd;
+pid_t mypid;
+char * buf;
+char * buflog;
+
+#define BUFLEN 4096
+#define BIGBUFLEN 65536
+
+void LOG(const char *txt)
+{
+ char _buf[BUFLEN];
+
+ int p = 0;
+ for (int a = 0; txt[a]; a++)
+ {
+ char c = txt[a];
+ if (c == '\n')
+ {
+ _buf[p++] = '\\';
+ _buf[p++] = 'n';
+ } else {
+ _buf[p++] = c;
+ }
+ }
+ _buf[p++] = '\n';
+ _buf[p] = '\0';
+ write(logfd, _buf, p);
+}
+
+int read_plugin(char * buf)
+{
+ int len;
+ int nread;
+ int size;
+ char header[8];
+
+ len = read(STDIN_FILENO, &header, 8);
+ if (len < 8){
+ LOG("#> Err: header too short");
+ close(logfd);
+ exit(2);
+ }
+ if (header[0] == 'F'){
+ LOG(">> EOD >>");
+ return 0;
+ }
+ if (header[0] == 'T'){
+ LOG(">> TERM >>");
+ close(logfd);
+ exit(0);
+ }
+ size = atoi(header+1);
+ if (size > BIGBUFLEN){
+ LOG("#> Err: message too long");
+ close(logfd);
+ exit(3);
+ }
+
+ if (header[0] == 'C'){
+ len = read(STDIN_FILENO, buf, size);
+ buf[len] = 0;
+ snprintf(buflog, BUFLEN, "> %s", buf);
+ LOG(buflog);
+ } else {
+ snprintf(buflog, BUFLEN, "> Data:%i", size);
+ LOG(buflog);
+ len = 0;
+ while (len < size){
+ nread = read(STDIN_FILENO, buf, size - len);
+ len += nread;
+ snprintf(buflog, BUFLEN, "> Dataread:%i", nread);
+ LOG(buflog);
+ }
+ }
+
+ return len;
+}
+
+void write_plugin(const char cmd, const char *str)
+{
+ int len;
+ const char * out;
+
+ if (str){
+ len = strlen(str);
+ out = str;
+ } else {
+ len = 0;
+ out = "";
+ }
+ printf("%c%06d\n", cmd, len);
+ printf("%s", out);
+ fflush(stdout);
+ snprintf(buflog, BUFLEN, "<< %c%06d:%s", cmd, len, out);
+ LOG(buflog);
+}
+
+void signal_eod(){
+ printf("F000000\n");
+ fflush(stdout);
+ LOG("<< EOD <<");
+}
+
+void signal_term(){
+ printf("T000000\n");
+ fflush(stdout);
+ LOG("<< TERM <<");
+}
+
+void perform_backup()
+{
+ // Backup Loop
+ snprintf(buf, BIGBUFLEN, "FNAME:%s/bucket/%d/vm1.iso\n", PLUGINPREFIX, mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:F 1048576 100 100 100640 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ write_plugin('I', "TEST5");
+ signal_eod();
+ // here comes a file data contents
+ write_plugin('C', "DATA\n");
+ write_plugin('D', "/* here comes a file data contents */");
+ write_plugin('D', "/* here comes another file line */");
+ write_plugin('D', "/* here comes another file line */");
+ write_plugin('D', "/* here comes another file line */");
+ write_plugin('D', "/* here comes another file line */");
+ signal_eod();
+ write_plugin('I', "TEST5Data");
+ // and now additional metadata
+ write_plugin('C', "ACL\n");
+ write_plugin('D', "user::rw-\nuser:root:-wx\ngroup::r--\nmask::rwx\nother::r--\n");
+ write_plugin('I', "TEST5Acl");
+ signal_eod();
+#if 0
+ snprintf(buf, BIGBUFLEN, "No matches found for pattern container1/otherobject\n");
+ write_plugin('E', buf);
+ signal_eod();
+ return;
+#endif
+
+ // next file
+ write_plugin('I', "TEST6");
+ snprintf(buf, BIGBUFLEN, "FNAME:%s/bucket/%d/etc/issue\n", PLUGINPREFIX, mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:F 26 200 200 100640 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ write_plugin('C', "PIPE:/etc/issue\n");
+ read_plugin(buf);
+ signal_eod();
+ write_plugin('C', "DATA\n");
+ write_plugin('I', "TEST6Data");
+
+#if 1
+ // test some stderror handling
+ errno = EACCES;
+ perror("I've got some unsuspected error which I'd like to display on stderr (COMM_STDERR)");
+#endif
+
+ // next file
+ snprintf(buf, BIGBUFLEN, "FNAME:%s/bucket/%d/vm2.iso\n", PLUGINPREFIX, mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:F 1048576 200 200 100640 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ signal_eod();
+ write_plugin('I', "TEST7");
+ /* here comes a file data contents */
+ write_plugin('C', "DATA\n");
+ write_plugin('D', "/* here comes a file data contents */");
+ write_plugin('D', "/* here comes another file line */");
+ write_plugin('D', "/* here comes another file line */");
+ write_plugin('D', "/* here comes another file line */");
+ write_plugin('D', "/* here comes another file line */");
+ signal_eod();
+ write_plugin('I', "TEST7Data");
+ write_plugin('C', "XATTR\n");
+ write_plugin('D', "bacula.custom.data=Inteos\nsystem.custom.data=Bacula\n");
+ signal_eod();
+
+ // next file
+ write_plugin('I', "TEST8");
+ snprintf(buf, BIGBUFLEN, "FNAME:%s/bucket/%d/SHELL\n", PLUGINPREFIX, mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:F 1099016 0 0 100640 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ write_plugin('C', "PIPE:/bin/bash\n");
+ read_plugin(buf);
+ signal_eod();
+ write_plugin('C', "DATA\n");
+ write_plugin('I', "TEST8Data");
+
+#if 1
+ // test Plugin Objects interface
+ write_plugin('I', "TEST PluginObject");
+ snprintf(buf, BIGBUFLEN, "PLUGINOBJ:%s/images/%d/vm1\n", PLUGINPREFIX, mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "PLUGINOBJ_CAT:Image\n");
+ write_plugin('C', "PLUGINOBJ_TYPE:VM\n");
+ snprintf(buf, BIGBUFLEN, "PLUGINOBJ_NAME:%s%d/vm1 - Name\n", PLUGINPREFIX, mypid);
+ write_plugin('C', buf);
+ snprintf(buf, BIGBUFLEN, "PLUGINOBJ_SRC:%s\n", PLUGINPREFIX);
+ write_plugin('C', buf);
+ write_plugin('C', "PLUGINOBJ_UUID:c3260b8c560e5e093e8913065fa3cba9\n");
+ write_plugin('C', "PLUGINOBJ_SIZE:1024kB\n");
+ signal_eod();
+ write_plugin('I', "TEST PluginObject - END");
+#endif
+
+ // next file
+ write_plugin('I', "TEST9");
+ snprintf(buf, BIGBUFLEN, "FNAME:%s/bucket/%d/lockfile\n", PLUGINPREFIX, mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:E 0 300 300 0100640 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ signal_eod();
+ write_plugin('I', "TEST9E");
+ signal_eod();
+
+ // next file
+ snprintf(buf, BIGBUFLEN, "FNAME:%s/bucket/%d/file.xattr\n", PLUGINPREFIX, mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:E 0 300 300 0100640 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ signal_eod();
+ write_plugin('I', "TEST10");
+ signal_eod();
+ write_plugin('C', "XATTR\n");
+ write_plugin('D', "bacula.custom.data=Inteos\nsystem.custom.data=Bacula\n");
+ signal_eod();
+
+ 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);
+ write_plugin('C', buf);
+ signal_eod();
+ write_plugin('I', "TEST11 - segmented object");
+ write_plugin('C', "DATA\n");
+ write_plugin('D', "/* here comes a file data contents */");
+ write_plugin('D', "/* here comes another file line */");
+ write_plugin('D', "/* here comes another file line */");
+ write_plugin('D', "/* here comes another file line */");
+ write_plugin('D', "/* here comes another file line */");
+ signal_eod();
+
+#if 0
+ snprintf(buf, BIGBUFLEN, "FNAME:" PLUGINPREFIX "/bucket/%d/file on error\n", mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:F 234560 900 900 0100640 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ signal_eod();
+ write_plugin('A', "Some error...\n");
+ return;
+#endif
+
+ snprintf(buf, BIGBUFLEN, "FNAME:%s/bucket/%d/\n", PLUGINPREFIX, mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:D 1024 100 100 040755 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ signal_eod();
+ write_plugin('I', "TEST12 - backup dir");
+ signal_eod();
+ write_plugin('C', "XATTR\n");
+ write_plugin('D', "bacula.custom.data=Inteos\nsystem.custom.data=Bacula\n");
+ signal_eod();
+
+ snprintf(buf, BIGBUFLEN, "FNAME:%s/bucket/\n", PLUGINPREFIX);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:D 1024 100 100 040755 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ signal_eod();
+ write_plugin('I', "TEST12 - backup another dir");
+ write_plugin('W', "Make some warning messages.");
+ signal_eod();
+
+ /* this is the end of all data */
+ signal_eod();
+}
+
+void perform_estimate(){
+ /* Estimate Loop (5) */
+ snprintf(buf, BIGBUFLEN, "FNAME:%s/bucket/%d/vm1.iso\n", PLUGINPREFIX, mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:F 1048576 100 100 100640 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ // write_plugin('I', "TEST5");
+ signal_eod();
+
+ snprintf(buf, BIGBUFLEN, "FNAME:%s/bucket/%d/vm2.iso\n", PLUGINPREFIX, mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:F 1048576 200 200 100640 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ signal_eod();
+ // write_plugin('I', "TEST5A");
+
+#if 1
+ // test some stderror handling
+ errno = EACCES;
+ perror("I've got some unsuspected error which I'd like to display on stderr (COMM_STDERR)");
+#endif
+
+ snprintf(buf, BIGBUFLEN, "FNAME:%s/bucket/%d/lockfile\n", PLUGINPREFIX, mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:E 0 300 300 0100640 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ signal_eod();
+ // write_plugin('I', "TEST5B");
+
+ snprintf(buf, BIGBUFLEN, "FNAME:%s/bucket/%d/vmsnap.iso\n", PLUGINPREFIX, mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:S 0 0 0 0120777 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ snprintf(buf, BIGBUFLEN, "LSTAT:/bucket/%d/vm1.iso\n", mypid);
+ write_plugin('C', buf);
+ signal_eod();
+ // write_plugin('I', "TEST5B");
+
+ snprintf(buf, BIGBUFLEN, "FNAME:%s/bucket/%d/\n", PLUGINPREFIX, mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:D 1024 100 100 040755 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ signal_eod();
+ // write_plugin('I', "TEST5 - dir");
+
+ snprintf(buf, BIGBUFLEN, "FNAME:%s/bucket/\n", PLUGINPREFIX);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:D 1024 100 100 040755 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ signal_eod();
+ // write_plugin('I', "TEST5 - another dir");
+
+ /* this is the end of all data */
+ signal_eod();
+}
+
+/*
+ * The listing procedure
+ * when:
+ * - / - it display drwxr-x--- containers
+ * - containers - it display drwxr-x--- bucket1
+ * drwxr-x--- bucket2
+ */
+void perform_listing(char *listing){
+ /* Listing Loop (5) */
+ if (strcmp(listing, "containers") == 0){
+ /* this is a containers listing */
+ write_plugin('C', "FNAME:bucket1/\n");
+ write_plugin('C', "STAT:D 1024 100 100 040755 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ signal_eod();
+#if 1
+ // test some stderror handling
+ errno = EACCES;
+ perror("I've got some unsuspected error which I'd like to display on stderr (COMM_STDERR)");
+#endif
+
+ write_plugin('C', "FNAME:bucket2/\n");
+ write_plugin('C', "STAT:D 1024 100 100 040755 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ signal_eod();
+ } else {
+ if (strcmp(listing, "containers/bucket1") == 0){
+ snprintf(buf, BIGBUFLEN, "FNAME:bucket1/%d/vm1.iso\n", mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:F 1048576 100 100 100640 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ signal_eod();
+
+ snprintf(buf, BIGBUFLEN, "FNAME:bucket1/%d/lockfile\n", mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:E 0 300 300 0100640 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ signal_eod();
+ } else
+ if (strcmp(listing, "containers/bucket2") == 0){
+ snprintf(buf, BIGBUFLEN, "FNAME:bucket2/%d/vm2.iso\n", mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:F 1048576 200 200 100640 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ signal_eod();
+
+ snprintf(buf, BIGBUFLEN, "FNAME:bucket2/%d/vmsnap.iso\n", mypid);
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:S 0 0 0 0120777 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ snprintf(buf, BIGBUFLEN, "LSTAT:/bucket/%d/vm1.iso\n", mypid);
+ write_plugin('C', buf);
+ signal_eod();
+ } else {
+ /* this is a top-level listing, response with a single containers list */
+ snprintf(buf, BIGBUFLEN, "FNAME:containers\n");
+ write_plugin('C', buf);
+ write_plugin('C', "STAT:D 0 0 0 040755 1\n");
+ write_plugin('C', "TSTAMP:1504271937 1504271937 1504271937\n");
+ // write_plugin('I', "TEST5");
+ signal_eod();
+ }
+ }
+
+ /* this is the end of all data */
+ signal_eod();
+}
+
+void perform_restore(){
+
+ int len;
+ int fsize;
+ bool loopgo = true;
+
+#if 1
+ // test some stderror handling
+ errno = EACCES;
+ perror("I've got some unsuspected error which I'd like to display on stderr (COMM_STDERR)");
+#endif
+
+ /* Restore Loop (5) */
+ LOG("#> Restore Loop.");
+ while (true){
+ read_plugin(buf);
+ /* check if FINISH job */
+ if (strcmp(buf, "FINISH\n") == 0){
+ LOG("#> finish files.");
+ break;
+ }
+ /* check for ACL command */
+ if (strcmp(buf, "ACL\n") == 0){
+ while (read_plugin(buf) > 0);
+ LOG("#> ACL data saved.");
+ write_plugin('I', "TEST5R - acl data saved.");
+ write_plugin('C', "OK\n");
+ continue;
+ }
+
+
+ /* check for XATTR command */
+ if (strcmp(buf, "XATTR\n") == 0){
+ while (read_plugin(buf) > 0);
+ LOG("#> XATTR data saved.");
+ write_plugin('I', "TEST5R - xattr data saved.");
+ write_plugin('C', "OK\n");
+ continue;
+ }
+ /* check if FNAME then follow file parameters */
+ if (strncmp(buf, "FNAME:", 6) == 0){
+ /* we read here a file parameters */
+ while (read_plugin(buf) > 0);
+ /* signal OK */
+#if 1
+ write_plugin('I', "TEST5R - create file ok.");
+ write_plugin('C', "OK\n");
+#else
+ write_plugin('I', "TEST5R - create file skipped.");
+ write_plugin('C', "SKIP\n");
+#endif
+ continue;
+ }
+ /* check if DATA command, so read the data packets */
+ if (strcmp(buf, "DATA\n") == 0){
+ len = read_plugin(buf);
+ if (len == 0){
+ /* empty file to restore */
+ LOG("#> Empty file.");
+ continue;
+ }
+ loopgo = true;
+ fsize = len;
+ while (loopgo){
+ len = read_plugin(buf);
+ fsize += len;
+ if (len > 0){
+ LOG("#> file data saved.");
+ continue;
+ } else {
+ loopgo = false;
+ snprintf(buflog, 4096, "#> file data END = %i", fsize);
+ }
+ }
+ /* confirm restore ok */
+ write_plugin('I', "TEST5R - end of data.");
+ write_plugin('C', "OK\n");
+ } else {
+ write_plugin('E', "Error DATA command required.");
+ exit (1);
+ }
+ }
+
+ /* this is the end of all data */
+ signal_eod();
+}
+
+/*
+ *
+ */
+int main(int argc, char** argv) {
+
+ int len;
+// int abort = 0;
+ char *listing;
+
+ buf = (char*)malloc(BIGBUFLEN);
+ if (buf == NULL){
+ exit(255);
+ }
+ buflog = (char*)malloc(BUFLEN);
+ if (buflog == NULL){
+ exit(255);
+ }
+ listing = (char*)malloc(BUFLEN);
+ if (listing == NULL){
+ exit(255);
+ }
+
+ mypid = getpid();
+ snprintf(buf, 4096, "%s/%s_backend_%d.log", LOGDIR, PLUGINNAME, mypid);
+ logfd = open(buf, O_CREAT|O_TRUNC|O_WRONLY, 0640);
+ if (logfd < 0){
+ exit (1);
+ }
+ //sleep(30);
+
+ /* handshake (1) */
+ len = read_plugin(buf);
+#if 1
+ write_plugin('C',"Hello Bacula\n");
+#else
+ write_plugin('E',"Invalid Plugin name.");
+ goto Term;
+#endif
+
+ /* Job Info (2) */
+ while ((len = read_plugin(buf)) > 0);
+ write_plugin('I', "TEST2");
+ signal_eod();
+
+ /* Plugin Params (3) */
+ while ((len = read_plugin(buf)) > 0){
+ if (strcmp(buf, "abort_on_error=1\n") == 0){
+ // abort = 1;
+ }
+ if (sscanf(buf, "listing=%s\n", buf) == 1){
+ strcpy(listing, buf);
+ }
+ }
+ write_plugin('I', "TEST3");
+ signal_eod();
+
+ /* Start Backup/Estimate/Restore (4) */
+ len = read_plugin(buf);
+ write_plugin('I', "TEST4");
+#if 0
+ if (abort){
+ write_plugin('A', "Invalid credentials.");
+ goto Term;
+ }
+#endif
+ signal_eod();
+
+ /* check what kind of Job we have */
+ buf[len] = 0;
+ if (strcmp(buf, "BackupStart\n") == 0){
+ perform_backup();
+ } else
+ if (strcmp(buf, "EstimateStart\n") == 0){
+ perform_estimate();
+ } else
+ if (strcmp(buf, "ListingStart\n") == 0){
+ perform_listing(listing);
+ } else
+ if (strcmp(buf, "RestoreStart\n") == 0){
+ perform_restore();
+ }
+
+ /* End Job */
+ len = read_plugin(buf);
+ write_plugin('I', "TESTEND");
+ signal_eod();
+ len = read_plugin(buf);
+
+#if 0
+Term:
+#endif
+ signal_term();
+ LOG("#> Terminating backend.");
+ close(logfd);
+ free(buf);
+ free(buflog);
+ free(listing);
+ return (EXIT_SUCCESS);
+}
projects / thirdparty / bacula.git / commitdiff
