We have several callers that were formatting the argument strings themselves; consolidate this effort by adding new convenience functions directly in libqtest, and update some call-sites that can benefit from it. Note that the new functions qtest_startf() and qtest_vstartf() behave more like qtest_init() (the caller must assign global_qtest after the fact, rather than getting it implicitly set). This helps us prepare for future patches that get rid of the global variable, by explicitly highlighting which tests still depend on it now. Signed-off-by: Eric Blake <eblake@redhat.com> [thuth: Dropped the hunks that do not apply cleanly to qemu master yet and added the missing g_free(args) in qtest_vstartf()] Signed-off-by: Thomas Huth <thuth@redhat.com> Message-Id: <1508336428-20511-2-git-send-email-thuth@redhat.com> Acked-by: Michael S. Tsirkin <mst@redhat.com> Signed-off-by: Cornelia Huck <cohuck@redhat.com>
213 lines
6.5 KiB
C
213 lines
6.5 KiB
C
/*
|
|
* QTest testcase for filter-redirector
|
|
*
|
|
* 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.
|
|
*
|
|
* Case 1, tx traffic flow:
|
|
*
|
|
* qemu side | test side
|
|
* |
|
|
* +---------+ | +-------+
|
|
* | backend <---------------+ sock0 |
|
|
* +----+----+ | +-------+
|
|
* | |
|
|
* +----v----+ +-------+ |
|
|
* | rd0 +->+chardev| |
|
|
* +---------+ +---+---+ |
|
|
* | |
|
|
* +---------+ | |
|
|
* | rd1 <------+ |
|
|
* +----+----+ |
|
|
* | |
|
|
* +----v----+ | +-------+
|
|
* | rd2 +--------------->sock1 |
|
|
* +---------+ | +-------+
|
|
* +
|
|
*
|
|
* --------------------------------------
|
|
* Case 2, rx traffic flow
|
|
* qemu side | test side
|
|
* |
|
|
* +---------+ | +-------+
|
|
* | backend +---------------> sock1 |
|
|
* +----^----+ | +-------+
|
|
* | |
|
|
* +----+----+ +-------+ |
|
|
* | rd0 +<-+chardev| |
|
|
* +---------+ +---+---+ |
|
|
* ^ |
|
|
* +---------+ | |
|
|
* | rd1 +------+ |
|
|
* +----^----+ |
|
|
* | |
|
|
* +----+----+ | +-------+
|
|
* | rd2 <---------------+sock0 |
|
|
* +---------+ | +-------+
|
|
* +
|
|
*/
|
|
|
|
#include "qemu/osdep.h"
|
|
#include "libqtest.h"
|
|
#include "qemu/iov.h"
|
|
#include "qemu/sockets.h"
|
|
#include "qemu/error-report.h"
|
|
#include "qemu/main-loop.h"
|
|
|
|
static const char *get_devstr(void)
|
|
{
|
|
if (g_str_equal(qtest_get_arch(), "s390x")) {
|
|
return "virtio-net-ccw";
|
|
}
|
|
|
|
return "rtl8139";
|
|
}
|
|
|
|
|
|
static void test_redirector_tx(void)
|
|
{
|
|
int backend_sock[2], recv_sock;
|
|
uint32_t ret = 0, len = 0;
|
|
char send_buf[] = "Hello!!";
|
|
char sock_path0[] = "filter-redirector0.XXXXXX";
|
|
char sock_path1[] = "filter-redirector1.XXXXXX";
|
|
char *recv_buf;
|
|
uint32_t size = sizeof(send_buf);
|
|
size = htonl(size);
|
|
|
|
ret = socketpair(PF_UNIX, SOCK_STREAM, 0, backend_sock);
|
|
g_assert_cmpint(ret, !=, -1);
|
|
|
|
ret = mkstemp(sock_path0);
|
|
g_assert_cmpint(ret, !=, -1);
|
|
ret = mkstemp(sock_path1);
|
|
g_assert_cmpint(ret, !=, -1);
|
|
|
|
global_qtest = qtest_startf(
|
|
"-netdev socket,id=qtest-bn0,fd=%d "
|
|
"-device %s,netdev=qtest-bn0,id=qtest-e0 "
|
|
"-chardev socket,id=redirector0,path=%s,server,nowait "
|
|
"-chardev socket,id=redirector1,path=%s,server,nowait "
|
|
"-chardev socket,id=redirector2,path=%s,nowait "
|
|
"-object filter-redirector,id=qtest-f0,netdev=qtest-bn0,"
|
|
"queue=tx,outdev=redirector0 "
|
|
"-object filter-redirector,id=qtest-f1,netdev=qtest-bn0,"
|
|
"queue=tx,indev=redirector2 "
|
|
"-object filter-redirector,id=qtest-f2,netdev=qtest-bn0,"
|
|
"queue=tx,outdev=redirector1 ", backend_sock[1], get_devstr(),
|
|
sock_path0, sock_path1, sock_path0);
|
|
|
|
recv_sock = unix_connect(sock_path1, NULL);
|
|
g_assert_cmpint(recv_sock, !=, -1);
|
|
|
|
/* send a qmp command to guarantee that 'connected' is setting to true. */
|
|
qmp_discard_response("{ 'execute' : 'query-status'}");
|
|
|
|
struct iovec iov[] = {
|
|
{
|
|
.iov_base = &size,
|
|
.iov_len = sizeof(size),
|
|
}, {
|
|
.iov_base = send_buf,
|
|
.iov_len = sizeof(send_buf),
|
|
},
|
|
};
|
|
|
|
ret = iov_send(backend_sock[0], iov, 2, 0, sizeof(size) + sizeof(send_buf));
|
|
g_assert_cmpint(ret, ==, sizeof(send_buf) + sizeof(size));
|
|
close(backend_sock[0]);
|
|
|
|
ret = qemu_recv(recv_sock, &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, recv_buf, len, 0);
|
|
g_assert_cmpstr(recv_buf, ==, send_buf);
|
|
|
|
g_free(recv_buf);
|
|
close(recv_sock);
|
|
unlink(sock_path0);
|
|
unlink(sock_path1);
|
|
qtest_end();
|
|
}
|
|
|
|
static void test_redirector_rx(void)
|
|
{
|
|
int backend_sock[2], send_sock;
|
|
uint32_t ret = 0, len = 0;
|
|
char send_buf[] = "Hello!!";
|
|
char sock_path0[] = "filter-redirector0.XXXXXX";
|
|
char sock_path1[] = "filter-redirector1.XXXXXX";
|
|
char *recv_buf;
|
|
uint32_t size = sizeof(send_buf);
|
|
size = htonl(size);
|
|
|
|
ret = socketpair(PF_UNIX, SOCK_STREAM, 0, backend_sock);
|
|
g_assert_cmpint(ret, !=, -1);
|
|
|
|
ret = mkstemp(sock_path0);
|
|
g_assert_cmpint(ret, !=, -1);
|
|
ret = mkstemp(sock_path1);
|
|
g_assert_cmpint(ret, !=, -1);
|
|
|
|
global_qtest = qtest_startf(
|
|
"-netdev socket,id=qtest-bn0,fd=%d "
|
|
"-device %s,netdev=qtest-bn0,id=qtest-e0 "
|
|
"-chardev socket,id=redirector0,path=%s,server,nowait "
|
|
"-chardev socket,id=redirector1,path=%s,server,nowait "
|
|
"-chardev socket,id=redirector2,path=%s,nowait "
|
|
"-object filter-redirector,id=qtest-f0,netdev=qtest-bn0,"
|
|
"queue=rx,indev=redirector0 "
|
|
"-object filter-redirector,id=qtest-f1,netdev=qtest-bn0,"
|
|
"queue=rx,outdev=redirector2 "
|
|
"-object filter-redirector,id=qtest-f2,netdev=qtest-bn0,"
|
|
"queue=rx,indev=redirector1 ", backend_sock[1], get_devstr(),
|
|
sock_path0, sock_path1, sock_path0);
|
|
|
|
struct iovec iov[] = {
|
|
{
|
|
.iov_base = &size,
|
|
.iov_len = sizeof(size),
|
|
}, {
|
|
.iov_base = send_buf,
|
|
.iov_len = sizeof(send_buf),
|
|
},
|
|
};
|
|
|
|
send_sock = unix_connect(sock_path1, NULL);
|
|
g_assert_cmpint(send_sock, !=, -1);
|
|
/* send a qmp command to guarantee that 'connected' is setting to true. */
|
|
qmp_discard_response("{ 'execute' : 'query-status'}");
|
|
|
|
ret = iov_send(send_sock, iov, 2, 0, sizeof(size) + sizeof(send_buf));
|
|
g_assert_cmpint(ret, ==, sizeof(send_buf) + sizeof(size));
|
|
close(send_sock);
|
|
|
|
ret = qemu_recv(backend_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(backend_sock[0], recv_buf, len, 0);
|
|
g_assert_cmpstr(recv_buf, ==, send_buf);
|
|
|
|
g_free(recv_buf);
|
|
unlink(sock_path0);
|
|
unlink(sock_path1);
|
|
qtest_end();
|
|
}
|
|
|
|
int main(int argc, char **argv)
|
|
{
|
|
g_test_init(&argc, &argv, NULL);
|
|
qtest_add_func("/netfilter/redirector_tx", test_redirector_tx);
|
|
qtest_add_func("/netfilter/redirector_rx", test_redirector_rx);
|
|
return g_test_run();
|
|
}
|