spice-display.c 24.8 KB
Newer Older
G
Gerd Hoffmann 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17
/*
 * Copyright (C) 2010 Red Hat, Inc.
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License as
 * published by the Free Software Foundation; either version 2 or
 * (at your option) version 3 of the License.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, see <http://www.gnu.org/licenses/>.
 */

P
Peter Maydell 已提交
18
#include "qemu/osdep.h"
G
Gerd Hoffmann 已提交
19
#include "qemu-common.h"
20
#include "ui/qemu-spice.h"
21 22
#include "qemu/timer.h"
#include "qemu/queue.h"
23
#include "ui/console.h"
24
#include "sysemu/sysemu.h"
A
Alon Levy 已提交
25
#include "trace.h"
G
Gerd Hoffmann 已提交
26

27
#include "ui/spice-display.h"
G
Gerd Hoffmann 已提交
28 29 30

static int debug = 0;

31
static void GCC_FMT_ATTR(2, 3) dprint(int level, const char *fmt, ...)
G
Gerd Hoffmann 已提交
32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63
{
    va_list args;

    if (level <= debug) {
        va_start(args, fmt);
        vfprintf(stderr, fmt, args);
        va_end(args);
    }
}

int qemu_spice_rect_is_empty(const QXLRect* r)
{
    return r->top == r->bottom || r->left == r->right;
}

void qemu_spice_rect_union(QXLRect *dest, const QXLRect *r)
{
    if (qemu_spice_rect_is_empty(r)) {
        return;
    }

    if (qemu_spice_rect_is_empty(dest)) {
        *dest = *r;
        return;
    }

    dest->top = MIN(dest->top, r->top);
    dest->left = MIN(dest->left, r->left);
    dest->bottom = MAX(dest->bottom, r->bottom);
    dest->right = MAX(dest->right, r->right);
}

A
Alon Levy 已提交
64 65 66 67 68 69 70 71 72 73
QXLCookie *qxl_cookie_new(int type, uint64_t io)
{
    QXLCookie *cookie;

    cookie = g_malloc0(sizeof(*cookie));
    cookie->type = type;
    cookie->io = io;
    return cookie;
}

74 75
void qemu_spice_add_memslot(SimpleSpiceDisplay *ssd, QXLDevMemSlot *memslot,
                            qxl_async_io async)
76
{
A
Alon Levy 已提交
77 78 79 80
    trace_qemu_spice_add_memslot(ssd->qxl.id, memslot->slot_id,
                                memslot->virt_start, memslot->virt_end,
                                async);

81
    if (async != QXL_SYNC) {
A
Alon Levy 已提交
82
        spice_qxl_add_memslot_async(&ssd->qxl, memslot,
83 84
                (uintptr_t)qxl_cookie_new(QXL_COOKIE_TYPE_IO,
                                          QXL_IO_MEMSLOT_ADD_ASYNC));
85
    } else {
86
        spice_qxl_add_memslot(&ssd->qxl, memslot);
87
    }
88 89 90 91
}

void qemu_spice_del_memslot(SimpleSpiceDisplay *ssd, uint32_t gid, uint32_t sid)
{
A
Alon Levy 已提交
92
    trace_qemu_spice_del_memslot(ssd->qxl.id, gid, sid);
93
    spice_qxl_del_memslot(&ssd->qxl, gid, sid);
94 95 96
}

void qemu_spice_create_primary_surface(SimpleSpiceDisplay *ssd, uint32_t id,
97 98
                                       QXLDevSurfaceCreate *surface,
                                       qxl_async_io async)
99
{
A
Alon Levy 已提交
100
    trace_qemu_spice_create_primary_surface(ssd->qxl.id, id, surface, async);
101
    if (async != QXL_SYNC) {
A
Alon Levy 已提交
102
        spice_qxl_create_primary_surface_async(&ssd->qxl, id, surface,
103 104
                (uintptr_t)qxl_cookie_new(QXL_COOKIE_TYPE_IO,
                                          QXL_IO_CREATE_PRIMARY_ASYNC));
105
    } else {
106
        spice_qxl_create_primary_surface(&ssd->qxl, id, surface);
107
    }
108 109
}

110 111
void qemu_spice_destroy_primary_surface(SimpleSpiceDisplay *ssd,
                                        uint32_t id, qxl_async_io async)
112
{
A
Alon Levy 已提交
113
    trace_qemu_spice_destroy_primary_surface(ssd->qxl.id, id, async);
114
    if (async != QXL_SYNC) {
A
Alon Levy 已提交
115
        spice_qxl_destroy_primary_surface_async(&ssd->qxl, id,
116 117
                (uintptr_t)qxl_cookie_new(QXL_COOKIE_TYPE_IO,
                                          QXL_IO_DESTROY_PRIMARY_ASYNC));
118
    } else {
119
        spice_qxl_destroy_primary_surface(&ssd->qxl, id);
120
    }
121 122 123 124
}

