spice-display.c 24.5 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 "ui/console.h"
23
#include "sysemu/sysemu.h"
A
Alon Levy 已提交
24
#include "trace.h"
G
Gerd Hoffmann 已提交
25

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

static int debug = 0;

30
static void GCC_FMT_ATTR(2, 3) dprint(int level, const char *fmt, ...)
G
Gerd Hoffmann 已提交
31 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
{
    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 已提交
63 64 65 66 67 68 69 70 71 72
QXLCookie *qxl_cookie_new(int type, uint64_t io)
{
    QXLCookie *cookie;

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

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

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

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

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

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

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

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

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

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

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

152
    drawable->bbox            = *rect;
G
Gerd Hoffmann 已提交
153 154
    drawable->clip.type       = SPICE_CLIP_TYPE_NONE;
    drawable->effect          = QXL_EFFECT_OPAQUE;
G
Gerd Hoffmann 已提交
155
    drawable->release_info.id = (uintptr_t)(&update->ext);
G
Gerd Hoffmann 已提交
156 157 158 159
    drawable->type            = QXL_DRAW_COPY;
    drawable->surfaces_dest[0] = -1;
    drawable->surfaces_dest[1] = -1;
    drawable->surfaces_dest[2] = -1;
A
Alon Levy 已提交
160 161 162 163
    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 已提交
164 165

    drawable->u.copy.rop_descriptor  = SPICE_ROPD_OP_PUT;
166
    drawable->u.copy.src_bitmap      = (uintptr_t)image;
G
Gerd Hoffmann 已提交
167 168 169 170 171 172 173 174 175
    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;
176
    image->bitmap.data = (uintptr_t)(update->bitmap);
G
Gerd Hoffmann 已提交
177 178 179
    image->bitmap.palette = 0;
    image->bitmap.format = SPICE_BITMAP_FMT_32BIT;

180
    dest = pixman_image_create_bits(PIXMAN_LE_x8r8g8b8, bw, bh,
G
Gerd Hoffmann 已提交
181 182 183 184 185 186 187 188
                                    (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 已提交
189 190

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

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

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

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

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

G
Gerd Hoffmann 已提交
213
    guest = surface_data(ssd->ds);
G
Gerd Hoffmann 已提交
214
    mirror = (void *)pixman_image_get_data(ssd->mirror);
215
    for (y = ssd->dirty.top; y < ssd->dirty.bottom; y++) {
216 217
        yoff1 = y * surface_stride(ssd->ds);
        yoff2 = y * pixman_image_get_stride(ssd->mirror);
218 219 220 221
        for (x = ssd->dirty.left; x < ssd->dirty.right; x += blksize) {
            xoff = x * bpp;
            blk = x / blksize;
            bw = MIN(blksize, ssd->dirty.right - x);
222 223
            if (memcmp(guest + yoff1 + xoff,
                       mirror + yoff2 + xoff,
224 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
                       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;
        }
    }

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

G
Gerd Hoffmann 已提交
261 262
static SimpleSpiceCursor*
qemu_spice_create_cursor_update(SimpleSpiceDisplay *ssd,
M
Marc-André Lureau 已提交
263 264
                                QEMUCursor *c,
                                int on)
G
Gerd Hoffmann 已提交
265 266 267 268 269 270 271 272 273 274 275 276 277 278
{
    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;
279 280
        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 已提交
281 282 283 284 285 286 287 288 289 290 291
        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 已提交
292 293
    } else if (!on) {
        ccmd->type = QXL_CURSOR_HIDE;
G
Gerd Hoffmann 已提交
294 295
    } else {
        ccmd->type = QXL_CURSOR_MOVE;
296 297
        ccmd->u.position.x = ssd->ptr_x + ssd->hot_x;
        ccmd->u.position.y = ssd->ptr_y + ssd->hot_y;
G
Gerd Hoffmann 已提交
298 299 300 301 302 303 304 305 306
    }
    ccmd->release_info.id = (uintptr_t)(&update->ext);

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

    return update;
}

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

void qemu_spice_create_host_memslot(SimpleSpiceDisplay *ssd)
{
    QXLDevMemSlot memslot;

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

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

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

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

338 339 340 341 342 343 344 345 346 347 348 349 350
    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 已提交
351 352

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

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

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

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

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

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

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

390 391
    dprint(2, "%s/%d: x %d y %d w %d h %d\n", __func__,
           ssd->qxl.id, x, y, w, h);
G
Gerd Hoffmann 已提交
392 393 394 395 396 397 398 399 400 401 402
    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);
}

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

409 410
    if (surface && ssd->surface &&
        surface_width(surface) == pixman_image_get_width(ssd->surface) &&
411 412
        surface_height(surface) == pixman_image_get_height(ssd->surface) &&
        surface_format(surface) == pixman_image_get_format(ssd->surface)) {
413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432
        /* 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
    SimpleSpiceDisplay *ssd = container_of(sin, SimpleSpiceDisplay, qxl);
    QemuUIInfo info;
G
Gerd Hoffmann 已提交
664 665 666 667

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

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

G
Gerd Hoffmann 已提交
673 674 675 676 677 678 679 680 681
    /*
     * 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 已提交
682 683 684 685
    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;
686 687
}

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

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

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

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

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

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

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

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

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

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

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

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