freebsd-dev/tests/sys/netgraph/hub.c
Mitchell Horne d99a40e5ba Remove riscv workaround in sys.netgraph.hub.loop test
The test case now passes on this architecture. This reverts commits
d5fd5cdc06 and 168b579a48.

Reviewed by:	lwhsu, imp
Differential Revision:	https://reviews.freebsd.org/D33252
2021-12-05 11:12:40 -04:00

232 lines
5.1 KiB
C

/*-
* SPDX-License-Identifier: BSD-3-Clause
*
* Copyright 2021 Lutz Donnerhacke
*
* 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.
* 3. Neither the name of the copyright holder nor the names of its
* contributors may be used to endorse or promote products derived
* from this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS 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 COPYRIGHT HOLDER 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 <atf-c.h>
#include <errno.h>
#include <stdio.h>
#include "util.h"
ATF_TC(basic);
ATF_TC_HEAD(basic, conf)
{
atf_tc_set_md_var(conf, "require.user", "root");
}
ATF_TC_BODY(basic, dummy)
{
char msg[] = "test";
ng_counter_t r;
ng_errors(PASS);
ng_shutdown("hub:");
ng_errors(FAIL);
ng_init();
ng_mkpeer(".", "a", "hub", "a");
ng_name("a", "hub");
ng_connect(".", "b", "hub:", "b");
ng_connect(".", "c", "hub:", "c");
/* do not bounce back */
ng_register_data("a", get_data0);
ng_counter_clear(r);
ng_send_data("a", msg, sizeof(msg));
ng_handle_events(50, r);
ATF_CHECK(r[0] == 0);
/* send to others */
ng_register_data("b", get_data0);
ng_register_data("c", get_data0);
ng_counter_clear(r);
ng_send_data("a", msg, sizeof(msg));
ng_handle_events(50, r);
ATF_CHECK(r[0] == 2);
ng_counter_clear(r);
ng_send_data("b", msg, sizeof(msg));
ng_handle_events(50, r);
ATF_CHECK(r[0] == 2);
ng_counter_clear(r);
ng_send_data("c", msg, sizeof(msg));
ng_handle_events(50, r);
ATF_CHECK(r[0] == 2);
/* remove a link */
ng_rmhook(".", "b");
ng_counter_clear(r);
ng_send_data("a", msg, sizeof(msg));
ng_handle_events(50, r);
ATF_CHECK(r[0] == 1);
ng_shutdown("hub:");
}
ATF_TC(persistence);
ATF_TC_HEAD(persistence, conf)
{
atf_tc_set_md_var(conf, "require.user", "root");
}
ATF_TC_BODY(persistence, dummy)
{
ng_errors(PASS);
ng_shutdown("hub:");
ng_errors(FAIL);
ng_init();
ng_mkpeer(".", "a", "hub", "a");
ng_name("a", "hub");
ng_send_msg("hub:", "setpersistent");
ng_rmhook(".", "a");
ng_shutdown("hub:");
}
ATF_TC(loop);
ATF_TC_HEAD(loop, conf)
{
atf_tc_set_md_var(conf, "require.user", "root");
}
ATF_TC_BODY(loop, dummy)
{
ng_counter_t r;
int i;
char msg[] = "LOOP Alert!";
ng_errors(PASS);
ng_shutdown("hub1:");
ng_shutdown("hub2:");
ng_errors(FAIL);
ng_init();
ng_mkpeer(".", "a", "hub", "a");
ng_name("a", "hub1");
ng_mkpeer(".", "b", "hub", "b");
ng_name("b", "hub2");
ng_register_data("a", get_data0);
ng_register_data("b", get_data0);
/*-
* Open loop
*
* /-- hub1
* . < |
* \-- hub2
*/
ng_connect("hub1:", "xc1", "hub2:", "xc1");
ng_counter_clear(r);
ng_send_data("a", msg, sizeof(msg));
ng_handle_events(50, r);
ATF_CHECK(r[0] == 1);
/*-
* Closed loop, DANGEROUS!
*
* /-- hub1 -\
* . < | |
* \-- hub2 -/
*/
ng_connect("hub1:", "xc2", "hub2:", "xc2");
ng_counter_clear(r);
ng_send_data("a", msg, sizeof(msg));
for (i = 0; i < 10; i++) /* don't run forever */
if (!ng_handle_event(50, r))
break;
ATF_CHECK(r[0] > 7);
ng_shutdown("hub1:");
ng_shutdown("hub2:");
}
ATF_TC(many_hooks);
ATF_TC_HEAD(many_hooks, conf)
{
atf_tc_set_md_var(conf, "require.user", "root");
}
ATF_TC_BODY(many_hooks, dummy)
{
ng_counter_t r;
int i;
char msg[] = "test";
const int HOOKS = 1000;
ng_errors(PASS);
ng_shutdown("hub:");
ng_errors(FAIL);
ng_init();
ng_mkpeer(".", "a", "hub", "a");
ng_name("a", "hub");
ng_register_data("a", get_data0);
ng_counter_clear(r);
for (i = 0; i < HOOKS; i++)
{
char hook[20];
snprintf(hook, sizeof(hook), "hook%d", i);
ng_connect(".", hook, "hub:", hook);
ng_errors(PASS);
ng_send_data(hook, msg, sizeof(msg));
ng_errors(FAIL);
if (errno != 0)
break;
ng_handle_events(50, r);
}
ATF_CHECK(r[0] > 100);
atf_tc_expect_fail("Implementation limitation (%d)", i);
ATF_CHECK(r[0] == HOOKS);
atf_tc_expect_pass();
ng_shutdown("hub:");
}
ATF_TP_ADD_TCS(hub)
{
ATF_TP_ADD_TC(hub, basic);
ATF_TP_ADD_TC(hub, loop);
ATF_TP_ADD_TC(hub, persistence);
ATF_TP_ADD_TC(hub, many_hooks);
return atf_no_error();
}