xref: /openbmc/qemu/chardev/spice.c (revision 5111edaf)
1 #include "qemu/osdep.h"
2 #include "trace.h"
3 #include "ui/qemu-spice.h"
4 #include "chardev/char.h"
5 #include "chardev/spice.h"
6 #include "qapi/error.h"
7 #include "qemu/error-report.h"
8 #include "qemu/module.h"
9 #include "qemu/option.h"
10 #include <spice/protocol.h>
11 
12 typedef struct SpiceCharSource {
13     GSource               source;
14     SpiceChardev       *scd;
15 } SpiceCharSource;
16 
17 static int vmc_write(SpiceCharDeviceInstance *sin, const uint8_t *buf, int len)
18 {
19     SpiceChardev *scd = container_of(sin, SpiceChardev, sin);
20     Chardev *chr = CHARDEV(scd);
21     ssize_t out = 0;
22     ssize_t last_out;
23     uint8_t* p = (uint8_t*)buf;
24 
25     while (len > 0) {
26         int can_write = qemu_chr_be_can_write(chr);
27         last_out = MIN(len, can_write);
28         if (last_out <= 0) {
29             break;
30         }
31         qemu_chr_be_write(chr, p, last_out);
32         out += last_out;
33         len -= last_out;
34         p += last_out;
35     }
36 
37     trace_spice_vmc_write(out, len + out);
38     return out;
39 }
40 
41 static int vmc_read(SpiceCharDeviceInstance *sin, uint8_t *buf, int len)
42 {
43     SpiceChardev *scd = container_of(sin, SpiceChardev, sin);
44     int bytes = MIN(len, scd->datalen);
45 
46     if (bytes > 0) {
47         memcpy(buf, scd->datapos, bytes);
48         scd->datapos += bytes;
49         scd->datalen -= bytes;
50         assert(scd->datalen >= 0);
51     }
52     if (scd->datalen == 0) {
53         scd->datapos = 0;
54         scd->blocked = false;
55     }
56     trace_spice_vmc_read(bytes, len);
57     return bytes;
58 }
59 
60 static void vmc_event(SpiceCharDeviceInstance *sin, uint8_t event)
61 {
62     SpiceChardev *scd = container_of(sin, SpiceChardev, sin);
63     Chardev *chr = CHARDEV(scd);
64     int chr_event;
65 
66     switch (event) {
67     case SPICE_PORT_EVENT_BREAK:
68         chr_event = CHR_EVENT_BREAK;
69         break;
70     default:
71         return;
72     }
73 
74     trace_spice_vmc_event(chr_event);
75     qemu_chr_be_event(chr, chr_event);
76 }
77 
78 static void vmc_state(SpiceCharDeviceInstance *sin, int connected)
79 {
80     SpiceChardev *scd = container_of(sin, SpiceChardev, sin);
81     Chardev *chr = CHARDEV(scd);
82 
83     if ((chr->be_open && connected) ||
84         (!chr->be_open && !connected)) {
85         return;
86     }
87 
88     qemu_chr_be_event(chr,
89                       connected ? CHR_EVENT_OPENED : CHR_EVENT_CLOSED);
90 }
91 
92 static SpiceCharDeviceInterface vmc_interface = {
93     .base.type          = SPICE_INTERFACE_CHAR_DEVICE,
94     .base.description   = "spice virtual channel char device",
95     .base.major_version = SPICE_INTERFACE_CHAR_DEVICE_MAJOR,
96     .base.minor_version = SPICE_INTERFACE_CHAR_DEVICE_MINOR,
97     .state              = vmc_state,
98     .write              = vmc_write,
99     .read               = vmc_read,
100     .event              = vmc_event,
101 #if SPICE_SERVER_VERSION >= 0x000c06
102     .flags              = SPICE_CHAR_DEVICE_NOTIFY_WRITABLE,
103 #endif
104 };
105 
106 
107 static void vmc_register_interface(SpiceChardev *scd)
108 {
109     if (scd->active) {
110         return;
111     }
112     scd->sin.base.sif = &vmc_interface.base;
113     qemu_spice.add_interface(&scd->sin.base);
114     scd->active = true;
115     trace_spice_vmc_register_interface(scd);
116 }
117 
118 static void vmc_unregister_interface(SpiceChardev *scd)
119 {
120     if (!scd->active) {
121         return;
122     }
123     spice_server_remove_interface(&scd->sin.base);
124     scd->active = false;
125     trace_spice_vmc_unregister_interface(scd);
126 }
127 
128 static gboolean spice_char_source_prepare(GSource *source, gint *timeout)
129 {
130     SpiceCharSource *src = (SpiceCharSource *)source;
131     Chardev *chr = CHARDEV(src->scd);
132 
133     *timeout = -1;
134 
135     if (!chr->be_open) {
136         return true;
137     }
138 
139     return !src->scd->blocked;
140 }
141 
142 static gboolean spice_char_source_check(GSource *source)
143 {
144     SpiceCharSource *src = (SpiceCharSource *)source;
145     Chardev *chr = CHARDEV(src->scd);
146 
147     if (!chr->be_open) {
148         return true;
149     }
150 
151     return !src->scd->blocked;
152 }
153 
154 static gboolean spice_char_source_dispatch(GSource *source,
155     GSourceFunc callback, gpointer user_data)
156 {
157     SpiceCharSource *src = (SpiceCharSource *)source;
158     Chardev *chr = CHARDEV(src->scd);
159     GIOFunc func = (GIOFunc)callback;
160     GIOCondition cond = chr->be_open ? G_IO_OUT : G_IO_HUP;
161 
162     return func(NULL, cond, user_data);
163 }
164 
165 static GSourceFuncs SpiceCharSourceFuncs = {
166     .prepare  = spice_char_source_prepare,
167     .check    = spice_char_source_check,
168     .dispatch = spice_char_source_dispatch,
169 };
170 
171 static GSource *spice_chr_add_watch(Chardev *chr, GIOCondition cond)
172 {
173     SpiceChardev *scd = SPICE_CHARDEV(chr);
174     SpiceCharSource *src;
175 
176     assert(cond & G_IO_OUT);
177 
178     src = (SpiceCharSource *)g_source_new(&SpiceCharSourceFuncs,
179                                           sizeof(SpiceCharSource));
180     src->scd = scd;
181 
182     return (GSource *)src;
183 }
184 
185 static int spice_chr_write(Chardev *chr, const uint8_t *buf, int len)
186 {
187     SpiceChardev *s = SPICE_CHARDEV(chr);
188     int read_bytes;
189 
190     assert(s->datalen == 0);
191 
192     if (!chr->be_open) {
193         trace_spice_chr_discard_write(len);
194         return len;
195     }
196 
197     s->datapos = buf;
198     s->datalen = len;
199     spice_server_char_device_wakeup(&s->sin);
200     read_bytes = len - s->datalen;
201     if (read_bytes != len) {
202         /* We'll get passed in the unconsumed data with the next call */
203         s->datalen = 0;
204         s->datapos = NULL;
205         s->blocked = true;
206     }
207     return read_bytes;
208 }
209 
210 static void char_spice_finalize(Object *obj)
211 {
212     SpiceChardev *s = SPICE_CHARDEV(obj);
213 
214     vmc_unregister_interface(s);
215 
216     g_free((char *)s->sin.subtype);
217     g_free((char *)s->sin.portname);
218 }
219 
220 static void spice_vmc_set_fe_open(struct Chardev *chr, int fe_open)
221 {
222     SpiceChardev *s = SPICE_CHARDEV(chr);
223     if (fe_open) {
224         vmc_register_interface(s);
225     } else {
226         vmc_unregister_interface(s);
227     }
228 }
229 
230 static void spice_port_set_fe_open(struct Chardev *chr, int fe_open)
231 {
232     SpiceChardev *s = SPICE_CHARDEV(chr);
233 
234     if (fe_open) {
235         spice_server_port_event(&s->sin, SPICE_PORT_EVENT_OPENED);
236     } else {
237         spice_server_port_event(&s->sin, SPICE_PORT_EVENT_CLOSED);
238     }
239 }
240 
241 static void spice_chr_accept_input(struct Chardev *chr)
242 {
243     SpiceChardev *s = SPICE_CHARDEV(chr);
244 
245     spice_server_char_device_wakeup(&s->sin);
246 }
247 
248 static void chr_open(Chardev *chr, const char *subtype)
249 {
250     SpiceChardev *s = SPICE_CHARDEV(chr);
251 
252     s->active = false;
253     s->sin.subtype = g_strdup(subtype);
254 }
255 
256 static void qemu_chr_open_spice_vmc(Chardev *chr,
257                                     ChardevBackend *backend,
258                                     bool *be_opened,
259                                     Error **errp)
260 {
261     ChardevSpiceChannel *spicevmc = backend->u.spicevmc.data;
262     const char *type = spicevmc->type;
263     const char **psubtype = spice_server_char_device_recognized_subtypes();
264 
265     for (; *psubtype != NULL; ++psubtype) {
266         if (strcmp(type, *psubtype) == 0) {
267             break;
268         }
269     }
270     if (*psubtype == NULL) {
271         char *subtypes = g_strjoinv(", ",
272             (gchar **)spice_server_char_device_recognized_subtypes());
273 
274         error_setg(errp, "unsupported type name: %s", type);
275         error_append_hint(errp, "allowed spice char type names: %s\n",
276                           subtypes);
277 
278         g_free(subtypes);
279         return;
280     }
281 
282     *be_opened = false;
283 #if SPICE_SERVER_VERSION < 0x000e02
284     /* Spice < 0.14.2 doesn't explicitly open smartcard chardev */
285     if (strcmp(type, "smartcard") == 0) {
286         *be_opened = true;
287     }
288 #endif
289     chr_open(chr, type);
290 }
291 
292 static void qemu_chr_open_spice_port(Chardev *chr,
293                                      ChardevBackend *backend,
294                                      bool *be_opened,
295                                      Error **errp)
296 {
297     ChardevSpicePort *spiceport = backend->u.spiceport.data;
298     const char *name = spiceport->fqdn;
299     SpiceChardev *s;
300 
301     if (name == NULL) {
302         error_setg(errp, "missing name parameter");
303         return;
304     }
305 
306     if (!using_spice) {
307         error_setg(errp, "spice not enabled");
308         return;
309     }
310 
311     chr_open(chr, "port");
312 
313     *be_opened = false;
314     s = SPICE_CHARDEV(chr);
315     s->sin.portname = g_strdup(name);
316 
317     vmc_register_interface(s);
318 }
319 
320 static void qemu_chr_parse_spice_vmc(QemuOpts *opts, ChardevBackend *backend,
321                                      Error **errp)
322 {
323     const char *name = qemu_opt_get(opts, "name");
324     ChardevSpiceChannel *spicevmc;
325 
326     if (name == NULL) {
327         error_setg(errp, "chardev: spice channel: no name given");
328         return;
329     }
330     backend->type = CHARDEV_BACKEND_KIND_SPICEVMC;
331     spicevmc = backend->u.spicevmc.data = g_new0(ChardevSpiceChannel, 1);
332     qemu_chr_parse_common(opts, qapi_ChardevSpiceChannel_base(spicevmc));
333     spicevmc->type = g_strdup(name);
334 }
335 
336 static void qemu_chr_parse_spice_port(QemuOpts *opts, ChardevBackend *backend,
337                                       Error **errp)
338 {
339     const char *name = qemu_opt_get(opts, "name");
340     ChardevSpicePort *spiceport;
341 
342     if (name == NULL) {
343         error_setg(errp, "chardev: spice port: no name given");
344         return;
345     }
346     backend->type = CHARDEV_BACKEND_KIND_SPICEPORT;
347     spiceport = backend->u.spiceport.data = g_new0(ChardevSpicePort, 1);
348     qemu_chr_parse_common(opts, qapi_ChardevSpicePort_base(spiceport));
349     spiceport->fqdn = g_strdup(name);
350 }
351 
352 static void char_spice_class_init(ObjectClass *oc, void *data)
353 {
354     ChardevClass *cc = CHARDEV_CLASS(oc);
355 
356     cc->chr_write = spice_chr_write;
357     cc->chr_add_watch = spice_chr_add_watch;
358     cc->chr_accept_input = spice_chr_accept_input;
359 }
360 
361 static const TypeInfo char_spice_type_info = {
362     .name = TYPE_CHARDEV_SPICE,
363     .parent = TYPE_CHARDEV,
364     .instance_size = sizeof(SpiceChardev),
365     .instance_finalize = char_spice_finalize,
366     .class_init = char_spice_class_init,
367     .abstract = true,
368 };
369 module_obj(TYPE_CHARDEV_SPICE);
370 
371 static void char_spicevmc_class_init(ObjectClass *oc, void *data)
372 {
373     ChardevClass *cc = CHARDEV_CLASS(oc);
374 
375     cc->parse = qemu_chr_parse_spice_vmc;
376     cc->open = qemu_chr_open_spice_vmc;
377     cc->chr_set_fe_open = spice_vmc_set_fe_open;
378 }
379 
380 static const TypeInfo char_spicevmc_type_info = {
381     .name = TYPE_CHARDEV_SPICEVMC,
382     .parent = TYPE_CHARDEV_SPICE,
383     .class_init = char_spicevmc_class_init,
384 };
385 
386 static void char_spiceport_class_init(ObjectClass *oc, void *data)
387 {
388     ChardevClass *cc = CHARDEV_CLASS(oc);
389 
390     cc->parse = qemu_chr_parse_spice_port;
391     cc->open = qemu_chr_open_spice_port;
392     cc->chr_set_fe_open = spice_port_set_fe_open;
393 }
394 
395 static const TypeInfo char_spiceport_type_info = {
396     .name = TYPE_CHARDEV_SPICEPORT,
397     .parent = TYPE_CHARDEV_SPICE,
398     .class_init = char_spiceport_class_init,
399 };
400 module_obj(TYPE_CHARDEV_SPICEPORT);
401 
402 static void register_types(void)
403 {
404     type_register_static(&char_spice_type_info);
405     type_register_static(&char_spicevmc_type_info);
406     type_register_static(&char_spiceport_type_info);
407 }
408 
409 type_init(register_types);
410 
411 module_dep("ui-spice-core");
412