pxcloud/spice
6
0
Fork 0
mirror of https://gitlab.uni-freiburg.de/opensourcevdi/spice synced 2026-08-12 15:00:30 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

server/red_channel: move SET_ACK to red_channel

Browse Source
This commit is contained in:
Alon Levy 2010-11-09 11:57:13 +02:00
parent 2fcd35b073
commit 5e1ba1101b
4 changed files with 43 additions and 52 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
server/red_channel.c
View File

@ -28,6 +28,7 @@
#include <errno.h>
#include "stat.h"
#include "red_channel.h"
#include "generated_marshallers.h"
static PipeItem *red_channel_pipe_get(RedChannel *channel);
static void red_channel_event(int fd, int event, void *data);
@ -253,10 +254,33 @@ static void red_channel_reset_send_data(RedChannel *channel)
channel->send_data.header->serial = ++channel->send_data.serial;
}
void red_channel_push_set_ack(RedChannel *channel)
{
red_channel_pipe_add_type(channel, PIPE_ITEM_TYPE_SET_ACK);
}
static void red_channel_send_set_ack(RedChannel *channel)
{
SpiceMsgSetAck ack;
ASSERT(channel);
red_channel_init_send_data(channel, SPICE_MSG_SET_ACK, NULL);
ack.generation = ++channel->ack_data.generation;
ack.window = channel->ack_data.client_window;
channel->ack_data.messages_window = 0;
spice_marshall_msg_set_ack(channel->send_data.marshaller, &ack);
red_channel_begin_send_message(channel);
}
static void red_channel_send_item(RedChannel *channel, PipeItem *item)
{
red_channel_reset_send_data(channel);
switch (item->type) {
case PIPE_ITEM_TYPE_SET_ACK:
red_channel_send_set_ack(channel);
return;
}
/* only reached if not handled here */
channel->send_item(channel, item);
@ -265,6 +289,9 @@ static void red_channel_send_item(RedChannel *channel, PipeItem *item)
static void red_channel_release_item(RedChannel *channel, PipeItem *item, int item_pushed)
{
switch (item->type) {
case PIPE_ITEM_TYPE_SET_ACK:
free(item);
return;
}
/* only reached if not handled here */
channel->release_item(channel, item, item_pushed);

11
server/red_channel.h
View File

@ -89,6 +89,16 @@ typedef struct BufDescriptor {
uint8_t *data;
} BufDescriptor;
/* Messages handled by red_channel
* SET_ACK - sent to client on channel connection
* Note that the numbers don't have to correspond to spice message types,
* but we keep the 100 first allocated for base channel approach.
* */
enum {
PIPE_ITEM_TYPE_SET_ACK=1,
PIPE_ITEM_TYPE_CHANNEL_BASE=101,
};
typedef struct PipeItem {
RingItem link;
int type;
@ -226,6 +236,7 @@ void red_channel_pipe_add_type(RedChannel *channel, int pipe_item_type);
void red_channel_ack_zero_messages_window(RedChannel *channel);
void red_channel_ack_set_client_window(RedChannel *channel, int client_window);
void red_channel_push_set_ack(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

22
server/red_tunnel_worker.c
View File

@ -67,8 +67,7 @@
typedef struct TunnelWorker TunnelWorker;
enum {
PIPE_ITEM_TYPE_SET_ACK,
PIPE_ITEM_TYPE_MIGRATE,
PIPE_ITEM_TYPE_MIGRATE = PIPE_ITEM_TYPE_CHANNEL_BASE,
PIPE_ITEM_TYPE_MIGRATE_DATA,
PIPE_ITEM_TYPE_TUNNEL_INIT,
PIPE_ITEM_TYPE_SERVICE_IP_MAP,
@ -2334,19 +2333,6 @@ static int tunnel_channel_handle_message(RedChannel *channel, SpiceDataHeader *h
/* outgoing msgs
********************************/
static void tunnel_channel_send_set_ack(TunnelChannel *channel, PipeItem *item)
{
ASSERT(channel);
channel->base.send_data.u.ack.generation = ++channel->base.ack_data.generation;
channel->base.send_data.u.ack.window = CLIENT_ACK_WINDOW;
red_channel_init_send_data(&channel->base, SPICE_MSG_SET_ACK, item);
red_channel_add_buf(&channel->base, &channel->base.send_data.u.ack, sizeof(SpiceMsgSetAck));
red_channel_begin_send_message(&channel->base);
}
static void tunnel_channel_send_migrate(TunnelChannel *channel, PipeItem *item)
{
ASSERT(channel);
@ -2813,9 +2799,6 @@ static void tunnel_channel_send_item(RedChannel *channel, PipeItem *item)
TunnelChannel *tunnel_channel = (TunnelChannel *)channel;
switch (item->type) {
case PIPE_ITEM_TYPE_SET_ACK:
tunnel_channel_send_set_ack(tunnel_channel, item);
break;
case PIPE_ITEM_TYPE_TUNNEL_INIT:
tunnel_channel_send_init(tunnel_channel, item);
break;
@ -2860,7 +2843,6 @@ static void tunnel_channel_release_pipe_item(RedChannel *channel, PipeItem *item
return;
}
switch (item->type) {
case PIPE_ITEM_TYPE_SET_ACK:
case PIPE_ITEM_TYPE_TUNNEL_INIT:
free(item);
break;
@ -3409,7 +3391,7 @@ static void tunnel_channel_disconnect(RedChannel *channel)
static void on_new_tunnel_channel(TunnelChannel *channel)
{
red_channel_pipe_add_type(&channel->base, PIPE_ITEM_TYPE_SET_ACK);
red_channel_push_set_ack(&channel->base);
if (channel->base.migrate) {
channel->expect_migrate_data = TRUE;

35
server/red_worker.c
View File

@ -231,12 +231,11 @@ enum {
};
enum {
PIPE_ITEM_TYPE_DRAW,
PIPE_ITEM_TYPE_DRAW = PIPE_ITEM_TYPE_CHANNEL_BASE,
PIPE_ITEM_TYPE_INVAL_ONE,
PIPE_ITEM_TYPE_CURSOR,
PIPE_ITEM_TYPE_MIGRATE,
PIPE_ITEM_TYPE_LOCAL_CURSOR,
PIPE_ITEM_TYPE_SET_ACK,
PIPE_ITEM_TYPE_CURSOR_INIT,
PIPE_ITEM_TYPE_IMAGE,
PIPE_ITEM_TYPE_STREAM_CREATE,
@ -7548,21 +7547,6 @@ static inline void send_qxl_drawable(DisplayChannel *display_channel, Drawable *
red_lossy_send_qxl_drawable(display_channel->common.worker, display_channel, item);
}
static void red_send_set_ack(RedChannel *channel)
{
SpiceMsgSetAck ack;
ASSERT(channel);
red_channel_init_send_data(channel, SPICE_MSG_SET_ACK, NULL);
ack.generation = ++channel->ack_data.generation;
ack.window = channel->ack_data.client_window;
channel->ack_data.messages_window = 0;
spice_marshall_msg_set_ack(channel->send_data.marshaller, &ack);
red_channel_begin_send_message(channel);
}
static inline void red_send_verb(RedChannel *channel, uint16_t verb)
{
ASSERT(channel);
@ -8130,10 +8114,6 @@ static void display_channel_send_item(RedChannel *base, PipeItem *pipe_item)
display_channel_send_migrate_data(display_channel);
free(pipe_item);
break;
case PIPE_ITEM_TYPE_SET_ACK:
red_send_set_ack((RedChannel *)display_channel);
free(pipe_item);
break;
case PIPE_ITEM_TYPE_IMAGE:
red_send_image(display_channel, (ImageItem *)pipe_item);
release_image_item((ImageItem *)pipe_item);
@ -8196,10 +8176,6 @@ static void cursor_channel_send_item(RedChannel *channel, PipeItem *pipe_item)
cursor_channel_send_migrate(cursor_channel);
free(pipe_item);
break;
case PIPE_ITEM_TYPE_SET_ACK:
red_send_set_ack(channel);
free(pipe_item);
break;
case PIPE_ITEM_TYPE_CURSOR_INIT:
red_reset_cursor_cache(cursor_channel);
red_send_cursor_init(cursor_channel);
@ -8672,7 +8648,7 @@ static void on_new_display_channel(RedWorker *worker)
DisplayChannel *display_channel = worker->display_channel;
ASSERT(display_channel);
red_channel_pipe_add_type(&display_channel->common.base, PIPE_ITEM_TYPE_SET_ACK);
red_channel_push_set_ack(&display_channel->common.base);
if (display_channel->common.base.migrate) {
display_channel->expect_migrate_data = TRUE;
@ -9158,8 +9134,6 @@ static void display_channel_release_item(RedChannel *channel, PipeItem *item, in
case PIPE_ITEM_TYPE_IMAGE:
release_image_item((ImageItem *)item);
break;
case PIPE_ITEM_TYPE_SET_ACK:
break;
default:
PANIC("invalid item type");
}
@ -9272,7 +9246,7 @@ static void on_new_cursor_channel(RedWorker *worker)
ASSERT(channel);
red_channel_ack_zero_messages_window(&channel->common.base);
red_channel_pipe_add_type(&channel->common.base, PIPE_ITEM_TYPE_SET_ACK);
red_channel_push_set_ack(&channel->common.base);
if (worker->surfaces[0].context.canvas && !channel->common.base.migrate) {
red_channel_pipe_add_type(&worker->cursor_channel->common.base, PIPE_ITEM_TYPE_CURSOR_INIT);
}
@ -9293,9 +9267,6 @@ static void cursor_channel_release_item(RedChannel *channel, PipeItem *item, int
case PIPE_ITEM_TYPE_CURSOR:
red_release_cursor(common->worker, SPICE_CONTAINEROF(item, CursorItem, pipe_data));
break;
case PIPE_ITEM_TYPE_SET_ACK:
free(item);
break;
default:
PANIC("invalid item type");
}