void qemu_spice_wakeup(SimpleSpiceDisplay *ssd)
{
A
Alon Levy 已提交
125
    trace_qemu_spice_wakeup(ssd->qxl.id);
126
    spice_qxl_wakeup(&ssd->qxl);
127 128
}

129 130
static void qemu_spice_create_one_update(SimpleSpiceDisplay *ssd,
                                         QXLRect *rect)
G
Gerd Hoffmann 已提交
131 132 133 134 135
{
    SimpleSpiceUpdate *update;
    QXLDrawable *drawable;
    QXLImage *image;
    QXLCommand *cmd;
G
Gerd Hoffmann 已提交
136
    int bw, bh;
A
Alon Levy 已提交
137
    struct timespec time_space;
G
Gerd Hoffmann 已提交
138
    pixman_image_t *dest;
G
Gerd Hoffmann 已提交
139

A
Alon Levy 已提交
140
    trace_qemu_spice_create_update(
141 142
           rect->left, rect->right,
           rect->top, rect->bottom);
G
Gerd Hoffmann 已提交
143

144
    update   = g_malloc0(sizeof(*update));
G
Gerd Hoffmann 已提交
145 146 147 148
    drawable = &update->drawable;
    image    = &update->image;
    cmd      = &update->ext.cmd;

149 150
    bw       = rect->right - rect->left;
    bh       = rect->bottom - rect->top;
151
    update->bitmap = g_malloc(bw * bh * 4);
G
Gerd Hoffmann 已提交
152

153
    drawable->bbox            = *rect;
G
Gerd Hoffmann 已提交
154 155
    drawable->clip.type       = SPICE_CLIP_TYPE_NONE;
    drawable->effect          = QXL_EFFECT_OPAQUE;
G
Gerd Hoffmann 已提交
156
    drawable->release_info.id = (uintptr_t)(&update->ext);
G
Gerd Hoffmann 已提交
157 158 159 160
    drawable->type            = QXL_DRAW_COPY;
    drawable->surfaces_dest[0] = -1;
    drawable->surfaces_dest[1] = -1;
    drawable->surfaces_dest[2] = -1;
A
Alon Levy 已提交
161 162 163 164
    clock_gettime(CLOCK_MONOTONIC, &time_space);
    /* time in milliseconds from epoch. */
    drawable->mm_time = time_space.tv_sec * 1000
                      + time_space.tv_nsec / 1000 / 1000;
G
Gerd Hoffmann 已提交
165 166

    drawable->u.copy.rop_descriptor  = SPICE_ROPD_OP_PUT;
167
    drawable->u.copy.src_bitmap      = (uintptr_t)image;
G
Gerd Hoffmann 已提交
168 169 170 171 172 173 174 175 176
    drawable->u.copy.src_area.right  = bw;
    drawable->u.copy.src_area.bottom = bh;

    QXL_SET_IMAGE_ID(image, QXL_IMAGE_GROUP_DEVICE, ssd->unique++);
    image->descriptor.type   = SPICE_IMAGE_TYPE_BITMAP;
    image->bitmap.flags      = QXL_BITMAP_DIRECT | QXL_BITMAP_TOP_DOWN;
    image->bitmap.stride     = bw * 4;
    image->descriptor.width  = image->bitmap.x = bw;
    image->descriptor.height = image->bitmap.y = bh;
177
    image->bitmap.data = (uintptr_t)(update->bitmap);
G
Gerd Hoffmann 已提交
178 179 180
    image->bitmap.palette = 0;
    image->bitmap.format = SPICE_BITMAP_FMT_32BIT;

181
    dest = pixman_image_create_bits(PIXMAN_LE_x8r8g8b8, bw, bh,
G
Gerd Hoffmann 已提交
182 183 184 185 186 187 188 189
                                    (void *)update->bitmap, bw * 4);
    pixman_image_composite(PIXMAN_OP_SRC, ssd->surface, NULL, ssd->mirror,
                           rect->left, rect->top, 0, 0,
                           rect->left, rect->top, bw, bh);
    pixman_image_composite(PIXMAN_OP_SRC, ssd->mirror, NULL, dest,
                           rect->left, rect->top, 0, 0,
                           0, 0, bw, bh);
    pixman_image_unref(dest);
G
Gerd Hoffmann 已提交
190 191

    cmd->type = QXL_CMD_DRAW;
192
    cmd->data = (uintptr_t)drawable;
G
Gerd Hoffmann 已提交
193

194
    QTAILQ_INSERT_TAIL(&ssd->updates, update, next);
G
Gerd Hoffmann 已提交
195 196
}

