spice-display.c 28.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

    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
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)
{
653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669
    QXLCookie *cookie = (QXLCookie *)(uintptr_t)cookie_token;

    switch (cookie->type) {
#ifdef HAVE_SPICE_GL
    case QXL_COOKIE_TYPE_GL_DRAW_DONE:
    {
        SimpleSpiceDisplay *ssd = container_of(sin, SimpleSpiceDisplay, qxl);
        qemu_bh_schedule(ssd->gl_unblock_bh);
        break;
    }
#endif
    default:
        /* should never be called, used in qxl native mode only */
        fprintf(stderr, "%s: abort()\n", __func__);
        abort();
    }
    g_free(cookie);
670 671 672 673 674 675 676 677 678 679
}

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 已提交
680
                                            VDAgentMonitorsConfig *mc)
681
{
G
Gerd Hoffmann 已提交
682 683
    SimpleSpiceDisplay *ssd = container_of(sin, SimpleSpiceDisplay, qxl);
    QemuUIInfo info;
G
Gerd Hoffmann 已提交
684 685 686 687

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

689 690 691 692
    if (!mc) {
        return 1;
    }

G
Gerd Hoffmann 已提交
693 694 695 696 697 698 699 700 701
    /*
     * 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 已提交
702 703 704 705
    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;
706 707
}

G
Gerd Hoffmann 已提交
708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726
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,
727 728 729 730
    .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 已提交
731 732
};

733 734
static void display_update(DisplayChangeListener *dcl,
                           int x, int y, int w, int h)
G
Gerd Hoffmann 已提交
735
{
G
Gerd Hoffmann 已提交
736 737
    SimpleSpiceDisplay *ssd = container_of(dcl, SimpleSpiceDisplay, dcl);
    qemu_spice_display_update(ssd, x, y, w, h);
G
Gerd Hoffmann 已提交
738 739
}

740
static void display_switch(DisplayChangeListener *dcl,
741
                           DisplaySurface *surface)
G
Gerd Hoffmann 已提交
742
{
G
Gerd Hoffmann 已提交
743
    SimpleSpiceDisplay *ssd = container_of(dcl, SimpleSpiceDisplay, dcl);
744
    qemu_spice_display_switch(ssd, surface);
G
Gerd Hoffmann 已提交
745 746
}

747
static void display_refresh(DisplayChangeListener *dcl)
G
Gerd Hoffmann 已提交
748
{
G
Gerd Hoffmann 已提交
749 750
    SimpleSpiceDisplay *ssd = container_of(dcl, SimpleSpiceDisplay, dcl);
    qemu_spice_display_refresh(ssd);
G
Gerd Hoffmann 已提交
751 752
}

G
Gerd Hoffmann 已提交
753 754 755 756 757 758 759
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;
760
    ssd->ptr_y = y;
761
    g_free(ssd->ptr_move);
M
Marc-André Lureau 已提交
762
    ssd->ptr_move = qemu_spice_create_cursor_update(ssd, NULL, on);
G
Gerd Hoffmann 已提交
763 764 765 766 767 768 769 770 771
    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);
772 773 774 775 776
    if (c) {
        cursor_get(c);
    }
    cursor_put(ssd->cursor);
    ssd->cursor = c;
777 778
    ssd->hot_x = c->hot_x;
    ssd->hot_y = c->hot_y;
779 780 781
    g_free(ssd->ptr_move);
    ssd->ptr_move = NULL;
    g_free(ssd->ptr_define);
M
Marc-André Lureau 已提交
782
    ssd->ptr_define = qemu_spice_create_cursor_update(ssd, c, 0);
G
Gerd Hoffmann 已提交
783 784 785
    qemu_mutex_unlock(&ssd->lock);
}

786
static const DisplayChangeListenerOps display_listener_ops = {
787 788 789 790 791 792 793
    .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 已提交
794 795
};

796 797 798 799
#ifdef HAVE_SPICE_GL

static void qemu_spice_gl_block(SimpleSpiceDisplay *ssd, bool block)
{
G
Gerd Hoffmann 已提交
800 801 802 803 804 805 806 807 808
    uint64_t timeout;

    if (block) {
        timeout = qemu_clock_get_ms(QEMU_CLOCK_REALTIME);
        timeout += 1000; /* one sec */
        timer_mod(ssd->gl_unblock_timer, timeout);
    } else {
        timer_del(ssd->gl_unblock_timer);
    }
809 810 811 812 813 814 815 816 817 818
    graphic_hw_gl_block(ssd->dcl.con, block);
}

static void qemu_spice_gl_unblock_bh(void *opaque)
{
    SimpleSpiceDisplay *ssd = opaque;

    qemu_spice_gl_block(ssd, false);
}

