a8d2532645
No header includes qemu-common.h after this commit, as prescribed by qemu-common.h's file comment. Signed-off-by: Markus Armbruster <armbru@redhat.com> Message-Id: <20190523143508.25387-5-armbru@redhat.com> [Rebased with conflicts resolved automatically, except for include/hw/arm/xlnx-zynqmp.h hw/arm/nrf51_soc.c hw/arm/msf2-soc.c block/qcow2-refcount.c block/qcow2-cluster.c block/qcow2-cache.c target/arm/cpu.h target/lm32/cpu.h target/m68k/cpu.h target/mips/cpu.h target/moxie/cpu.h target/nios2/cpu.h target/openrisc/cpu.h target/riscv/cpu.h target/tilegx/cpu.h target/tricore/cpu.h target/unicore32/cpu.h target/xtensa/cpu.h; bsd-user/main.c and net/tap-bsd.c fixed up]
95 lines
2.6 KiB
C
95 lines
2.6 KiB
C
/*
|
|
* QTest testcase for filter-mirror
|
|
*
|
|
* Copyright (c) 2016 FUJITSU LIMITED
|
|
* Author: Zhang Chen <zhangchen.fnst@cn.fujitsu.com>
|
|
*
|
|
* This work is licensed under the terms of the GNU GPL, version 2 or
|
|
* later. See the COPYING file in the top-level directory.
|
|
*/
|
|
|
|
#include "qemu/osdep.h"
|
|
#include "qemu-common.h"
|
|
#include "libqtest.h"
|
|
#include "qapi/qmp/qdict.h"
|
|
#include "qemu/iov.h"
|
|
#include "qemu/sockets.h"
|
|
#include "qemu/error-report.h"
|
|
#include "qemu/main-loop.h"
|
|
|
|
/* TODO actually test the results and get rid of this */
|
|
#define qmp_discard_response(qs, ...) qobject_unref(qtest_qmp(qs, __VA_ARGS__))
|
|
|
|
static void test_mirror(void)
|
|
{
|
|
int send_sock[2], recv_sock[2];
|
|
uint32_t ret = 0, len = 0;
|
|
char send_buf[] = "Hello! filter-mirror~";
|
|
char *recv_buf;
|
|
uint32_t size = sizeof(send_buf);
|
|
size = htonl(size);
|
|
const char *devstr = "e1000";
|
|
QTestState *qts;
|
|
|
|
if (g_str_equal(qtest_get_arch(), "s390x")) {
|
|
devstr = "virtio-net-ccw";
|
|
}
|
|
|
|
ret = socketpair(PF_UNIX, SOCK_STREAM, 0, send_sock);
|
|
g_assert_cmpint(ret, !=, -1);
|
|
|
|
ret = socketpair(PF_UNIX, SOCK_STREAM, 0, recv_sock);
|
|
g_assert_cmpint(ret, !=, -1);
|
|
|
|
qts = qtest_initf(
|
|
"-netdev socket,id=qtest-bn0,fd=%d "
|
|
"-device %s,netdev=qtest-bn0,id=qtest-e0 "
|
|
"-chardev socket,id=mirror0,fd=%d "
|
|
"-object filter-mirror,id=qtest-f0,netdev=qtest-bn0,queue=tx,outdev=mirror0 "
|
|
, send_sock[1], devstr, recv_sock[1]);
|
|
|
|
struct iovec iov[] = {
|
|
{
|
|
.iov_base = &size,
|
|
.iov_len = sizeof(size),
|
|
}, {
|
|
.iov_base = send_buf,
|
|
.iov_len = sizeof(send_buf),
|
|
},
|
|
};
|
|
|
|
/* send a qmp command to guarantee that 'connected' is setting to true. */
|
|
qmp_discard_response(qts, "{ 'execute' : 'query-status'}");
|
|
ret = iov_send(send_sock[0], iov, 2, 0, sizeof(size) + sizeof(send_buf));
|
|
g_assert_cmpint(ret, ==, sizeof(send_buf) + sizeof(size));
|
|
close(send_sock[0]);
|
|
|
|
ret = qemu_recv(recv_sock[0], &len, sizeof(len), 0);
|
|
g_assert_cmpint(ret, ==, sizeof(len));
|
|
len = ntohl(len);
|
|
|
|
g_assert_cmpint(len, ==, sizeof(send_buf));
|
|
recv_buf = g_malloc(len);
|
|
ret = qemu_recv(recv_sock[0], recv_buf, len, 0);
|
|
g_assert_cmpstr(recv_buf, ==, send_buf);
|
|
|
|
g_free(recv_buf);
|
|
close(send_sock[0]);
|
|
close(send_sock[1]);
|
|
close(recv_sock[0]);
|
|
close(recv_sock[1]);
|
|
qtest_quit(qts);
|
|
}
|
|
|
|
int main(int argc, char **argv)
|
|
{
|
|
int ret;
|
|
|
|
g_test_init(&argc, &argv, NULL);
|
|
|
|
qtest_add_func("/netfilter/mirror", test_mirror);
|
|
ret = g_test_run();
|
|
|
|
return ret;
|
|
}
|