197 198
static void qemu_spice_create_update(SimpleSpiceDisplay *ssd)
{
199
    static const int blksize = 32;
G
Gerd Hoffmann 已提交
200
    int blocks = (surface_width(ssd->ds) + blksize - 1) / blksize;
201
    int dirty_top[blocks];
202
    int y, yoff1, yoff2, x, xoff, blk, bw;
G
Gerd Hoffmann 已提交
203
    int bpp = surface_bytes_per_pixel(ssd->ds);
204 205
    uint8_t *guest, *mirror;

206 207 208
    if (qemu_spice_rect_is_empty(&ssd->dirty)) {
        return;
    };
G
Gerd Hoffmann 已提交
209

210 211 212 213
    for (blk = 0; blk < blocks; blk++) {
        dirty_top[blk] = -1;
    }

G
Gerd Hoffmann 已提交
214
    guest = surface_data(ssd->ds);
G
Gerd Hoffmann 已提交
215
    mirror = (void *)pixman_image_get_data(ssd->mirror);
216
    for (y = ssd->dirty.top; y < ssd->dirty.bottom; y++) {
217 218
        yoff1 = y * surface_stride(ssd->ds);
        yoff2 = y * pixman_image_get_stride(ssd->mirror);
219 220 221 222
        for (x = ssd->dirty.left; x < ssd->dirty.right; x += blksize) {
            xoff = x * bpp;
            blk = x / blksize;
            bw = MIN(blksize, ssd->dirty.right - x);
223 224
            if (memcmp(guest + yoff1 + xoff,
                       mirror + yoff2 + xoff,
225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258
                       bw * bpp) == 0) {
                if (dirty_top[blk] != -1) {
                    QXLRect update = {
                        .top    = dirty_top[blk],
                        .bottom = y,
                        .left   = x,
                        .right  = x + bw,
                    };
                    qemu_spice_create_one_update(ssd, &update);
                    dirty_top[blk] = -1;
                }
            } else {
                if (dirty_top[blk] == -1) {
                    dirty_top[blk] = y;
                }
            }
        }
    }

    for (x = ssd->dirty.left; x < ssd->dirty.right; x += blksize) {
        blk = x / blksize;
        bw = MIN(blksize, ssd->dirty.right - x);
        if (dirty_top[blk] != -1) {
            QXLRect update = {
                .top    = dirty_top[blk],
                .bottom = ssd->dirty.bottom,
                .left   = x,
                .right  = x + bw,
            };
            qemu_spice_create_one_update(ssd, &update);
            dirty_top[blk] = -1;
        }
    }

259 260 261
    memset(&ssd->dirty, 0, sizeof(ssd->dirty));
}

G
Gerd Hoffmann 已提交
262 263
static SimpleSpiceCursor*
qemu_spice_create_cursor_update(SimpleSpiceDisplay *ssd,
M
Marc-André Lureau 已提交
264 265
                                QEMUCursor *c,
                                int on)
G
Gerd Hoffmann 已提交
266 267 268 269 270 271 272 273 274 275 276 277 278 279
{
    size_t size = c ? c->width * c->height * 4 : 0;
    SimpleSpiceCursor *update;
    QXLCursorCmd *ccmd;
    QXLCursor *cursor;
    QXLCommand *cmd;

    update   = g_malloc0(sizeof(*update) + size);
    ccmd     = &update->cmd;
    cursor   = &update->cursor;
    cmd      = &update->ext.cmd;

    if (c) {
        ccmd->type = QXL_CURSOR_SET;
280 281
        ccmd->u.set.position.x = ssd->ptr_x + ssd->hot_x;
        ccmd->u.set.position.y = ssd->ptr_y + ssd->hot_y;
G
Gerd Hoffmann 已提交
282 283 284 285 286 287 288 289 290 291 292
        ccmd->u.set.visible    = true;
        ccmd->u.set.shape      = (uintptr_t)cursor;
        cursor->header.unique     = ssd->unique++;
        cursor->header.type       = SPICE_CURSOR_TYPE_ALPHA;
        cursor->header.width      = c->width;
        cursor->header.height     = c->height;
        cursor->header.hot_spot_x = c->hot_x;
        cursor->header.hot_spot_y = c->hot_y;
        cursor->data_size         = size;
        cursor->chunk.data_size   = size;
        memcpy(cursor->chunk.data, c->data, size);
M
Marc-André Lureau 已提交
293 294
    } else if (!on) {
        ccmd->type = QXL_CURSOR_HIDE;
G
Gerd Hoffmann 已提交
295 296
    } else {
        ccmd->type = QXL_CURSOR_MOVE;
297 298
        ccmd->u.position.x = ssd->ptr_x + ssd->hot_x;
        ccmd->u.position.y = ssd->ptr_y + ssd->hot_y;
G
Gerd Hoffmann 已提交
299 300 301 302 303 304 305 306 307
    }
    ccmd->release_info.id = (uintptr_t)(&update->ext);

    cmd->type = QXL_CMD_CURSOR;
    cmd->data = (uintptr_t)ccmd;

    return update;
}

