1 #include "qemu/osdep.h"
2 #include "qemu/dbus.h"
3 #include <gio/gio.h>
4 #include <gio/gunixfdlist.h>
5 #include "libqos/libqtest.h"
6 #include "dbus-display1.h"
7 
8 static GDBusConnection*
9 test_dbus_p2p_from_fd(int fd)
10 {
11     g_autoptr(GError) err = NULL;
12     g_autoptr(GSocket) socket = NULL;
13     g_autoptr(GSocketConnection) socketc = NULL;
14     GDBusConnection *conn;
15 
16     socket = g_socket_new_from_fd(fd, &err);
17     g_assert_no_error(err);
18 
19     socketc = g_socket_connection_factory_create_connection(socket);
20     g_assert(socketc != NULL);
21 
22     conn = g_dbus_connection_new_sync(
23         G_IO_STREAM(socketc), NULL,
24         G_DBUS_CONNECTION_FLAGS_AUTHENTICATION_CLIENT |
25         G_DBUS_CONNECTION_FLAGS_DELAY_MESSAGE_PROCESSING,
26         NULL, NULL, &err);
27     g_assert_no_error(err);
28 
29     return conn;
30 }
31 
32 static void
33 test_setup(QTestState **qts, GDBusConnection **conn)
34 {
35     int pair[2];
36 
37     *qts = qtest_init("-display dbus,p2p=yes -name dbus-test");
38 
39     g_assert_cmpint(socketpair(AF_UNIX, SOCK_STREAM, 0, pair), ==, 0);
40 
41     qtest_qmp_add_client(*qts, "@dbus-display", pair[1]);
42 
43     *conn = test_dbus_p2p_from_fd(pair[0]);
44     g_dbus_connection_start_message_processing(*conn);
45 }
46 
47 static void
48 test_dbus_display_vm(void)
49 {
50     g_autoptr(GError) err = NULL;
51     g_autoptr(GDBusConnection) conn = NULL;
52     g_autoptr(QemuDBusDisplay1VMProxy) vm = NULL;
53     QTestState *qts = NULL;
54 
55     test_setup(&qts, &conn);
56 
57     vm = QEMU_DBUS_DISPLAY1_VM_PROXY(
58         qemu_dbus_display1_vm_proxy_new_sync(
59             conn,
60             G_DBUS_PROXY_FLAGS_NONE,
61             NULL,
62             DBUS_DISPLAY1_ROOT "/VM",
63             NULL,
64             &err));
65     g_assert_no_error(err);
66 
67     g_assert_cmpstr(
68         qemu_dbus_display1_vm_get_name(QEMU_DBUS_DISPLAY1_VM(vm)),
69         ==,
70         "dbus-test");
71     qtest_quit(qts);
72 }
73 
74 typedef struct TestDBusConsoleRegister {
75     GMainLoop *loop;
76     GThread *thread;
77     GDBusConnection *listener_conn;
78     GDBusObjectManagerServer *server;
79 } TestDBusConsoleRegister;
80 
81 static gboolean listener_handle_scanout(
82     QemuDBusDisplay1Listener *object,
83     GDBusMethodInvocation *invocation,
84     guint arg_width,
85     guint arg_height,
86     guint arg_stride,
87     guint arg_pixman_format,
88     GVariant *arg_data,
89     TestDBusConsoleRegister *test)
90 {
91     g_main_loop_quit(test->loop);
92 
93     return DBUS_METHOD_INVOCATION_HANDLED;
94 }
95 
96 static void
97 test_dbus_console_setup_listener(TestDBusConsoleRegister *test)
98 {
99     g_autoptr(GDBusObjectSkeleton) listener = NULL;
100     g_autoptr(QemuDBusDisplay1ListenerSkeleton) iface = NULL;
101 
102     test->server = g_dbus_object_manager_server_new(DBUS_DISPLAY1_ROOT);
103     listener = g_dbus_object_skeleton_new(DBUS_DISPLAY1_ROOT "/Listener");
104     iface = QEMU_DBUS_DISPLAY1_LISTENER_SKELETON(
105         qemu_dbus_display1_listener_skeleton_new());
106     g_object_connect(iface,
107                      "signal::handle-scanout", listener_handle_scanout, test,
108                      NULL);
109     g_dbus_object_skeleton_add_interface(listener,
110                                          G_DBUS_INTERFACE_SKELETON(iface));
111     g_dbus_object_manager_server_export(test->server, listener);
112     g_dbus_object_manager_server_set_connection(test->server,
113                                                 test->listener_conn);
114 
115     g_dbus_connection_start_message_processing(test->listener_conn);
116 }
117 
118 static void
119 test_dbus_console_registered(GObject *source_object,
120                              GAsyncResult *res,
121                              gpointer user_data)
122 {
123     TestDBusConsoleRegister *test = user_data;
124     g_autoptr(GError) err = NULL;
125 
126     qemu_dbus_display1_console_call_register_listener_finish(
127         QEMU_DBUS_DISPLAY1_CONSOLE(source_object),
128         NULL, res, &err);
129     g_assert_no_error(err);
130 
131     test->listener_conn = g_thread_join(test->thread);
132     test_dbus_console_setup_listener(test);
133 }
134 
135 static gpointer
136 test_dbus_p2p_server_setup_thread(gpointer data)
137 {
138     return test_dbus_p2p_from_fd(GPOINTER_TO_INT(data));
139 }
140 
141 static void
142 test_dbus_display_console(void)
143 {
144     g_autoptr(GError) err = NULL;
145     g_autoptr(GDBusConnection) conn = NULL;
146     g_autoptr(QemuDBusDisplay1ConsoleProxy) console = NULL;
147     g_autoptr(GUnixFDList) fd_list = NULL;
148     g_autoptr(GMainLoop) loop = NULL;
149     QTestState *qts = NULL;
150     int pair[2], idx;
151     TestDBusConsoleRegister test;
152 
153     test_setup(&qts, &conn);
154 
155     g_assert_cmpint(socketpair(AF_UNIX, SOCK_STREAM, 0, pair), ==, 0);
156     fd_list = g_unix_fd_list_new();
157     idx = g_unix_fd_list_append(fd_list, pair[1], NULL);
158 
159     console = QEMU_DBUS_DISPLAY1_CONSOLE_PROXY(
160         qemu_dbus_display1_console_proxy_new_sync(
161             conn,
162             G_DBUS_PROXY_FLAGS_NONE,
163             NULL,
164             "/org/qemu/Display1/Console_0",
165             NULL,
166             &err));
167     g_assert_no_error(err);
168 
169     test.loop = loop = g_main_loop_new(NULL, FALSE);
170     test.thread = g_thread_new(NULL, test_dbus_p2p_server_setup_thread,
171                                GINT_TO_POINTER(pair[0]));
172 
173     qemu_dbus_display1_console_call_register_listener(
174         QEMU_DBUS_DISPLAY1_CONSOLE(console),
175         g_variant_new_handle(idx),
176         G_DBUS_CALL_FLAGS_NONE,
177         -1,
178         fd_list,
179         NULL,
180         test_dbus_console_registered,
181         &test);
182 
183     g_main_loop_run(loop);
184 
185     g_clear_object(&test.server);
186     g_clear_object(&test.listener_conn);
187     qtest_quit(qts);
188 }
189 
190 static void
191 test_dbus_display_keyboard(void)
192 {
193     g_autoptr(GError) err = NULL;
194     g_autoptr(GDBusConnection) conn = NULL;
195     g_autoptr(QemuDBusDisplay1KeyboardProxy) keyboard = NULL;
196     QTestState *qts = NULL;
197 
198     test_setup(&qts, &conn);
199 
200     keyboard = QEMU_DBUS_DISPLAY1_KEYBOARD_PROXY(
201         qemu_dbus_display1_keyboard_proxy_new_sync(
202             conn,
203             G_DBUS_PROXY_FLAGS_NONE,
204             NULL,
205             "/org/qemu/Display1/Console_0",
206             NULL,
207             &err));
208     g_assert_no_error(err);
209 
210 
211     g_assert_cmpint(qtest_inb(qts, 0x64) & 0x1, ==, 0);
212     g_assert_cmpint(qtest_inb(qts, 0x60), ==, 0);
213 
214     qemu_dbus_display1_keyboard_call_press_sync(
215         QEMU_DBUS_DISPLAY1_KEYBOARD(keyboard),
216         0x1C, /* qnum enter */
217         G_DBUS_CALL_FLAGS_NONE,
218         -1,
219         NULL,
220         &err);
221     g_assert_no_error(err);
222 
223     /* may be should wait for interrupt? */
224     g_assert_cmpint(qtest_inb(qts, 0x64) & 0x1, ==, 1);
225     g_assert_cmpint(qtest_inb(qts, 0x60), ==, 0x5A); /* scan code 2 enter */
226 
227     qemu_dbus_display1_keyboard_call_release_sync(
228         QEMU_DBUS_DISPLAY1_KEYBOARD(keyboard),
229         0x1C, /* qnum enter */
230         G_DBUS_CALL_FLAGS_NONE,
231         -1,
232         NULL,
233         &err);
234     g_assert_no_error(err);
235 
236     g_assert_cmpint(qtest_inb(qts, 0x64) & 0x1, ==, 1);
237     g_assert_cmpint(qtest_inb(qts, 0x60), ==, 0xF0); /* scan code 2 release */
238     g_assert_cmpint(qtest_inb(qts, 0x60), ==, 0x5A); /* scan code 2 enter */
239 
240     g_assert_cmpint(qemu_dbus_display1_keyboard_get_modifiers(
241                         QEMU_DBUS_DISPLAY1_KEYBOARD(keyboard)), ==, 0);
242 
243     qtest_quit(qts);
244 }
245 
246 int
247 main(int argc, char **argv)
248 {
249     g_test_init(&argc, &argv, NULL);
250 
251     qtest_add_func("/dbus-display/vm", test_dbus_display_vm);
252     qtest_add_func("/dbus-display/console", test_dbus_display_console);
253     qtest_add_func("/dbus-display/keyboard", test_dbus_display_keyboard);
254 
255     return g_test_run();
256 }
257