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