G
Gerd Hoffmann 已提交
308
/*
309
 * Called from spice server thread context (via interface_release_resource)
G
Gerd Hoffmann 已提交
310
 * We do *not* hold the global qemu mutex here, so extra care is needed
S
Stefan Weil 已提交
311
 * when calling qemu functions.  QEMU interfaces used:
312
 *    - g_free (underlying glibc free is re-entrant).
G
Gerd Hoffmann 已提交
313 314 315
 */
void qemu_spice_destroy_update(SimpleSpiceDisplay *sdpy, SimpleSpiceUpdate *update)
{
316 317
    g_free(update->bitmap);
    g_free(update);
G
Gerd Hoffmann 已提交
318 319 320 321 322 323
}

void qemu_spice_create_host_memslot(SimpleSpiceDisplay *ssd)
{
    QXLDevMemSlot memslot;

324
    dprint(1, "%s/%d:\n", __func__, ssd->qxl.id);
G
Gerd Hoffmann 已提交
325 326 327 328

    memset(&memslot, 0, sizeof(memslot));
    memslot.slot_group_id = MEMSLOT_GROUP_HOST;
    memslot.virt_end = ~0;
329
    qemu_spice_add_memslot(ssd, &memslot, QXL_SYNC);
G
Gerd Hoffmann 已提交
330 331 332 333 334
}

void qemu_spice_create_host_primary(SimpleSpiceDisplay *ssd)
{
    QXLDevSurfaceCreate surface;
335
    uint64_t surface_size;
G
Gerd Hoffmann 已提交
336

337 338
    memset(&surface, 0, sizeof(surface));

339 340 341 342 343 344 345 346 347 348 349 350 351
    surface_size = (uint64_t) surface_width(ssd->ds) *
        surface_height(ssd->ds) * 4;
    assert(surface_size > 0);
    assert(surface_size < INT_MAX);
    if (ssd->bufsize < surface_size) {
        ssd->bufsize = surface_size;
        g_free(ssd->buf);
        ssd->buf = g_malloc(ssd->bufsize);
    }

    dprint(1, "%s/%d: %ux%u (size %" PRIu64 "/%d)\n", __func__, ssd->qxl.id,
           surface_width(ssd->ds), surface_height(ssd->ds),
           surface_size, ssd->bufsize);
G
Gerd Hoffmann 已提交
352 353

    surface.format     = SPICE_SURFACE_FMT_32_xRGB;
G
Gerd Hoffmann 已提交
354 355
    surface.width      = surface_width(ssd->ds);
    surface.height     = surface_height(ssd->ds);
G
Gerd Hoffmann 已提交
356
    surface.stride     = -surface.width * 4;
G
Gerd Hoffmann 已提交
357
    surface.mouse_mode = true;
G
Gerd Hoffmann 已提交
358 359
    surface.flags      = 0;
    surface.type       = 0;
360
    surface.mem        = (uintptr_t)ssd->buf;
G
Gerd Hoffmann 已提交
361
    surface.group_id   = MEMSLOT_GROUP_HOST;
362

363
    qemu_spice_create_primary_surface(ssd, 0, &surface, QXL_SYNC);
G
Gerd Hoffmann 已提交
364 365 366 367
}

void qemu_spice_destroy_host_primary(SimpleSpiceDisplay *ssd)
{
368
    dprint(1, "%s/%d:\n", __func__, ssd->qxl.id);
G
Gerd Hoffmann 已提交
369

370
    qemu_spice_destroy_primary_surface(ssd, 0, QXL_SYNC);
G
Gerd Hoffmann 已提交
371 372
}

373
void qemu_spice_display_init_common(SimpleSpiceDisplay *ssd)
374 375
{
    qemu_mutex_init(&ssd->lock);
376
    QTAILQ_INIT(&ssd->updates);
377 378
    ssd->mouse_x = -1;
    ssd->mouse_y = -1;
379 380 381
    if (ssd->num_surfaces == 0) {
        ssd->num_surfaces = 1024;
    }
382 383
}

G
Gerd Hoffmann 已提交
384 385 386 387 388 389 390
/* display listener callbacks */

void qemu_spice_display_update(SimpleSpiceDisplay *ssd,
                               int x, int y, int w, int h)
{
    QXLRect update_area;

391 392
    dprint(2, "%s/%d: x %d y %d w %d h %d\n", __func__,
           ssd->qxl.id, x, y, w, h);
G
Gerd Hoffmann 已提交
393 394 395 396 397 398 399 400 401 402 403
    update_area.left = x,
    update_area.right = x + w;
    update_area.top = y;
    update_area.bottom = y + h;

    if (qemu_spice_rect_is_empty(&ssd->dirty)) {
        ssd->notify++;
    }
    qemu_spice_rect_union(&ssd->dirty, &update_area);
}

