spice-display.c 24.6 KB
Newer Older
G
Gerd Hoffmann 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
/*
 * 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/>.
 */

#include "qemu-common.h"
19
#include "ui/qemu-spice.h"
20 21
#include "qemu/timer.h"
#include "qemu/queue.h"
22
#include "monitor/monitor.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 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432
    if (surface && ssd->surface &&
        surface_width(surface) == pixman_image_get_width(ssd->surface) &&
        surface_height(surface) == pixman_image_get_height(ssd->surface)) {
        /* 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 已提交
433 434

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

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

    memset(&ssd->dirty, 0, sizeof(ssd->dirty));
    ssd->notify++;
}

464
static void qemu_spice_cursor_refresh_unlocked(SimpleSpiceDisplay *ssd)
G
Gerd Hoffmann 已提交
465
{
466
    if (ssd->cursor) {
467 468
        assert(ssd->dcl.con);
        dpy_cursor_define(ssd->dcl.con, ssd->cursor);
469 470 471 472
        cursor_put(ssd->cursor);
        ssd->cursor = NULL;
    }
    if (ssd->mouse_x != -1 && ssd->mouse_y != -1) {
473 474
        assert(ssd->dcl.con);
        dpy_mouse_set(ssd->dcl.con, ssd->mouse_x, ssd->mouse_y, 1);
475 476 477
        ssd->mouse_x = -1;
        ssd->mouse_y = -1;
    }
478 479
}

480 481 482 483 484 485 486 487 488
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);
}

489 490
void qemu_spice_display_refresh(SimpleSpiceDisplay *ssd)
{
491
    dprint(3, "%s/%d:\n", __func__, ssd->qxl.id);
492
    graphic_hw_update(ssd->dcl.con);
493 494

    qemu_mutex_lock(&ssd->lock);
G
Gerd Hoffmann 已提交
495
    if (QTAILQ_EMPTY(&ssd->updates) && ssd->ds) {
496
        qemu_spice_create_update(ssd);
497 498
        ssd->notify++;
    }
499 500
    qemu_mutex_unlock(&ssd->lock);

G
Gerd Hoffmann 已提交
501 502
    if (ssd->notify) {
        ssd->notify = 0;
503
        qemu_spice_wakeup(ssd);
504
        dprint(2, "%s/%d: notify\n", __func__, ssd->qxl.id);
G
Gerd Hoffmann 已提交
505 506 507 508 509 510 511 512 513
    }
}

/* spice display interface callbacks */

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

514
    dprint(1, "%s/%d:\n", __func__, ssd->qxl.id);
G
Gerd Hoffmann 已提交
515 516 517 518 519
    ssd->worker = qxl_worker;
}

static void interface_set_compression_level(QXLInstance *sin, int level)
{
520
    dprint(1, "%s/%d:\n", __func__, sin->id);
G
Gerd Hoffmann 已提交
521 522 523 524 525
    /* nothing to do */
}

static void interface_set_mm_time(QXLInstance *sin, uint32_t mm_time)
{
526
    dprint(3, "%s/%d:\n", __func__, sin->id);
G
Gerd Hoffmann 已提交
527 528 529 530 531 532 533 534 535 536 537 538
    /* 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;
539
    info->qxl_ram_size = 16 * 1024 * 1024;
540
    info->n_surfaces = ssd->num_surfaces;
G
Gerd Hoffmann 已提交
541 542
}

543
static int interface_get_command(QXLInstance *sin, QXLCommandExt *ext)
G
Gerd Hoffmann 已提交
544 545 546
{
    SimpleSpiceDisplay *ssd = container_of(sin, SimpleSpiceDisplay, qxl);
    SimpleSpiceUpdate *update;
547
    int ret = false;
G
Gerd Hoffmann 已提交
548

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

    qemu_mutex_lock(&ssd->lock);
552 553 554
    update = QTAILQ_FIRST(&ssd->updates);
    if (update != NULL) {
        QTAILQ_REMOVE(&ssd->updates, update, next);
555 556
        *ext = update->ext;
        ret = true;
G
Gerd Hoffmann 已提交
557
    }
558 559 560
    qemu_mutex_unlock(&ssd->lock);

    return ret;
G
Gerd Hoffmann 已提交
561 562 563 564
}

static int interface_req_cmd_notification(QXLInstance *sin)
{
565
    dprint(1, "%s/%d:\n", __func__, sin->id);
G
Gerd Hoffmann 已提交
566 567 568 569
    return 1;
}

static void interface_release_resource(QXLInstance *sin,
570
                                       QXLReleaseInfoExt rext)
G
Gerd Hoffmann 已提交
571 572
{
    SimpleSpiceDisplay *ssd = container_of(sin, SimpleSpiceDisplay, qxl);
G
Gerd Hoffmann 已提交
573 574 575
    SimpleSpiceUpdate *update;
    SimpleSpiceCursor *cursor;
    QXLCommandExt *ext;
G
Gerd Hoffmann 已提交
576

577
    dprint(2, "%s/%d:\n", __func__, ssd->qxl.id);
G
Gerd Hoffmann 已提交
578
    ext = (void *)(intptr_t)(rext.info->id);
G
Gerd Hoffmann 已提交
579 580 581 582 583 584 585 586 587 588 589 590
    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 已提交
591 592
}

593
static int interface_get_cursor_command(QXLInstance *sin, QXLCommandExt *ext)
G
Gerd Hoffmann 已提交
594
{
G
Gerd Hoffmann 已提交
595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613
    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 已提交
614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634
}

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;
}

635 636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659
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 已提交
660
                                            VDAgentMonitorsConfig *mc)
661
{
G
Gerd Hoffmann 已提交
662 663 664 665
    SimpleSpiceDisplay *ssd = container_of(sin, SimpleSpiceDisplay, qxl);
    QemuUIInfo info;
    int rc;

666 667 668 669
    if (!mc) {
        return 1;
    }

G
Gerd Hoffmann 已提交
670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686
    /*
     * 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;
    }
    rc = dpy_set_ui_info(ssd->dcl.con, &info);
    dprint(1, "%s/%d: size %dx%d, rc %d   <---   ==========================\n",
           __func__, ssd->qxl.id, info.width, info.height, rc);
    if (rc != 0) {
        return 0; /* == not supported by guest */
    } else {
        return 1;
    }