G
Gerd Hoffmann 已提交
819 820 821 822 823
static void qemu_spice_gl_block_timer(void *opaque)
{
    fprintf(stderr, "WARNING: spice: no gl-draw-done within one second\n");
}

824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892
static QEMUGLContext qemu_spice_gl_create_context(DisplayChangeListener *dcl,
                                                  QEMUGLParams *params)
{
    eglMakeCurrent(qemu_egl_display, EGL_NO_SURFACE, EGL_NO_SURFACE,
                   qemu_egl_rn_ctx);
    return qemu_egl_create_context(dcl, params);
}

static void qemu_spice_gl_scanout(DisplayChangeListener *dcl,
                                  uint32_t tex_id,
                                  bool y_0_top,
                                  uint32_t x, uint32_t y,
                                  uint32_t w, uint32_t h)
{
    SimpleSpiceDisplay *ssd = container_of(dcl, SimpleSpiceDisplay, dcl);
    EGLint stride = 0, fourcc = 0;
    int fd = -1;

    if (tex_id) {
        fd = egl_get_fd_for_texture(tex_id, &stride, &fourcc);
        if (fd < 0) {
            fprintf(stderr, "%s: failed to get fd for texture\n", __func__);
            return;
        }
    }
    dprint(0, "%s: %dx%d (stride %d, fourcc 0x%x)\n", __func__,
           w, h, stride, fourcc);

    assert(!tex_id || fd >= 0);

    /* note: spice server will close the fd */
    spice_qxl_gl_scanout(&ssd->qxl, fd,
                         surface_width(ssd->ds),
                         surface_height(ssd->ds),
                         stride, fourcc, y_0_top);
}

static void qemu_spice_gl_update(DisplayChangeListener *dcl,
                                 uint32_t x, uint32_t y, uint32_t w, uint32_t h)
{
    SimpleSpiceDisplay *ssd = container_of(dcl, SimpleSpiceDisplay, dcl);
    uint64_t cookie;

    dprint(1, "%s\n", __func__);
    qemu_spice_gl_block(ssd, true);
    cookie = (uintptr_t)qxl_cookie_new(QXL_COOKIE_TYPE_GL_DRAW_DONE, 0);
    spice_qxl_gl_draw_async(&ssd->qxl, x, y, w, h, cookie);
}

static const DisplayChangeListenerOps display_listener_gl_ops = {
    .dpy_name             = "spice-egl",
    .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,

    .dpy_gl_ctx_create       = qemu_spice_gl_create_context,
    .dpy_gl_ctx_destroy      = qemu_egl_destroy_context,
    .dpy_gl_ctx_make_current = qemu_egl_make_context_current,
    .dpy_gl_ctx_get_current  = qemu_egl_get_current_context,

    .dpy_gl_scanout          = qemu_spice_gl_scanout,
    .dpy_gl_update           = qemu_spice_gl_update,
};

#endif /* HAVE_SPICE_GL */

G
Gerd Hoffmann 已提交
893
static void qemu_spice_display_init_one(QemuConsole *con)
G
Gerd Hoffmann 已提交
894
{
G
Gerd Hoffmann 已提交
895 896
    SimpleSpiceDisplay *ssd = g_new0(SimpleSpiceDisplay, 1);

897
    qemu_spice_display_init_common(ssd);
G
Gerd Hoffmann 已提交
898

899
    ssd->dcl.ops = &display_listener_ops;
900 901 902 903 904
#ifdef HAVE_SPICE_GL
    if (display_opengl) {
        ssd->dcl.ops = &display_listener_gl_ops;
        ssd->dmabuf_fd = -1;
        ssd->gl_unblock_bh = qemu_bh_new(qemu_spice_gl_unblock_bh, ssd);
G
Gerd Hoffmann 已提交
905 906
        ssd->gl_unblock_timer = timer_new_ms(QEMU_CLOCK_REALTIME,
                                             qemu_spice_gl_block_timer, ssd);
907 908
    }
#endif
909 910
    ssd->dcl.con = con;

G
Gerd Hoffmann 已提交
911
    ssd->qxl.base.sif = &dpy_interface.base;
G
Gerd Hoffmann 已提交
912
    qemu_spice_add_display_interface(&ssd->qxl, con);
G
Gerd Hoffmann 已提交
913 914
    assert(ssd->worker);
    qemu_spice_create_host_memslot(ssd);
915

916
    register_displaychangelistener(&ssd->dcl);
G
Gerd Hoffmann 已提交
917
}
G
Gerd Hoffmann 已提交
918 919 920 921 922 923 924 925 926 927 928 929 930 931 932 933 934

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