404 405
void qemu_spice_display_switch(SimpleSpiceDisplay *ssd,
                               DisplaySurface *surface)
G
Gerd Hoffmann 已提交
406
{
407
    SimpleSpiceUpdate *update;
408
    bool need_destroy;
409

410 411
    if (surface && ssd->surface &&
        surface_width(surface) == pixman_image_get_width(ssd->surface) &&
412 413
        surface_height(surface) == pixman_image_get_height(ssd->surface) &&
        surface_format(surface) == pixman_image_get_format(ssd->surface)) {
414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433
        /* no-resize fast path: just swap backing store */
        dprint(1, "%s/%d: fast (%dx%d)\n", __func__, ssd->qxl.id,
               surface_width(surface), surface_height(surface));
        qemu_mutex_lock(&ssd->lock);
        ssd->ds = surface;
        pixman_image_unref(ssd->surface);
        ssd->surface = pixman_image_ref(ssd->ds->image);
        qemu_mutex_unlock(&ssd->lock);
        qemu_spice_display_update(ssd, 0, 0,
                                  surface_width(surface),
                                  surface_height(surface));
        return;
    }

    /* full mode switch */
    dprint(1, "%s/%d: full (%dx%d -> %dx%d)\n", __func__, ssd->qxl.id,
           ssd->surface ? pixman_image_get_width(ssd->surface)  : 0,
           ssd->surface ? pixman_image_get_height(ssd->surface) : 0,
           surface ? surface_width(surface)  : 0,
           surface ? surface_height(surface) : 0);
G
Gerd Hoffmann 已提交
434 435

    memset(&ssd->dirty, 0, sizeof(ssd->dirty));
G
Gerd Hoffmann 已提交
436 437 438 439 440 441
    if (ssd->surface) {
        pixman_image_unref(ssd->surface);
        ssd->surface = NULL;
        pixman_image_unref(ssd->mirror);
        ssd->mirror = NULL;
    }
G
Gerd Hoffmann 已提交
442

443
    qemu_mutex_lock(&ssd->lock);
444
    need_destroy = (ssd->ds != NULL);
G
Gerd Hoffmann 已提交
445
    ssd->ds = surface;
446 447 448
    while ((update = QTAILQ_FIRST(&ssd->updates)) != NULL) {
        QTAILQ_REMOVE(&ssd->updates, update, next);
        qemu_spice_destroy_update(ssd, update);
449 450
    }
    qemu_mutex_unlock(&ssd->lock);
451 452 453 454
    if (need_destroy) {
        qemu_spice_destroy_host_primary(ssd);
    }
    if (ssd->ds) {
455 456 457
        ssd->surface = pixman_image_ref(ssd->ds->image);
        ssd->mirror  = qemu_pixman_mirror_create(ssd->ds->format,
                                                 ssd->ds->image);
458 459
        qemu_spice_create_host_primary(ssd);
    }
G
Gerd Hoffmann 已提交
460 461 462

    memset(&ssd->dirty, 0, sizeof(ssd->dirty));
    ssd->notify++;
463 464 465 466 467 468 469

    qemu_mutex_lock(&ssd->lock);
    if (ssd->cursor) {
        g_free(ssd->ptr_define);
        ssd->ptr_define = qemu_spice_create_cursor_update(ssd, ssd->cursor, 0);
    }
    qemu_mutex_unlock(&ssd->lock);
G
Gerd Hoffmann 已提交
470 471
}

472
static void qemu_spice_cursor_refresh_unlocked(SimpleSpiceDisplay *ssd)
G
Gerd Hoffmann 已提交
473
{
474
    if (ssd->cursor) {
475 476
        assert(ssd->dcl.con);
        dpy_cursor_define(ssd->dcl.con, ssd->cursor);
477 478
    }
    if (ssd->mouse_x != -1 && ssd->mouse_y != -1) {
479 480
        assert(ssd->dcl.con);
        dpy_mouse_set(ssd->dcl.con, ssd->mouse_x, ssd->mouse_y, 1);
481 482 483
        ssd->mouse_x = -1;
        ssd->mouse_y = -1;
    }
484 485
}

486 487 488 489 490 491 492 493 494
void qemu_spice_cursor_refresh_bh(void *opaque)
{
    SimpleSpiceDisplay *ssd = opaque;

    qemu_mutex_lock(&ssd->lock);
    qemu_spice_cursor_refresh_unlocked(ssd);
    qemu_mutex_unlock(&ssd->lock);
}

