[Spice-devel] [RFC v4 53/62] server/red_worker: move free from display_channel_send_item to _release_item

Marc-André Lureau marcandre.lureau at gmail.com
Mon May 2 16:54:11 PDT 2011


On Tue, Apr 26, 2011 at 12:55 PM, Alon Levy <alevy at redhat.com> wrote:
> ---
>  server/red_worker.c |   74 ++++++++++++++++++++++++++++++--------------------
>  1 files changed, 44 insertions(+), 30 deletions(-)
>
> diff --git a/server/red_worker.c b/server/red_worker.c
> index 4402570..6ab3d7c 100644
> --- a/server/red_worker.c
> +++ b/server/red_worker.c
> @@ -8402,86 +8402,70 @@ static void display_channel_send_item(RedChannelClient *rcc, PipeItem *pipe_item
>  {
>     SpiceMarshaller *m = red_channel_client_get_marshaller(rcc);
>     DisplayChannelClient *dcc = RCC_TO_DCC(rcc);
> -    DisplayChannel *display_channel = DCC_TO_DC(dcc);
> -    RedWorker *worker = display_channel->common.worker;
> -    Surfaces *surfaces = dcc->common.surfaces;
> +    RedWorker *worker = DCC_TO_WORKER(dcc);
>
>     red_display_reset_send_data(dcc);
>     switch (pipe_item->type) {
>     case PIPE_ITEM_TYPE_DRAW: {
>         Drawable *drawable = SPICE_CONTAINEROF(pipe_item, Drawable, pipe_item);
>         marshall_qxl_drawable(rcc, m, drawable);
> -        release_drawable(worker, &worker->surfaces, drawable);
> +        release_drawable(worker, dcc->common.surfaces, drawable);
>         break;
>     }
>     case PIPE_ITEM_TYPE_INVAL_ONE:
>         red_marshall_inval(rcc, m, (CacheItem *)pipe_item);
> -        free(pipe_item);
>         break;
>     case PIPE_ITEM_TYPE_STREAM_CREATE: {
>         StreamAgent *agent = SPICE_CONTAINEROF(pipe_item, StreamAgent, create_item);
>         red_display_marshall_stream_start(rcc, m, agent);
> -        red_display_release_stream(surfaces, agent);
>         break;
>     }
>     case PIPE_ITEM_TYPE_STREAM_CLIP: {
>         StreamClipItem* clip_item = (StreamClipItem *)pipe_item;
>         red_display_marshall_stream_clip(rcc, m, clip_item);
> -        red_display_release_stream_clip(surfaces, clip_item);
>         break;
>     }
>     case PIPE_ITEM_TYPE_STREAM_DESTROY: {
>         StreamAgent *agent = SPICE_CONTAINEROF(pipe_item, StreamAgent, destroy_item);
>         red_display_marshall_stream_end(rcc, m, agent);
> -        red_display_release_stream(surfaces, agent);
>         break;
>     }
>     case PIPE_ITEM_TYPE_UPGRADE:
>         red_display_marshall_upgrade(rcc, m, (UpgradeItem *)pipe_item);
> -        release_upgrade_item(worker, &worker->surfaces, (UpgradeItem *)pipe_item);
>         break;
>     case PIPE_ITEM_TYPE_VERB:
>         red_marshall_verb(rcc, ((VerbItem*)pipe_item)->verb);
> -        free(pipe_item);
>         break;
>     case PIPE_ITEM_TYPE_MIGRATE:
>         red_printf("PIPE_ITEM_TYPE_MIGRATE");
>         display_channel_marshall_migrate(rcc, m);
> -        free(pipe_item);
>         break;
>     case PIPE_ITEM_TYPE_MIGRATE_DATA:
>         display_channel_marshall_migrate_data(rcc, m);
> -        free(pipe_item);
>         break;
>     case PIPE_ITEM_TYPE_IMAGE:
>         red_marshall_image(rcc, m, (ImageItem *)pipe_item);
> -        release_image_item((ImageItem *)pipe_item);

here

>         break;
>     case PIPE_ITEM_TYPE_PIXMAP_SYNC:
>         display_channel_marshall_pixmap_sync(rcc, m);
> -        free(pipe_item);
>         break;
>     case PIPE_ITEM_TYPE_PIXMAP_RESET:
>         display_channel_marshall_reset_cache(rcc, m);
> -        free(pipe_item);
>         break;
>     case PIPE_ITEM_TYPE_INVAL_PALLET_CACHE:
>         red_reset_palette_cache(dcc);
>         red_marshall_verb(rcc, SPICE_MSG_DISPLAY_INVAL_ALL_PALETTES);
> -        free(pipe_item);
>         break;
>     case PIPE_ITEM_TYPE_CREATE_SURFACE: {
>         SurfaceCreateItem *surface_create = SPICE_CONTAINEROF(pipe_item, SurfaceCreateItem,
>                                                               pipe_item);
>         red_marshall_surface_create(rcc, m, &surface_create->surface_create);
> -        free(surface_create);
>         break;
>     }
>     case PIPE_ITEM_TYPE_DESTROY_SURFACE: {
>         SurfaceDestroyItem *surface_destroy = SPICE_CONTAINEROF(pipe_item, SurfaceDestroyItem,
>                                                                 pipe_item);
>         red_marshall_surface_destroy(rcc, m, surface_destroy->surface_destroy.surface_id);
> -        free(surface_destroy);
>         break;
>     }
>     default:
> @@ -9705,7 +9689,7 @@ static void display_channel_hold_pipe_item(RedChannelClient *rcc, PipeItem *item
>     }
>  }
>
> -static void display_channel_release_item(RedChannelClient *rcc, PipeItem *item,
> +static void display_channel_release_item(RedChannelClient *rcc, PipeItem *pipe_item,
>                                          int item_pushed /* ignored */)
>  {
>     RedChannel *channel = rcc->channel;
> @@ -9714,25 +9698,55 @@ static void display_channel_release_item(RedChannelClient *rcc, PipeItem *item,
>     DisplayChannelClient *dcc = RCC_TO_DCC(rcc);
>     Surfaces *surfaces = dcc->common.surfaces;
>
> -    ASSERT(item);
> -    switch (item->type) {
> -    case PIPE_ITEM_TYPE_DRAW:
> -    case PIPE_ITEM_TYPE_STREAM_CREATE:
> -        release_drawable(common->worker, &common->worker->surfaces,
> -                         SPICE_CONTAINEROF(item, Drawable, pipe_item));
> +    ASSERT(pipe_item);
> +    switch (pipe_item->type) {
> +    case PIPE_ITEM_TYPE_DRAW: {
> +        Drawable *drawable = SPICE_CONTAINEROF(pipe_item, Drawable, pipe_item);
> +        release_drawable(worker, surfaces, drawable);
>         break;
> +    }
> +    case PIPE_ITEM_TYPE_STREAM_CREATE: {
> +        StreamAgent *agent = SPICE_CONTAINEROF(pipe_item, StreamAgent, create_item);
> +        red_display_release_stream(surfaces, agent);
> +        release_drawable(common->worker, surfaces,
> +                         SPICE_CONTAINEROF(pipe_item, Drawable, pipe_item));
> +        break;
> +    }
>     case PIPE_ITEM_TYPE_STREAM_CLIP:
> -        red_display_release_stream_clip(surfaces, (StreamClipItem *)item);
> +        red_display_release_stream_clip(surfaces, (StreamClipItem *)pipe_item);
>         break;
> +    case PIPE_ITEM_TYPE_STREAM_DESTROY: {
> +        StreamAgent *agent = SPICE_CONTAINEROF(pipe_item, StreamAgent, destroy_item);
> +        red_display_release_stream(surfaces, agent);
> +        break;
> +    }
>     case PIPE_ITEM_TYPE_UPGRADE:
> -        release_upgrade_item(worker, &worker->surfaces, (UpgradeItem *)item);
> +        release_upgrade_item(worker, &worker->surfaces, (UpgradeItem *)pipe_item);
> +        break;
> +    case PIPE_ITEM_TYPE_INVAL_ONE:
> +    case PIPE_ITEM_TYPE_VERB:
> +    case PIPE_ITEM_TYPE_MIGRATE:
> +    case PIPE_ITEM_TYPE_MIGRATE_DATA:
> +    case PIPE_ITEM_TYPE_PIXMAP_SYNC:
> +    case PIPE_ITEM_TYPE_PIXMAP_RESET:
> +    case PIPE_ITEM_TYPE_INVAL_PALLET_CACHE:
> +        free(pipe_item);
>         break;
>     case PIPE_ITEM_TYPE_IMAGE:
> -        release_image_item((ImageItem *)item);
> +        release_image_item((ImageItem *)pipe_item);

We use to call release_image_item() twice? Is that normal?

>         break;
> -    case PIPE_ITEM_TYPE_VERB:
> -        free(item);
> +    case PIPE_ITEM_TYPE_CREATE_SURFACE: {
> +        SurfaceCreateItem *surface_create = SPICE_CONTAINEROF(pipe_item, SurfaceCreateItem,
> +                                                              pipe_item);
> +        free(surface_create);
>         break;
> +    }
> +    case PIPE_ITEM_TYPE_DESTROY_SURFACE: {
> +        SurfaceDestroyItem *surface_destroy = SPICE_CONTAINEROF(pipe_item, SurfaceDestroyItem,
> +                                                                pipe_item);
> +        free(surface_destroy);
> +        break;
> +    }
>     default:
>         PANIC("invalid item type");
>     }
> --
> 1.7.4.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