687 688
}

G
Gerd Hoffmann 已提交
689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707
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,
708 709 710 711
    .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 已提交
712 713
};

714 715
static void display_update(DisplayChangeListener *dcl,
                           int x, int y, int w, int h)
G
Gerd Hoffmann 已提交
716
{
G
Gerd Hoffmann 已提交
717 718
    SimpleSpiceDisplay *ssd = container_of(dcl, SimpleSpiceDisplay, dcl);
    qemu_spice_display_update(ssd, x, y, w, h);
G
Gerd Hoffmann 已提交
719 720
}

721
static void display_switch(DisplayChangeListener *dcl,
722
                           DisplaySurface *surface)
G
Gerd Hoffmann 已提交
723
{
G
Gerd Hoffmann 已提交
724
    SimpleSpiceDisplay *ssd = container_of(dcl, SimpleSpiceDisplay, dcl);
725
    qemu_spice_display_switch(ssd, surface);
G
Gerd Hoffmann 已提交
726 727
}

728
static void display_refresh(DisplayChangeListener *dcl)
G
Gerd Hoffmann 已提交
729
{
G
Gerd Hoffmann 已提交
730 731
    SimpleSpiceDisplay *ssd = container_of(dcl, SimpleSpiceDisplay, dcl);
    qemu_spice_display_refresh(ssd);
G
Gerd Hoffmann 已提交
732 733
}

G
Gerd Hoffmann 已提交
734 735 736 737 738 739 740
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;
741
    ssd->ptr_y = y;
G
Gerd Hoffmann 已提交
742 743 744
    if (ssd->ptr_move) {
        g_free(ssd->ptr_move);
    }
M
Marc-André Lureau 已提交
745
    ssd->ptr_move = qemu_spice_create_cursor_update(ssd, NULL, on);
G
Gerd Hoffmann 已提交
746 747 748 749 750 751 752 753 754
    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);
755 756
    ssd->hot_x = c->hot_x;
    ssd->hot_y = c->hot_y;
G
Gerd Hoffmann 已提交
757 758 759 760 761 762 763
    if (ssd->ptr_move) {
        g_free(ssd->ptr_move);
        ssd->ptr_move = NULL;
    }
    if (ssd->ptr_define) {
        g_free(ssd->ptr_define);
    }
M
Marc-André Lureau 已提交
764
    ssd->ptr_define = qemu_spice_create_cursor_update(ssd, c, 0);
G
Gerd Hoffmann 已提交
765 766 767
    qemu_mutex_unlock(&ssd->lock);
}

768
static const DisplayChangeListenerOps display_listener_ops = {
769 770 771 772 773 774 775
    .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 已提交
776 777
};

G
Gerd Hoffmann 已提交
778
static void qemu_spice_display_init_one(QemuConsole *con)
G
Gerd Hoffmann 已提交
779
{
G
Gerd Hoffmann 已提交
780 781
    SimpleSpiceDisplay *ssd = g_new0(SimpleSpiceDisplay, 1);

782
    qemu_spice_display_init_common(ssd);
G
Gerd Hoffmann 已提交
783

G
Gerd Hoffmann 已提交
784
    ssd->qxl.base.sif = &dpy_interface.base;
G
Gerd Hoffmann 已提交
785
    qemu_spice_add_display_interface(&ssd->qxl, con);
G
Gerd Hoffmann 已提交
786
    assert(ssd->worker);
G
Gerd Hoffmann 已提交
787

G
Gerd Hoffmann 已提交
788
    qemu_spice_create_host_memslot(ssd);
789

G
Gerd Hoffmann 已提交
790
    ssd->dcl.ops = &display_listener_ops;
G
Gerd Hoffmann 已提交
791
    ssd->dcl.con = con;
792
    register_displaychangelistener(&ssd->dcl);
G
Gerd Hoffmann 已提交
793
}
G
Gerd Hoffmann 已提交
794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810

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);
    }
}