495 496
void qemu_spice_display_refresh(SimpleSpiceDisplay *ssd)
{
497
    dprint(3, "%s/%d:\n", __func__, ssd->qxl.id);
498
    graphic_hw_update(ssd->dcl.con);
499 500

    qemu_mutex_lock(&ssd->lock);
G
Gerd Hoffmann 已提交
501
    if (QTAILQ_EMPTY(&ssd->updates) && ssd->ds) {
502
        qemu_spice_create_update(ssd);
503 504
        ssd->notify++;
    }
505 506
    qemu_mutex_unlock(&ssd->lock);

G
Gerd Hoffmann 已提交
507 508
    if (ssd->notify) {
        ssd->notify = 0;
509
        qemu_spice_wakeup(ssd);
510
        dprint(2, "%s/%d: notify\n", __func__, ssd->qxl.id);
G
Gerd Hoffmann 已提交
511 512 513 514 515 516 517 518 519
    }
}

/* spice display interface callbacks */

static void interface_attach_worker(QXLInstance *sin, QXLWorker *qxl_worker)
{
    SimpleSpiceDisplay *ssd = container_of(sin, SimpleSpiceDisplay, qxl);

520
    dprint(1, "%s/%d:\n", __func__, ssd->qxl.id);
G
Gerd Hoffmann 已提交
521 522 523 524 525
    ssd->worker = qxl_worker;
}

static void interface_set_compression_level(QXLInstance *sin, int level)
{
526
    dprint(1, "%s/%d:\n", __func__, sin->id);
G
Gerd Hoffmann 已提交
527 528 529 530 531
    /* nothing to do */
}

static void interface_set_mm_time(QXLInstance *sin, uint32_t mm_time)
{
532
    dprint(3, "%s/%d:\n", __func__, sin->id);
G
Gerd Hoffmann 已提交
533 534 535 536 537 538 539 540 541 542 543 544
    /* nothing to do */
}

static void interface_get_init_info(QXLInstance *sin, QXLDevInitInfo *info)
{
    SimpleSpiceDisplay *ssd = container_of(sin, SimpleSpiceDisplay, qxl);

    info->memslot_gen_bits = MEMSLOT_GENERATION_BITS;
    info->memslot_id_bits  = MEMSLOT_SLOT_BITS;
    info->num_memslots = NUM_MEMSLOTS;
    info->num_memslots_groups = NUM_MEMSLOTS_GROUPS;
    info->internal_groupslot_id = 0;
545
    info->qxl_ram_size = 16 * 1024 * 1024;
546
    info->n_surfaces = ssd->num_surfaces;
G
Gerd Hoffmann 已提交
547 548
}

549
static int interface_get_command(QXLInstance *sin, QXLCommandExt *ext)
G
Gerd Hoffmann 已提交
550 551 552
{
    SimpleSpiceDisplay *ssd = container_of(sin, SimpleSpiceDisplay, qxl);
    SimpleSpiceUpdate *update;
553
    int ret = false;
G
Gerd Hoffmann 已提交
554

555
    dprint(3, "%s/%d:\n", __func__, ssd->qxl.id);
556 557

    qemu_mutex_lock(&ssd->lock);
558 559 560
    update = QTAILQ_FIRST(&ssd->updates);
    if (update != NULL) {
        QTAILQ_REMOVE(&ssd->updates, update, next);
561 562
        *ext = update->ext;
        ret = true;
G
Gerd Hoffmann 已提交
563
    }
564 565 566
    qemu_mutex_unlock(&ssd->lock);

    return ret;
G
Gerd Hoffmann 已提交
567 568 569 570
}

static int interface_req_cmd_notification(QXLInstance *sin)
{
571
    dprint(1, "%s/%d:\n", __func__, sin->id);
G
Gerd Hoffmann 已提交
572 573 574 575
    return 1;
}

static void interface_release_resource(QXLInstance *sin,
576
                                       QXLReleaseInfoExt rext)
G
Gerd Hoffmann 已提交
577 578
{
    SimpleSpiceDisplay *ssd = container_of(sin, SimpleSpiceDisplay, qxl);
G
Gerd Hoffmann 已提交
579 580 581
    SimpleSpiceUpdate *update;
    SimpleSpiceCursor *cursor;
    QXLCommandExt *ext;
G
Gerd Hoffmann 已提交
582

583
    dprint(2, "%s/%d:\n", __func__, ssd->qxl.id);
G
Gerd Hoffmann 已提交
584
    ext = (void *)(intptr_t)(rext.info->id);
G
Gerd Hoffmann 已提交
585 586 587 588 589 590 591 592 593 594 595 596
    switch (ext->cmd.type) {
    case QXL_CMD_DRAW:
        update = container_of(ext, SimpleSpiceUpdate, ext);
        qemu_spice_destroy_update(ssd, update);
        break;
    case QXL_CMD_CURSOR:
        cursor = container_of(ext, SimpleSpiceCursor, ext);
        g_free(cursor);
        break;
    default:
        g_assert_not_reached();
    }
G
Gerd Hoffmann 已提交
597 598
}

