[Spice-devel] [PATCH 2.5/7] Call AsyncRead variables 'async' instead of 'obj'

Marc-André Lureau marcandre.lureau at gmail.com
Tue Mar 25 06:32:46 PDT 2014


ack


On Tue, Mar 25, 2014 at 2:23 PM, Christophe Fergeau <cfergeau at redhat.com>wrote:

> This is a more explicit name.
> ---
>
> This goes after PATCH 2/7 and renames all 'obj' variables.
>
>  server/reds_stream.c | 60
> ++++++++++++++++++++++++++--------------------------
>  1 file changed, 30 insertions(+), 30 deletions(-)
>
> diff --git a/server/reds_stream.c b/server/reds_stream.c
> index 50660e8..ad10889 100644
> --- a/server/reds_stream.c
> +++ b/server/reds_stream.c
> @@ -391,54 +391,54 @@ void reds_stream_set_async_error_handler(RedsStream
> *stream,
>      stream->priv->async_read.error = error_handler;
>  }
>
> -static inline void async_read_clear_handlers(AsyncRead *obj)
> +static inline void async_read_clear_handlers(AsyncRead *async)
>  {
> -    if (obj->stream->watch) {
> -        reds_stream_remove_watch(obj->stream);
> +    if (async->stream->watch) {
> +        reds_stream_remove_watch(async->stream);
>      }
> -    obj->stream = NULL;
> +    async->stream = NULL;
>  }
>
>  void async_read_handler(int fd, int event, void *data)
>  {
> -    AsyncRead *obj = (AsyncRead *)data;
> +    AsyncRead *async = (AsyncRead *)data;
>
>      for (;;) {
> -        int n = obj->end - obj->now;
> +        int n = async->end - async->now;
>
>          spice_assert(n > 0);
> -        n = reds_stream_read(obj->stream, obj->now, n);
> +        n = reds_stream_read(async->stream, async->now, n);
>          if (n <= 0) {
>              if (n < 0) {
>                  switch (errno) {
>                  case EAGAIN:
> -                    if (!obj->stream->watch) {
> -                        obj->stream->watch =
> core->watch_add(obj->stream->socket,
> -
> SPICE_WATCH_EVENT_READ,
> -
> async_read_handler, obj);
> +                    if (!async->stream->watch) {
> +                        async->stream->watch =
> core->watch_add(async->stream->socket,
> +
> SPICE_WATCH_EVENT_READ,
> +
> async_read_handler, async);
>                      }
>                      return;
>                  case EINTR:
>                      break;
>                  default:
> -                    async_read_clear_handlers(obj);
> -                   if (obj->error) {
> -                        obj->error(obj->opaque, errno);
> +                    async_read_clear_handlers(async);
> +                   if (async->error) {
> +                        async->error(async->opaque, errno);
>                     }
>                      return;
>                  }
>              } else {
> -                async_read_clear_handlers(obj);
> -               if (obj->error) {
> -                   obj->error(obj->opaque, 0);
> +                async_read_clear_handlers(async);
> +               if (async->error) {
> +                   async->error(async->opaque, 0);
>                 }
>                  return;
>              }
>          } else {
> -            obj->now += n;
> -            if (obj->now == obj->end) {
> -                async_read_clear_handlers(obj);
> -                obj->done(obj->opaque);
> +            async->now += n;
> +            if (async->now == async->end) {
> +                async_read_clear_handlers(async);
> +                async->done(async->opaque);
>                  return;
>              }
>          }
> @@ -450,15 +450,15 @@ void reds_stream_async_read(RedsStream *stream,
>                              AsyncReadDone read_done_cb,
>                              void *opaque)
>  {
> -    AsyncRead *obj = &stream->priv->async_read;
> -
> -    g_return_if_fail(!obj->stream);
> -    obj->stream = stream;
> -    obj->now = data;
> -    obj->end = obj->now + size;
> -    obj->done = read_done_cb;
> -    obj->opaque = opaque;
> -    async_read_handler(0, 0, obj);
> +    AsyncRead *async = &stream->priv->async_read;
> +
> +    g_return_if_fail(!async->stream);
> +    async->stream = stream;
> +    async->now = data;
> +    async->end = async->now + size;
> +    async->done = read_done_cb;
> +    async->opaque = opaque;
> +    async_read_handler(0, 0, async);
>
>  }
>
> --
> 1.8.5.3
>
> _______________________________________________
> Spice-devel mailing list
> Spice-devel at lists.freedesktop.org
> http://lists.freedesktop.org/mailman/listinfo/spice-devel
>



-- 
Marc-André Lureau
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.freedesktop.org/archives/spice-devel/attachments/20140325/a56c77f3/attachment.html>


More information about the Spice-devel mailing list