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
/*
 * 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 463 464

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

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

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

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

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

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

/* spice display interface callbacks */

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

670 671 672 673
    if (!mc) {
        return 1;
    }

G
Gerd Hoffmann 已提交
674 675 676 677 678 679 680 681 682
    /*
     * 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 已提交
683 684 685 686
    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;
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;
742
    g_free(ssd->ptr_move);
M
Marc-André Lureau 已提交
743
    ssd->ptr_move = qemu_spice_create_cursor_update(ssd, NULL, on);
G
Gerd Hoffmann 已提交
744 745 746 747 748 749 750 751 752
    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);
753 754
    ssd->hot_x = c->hot_x;
    ssd->hot_y = c->hot_y;
755 756 757
    g_free(ssd->ptr_move);
    ssd->ptr_move = NULL;
    g_free(ssd->ptr_define);
M
Marc-André Lureau 已提交
758
    ssd->ptr_define = qemu_spice_create_cursor_update(ssd, c, 0);
G
Gerd Hoffmann 已提交
759 760 761
    qemu_mutex_unlock(&ssd->lock);
}

762
static const DisplayChangeListenerOps display_listener_ops = {
763 764 765 766 767 768 769
    .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 已提交
770 771
};

G
Gerd Hoffmann 已提交
772
static void qemu_spice_display_init_one(QemuConsole *con)
G
Gerd Hoffmann 已提交
773
{
G
Gerd Hoffmann 已提交
774 775
    SimpleSpiceDisplay *ssd = g_new0(SimpleSpiceDisplay, 1);

776
    qemu_spice_display_init_common(ssd);
G
Gerd Hoffmann 已提交
777

G
Gerd Hoffmann 已提交
778
    ssd->qxl.base.sif = &dpy_interface.base;
G
Gerd Hoffmann 已提交
779
    qemu_spice_add_display_interface(&ssd->qxl, con);
G
Gerd Hoffmann 已提交
780
    assert(ssd->worker);
G
Gerd Hoffmann 已提交
781

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

G
Gerd Hoffmann 已提交
784
    ssd->dcl.ops = &display_listener_ops;
G
Gerd Hoffmann 已提交
785
    ssd->dcl.con = con;
786
    register_displaychangelistener(&ssd->dcl);
G
Gerd Hoffmann 已提交
787
}
G
Gerd Hoffmann 已提交
788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804

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