599
static int interface_get_cursor_command(QXLInstance *sin, QXLCommandExt *ext)
G
Gerd Hoffmann 已提交
600
{
G
Gerd Hoffmann 已提交
601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619
    SimpleSpiceDisplay *ssd = container_of(sin, SimpleSpiceDisplay, qxl);
    int ret;

    dprint(3, "%s/%d:\n", __func__, ssd->qxl.id);

    qemu_mutex_lock(&ssd->lock);
    if (ssd->ptr_define) {
        *ext = ssd->ptr_define->ext;
        ssd->ptr_define = NULL;
        ret = true;
    } else if (ssd->ptr_move) {
        *ext = ssd->ptr_move->ext;
        ssd->ptr_move = NULL;
        ret = true;
    } else {
        ret = false;
    }
    qemu_mutex_unlock(&ssd->lock);
    return ret;
G
Gerd Hoffmann 已提交
620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640
}

static int interface_req_cursor_notification(QXLInstance *sin)
{
    dprint(1, "%s:\n", __FUNCTION__);
    return 1;
}

static void interface_notify_update(QXLInstance *sin, uint32_t update_id)
{
    fprintf(stderr, "%s: abort()\n", __FUNCTION__);
    abort();
}

static int interface_flush_resources(QXLInstance *sin)
{
    fprintf(stderr, "%s: abort()\n", __FUNCTION__);
    abort();
    return 0;
}

641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665
static void interface_update_area_complete(QXLInstance *sin,
        uint32_t surface_id,
        QXLRect *dirty, uint32_t num_updated_rects)
{
    /* should never be called, used in qxl native mode only */
    fprintf(stderr, "%s: abort()\n", __func__);
    abort();
}

/* called from spice server thread context only */
static void interface_async_complete(QXLInstance *sin, uint64_t cookie_token)
{
    /* should never be called, used in qxl native mode only */
    fprintf(stderr, "%s: abort()\n", __func__);
    abort();
}

static void interface_set_client_capabilities(QXLInstance *sin,
                                              uint8_t client_present,
                                              uint8_t caps[58])
{
    dprint(3, "%s:\n", __func__);
}

static int interface_client_monitors_config(QXLInstance *sin,
G
Gerd Hoffmann 已提交
666
                                            VDAgentMonitorsConfig *mc)
667
{
G
Gerd Hoffmann 已提交
668 669
    SimpleSpiceDisplay *ssd = container_of(sin, SimpleSpiceDisplay, qxl);
    QemuUIInfo info;
G
Gerd Hoffmann 已提交
670 671 672 673

    if (!dpy_ui_info_supported(ssd->dcl.con)) {
        return 0; /* == not supported by guest */
    }
G
Gerd Hoffmann 已提交
674

675 676 677 678
    if (!mc) {
        return 1;
    }

G
Gerd Hoffmann 已提交
679 680 681 682 683 684 685 686 687
    /*
     * FIXME: multihead is tricky due to the way
     * spice has multihead implemented.
     */
    memset(&info, 0, sizeof(info));
    if (mc->num_of_monitors > 0) {
        info.width  = mc->monitors[0].width;
        info.height = mc->monitors[0].height;
    }
G
Gerd Hoffmann 已提交
688 689 690 691
    dpy_set_ui_info(ssd->dcl.con, &info);
    dprint(1, "%s/%d: size %dx%d\n", __func__, ssd->qxl.id,
           info.width, info.height);
    return 1;
692 693
}

G
Gerd Hoffmann 已提交
694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712
static const QXLInterface dpy_interface = {
    .base.type               = SPICE_INTERFACE_QXL,
    .base.description        = "qemu simple display",
    .base.major_version      = SPICE_INTERFACE_QXL_MAJOR,
    .base.minor_version      = SPICE_INTERFACE_QXL_MINOR,

    .attache_worker          = interface_attach_worker,
    .set_compression_level   = interface_set_compression_level,
    .set_mm_time             = interface_set_mm_time,
    .get_init_info           = interface_get_init_info,

    /* the callbacks below are called from spice server thread context */
    .get_command             = interface_get_command,
    .req_cmd_notification    = interface_req_cmd_notification,
    .release_resource        = interface_release_resource,
    .get_cursor_command      = interface_get_cursor_command,
    .req_cursor_notification = interface_req_cursor_notification,
    .notify_update           = interface_notify_update,
    .flush_resources         = interface_flush_resources,
713 714 715 716
    .async_complete          = interface_async_complete,
    .update_area_complete    = interface_update_area_complete,
    .set_client_capabilities = interface_set_client_capabilities,
    .client_monitors_config  = interface_client_monitors_config,
G
Gerd Hoffmann 已提交
717 718
};

