diff --git a/server/red_channel.c b/server/red_channel.c index 8476319b..f2665a46 100644 --- a/server/red_channel.c +++ b/server/red_channel.c @@ -711,6 +711,11 @@ int red_channel_any_blocked(RedChannel *channel) return channel->send_data.blocked; } +int red_channel_send_message_pending(RedChannel *channel) +{ + return channel->send_data.header->type != 0; +} + /* accessors for RedChannel */ SpiceMarshaller *red_channel_get_marshaller(RedChannel *channel) { diff --git a/server/red_channel.h b/server/red_channel.h index 96b60952..ce8ef20a 100644 --- a/server/red_channel.h +++ b/server/red_channel.h @@ -257,6 +257,9 @@ int red_channel_all_blocked(RedChannel *channel); /* return TRUE if any of the connected clients to this channel are blocked */ int red_channel_any_blocked(RedChannel *channel); +/* helper for channels that have complex logic that can possibly ready a send */ +int red_channel_send_message_pending(RedChannel *channel); + // TODO: unstaticed for display/cursor channels. they do some specific pushes not through // adding elements or on events. but not sure if this is actually required (only result // should be that they ""try"" a little harder, but if the event system is correct it diff --git a/server/red_worker.c b/server/red_worker.c index e0894d9a..41c53c4c 100644 --- a/server/red_worker.c +++ b/server/red_worker.c @@ -7132,7 +7132,7 @@ static void red_lossy_send_qxl_drawable(RedWorker *worker, DisplayChannel *displ } // a message is pending - if (display_channel->common.base.send_data.header->type != 0) { + if (red_channel_send_message_pending(&display_channel->common.base)) { display_begin_send_message(display_channel); } }