Module Name: src
Committed By: pooka
Date: Tue Aug 10 21:55:28 UTC 2010
Modified Files:
src/tests/net: Makefile
Added Files:
src/tests/net/carp: Makefile t_basic.c
Log Message:
Add a most elementary carp test: it forks off two processes,
configures carp in each of them, and after verifying that the shared
address responds to ping it brutally kills the master like a proper
carnivore (none of that ifconfig down sissy vegan nonsense). Then
the test checks if the backup got its act together by pinging the
shared address and passes verdict.
To generate a diff of this commit:
cvs rdiff -u -r1.5 -r1.6 src/tests/net/Makefile
cvs rdiff -u -r0 -r1.1 src/tests/net/carp/Makefile \
src/tests/net/carp/t_basic.c
Please note that diffs are not public domain; they are subject to the
copyright notices on the relevant files.
Modified files:
Index: src/tests/net/Makefile
diff -u src/tests/net/Makefile:1.5 src/tests/net/Makefile:1.6
--- src/tests/net/Makefile:1.5 Sun Jul 25 21:42:08 2010
+++ src/tests/net/Makefile Tue Aug 10 21:55:28 2010
@@ -1,9 +1,9 @@
-# $NetBSD: Makefile,v 1.5 2010/07/25 21:42:08 pooka Exp $
+# $NetBSD: Makefile,v 1.6 2010/08/10 21:55:28 pooka Exp $
.include <bsd.own.mk>
TESTSDIR= ${TESTSBASE}/net
-TESTS_SUBDIRS= bpf icmp if_loop sys
+TESTS_SUBDIRS= bpf carp icmp if_loop sys
.include <bsd.test.mk>
Added files:
Index: src/tests/net/carp/Makefile
diff -u /dev/null src/tests/net/carp/Makefile:1.1
--- /dev/null Tue Aug 10 21:55:28 2010
+++ src/tests/net/carp/Makefile Tue Aug 10 21:55:28 2010
@@ -0,0 +1,13 @@
+# $NetBSD: Makefile,v 1.1 2010/08/10 21:55:28 pooka Exp $
+#
+
+.include <bsd.own.mk>
+
+TESTSDIR= ${TESTSBASE}/net/carp
+
+TESTS_C= t_basic
+
+LDADD+= -lrumpnet_shmif -lrumpnet_netinet -lrumpnet_net
+LDADD+= -lrumpnet -lrump -lrumpuser -lpthread
+
+.include <bsd.test.mk>
Index: src/tests/net/carp/t_basic.c
diff -u /dev/null src/tests/net/carp/t_basic.c:1.1
--- /dev/null Tue Aug 10 21:55:28 2010
+++ src/tests/net/carp/t_basic.c Tue Aug 10 21:55:28 2010
@@ -0,0 +1,216 @@
+/* $NetBSD: t_basic.c,v 1.1 2010/08/10 21:55:28 pooka Exp $ */
+
+/*-
+ * Copyright (c) 2010 The NetBSD Foundation, Inc.
+ * All rights reserved.
+ *
+ * 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 NETBSD FOUNDATION, INC. 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 THE FOUNDATION 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 <sys/cdefs.h>
+#ifndef lint
+__RCSID("$NetBSD: t_basic.c,v 1.1 2010/08/10 21:55:28 pooka Exp $");
+#endif /* not lint */
+
+#include <sys/types.h>
+#include <sys/socket.h>
+
+#include <netinet/in.h>
+#include <netinet/in_systm.h>
+#include <netinet/ip_carp.h>
+
+#include <rump/rump.h>
+#include <rump/rump_syscalls.h>
+
+#include <atf-c.h>
+#include <errno.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
+
+#include "../config/netconfig.c"
+#include "../../h_macros.h"
+
+static bool oknow = false;
+
+static void
+sighnd(int sig)
+{
+
+ ATF_REQUIRE_EQ(sig, SIGCHLD);
+ if (oknow)
+ return;
+
+ atf_tc_fail("child died unexpectedly");
+}
+
+ATF_TC(handover);
+ATF_TC_HEAD(handover, tc)
+{
+
+ atf_tc_set_md_var(tc, "descr", "check that carp handover works if "
+ "the master dies");
+ atf_tc_set_md_var(tc, "use.fs", "true");
+}
+
+#define THEBUS "buuuuuuus,etherbus"
+
+static void
+child(bool master)
+{
+ char ifname[IFNAMSIZ];
+ struct carpreq cr;
+ struct ifreq ifr;
+ const char *carpif;
+ int s;
+
+ /* helps reading carp debug output */
+ if (master)
+ carpif = "carp0";
+ else
+ carpif = "carp1";
+
+ /*
+ * Should use sysctl, bug debug is dabug.
+ */
+ {
+ //extern int rumpns_carp_opts[]; /* XXX */
+ //rumpns_carp_opts[CARPCTL_LOG] = 1;
+ }
+
+
+ rump_init();
+
+ memset(&ifr, 0, sizeof(ifr));
+ strlcpy(ifr.ifr_name, carpif, sizeof(ifr.ifr_name));
+
+ RL(s = rump_sys_socket(PF_INET, SOCK_DGRAM, 0));
+ RL(rump_sys_ioctl(s, SIOCIFCREATE, &ifr));
+
+ netcfg_rump_makeshmif(THEBUS, ifname);
+
+ if (master)
+ netcfg_rump_if(ifname, "10.1.1.1", "255.255.255.0");
+ else
+ netcfg_rump_if(ifname, "10.1.1.2", "255.255.255.0");
+
+ /* configure the carp interface */
+ ifr.ifr_data = &cr;
+ RL(rump_sys_ioctl(s, SIOCGVH, &ifr));
+
+ strlcpy(cr.carpr_carpdev, ifname, sizeof(cr.carpr_carpdev));
+ cr.carpr_vhid = 175;
+ if (master)
+ cr.carpr_advskew = 0;
+ else
+ cr.carpr_advskew = 200;
+ cr.carpr_advbase = 1;
+ strcpy(cr.carpr_key, "s3cret");
+
+ RL(rump_sys_ioctl(s, SIOCSVH, &ifr));
+ netcfg_rump_if(carpif, "10.1.1.100", "255.255.255.0");
+
+ /* tassa pause()en enka muuta voi */
+ pause();
+}
+
+ATF_TC_BODY(handover, tc)
+{
+ char ifname[IFNAMSIZ];
+ pid_t mpid, cpid;
+ int i, status;
+
+ signal(SIGCHLD, sighnd);
+
+ /* fork master */
+ switch (mpid = fork()) {
+ case -1:
+ atf_tc_fail_errno("fork failed");
+ /*NOTREACHED*/
+ case 0:
+ child(true);
+ /*NOTREACHED*/
+ default:
+ break;
+ }
+
+ /* fork backup */
+ switch (cpid = fork()) {
+ case -1:
+ kill(mpid, SIGKILL);
+ atf_tc_fail_errno("fork failed");
+ /*NOTREACHED*/
+ case 0:
+ child(false);
+ /*NOTREACHED*/
+ default:
+ break;
+ }
+
+ rump_init();
+ netcfg_rump_makeshmif(THEBUS, ifname);
+ netcfg_rump_if(ifname, "10.1.1.240", "255.255.255.0");
+
+ /* check that the primary addresses are up */
+ ATF_REQUIRE_EQ(netcfg_rump_pingtest("10.1.1.1", 1000), true);
+ ATF_REQUIRE_EQ(netcfg_rump_pingtest("10.1.1.2", 1000), true);
+
+ /* give carp a while to croak */
+ sleep(4);
+
+ /* check that the shared IP works */
+ ATF_REQUIRE_EQ(netcfg_rump_pingtest("10.1.1.100", 500), true);
+
+ /* KILLING SPREE */
+ oknow = true;
+ kill(mpid, SIGKILL);
+ wait(&status);
+ usleep(10000); /* just in case */
+ oknow = false;
+
+ /* check that primary is now dead */
+ ATF_REQUIRE_EQ(netcfg_rump_pingtest("10.1.1.1", 100), false);
+
+ /* do it in installments. carp will cluck meanwhile */
+ for (i = 0; i < 5; i++) {
+ if (netcfg_rump_pingtest("10.1.1.100", 1000) == true)
+ break;
+ }
+ if (i == 5)
+ atf_tc_fail("failed to failover");
+
+ /* to kill the child */
+ oknow = true;
+ kill(cpid, SIGKILL);
+
+ /* clean & done */
+}
+
+ATF_TP_ADD_TCS(tp)
+{
+
+ ATF_TP_ADD_TC(tp, handover);
+
+ return atf_no_error();
+}