719 720
static void display_update(DisplayChangeListener *dcl,
                           int x, int y, int w, int h)
G
Gerd Hoffmann 已提交
721
{
G
Gerd Hoffmann 已提交
722 723
    SimpleSpiceDisplay *ssd = container_of(dcl, SimpleSpiceDisplay, dcl);
    qemu_spice_display_update(ssd, x, y, w, h);
G
Gerd Hoffmann 已提交
724 725
}

726
static void display_switch(DisplayChangeListener *dcl,
727
                           DisplaySurface *surface)
G
Gerd Hoffmann 已提交
728
{
G
Gerd Hoffmann 已提交
729
    SimpleSpiceDisplay *ssd = container_of(dcl, SimpleSpiceDisplay, dcl);
730
    qemu_spice_display_switch(ssd, surface);
G
Gerd Hoffmann 已提交
731 732
}

733
static void display_refresh(DisplayChangeListener *dcl)
G
Gerd Hoffmann 已提交
734
{
G
Gerd Hoffmann 已提交
735 736
    SimpleSpiceDisplay *ssd = container_of(dcl, SimpleSpiceDisplay, dcl);
    qemu_spice_display_refresh(ssd);
G
Gerd Hoffmann 已提交
737 738
}

G
Gerd Hoffmann 已提交
739 740 741 742 743 744 745
static void display_mouse_set(DisplayChangeListener *dcl,
                              int x, int y, int on)
{
    SimpleSpiceDisplay *ssd = container_of(dcl, SimpleSpiceDisplay, dcl);

    qemu_mutex_lock(&ssd->lock);
    ssd->ptr_x = x;
746
    ssd->ptr_y = y;
747
    g_free(ssd->ptr_move);
M
Marc-André Lureau 已提交
748
    ssd->ptr_move = qemu_spice_create_cursor_update(ssd, NULL, on);
G
Gerd Hoffmann 已提交
749 750 751 752 753 754 755 756 757
    qemu_mutex_unlock(&ssd->lock);
}

static void display_mouse_define(DisplayChangeListener *dcl,
                                 QEMUCursor *c)
{
    SimpleSpiceDisplay *ssd = container_of(dcl, SimpleSpiceDisplay, dcl);

    qemu_mutex_lock(&ssd->lock);
758 759 760 761 762
    if (c) {
        cursor_get(c);
    }
    cursor_put(ssd->cursor);
    ssd->cursor = c;
763 764
    ssd->hot_x = c->hot_x;
    ssd->hot_y = c->hot_y;
765 766 767
    g_free(ssd->ptr_move);
    ssd->ptr_move = NULL;
    g_free(ssd->ptr_define);
M
Marc-André Lureau 已提交
768
    ssd->ptr_define = qemu_spice_create_cursor_update(ssd, c, 0);
G
Gerd Hoffmann 已提交
769 770 771
    qemu_mutex_unlock(&ssd->lock);
}

772
static const DisplayChangeListenerOps display_listener_ops = {
773 774 775 776 777 778 779
    .dpy_name             = "spice",
    .dpy_gfx_update       = display_update,
    .dpy_gfx_switch       = display_switch,
    .dpy_gfx_check_format = qemu_pixman_check_format,
    .dpy_refresh          = display_refresh,
    .dpy_mouse_set        = display_mouse_set,
    .dpy_cursor_define    = display_mouse_define,
G
Gerd Hoffmann 已提交
780 781
};

G
Gerd Hoffmann 已提交
782
static void qemu_spice_display_init_one(QemuConsole *con)
G
Gerd Hoffmann 已提交
783
{
G
Gerd Hoffmann 已提交
784 785
    SimpleSpiceDisplay *ssd = g_new0(SimpleSpiceDisplay, 1);

786
    qemu_spice_display_init_common(ssd);
G
Gerd Hoffmann 已提交
787

788 789 790
    ssd->dcl.ops = &display_listener_ops;
    ssd->dcl.con = con;

G
Gerd Hoffmann 已提交
791
    ssd->qxl.base.sif = &dpy_interface.base;
G
Gerd Hoffmann 已提交
792
    qemu_spice_add_display_interface(&ssd->qxl, con);
G
Gerd Hoffmann 已提交
793 794
    assert(ssd->worker);
    qemu_spice_create_host_memslot(ssd);
795

796
    register_displaychangelistener(&ssd->dcl);
G
Gerd Hoffmann 已提交
797
}
G
Gerd Hoffmann 已提交
798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814

void qemu_spice_display_init(void)
{
    QemuConsole *con;
    int i;

    for (i = 0;; i++) {
        con = qemu_console_lookup_by_index(i);
        if (!con || !qemu_console_is_graphic(con)) {
            break;
        }
        if (qemu_spice_have_display_interface(con)) {
            continue;
        }
        qemu_spice_display_init_one(con);
    }
}