pxcloud/spice
5
0
Fork 0
mirror of https://gitlab.uni-freiburg.de/opensourcevdi/spice synced 2025-12-29 17:07:15 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Save running property in QXLState

Browse Source 
This is a preparatory patch that states the running property in QXLState
and provides accessor functions that allows us to check whether the QXL
device is running from different threads.

Signed-off-by: Jonathon Jongsma <jjongsma@redhat.com>
Acked-by: Frediano Ziglio <fziglio@redhat.com>
This commit is contained in:
Jonathon Jongsma 2019-03-21 15:52:01 -05:00 committed by Frediano Ziglio
parent 571dc645c5
commit b0eab081be
4 changed files with 28 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
server/red-qxl.c
View File

@ -59,6 +59,8 @@ struct QXLState {
uint32_t device_display_ids[MAX_MONITORS_COUNT];
size_t monitors_count; // length of ^^^
bool running;
pthread_mutex_t scanout_mutex;
SpiceMsgDisplayGlScanoutUnix scanout;
uint64_t gl_draw_cookie;
@ -66,6 +68,17 @@ struct QXLState {
#define GL_DRAW_COOKIE_INVALID (~((uint64_t) 0))
bool red_qxl_is_running(QXLInstance *qxl)
{
return qxl->st->running;
}
/* used by RedWorker */
void red_qxl_set_running(QXLInstance *qxl, bool running)
{
qxl->st->running = running;
}
int red_qxl_check_qxl_version(QXLInstance *qxl, int major, int minor)
{
int qxl_major = qxl_get_interface(qxl)->base.major_version;

3
server/red-qxl.h
View File

@ -44,6 +44,9 @@ const char* red_qxl_get_device_address(const QXLInstance *qxl);
const uint32_t* red_qxl_get_device_display_ids(const QXLInstance *qxl);
size_t red_qxl_get_monitors_count(const QXLInstance *qxl);
/* check if QXL is running, should be used inside the worker thread */
bool red_qxl_is_running(QXLInstance *qxl);
/* Wrappers around QXLInterface vfuncs */
void red_qxl_get_init_info(QXLInstance *qxl, QXLDevInitInfo *info);
int red_qxl_get_command(QXLInstance *qxl, struct QXLCommandExt *cmd);

23
server/red-worker.c
View File

@ -63,7 +63,6 @@ struct RedWorker {
pthread_t thread;
QXLInstance *qxl;
SpiceWatch *dispatch_watch;
int running;
SpiceCoreInterfaceInternal core;
unsigned int event_timeout;
@ -115,7 +114,7 @@ static int red_process_cursor(RedWorker *worker, int *ring_is_empty)
QXLCommandExt ext_cmd;
int n = 0;
if (!worker->running) {
if (!red_qxl_is_running(worker->qxl)) {
*ring_is_empty = TRUE;
return n;
}
@ -173,7 +172,7 @@ static int red_process_display(RedWorker *worker, int *ring_is_empty)
int n = 0;
uint64_t start = spice_get_monotonic_time_ns();
if (!worker->running) {
if (!red_qxl_is_running(worker->qxl)) {
*ring_is_empty = TRUE;
return n;
}
@ -378,7 +377,7 @@ static void guest_set_client_capabilities(RedWorker *worker)
#define CLEAR_CAP(a,c) \
((a)[(c) / 8] &= ~(1 << ((c) % 8)))
if (!worker->running) {
if (!red_qxl_is_running(worker->qxl)) {
return;
}
if ((worker->display_channel == NULL) ||
@ -406,7 +405,7 @@ static void handle_dev_update_async(void *opaque, void *payload)
QXLRect *qxl_dirty_rects = NULL;
uint32_t num_dirty_rects = 0;
spice_return_if_fail(worker->running);
spice_return_if_fail(red_qxl_is_running(worker->qxl));
spice_return_if_fail(qxl_get_interface(worker->qxl)->update_area_complete);
flush_display_commands(worker);
@ -426,7 +425,7 @@ static void handle_dev_update(void *opaque, void *payload)
RedWorkerMessageUpdate *msg = payload;
QXLRect *qxl_dirty_rects = msg->qxl_dirty_rects;
spice_return_if_fail(worker->running);
spice_return_if_fail(red_qxl_is_running(worker->qxl));
flush_display_commands(worker);
display_channel_update(worker->display_channel,
@ -586,9 +585,9 @@ static void handle_dev_stop(void *opaque, void *payload)
RedWorker *worker = opaque;
spice_debug("stop");
spice_assert(worker->running);
spice_assert(red_qxl_is_running(worker->qxl));
worker->running = FALSE;
red_qxl_set_running(worker->qxl, false);
display_channel_free_glz_drawables(worker->display_channel);
display_channel_flush_all_surfaces(worker->display_channel);
@ -606,7 +605,7 @@ static void handle_dev_start(void *opaque, void *payload)
{
RedWorker *worker = opaque;
spice_assert(!worker->running);
spice_assert(!red_qxl_is_running(worker->qxl));
if (worker->cursor_channel) {
CommonGraphicsChannel *common = COMMON_GRAPHICS_CHANNEL(worker->cursor_channel);
common_graphics_channel_set_during_target_migrate(common, FALSE);
@ -616,7 +615,7 @@ static void handle_dev_start(void *opaque, void *payload)
common_graphics_channel_set_during_target_migrate(common, FALSE);
display_channel_wait_for_migrate_data(worker->display_channel);
}
worker->running = TRUE;
red_qxl_set_running(worker->qxl, true);
worker->event_timeout = 0;
guest_set_client_capabilities(worker);
}
@ -637,7 +636,7 @@ static void handle_dev_oom(void *opaque, void *payload)
RedChannel *display_red_channel = RED_CHANNEL(display);
int ring_is_empty;
spice_return_if_fail(worker->running);
spice_return_if_fail(red_qxl_is_running(worker->qxl));
// streams? but without streams also leak
display_channel_debug_oom(display, "OOM1");
while (red_process_display(worker, &ring_is_empty)) {
@ -1153,7 +1152,7 @@ static gboolean worker_source_check(GSource *source)
RedWorkerSource *wsource = SPICE_CONTAINEROF(source, RedWorkerSource, source);
RedWorker *worker = wsource->worker;
return worker->running /* TODO && worker->pending_process */;
return red_qxl_is_running(worker->qxl) /* TODO && worker->pending_process */;
}
static gboolean worker_source_dispatch(GSource *source, GSourceFunc callback,

1
server/red-worker.h
View File

@ -35,6 +35,7 @@ void red_worker_free(RedWorker *worker);
struct Dispatcher *red_qxl_get_dispatcher(QXLInstance *qxl);
void red_qxl_destroy_primary_surface_complete(QXLState *qxl_state);
void red_qxl_create_primary_surface_complete(QXLState *qxl_state, const QXLDevSurfaceCreate* surface);
void red_qxl_set_running(QXLInstance *qxl, bool running);
typedef uint32_t RedWorkerMessage;