Re: [PATCH 09/18] CommonChannel -> CommonWorkerChannel

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

 



On Tue, 2016-02-16 at 05:42 -0500, Frediano Ziglio wrote:
> > 
> > On Mon, 2016-02-15 at 16:01 +0000, Frediano Ziglio wrote:
> > > From: Jonathon Jongsma <jjongsma@xxxxxxxxxx>
> > > 
> > > Rename this struct to make it clear that it's only the base class
> > > for
> > > worker channels (e.g. display and cursor), not all channels.
> > > 
> 
> Still don't like the reference to Worker in the name.
> Currently Display/CursorChannel(Client) has no reference to
> RedWorker.
> And in the future I'd like the idea of not having that dependency.
> 
> Frediano

In that case worker should not be in the name. There was a suggestion
to use CommonQxlChannel or CommonGraphicsChannel. I like the "Graphics"
variant, it says more about the usage than "Worker".

Pavel

> 
> > > Also renamed CommonChannelClient to CommonWorkerChannelClient.
> > > ---
> > >  server/cursor-channel.c  | 26 +++++++++++++-------------
> > >  server/dcc.c             |  6 +++---
> > >  server/dcc.h             |  4 ++--
> > >  server/display-channel.h |  2 +-
> > >  server/red-worker.c      | 42 +++++++++++++++++++++-------------
> > > ----
> > > ----
> > >  server/red-worker.h      | 44 ++++++++++++++++++++++----------
> > > ----
> > > --------
> > >  6 files changed, 62 insertions(+), 62 deletions(-)
> > > 
> > > diff --git a/server/cursor-channel.c b/server/cursor-channel.c
> > > index 0ab0d80..59f2991 100644
> > > --- a/server/cursor-channel.c
> > > +++ b/server/cursor-channel.c
> > > @@ -51,7 +51,7 @@ typedef struct CursorPipeItem {
> > >  } CursorPipeItem;
> > >  
> > >  struct CursorChannel {
> > > -    CommonChannel common; // Must be the first thing
> > > +    CommonWorkerChannel common; // Must be the first thing
> > >  
> > >      CursorItem *item;
> > >      int cursor_visible;
> > > @@ -66,7 +66,7 @@ struct CursorChannel {
> > >  };
> > >  
> > >  struct CursorChannelClient {
> > > -    CommonChannelClient common;
> > > +    CommonWorkerChannelClient common;
> > >  
> > >      CacheItem *cursor_cache[CURSOR_CACHE_HASH_SIZE];
> > >      Ring cursor_cache_lru;
> > > @@ -415,7 +415,7 @@ static void
> > > cursor_channel_release_item(RedChannelClient *rcc, PipeItem
> > > *item, i
> > >  CursorChannel* cursor_channel_new(RedWorker *worker)
> > >  {
> > >      CursorChannel *cursor_channel;
> > > -    CommonChannel *channel = NULL;
> > > +    CommonWorkerChannel *channel = NULL;
> > >      ChannelCbs cbs = {
> > >          .on_disconnect =  cursor_channel_client_on_disconnect,
> > >          .send_item = cursor_channel_send_item,
> > > @@ -458,15 +458,15 @@ CursorChannelClient*
> > > cursor_channel_client_new(CursorChannel *cursor, RedClient
> > >      spice_return_val_if_fail(!num_caps || caps, NULL);
> > >  
> > >      CursorChannelClient *ccc =
> > > -        (CursorChannelClient*)common_channel_new_client(&cursor-
> > > > common,
> > > -                                                        sizeof(C
> > > urso
> > > rChannelClient),
> > > -                                                        client,
> > > stream,
> > > -                                                        mig_targ
> > > et,
> > > -                                                        FALSE,
> > > -                                                        common_c
> > > aps,
> > > -                                                        num_comm
> > > on_c
> > > aps,
> > > -                                                        caps,
> > > -                                                        num_caps
> > > );
> > > +        (CursorChannelClient*)common_worker_channel_new_client(&
> > > curs
> > > or->common,
> > > +                                                               s
> > > izeo
> > > f(CursorChannelClient),
> > > +                                                               c
> > > lien
> > > t, stream,
> > > +                                                               m
> > > ig_t
> > > arget,
> > > +                                                               F
> > > ALSE
> > > ,
> > > +                                                               c
> > > ommo
> > > n_caps,
> > > +                                                               n
> > > um_c
> > > ommon_caps,
> > > +                                                               c
> > > aps,
> > > +                                                               n
> > > um_c
> > > aps);
> > >      spice_return_val_if_fail(ccc != NULL, NULL);
> > >  
> > >      ring_init(&ccc->cursor_cache_lru);
> > > @@ -547,7 +547,7 @@ void cursor_channel_init(CursorChannel
> > > *cursor,
> > > CursorChannelClient *client)
> > >      spice_return_if_fail(cursor);
> > >  
> > >      if (!red_channel_is_connected(&cursor->common.base)
> > > -        || COMMON_CHANNEL(cursor)->during_target_migrate) {
> > > +        || COMMON_WORKER_CHANNEL(cursor)->during_target_migrate) 
> > > {
> > >          spice_debug("during_target_migrate: skip init");
> > >          return;
> > >      }
> > > diff --git a/server/dcc.c b/server/dcc.c
> > > index 9a4e90c..66de2bb 100644
> > > --- a/server/dcc.c
> > > +++ b/server/dcc.c
> > > @@ -368,8 +368,8 @@ DisplayChannelClient *dcc_new(DisplayChannel
> > > *display,
> > >  {
> > >      DisplayChannelClient *dcc;
> > >  
> > > -    dcc = (DisplayChannelClient*)common_channel_new_client(
> > > -        COMMON_CHANNEL(display), sizeof(DisplayChannelClient),
> > > +    dcc =
> > > (DisplayChannelClient*)common_worker_channel_new_client(
> > > +        COMMON_WORKER_CHANNEL(display),
> > > sizeof(DisplayChannelClient),
> > >          client, stream, mig_target, TRUE,
> > >          common_caps, num_common_caps,
> > >          caps, num_caps);
> > > @@ -626,7 +626,7 @@ void dcc_destroy_surface(DisplayChannelClient
> > > *dcc, uint32_t surface_id)
> > >      display = DCC_TO_DC(dcc);
> > >      channel = RED_CHANNEL(display);
> > >  
> > > -    if (COMMON_CHANNEL(display)->during_target_migrate ||
> > > +    if (COMMON_WORKER_CHANNEL(display)->during_target_migrate ||
> > >          !dcc->surface_client_created[surface_id]) {
> > >          return;
> > >      }
> > > diff --git a/server/dcc.h b/server/dcc.h
> > > index a482938..c78f3b8 100644
> > > --- a/server/dcc.h
> > > +++ b/server/dcc.h
> > > @@ -55,7 +55,7 @@ typedef struct FreeList {
> > >  } FreeList;
> > >  
> > >  struct DisplayChannelClient {
> > > -    CommonChannelClient common;
> > > +    CommonWorkerChannelClient common;
> > >      SpiceImageCompression image_compression;
> > >      spice_wan_compression_t jpeg_state;
> > >      spice_wan_compression_t zlib_glz_state;
> > > @@ -115,7 +115,7 @@ struct DisplayChannelClient {
> > >  };
> > >  
> > >  #define
> > > DCC_TO_WORKER(dcc)                                              \
> > > -    (SPICE_CONTAINEROF((dcc)->common.base.channel,
> > > CommonChannel,
> > > base)->worker)
> > > +    (SPICE_CONTAINEROF((dcc)->common.base.channel,
> > > CommonWorkerChannel, base)->worker)
> > >  #define
> > > DCC_TO_DC(dcc)                                                  \
> > >       SPICE_CONTAINEROF((dcc)->common.base.channel,
> > > DisplayChannel,
> > > common.base)
> > >  #define RCC_TO_DCC(rcc) SPICE_CONTAINEROF((rcc),
> > > DisplayChannelClient, common.base)
> > > diff --git a/server/display-channel.h b/server/display-channel.h
> > > index 13b13b1..f2e9f51 100644
> > > --- a/server/display-channel.h
> > > +++ b/server/display-channel.h
> > > @@ -164,7 +164,7 @@ struct _Drawable {
> > >  };
> > >  
> > >  struct DisplayChannel {
> > > -    CommonChannel common; // Must be the first thing
> > > +    CommonWorkerChannel common; // Must be the first thing
> > >      uint32_t bits_unique;
> > >  
> > >      MonitorsConfig *monitors_config;
> > > diff --git a/server/red-worker.c b/server/red-worker.c
> > > index 6780d2b..76e8625 100644
> > > --- a/server/red-worker.c
> > > +++ b/server/red-worker.c
> > > @@ -107,7 +107,7 @@ static int display_is_connected(RedWorker
> > > *worker)
> > >  
> > >  static uint8_t *common_alloc_recv_buf(RedChannelClient *rcc,
> > > uint16_t type, uint32_t size)
> > >  {
> > > -    CommonChannel *common = SPICE_CONTAINEROF(rcc->channel,
> > > CommonChannel, base);
> > > +    CommonWorkerChannel *common = SPICE_CONTAINEROF(rcc-
> > > >channel,
> > > CommonWorkerChannel, base);
> > >  
> > >      /* SPICE_MSGC_MIGRATE_DATA is the only client message whose
> > > size
> > > is dynamic */
> > >      if (type == SPICE_MSGC_MIGRATE_DATA) {
> > > @@ -407,7 +407,7 @@ static int
> > > common_channel_config_socket(RedChannelClient *rcc)
> > >      RedClient *client = red_channel_client_get_client(rcc);
> > >      MainChannelClient *mcc = red_client_get_main(client);
> > >      RedsStream *stream = red_channel_client_get_stream(rcc);
> > > -    CommonChannelClient *ccc = COMMON_CHANNEL_CLIENT(rcc);
> > > +    CommonWorkerChannelClient *ccc =
> > > COMMON_WORKER_CHANNEL_CLIENT(rcc);
> > >      int flags;
> > >      int delay_val;
> > >  
> > > @@ -439,16 +439,16 @@ static int
> > > common_channel_config_socket(RedChannelClient *rcc)
> > >      return TRUE;
> > >  }
> > >  
> > > -CommonChannelClient *common_channel_new_client(CommonChannel
> > > *common,
> > > -                                               int size,
> > > -                                               RedClient
> > > *client,
> > > -                                               RedsStream
> > > *stream,
> > > -                                               int mig_target,
> > > -                                               int
> > > monitor_latency,
> > > -                                               uint32_t
> > > *common_caps,
> > > -                                               int
> > > num_common_caps,
> > > -                                               uint32_t *caps,
> > > -                                               int num_caps)
> > > +CommonWorkerChannelClient
> > > *common_worker_channel_new_client(CommonWorkerChannel *common,
> > > +                                                            int
> > > size,
> > > +                                                            RedC
> > > lien
> > > t *client,
> > > +                                                            Reds
> > > Stre
> > > am *stream,
> > > +                                                            int
> > > mig_target,
> > > +                                                            int
> > > monitor_latency,
> > > +                                                            uint
> > > 32_t
> > > *common_caps,
> > > +                                                            int
> > > num_common_caps,
> > > +                                                            uint
> > > 32_t
> > > *caps,
> > > +                                                            int
> > > num_caps)
> > >  {
> > >      RedChannelClient *rcc =
> > >          red_channel_client_create(size, &common->base, client,
> > > stream, monitor_latency,
> > > @@ -456,7 +456,7 @@ CommonChannelClient
> > > *common_channel_new_client(CommonChannel *common,
> > >      if (!rcc) {
> > >          return NULL;
> > >      }
> > > -    CommonChannelClient *common_cc = (CommonChannelClient*)rcc;
> > > +    CommonWorkerChannelClient *common_cc =
> > > (CommonWorkerChannelClient*)rcc;
> > >      common_cc->id = common->qxl->id;
> > >      common->during_target_migrate = mig_target;
> > >  
> > > @@ -468,14 +468,14 @@ CommonChannelClient
> > > *common_channel_new_client(CommonChannel *common,
> > >  }
> > >  
> > >  
> > > -CommonChannel *red_worker_new_channel(RedWorker *worker, int
> > > size,
> > > -                                   const char *name,
> > > -                                   uint32_t channel_type, int
> > > migration_flags,
> > > -                                   ChannelCbs *channel_cbs,
> > > -                                   channel_handle_parsed_proc
> > > handle_parsed)
> > > +CommonWorkerChannel *red_worker_new_channel(RedWorker *worker,
> > > int
> > > size,
> > > +                                            const char *name,
> > > +                                            uint32_t
> > > channel_type,
> > > int migration_flags,
> > > +                                            ChannelCbs
> > > *channel_cbs,
> > > +                                            channel_handle_parse
> > > d_pr
> > > oc handle_parsed)
> > >  {
> > >      RedChannel *channel = NULL;
> > > -    CommonChannel *common;
> > > +    CommonWorkerChannel *common;
> > >  
> > >      spice_return_val_if_fail(worker, NULL);
> > >      spice_return_val_if_fail(channel_cbs, NULL);
> > > @@ -497,7 +497,7 @@ CommonChannel
> > > *red_worker_new_channel(RedWorker
> > > *worker, int size,
> > >      spice_return_val_if_fail(channel, NULL);
> > >      red_channel_set_stat_node(channel, stat_add_node(reds,
> > > worker-
> > > > stat, name, TRUE));
> > >  
> > > -    common = (CommonChannel *)channel;
> > > +    common = (CommonWorkerChannel *)channel;
> > >      common->qxl = worker->qxl;
> > >      return common;
> > >  }
> > > @@ -816,7 +816,7 @@ static void handle_dev_start(void *opaque,
> > > void
> > > *payload)
> > >  
> > >      spice_assert(!worker->running);
> > >      if (worker->cursor_channel) {
> > > -        COMMON_CHANNEL(worker->cursor_channel)-
> > > > during_target_migrate = FALSE;
> > > +        COMMON_WORKER_CHANNEL(worker->cursor_channel)-
> > > > during_target_migrate = FALSE;
> > >      }
> > >      if (worker->display_channel) {
> > >          worker->display_channel->common.during_target_migrate =
> > > FALSE;
> > > diff --git a/server/red-worker.h b/server/red-worker.h
> > > index 94974b7..8ef8287 100644
> > > --- a/server/red-worker.h
> > > +++ b/server/red-worker.h
> > > @@ -24,18 +24,18 @@
> > >  
> > >  typedef struct RedWorker RedWorker;
> > >  
> > > -typedef struct CommonChannelClient {
> > > +typedef struct CommonWorkerChannelClient {
> > >      RedChannelClient base;
> > >  
> > >      uint32_t id;
> > >      int is_low_bandwidth;
> > > -} CommonChannelClient;
> > > +} CommonWorkerChannelClient;
> > >  
> > > -#define COMMON_CHANNEL_CLIENT(Client)
> > > ((CommonChannelClient*)(Client))
> > > +#define COMMON_WORKER_CHANNEL_CLIENT(Client)
> > > ((CommonWorkerChannelClient*)(Client))
> > >  #define COMMON_CLIENT_TIMEOUT (NSEC_PER_SEC * 30)
> > >  
> > >  #define CHANNEL_RECEIVE_BUF_SIZE 1024
> > > -typedef struct CommonChannel {
> > > +typedef struct CommonWorkerChannel {
> > >      RedChannel base; // Must be the first thing
> > >  
> > >      QXLInstance *qxl;
> > > @@ -46,9 +46,9 @@ typedef struct CommonChannel {
> > >                                    The flag is used to avoid
> > > sending
> > > messages that are artifacts
> > >                                    of the transition from stopped
> > > vm
> > > to loaded vm (e.g., recreation
> > >                                    of the primary surface) */
> > > -} CommonChannel;
> > > +} CommonWorkerChannel;
> > >  
> > > -#define COMMON_CHANNEL(Channel) ((CommonChannel*)(Channel))
> > > +#define COMMON_WORKER_CHANNEL(Channel)
> > > ((CommonWorkerChannel*)(Channel))
> > >  
> > >  enum {
> > >      PIPE_ITEM_TYPE_VERB = PIPE_ITEM_TYPE_CHANNEL_BASE,
> > > @@ -99,21 +99,21 @@ RedChannel*
> > > red_worker_get_display_channel(RedWorker *worker);
> > >  
> > >  void red_drawable_unref(RedDrawable *red_drawable);
> > >  
> > > -CommonChannel *red_worker_new_channel(RedWorker *worker, int
> > > size,
> > > -                                   const char *name,
> > > -                                   uint32_t channel_type, int
> > > migration_flags,
> > > -                                   ChannelCbs *channel_cbs,
> > > -                                   channel_handle_parsed_proc
> > > handle_parsed);
> > > -
> > > -CommonChannelClient *common_channel_new_client(CommonChannel
> > > *common,
> > > -                                               int size,
> > > -                                               RedClient
> > > *client,
> > > -                                               RedsStream
> > > *stream,
> > > -                                               int mig_target,
> > > -                                               int
> > > monitor_latency,
> > > -                                               uint32_t
> > > *common_caps,
> > > -                                               int
> > > num_common_caps,
> > > -                                               uint32_t *caps,
> > > -                                               int num_caps);
> > > +CommonWorkerChannel *red_worker_new_channel(RedWorker *worker,
> > > int
> > > size,
> > > +                                            const char *name,
> > > +                                            uint32_t
> > > channel_type,
> > > int migration_flags,
> > > +                                            ChannelCbs
> > > *channel_cbs,
> > > +                                            channel_handle_parse
> > > d_pr
> > > oc handle_parsed);
> > > +
> > > +CommonWorkerChannelClient
> > > *common_worker_channel_new_client(CommonWorkerChannel *common,
> > > +                                                            int
> > > size,
> > > +                                                            RedC
> > > lien
> > > t *client,
> > > +                                                            Reds
> > > Stre
> > > am *stream,
> > > +                                                            int
> > > mig_target,
> > > +                                                            int
> > > monitor_latency,
> > > +                                                            uint
> > > 32_t
> > > *common_caps,
> > > +                                                            int
> > > num_common_caps,
> > > +                                                            uint
> > > 32_t
> > > *caps,
> > > +                                                            int
> > > num_caps);
> > >  
> > >  #endif
> > 
> > Acked-by: Fabiano Fidêncio <fidencio@xxxxxxxxxx>
> > 
> _______________________________________________
> Spice-devel mailing list
> Spice-devel@xxxxxxxxxxxxxxxxxxxxx
> https://lists.freedesktop.org/mailman/listinfo/spice-devel
_______________________________________________
Spice-devel mailing list
Spice-devel@xxxxxxxxxxxxxxxxxxxxx
https://lists.freedesktop.org/mailman/listinfo/spice-devel




[Index of Archives]     [Linux ARM Kernel]     [Linux ARM]     [Linux Omap]     [Fedora ARM]     [IETF Annouce]     [Security]     [Bugtraq]     [Linux]     [Linux OMAP]     [Linux MIPS]     [ECOS]     [Asterisk Internet PBX]     [Linux API]     [Monitors]