2 * QTest testcase for filter-mirror
4 * Copyright (c) 2016 FUJITSU LIMITED
5 * Author: Zhang Chen <zhangchen.fnst@cn.fujitsu.com>
7 * This work is licensed under the terms of the GNU GPL, version 2 or
8 * later. See the COPYING file in the top-level directory.
11 #include "qemu/osdep.h"
13 #include "qapi/qmp/qdict.h"
15 #include "qemu/sockets.h"
16 #include "qemu/error-report.h"
17 #include "qemu/main-loop.h"
19 /* TODO actually test the results and get rid of this */
20 #define qmp_discard_response(qs, ...) qobject_unref(qtest_qmp(qs, __VA_ARGS__))
22 static void test_mirror(void)
24 int send_sock
[2], recv_sock
[2];
25 uint32_t ret
= 0, len
= 0;
26 char send_buf
[] = "Hello! filter-mirror~";
28 uint32_t size
= sizeof(send_buf
);
32 ret
= socketpair(PF_UNIX
, SOCK_STREAM
, 0, send_sock
);
33 g_assert_cmpint(ret
, !=, -1);
35 ret
= socketpair(PF_UNIX
, SOCK_STREAM
, 0, recv_sock
);
36 g_assert_cmpint(ret
, !=, -1);
39 "-nic socket,id=qtest-bn0,fd=%d "
40 "-chardev socket,id=mirror0,fd=%d "
41 "-object filter-mirror,id=qtest-f0,netdev=qtest-bn0,queue=tx,outdev=mirror0 "
42 , send_sock
[1], recv_sock
[1]);
44 struct iovec iov
[] = {
47 .iov_len
= sizeof(size
),
50 .iov_len
= sizeof(send_buf
),
54 /* send a qmp command to guarantee that 'connected' is setting to true. */
55 qmp_discard_response(qts
, "{ 'execute' : 'query-status'}");
56 ret
= iov_send(send_sock
[0], iov
, 2, 0, sizeof(size
) + sizeof(send_buf
));
57 g_assert_cmpint(ret
, ==, sizeof(send_buf
) + sizeof(size
));
60 ret
= recv(recv_sock
[0], &len
, sizeof(len
), 0);
61 g_assert_cmpint(ret
, ==, sizeof(len
));
64 g_assert_cmpint(len
, ==, sizeof(send_buf
));
65 recv_buf
= g_malloc(len
);
66 ret
= recv(recv_sock
[0], recv_buf
, len
, 0);
67 g_assert_cmpstr(recv_buf
, ==, send_buf
);
77 int main(int argc
, char **argv
)
81 g_test_init(&argc
, &argv
, NULL
);
83 qtest_add_func("/netfilter/mirror", test_mirror
);