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

server/red_channel: make client ack window configurable

Browse Source 
from red_worker
This commit is contained in:
Alon Levy 2010-11-07 12:33:28 +02:00
parent 0512726b68
commit 23f37df548
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/red_channel.c
View File

@ -276,6 +276,7 @@ RedChannel *red_channel_create(int size, RedsStreamContext *peer,
channel->ack_data.messages_window = ~0; // blocks send message (maybe use send_data.blocked +
// block flags)
channel->ack_data.client_generation = ~0;
channel->ack_data.client_window = CLIENT_ACK_WINDOW;
channel->migrate = migrate;
ring_init(&channel->pipe);
@ -400,7 +401,7 @@ int red_channel_handle_message(RedChannel *channel, uint32_t size,
break;
case SPICE_MSGC_ACK:
if (channel->ack_data.client_generation == channel->ack_data.generation) {
channel->ack_data.messages_window -= CLIENT_ACK_WINDOW;
channel->ack_data.messages_window -= channel->ack_data.client_window;
red_channel_push(channel);
}
break;
@ -552,7 +553,8 @@ static PipeItem *red_channel_pipe_get(RedChannel *channel)
PipeItem *item;
if (!channel || channel->send_data.blocked ||
(channel->handle_acks && (channel->ack_data.messages_window > CLIENT_ACK_WINDOW * 2)) ||
(channel->handle_acks &&
(channel->ack_data.messages_window > channel->ack_data.client_window * 2)) ||
!(item = (PipeItem *)ring_get_tail(&channel->pipe))) {
return NULL;
}

1
server/red_channel.h
View File

@ -123,6 +123,7 @@ struct RedChannel {
uint32_t generation;
uint32_t client_generation;
uint32_t messages_window;
uint32_t client_window;
} ack_data;
Ring pipe;