[Spice-devel] [PATCH 01/23] server/red_worker: s/red_send_data/red_channel_send/

Marc-André Lureau marcandre.lureau at gmail.com
Sat Feb 12 12:03:13 PST 2011


ack

On Fri, Feb 11, 2011 at 6:22 PM, Alon Levy <alevy at redhat.com> wrote:
> ---
>  server/red_worker.c |   16 ++++++++--------
>  1 files changed, 8 insertions(+), 8 deletions(-)
>
> diff --git a/server/red_worker.c b/server/red_worker.c
> index d75856e..1113b4b 100644
> --- a/server/red_worker.c
> +++ b/server/red_worker.c
> @@ -7336,7 +7336,7 @@ static void inline channel_release_res(RedChannel *channel)
>     channel->send_data.item = NULL;
>  }
>
> -static void red_send_data(RedChannel *channel)
> +static void red_channel_send(RedChannel *channel)
>  {
>     for (;;) {
>         uint32_t n = channel->send_data.size - channel->send_data.pos;
> @@ -7407,7 +7407,7 @@ static inline void red_channel_begin_send_message(RedChannel *channel)
>     channel->send_data.header->size =  channel->send_data.size - sizeof(SpiceDataHeader);
>     channel->ack_data.messages_window++;
>     channel->send_data.header = NULL; /* avoid writing to this until we have a new message */
> -    red_send_data(channel);
> +    red_channel_send(channel);
>  }
>
>  static inline void display_begin_send_message(DisplayChannel *channel)
> @@ -8816,7 +8816,7 @@ static inline void flush_display_commands(RedWorker *worker)
>             RedChannel *channel = (RedChannel *)worker->display_channel;
>             red_ref_channel(channel);
>             red_receive(channel);
> -            red_send_data(channel);
> +            red_channel_send(channel);
>             if (red_now() >= end_time) {
>                 red_printf("update timeout");
>                 red_disconnect_display(channel);
> @@ -8858,7 +8858,7 @@ static inline void flush_cursor_commands(RedWorker *worker)
>             RedChannel *channel = (RedChannel *)worker->cursor_channel;
>             red_ref_channel(channel);
>             red_receive(channel);
> -            red_send_data(channel);
> +            red_channel_send(channel);
>             if (red_now() >= end_time) {
>                 red_printf("flush cursor timeout");
>                 red_disconnect_cursor(channel);
> @@ -9435,7 +9435,7 @@ static void handle_channel_events(EventListener *in_listener, uint32_t events)
>     }
>
>     if (channel->send_data.blocked) {
> -        red_send_data(channel);
> +        red_channel_send(channel);
>     }
>  }
>
> @@ -9708,7 +9708,7 @@ static void red_wait_outgoing_item(RedChannel *channel)
>     do {
>         usleep(DETACH_SLEEP_DURATION);
>         red_receive(channel);
> -        red_send_data(channel);
> +        red_channel_send(channel);
>     } while ((blocked = channel->send_data.blocked) && red_now() < end_time);
>
>     if (blocked) {
> @@ -9737,7 +9737,7 @@ static void red_wait_pipe_item_sent(RedChannel *channel, PipeItem *item)
>
>     if (channel->send_data.blocked) {
>         red_receive(channel);
> -        red_send_data(channel);
> +        red_channel_send(channel);
>     }
>     // todo: different push for each channel
>     red_push(common->worker);
> @@ -9745,7 +9745,7 @@ static void red_wait_pipe_item_sent(RedChannel *channel, PipeItem *item)
>     while((item_in_pipe = ring_item_is_linked(&item->link)) && (red_now() < end_time)) {
>         usleep(CHANNEL_PUSH_SLEEP_DURATION);
>         red_receive(channel);
> -        red_send_data(channel);
> +        red_channel_send(channel);
>         red_push(common->worker);
>     }
>
> --
> 1.7.4
>
> _______________________________________________
> Spice-devel mailing list
> Spice-devel at lists.freedesktop.org
> http://lists.freedesktop.org/mailman/listinfo/spice-devel
>



-- 
Marc-André Lureau


More information about the Spice-devel mailing list