commit 0506a42cf09b11d606e506d6d6934662c9711be7
parent 6720d8f548e33984822e3040a5c0eac41a0d091d
Author: Andrey Uzunov <andrey.uzunov@gmail.com>
Date: Mon, 2 Sep 2013 17:08:23 +0000
simple test added to check curl > mhd2spdy > microspdy2http > mhd
Diffstat:
2 files changed, 230 insertions(+), 1 deletion(-)
diff --git a/src/testspdy/Makefile.am b/src/testspdy/Makefile.am
@@ -15,7 +15,7 @@ AM_CPPFLAGS = \
-I$(top_srcdir) \
-I$(top_srcdir)/src/include \
-I$(top_srcdir)/src/applicationlayer \
-$(LIBCURL_CPPFLAGS)
+$(LIBCURL_CPPFLAGS)
if !HAVE_W32
PERF_GET_CONCURRENT=perf_get_concurrent
@@ -98,3 +98,14 @@ test_session_timeout_SOURCES = \
$(SPDY_SOURCES)
test_session_timeout_LDADD = $(SPDY_LDADD)
+if HAVE_CURL_BINARY
+
+check_PROGRAMS += \
+ test_proxies
+
+test_proxies_SOURCES = \
+ test_proxies.c \
+ $(SPDY_SOURCES)
+test_proxies_LDADD = $(SPDY_LDADD)
+
+endif
diff --git a/src/testspdy/test_proxies.c b/src/testspdy/test_proxies.c
@@ -0,0 +1,218 @@
+/*
+ This file is part of libmicrospdy
+ Copyright (C) 2013 Andrey Uzunov
+
+ This program is free software: you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published by
+ the Free Software Foundation, either version 3 of the License, or
+ (at your option) any later version.
+
+ This program is distributed in the hope that it will be useful,
+ but WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ GNU General Public License for more details.
+
+ You should have received a copy of the GNU General Public License
+ along with this program. If not, see <http://www.gnu.org/licenses/>.
+*/
+
+/**
+ * @file test_proxies.c
+ * @brief test curl > mhd2spdylay > microspdy2http > mhd
+ * @author Andrey Uzunov
+ */
+
+#include "platform.h"
+#include "microspdy.h"
+#include "common.h"
+#include <sys/wait.h>
+#include <stdio.h> /* printf, stderr, fprintf */
+#include <sys/types.h> /* pid_t */
+#include <unistd.h> /* _exit, fork */
+#include <stdlib.h> /* exit */
+#include <errno.h> /* errno */
+#include <sys/wait.h> /* pid_t */
+#include "common.h"
+
+#define EXPECTED_BODY "<html><head><title>libmicrohttpd demo</title></head><body>libmicrohttpd demo</body></html>"
+
+
+pid_t parent;
+ pid_t child_mhd;
+ pid_t child_spdy2http;
+ pid_t child_mhd2spdy;
+ pid_t child_curl;
+
+ uint16_t mhd_port;
+ uint16_t spdy2http_port;
+ uint16_t mhd2spdy_port;
+
+void
+killproc(int pid, const char *message)
+{
+ printf("%s\nkilling %i\n",message,pid);
+ kill(pid, SIGKILL);
+}
+
+
+void killchildren()
+{
+ if(0 != child_mhd)
+ killproc(child_mhd,"kill mhd\n");
+ if(0 != child_spdy2http)
+ killproc(child_spdy2http,"kill spdy2http\n");
+ if(0 != child_mhd2spdy)
+ killproc(child_mhd2spdy,"kill mhd2spdy\n");
+ if(0 != child_curl)
+ killproc(child_curl,"kill curl\n");
+}
+
+pid_t au_fork()
+{
+ pid_t child = fork();
+ if (child == -1)
+ {
+ killchildren();
+
+ killproc(parent,"fork failed\n");
+ }
+
+ return child;
+}
+
+
+int main()
+{
+ //pid_t child;
+ int childstatus;
+
+ parent = getpid();
+ mhd_port = get_port(4000);
+ spdy2http_port = get_port(4100);
+ mhd2spdy_port = get_port(4200);
+
+ child_mhd = au_fork();
+ if (child_mhd == 0)
+ {
+ //run MHD
+ int devnull;
+ char *port_s;
+
+ close(1);
+ devnull = open("/dev/null", O_WRONLY);
+ if (1 != devnull)
+ {
+ dup2(devnull, 1);
+ close(devnull);
+ }
+ asprintf(&port_s, "%i", mhd_port);
+ execlp ("../examples/minimal_example", "minimal_example", port_s, NULL);
+ fprintf(stderr, "executing mhd failed\nFor this test 'make' must be run before 'make check'!\n");
+ //killchildren();
+ _exit(1);
+ }
+
+
+ child_spdy2http = au_fork();
+ if (child_spdy2http == 0)
+ {
+ //run spdy2http
+ int devnull;
+ char *port_s;
+ //char *url;
+
+ close(1);
+ devnull = open("/dev/null", O_WRONLY);
+ if (1 != devnull)
+ {
+ dup2(devnull, 1);
+ close(devnull);
+ }
+ //asprintf(&url, "127.0.0.1:%i", mhd_port);
+ asprintf(&port_s, "%i", spdy2http_port);
+ sleep(1);
+ execlp ("../spdy2http/microspdy2http", "microspdy2http", "-v4rtT", "10", "-p", port_s, NULL);
+ fprintf(stderr, "executing microspdy2http failed\n");
+ //killchildren();
+ _exit(1);
+ }
+
+ child_mhd2spdy = au_fork();
+ if (child_mhd2spdy == 0)
+ {
+ //run MHD2sdpy
+ int devnull;
+ char *port_s;
+ char *url;
+
+ close(1);
+ devnull = open("/dev/null", O_WRONLY);
+ if (1 != devnull)
+ {
+ dup2(devnull, 1);
+ close(devnull);
+ }
+ asprintf(&url, "http://127.0.0.1:%i", spdy2http_port);
+ asprintf(&port_s, "%i", mhd2spdy_port);
+ sleep(2);
+ execlp ("../examples/mhd2spdy", "mhd2spdy", "-vosb", url, "-p", port_s, NULL);
+ fprintf(stderr, "executing mhd2spdy failed\n");
+ //killchildren();
+ _exit(1);
+ }
+
+ child_curl = au_fork();
+ if (child_curl == 0)
+ {
+ //run curl
+ FILE *p;
+ int devnull;
+ char *cmd;
+ unsigned int i;
+ char buf[strlen(EXPECTED_BODY) + 1];
+
+ close(1);
+ devnull = open("/dev/null", O_WRONLY);
+ if (1 != devnull)
+ {
+ dup2(devnull, 1);
+ close(devnull);
+ }
+
+ asprintf (&cmd, "curl --proxy http://127.0.0.1:%i http://127.0.0.1:%i/", mhd2spdy_port, mhd_port);
+ sleep(3);
+ p = popen(cmd, "r");
+ if (p != NULL)
+ {
+ for (i = 0; i < strlen(EXPECTED_BODY) && !feof(p); i++)
+ {
+ buf[i] = fgetc(p);
+ }
+
+ pclose(p);
+ buf[i] = 0;
+ _exit(strcmp(EXPECTED_BODY, buf));
+ }
+ fprintf(stderr, "executing curl failed\n");
+ //killchildren();
+ _exit(1);
+ }
+
+ do
+ {
+ if(waitpid(child_mhd,&childstatus,WNOHANG) == child_mhd
+ || waitpid(child_spdy2http,&childstatus,WNOHANG) == child_spdy2http
+ || waitpid(child_mhd2spdy,&childstatus,WNOHANG) == child_mhd2spdy)
+ {
+ killchildren();
+ return 1;
+ }
+ if(waitpid(child_curl,&childstatus,WNOHANG) == child_curl)
+ {
+ killchildren();
+ return WEXITSTATUS(childstatus);
+ }
+ sleep(1);
+ }
+ while(true);
+}
