trackrdrd: added unit tests for the ActiveMQ implementation of MQ

trackrdrd/Makefile.am

 ACLOCAL_AMFLAGS = -I m4
 
-SUBDIRS = src src/test src/mq/activemq
+SUBDIRS = src src/test src/mq/activemq src/mq/activemq/test
 
 if HAVE_RST2MAN
 dist_man_MANS = trackrdrd.3

trackrdrd/configure.ac

@@ -144,5 +144,6 @@ AC_CONFIG_FILES([
 	src/Makefile
         src/test/Makefile
         src/mq/activemq/Makefile
+        src/mq/activemq/test/Makefile
 ])
 AC_OUTPUT

trackrdrd/src/mq/activemq/test/Makefile.am

+INCLUDES = -I$(VARNISHSRC)/include -I$(VARNISHSRC) -I$(top_srcdir)/include
+
+TESTS = test_activemq
+
+check_PROGRAMS = test_activemq
+
+test_activemq_SOURCES = \
+	../../minunit.h \
+	../../../../include/mq.h \
+	test_activemq.c
+
+test_activemq_LDADD = \
+	../amq_connection.$(OBJEXT)  \
+	../amq.$(OBJEXT)  \
+	../config_common.$(OBJEXT)  \
+	../mq.$(OBJEXT) \
+	${PTHREAD_LIBS} \
+	@AMQ_LIBS@ \
+	@APR_LIBS@ \
+	@APU_LIBS@

trackrdrd/src/mq/activemq/test/test_activemq.c

+/*-
+ * Copyright (c) 2012-2014 UPLEX Nils Goroll Systemoptimierung
+ * Copyright (c) 2012-2014 Otto Gmbh & Co KG
+ * All rights reserved
+ * Use only with permission
+ *
+ * Author: Geoffrey Simmons <geoffrey.simmons@uplex.de>
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * 1. Redistributions of source code must retain the above copyright
+ *    notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ *    notice, this list of conditions and the following disclaimer in the
+ *    documentation and/or other materials provided with the distribution.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED.  IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE
+ * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+ * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
+ * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+ * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
+ * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
+ * SUCH DAMAGE.
+ *
+ */
+
+#include <string.h>
+
+#include "mq.h"
+#include "../../../test/minunit.h"
+
+/* Automake exit code for "skipped" in make check */
+#define EXIT_SKIPPED 77
+
+#define AMQ_CONFIG "../../../test/activemq.conf"
+#define NWORKERS 1
+
+int tests_run = 0;
+void *worker;
+
+/* N.B.: Always run the tests in this order */
+static char
+*test_global_init(void)
+{
+    const char *err;
+
+    printf("... testing ActiveMQ global initialization\n");
+
+    err = MQ_GlobalInit(NWORKERS, AMQ_CONFIG);
+    VMASSERT(err == NULL, "MQ_GlobalInit: %s", err);
+
+    return NULL;
+}
+
+static char
+*test_init_connection(void)
+{
+    const char *err;
+
+    printf("... testing ActiveMQ connection initialization\n");
+
+    err = MQ_InitConnections();
+    if (err != NULL && strstr(err, "Connection refused") != NULL) {
+        printf("Connection refused, ActiveMQ assumed not running\n");
+        exit(EXIT_SKIPPED);
+    }
+    VMASSERT(err == NULL, "MQ_InitConnections: %s", err);
+
+    return NULL;
+}
+
+static const char
+*test_worker_init(void)
+{
+    const char *err;
+
+    printf("... testing ActiveMQ worker init\n");
+
+    err = MQ_WorkerInit(&worker);
+    VMASSERT(err == NULL, "MQ_WorkerInit: %s", err);
+
+    MASSERT0(worker != NULL, "Worker is NULL after MQ_WorkerInit");
+
+    return NULL;
+}
+
+static const char
+*test_version(void)
+{
+    const char *err;
+    char version[BUFSIZ];
+
+    printf("... testing ActiveMQ version info\n");
+
+    MASSERT0(worker != NULL, "MQ_Version: worker is NULL before call");
+    err = MQ_Version(worker, version);
+    VMASSERT(err == NULL, "MQ_Version: %s", err);
+    MASSERT0(version[0] != '\0', "MQ_Version: version is empty");
+
+    return NULL;
+}
+
+static const char
+*test_clientID(void)
+{
+    const char *err;
+    char clientID[BUFSIZ];
+
+    printf("... testing ActiveMQ client ID info\n");
+
+    MASSERT0(worker != NULL, "MQ_ClientID: worker is NULL before call");
+    err = MQ_ClientID(worker, clientID);
+    VMASSERT(err == NULL, "MQ_ClientID: %s", err);
+    MASSERT0(clientID[0] != '\0', "MQ_ClientID: client ID is empty");
+
+    return NULL;
+}
+
+static const char
+*test_send(void)
+{
+    const char *err;
+
+    printf("... testing ActiveMQ message send\n");
+
+    MASSERT0(worker != NULL, "MQ_Send: worker is NULL before call");
+    err = MQ_Send(worker, "foo bar baz quux", 16);
+    VMASSERT(err == NULL, "MQ_Send: %s", err);
+
+    return NULL;
+}
+
+static const char
+*test_worker_shutdown(void)
+{
+    const char *err;
+
+    printf("... testing ActiveMQ worker shutdown\n");
+
+    MASSERT0(worker != NULL, "MQ_Send: worker is NULL before call");
+    err = MQ_WorkerShutdown(&worker);
+    VMASSERT(err == NULL, "MQ_WorkerShutdown: %s", err);
+
+    MASSERT0(worker == NULL, "Worker not NULL after shutdown");
+    
+    err = MQ_Send(worker, "foo bar baz quux", 16);
+    MASSERT0(err != NULL, "No failure on MQ_Send after worker shutdown");
+
+    return NULL;
+}
+
+static const char
+*test_global_shutdown(void)
+{
+    const char *err;
+
+    printf("... testing ActiveMQ global shutdown\n");
+
+    err = MQ_GlobalShutdown();
+    VMASSERT(err == NULL, "MQ_GlobalShutdown: %s", err);
+
+    return NULL;
+}
+
+static const char
+*all_tests(void)
+{
+    mu_run_test(test_global_init);
+    mu_run_test(test_init_connection);
+    mu_run_test(test_worker_init);
+    mu_run_test(test_version);
+    mu_run_test(test_clientID);
+    mu_run_test(test_send);
+    mu_run_test(test_worker_shutdown);
+    mu_run_test(test_global_shutdown);
+    return NULL;
+}
+
+TEST_RUNNER