pxcloud/spice
5
0
Fork 0
mirror of https://gitlab.uni-freiburg.de/opensourcevdi/spice synced 2025-12-26 22:48:19 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

make red_pipe_item_init_full more typesafe

Browse Source 
Use a proper type for free callback

Signed-off-by: Frediano Ziglio <fziglio@redhat.com>
Acked-by: Jonathon Jongsma <jjongsma@redhat.com>
This commit is contained in:
Frediano Ziglio 2016-05-13 19:47:14 +01:00
parent e960e00392
commit 8d764488ca
9 changed files with 47 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
server/cursor-channel.c
View File

@ -81,7 +81,7 @@ struct CursorChannelClient {
#include "cache-item.tmpl.c"
#undef CLIENT_CURSOR_CACHE
static void cursor_pipe_item_free(RedCursorPipeItem *pipe_item);
static red_pipe_item_free_t cursor_pipe_item_free;
static CursorItem *cursor_item_new(QXLInstance *qxl, RedCursorCmd *cmd)
{
@ -138,7 +138,7 @@ static RedPipeItem *new_cursor_pipe_item(RedChannelClient *rcc, void *data, int
RedCursorPipeItem *item = spice_malloc0(sizeof(RedCursorPipeItem));
red_pipe_item_init_full(&item->base, RED_PIPE_ITEM_TYPE_CURSOR,
(GDestroyNotify)cursor_pipe_item_free);
cursor_pipe_item_free);
item->cursor_item = data;
item->cursor_item->refs++;
return &item->base;
@ -204,9 +204,11 @@ void cursor_channel_disconnect(CursorChannel *cursor_channel)
}
static void cursor_pipe_item_free(RedCursorPipeItem *pipe_item)
static void cursor_pipe_item_free(RedPipeItem *base)
{
spice_return_if_fail(pipe_item);
spice_return_if_fail(base);
RedCursorPipeItem *pipe_item = SPICE_CONTAINEROF(base, RedCursorPipeItem, base);
spice_assert(!red_pipe_item_is_linked(&pipe_item->base));

8
server/dcc.c
View File

@ -306,7 +306,7 @@ static RedDrawablePipeItem *red_drawable_pipe_item_new(DisplayChannelClient *dcc
ring_item_init(&dpi->base);
ring_add(&drawable->pipes, &dpi->base);
red_pipe_item_init_full(&dpi->dpi_pipe_item, RED_PIPE_ITEM_TYPE_DRAW,
(GDestroyNotify)red_drawable_pipe_item_free);
red_drawable_pipe_item_free);
drawable->refs++;
return dpi;
}
@ -517,8 +517,10 @@ void dcc_stream_agent_clip(DisplayChannelClient* dcc, StreamAgent *agent)
red_channel_client_pipe_add(RED_CHANNEL_CLIENT(dcc), (RedPipeItem *)item);
}
static void red_monitors_config_item_free(RedMonitorsConfigItem *item)
static void red_monitors_config_item_free(RedPipeItem *base)
{
RedMonitorsConfigItem *item = SPICE_CONTAINEROF(base, RedMonitorsConfigItem, pipe_item);
monitors_config_unref(item->monitors_config);
free(item);
}
@ -532,7 +534,7 @@ static RedMonitorsConfigItem *red_monitors_config_item_new(RedChannel* channel,
mci->monitors_config = monitors_config;
red_pipe_item_init_full(&mci->pipe_item, RED_PIPE_ITEM_TYPE_MONITORS_CONFIG,
(GDestroyNotify)red_monitors_config_item_free);
red_monitors_config_item_free);
return mci;
}

10
server/main-channel-client.c
View File

@ -109,8 +109,9 @@ static const uint8_t zero_page[ZERO_BUF_SIZE] = {0};
static int main_channel_client_push_ping(MainChannelClient *mcc, int size);
static void main_notify_item_free(RedNotifyPipeItem *data)
static void main_notify_item_free(RedPipeItem *base)
{
RedNotifyPipeItem *data = SPICE_CONTAINEROF(base, RedNotifyPipeItem, base);
free(data->msg);
free(data);
}
@ -121,7 +122,7 @@ static RedPipeItem *main_notify_item_new(void *data, int num)
const char *msg = data;
red_pipe_item_init_full(&item->base, RED_PIPE_ITEM_TYPE_MAIN_NOTIFY,
(GDestroyNotify)main_notify_item_free);
main_notify_item_free);
item->msg = spice_strdup(msg);
return &item->base;
}
@ -181,8 +182,9 @@ void main_channel_client_push_agent_tokens(MainChannelClient *mcc, uint32_t num_
red_channel_client_pipe_add_push(&mcc->base, item);
}
static void main_agent_data_item_free(RedAgentDataPipeItem *item)
static void main_agent_data_item_free(RedPipeItem *base)
{
RedAgentDataPipeItem *item = SPICE_CONTAINEROF(base, RedAgentDataPipeItem, base);
item->free_data(item->data, item->opaque);
free(item);
}
@ -194,7 +196,7 @@ static RedPipeItem *main_agent_data_item_new(uint8_t* data, size_t len,
RedAgentDataPipeItem *item = spice_malloc(sizeof(RedAgentDataPipeItem));
red_pipe_item_init_full(&item->base, RED_PIPE_ITEM_TYPE_MAIN_AGENT_DATA,
(GDestroyNotify)main_agent_data_item_free);
main_agent_data_item_free);
item->data = data;
item->len = len;
item->free_data = free_data;

6
server/red-channel.c
View File

@ -2365,8 +2365,10 @@ int red_channel_client_wait_outgoing_item(RedChannelClient *rcc,
}
}
static void marker_pipe_item_free(MarkerPipeItem *item)
static void marker_pipe_item_free(RedPipeItem *base)
{
MarkerPipeItem *item = SPICE_CONTAINEROF(base, MarkerPipeItem, base);
if (item->item_in_pipe) {
*item->item_in_pipe = FALSE;
}
@ -2392,7 +2394,7 @@ int red_channel_client_wait_pipe_item_sent(RedChannelClient *rcc,
MarkerPipeItem *mark_item = spice_new0(MarkerPipeItem, 1);
red_pipe_item_init_full(&mark_item->base, RED_PIPE_ITEM_TYPE_MARKER,
(GDestroyNotify)marker_pipe_item_free);
marker_pipe_item_free);
item_in_pipe = TRUE;
mark_item->item_in_pipe = &item_in_pipe;
red_channel_client_pipe_add_after(rcc, &mark_item->base, item);

4
server/red-pipe-item.c
View File

@ -44,10 +44,10 @@ void red_pipe_item_unref(gpointer object)
void red_pipe_item_init_full(RedPipeItem *item,
gint type,
GDestroyNotify free_func)
red_pipe_item_free_t *free_func)
{
ring_item_init(&item->link);
item->type = type;
item->refcount = 1;
item->free_func = free_func ? free_func : (GDestroyNotify)free;
item->free_func = free_func ? free_func : (red_pipe_item_free_t *)free;
}

10
server/red-pipe-item.h
View File

@ -21,17 +21,21 @@
#include <glib.h>
#include <common/ring.h>
typedef struct {
struct RedPipeItem;
typedef void red_pipe_item_free_t(struct RedPipeItem *item);
typedef struct RedPipeItem {
RingItem link;
int type;
/* private */
int refcount;
GDestroyNotify free_func;
red_pipe_item_free_t *free_func;
} RedPipeItem;
void red_pipe_item_init_full(RedPipeItem *item, int type, GDestroyNotify free_func);
void red_pipe_item_init_full(RedPipeItem *item, int type, red_pipe_item_free_t free_func);
RedPipeItem *red_pipe_item_ref(gpointer item);
void red_pipe_item_unref(gpointer item);

8
server/reds.c
View File

@ -303,7 +303,7 @@ static uint32_t reds_qxl_ram_size(RedsState *reds);
static int calc_compression_level(RedsState *reds);
static RedVDIReadBuf *vdi_port_get_read_buf(RedCharDeviceVDIPort *dev);
static void vdi_port_read_buf_free(RedVDIReadBuf *buf);
static red_pipe_item_free_t vdi_port_read_buf_free;
static ChannelSecurityOptions *reds_find_channel_security(RedsState *reds, int id)
{
@ -790,7 +790,7 @@ static void vdi_read_buf_init(RedVDIReadBuf *buf)
* from the base class and are not going to use the type
*/
red_pipe_item_init_full(&buf->parent, -1,
(GDestroyNotify)vdi_port_read_buf_free);
vdi_port_read_buf_free);
}
static RedVDIReadBuf *vdi_port_get_read_buf(RedCharDeviceVDIPort *dev)
@ -811,8 +811,10 @@ static RedVDIReadBuf *vdi_port_get_read_buf(RedCharDeviceVDIPort *dev)
return buf;
}
static void vdi_port_read_buf_free(RedVDIReadBuf *buf)
static void vdi_port_read_buf_free(RedPipeItem *base)
{
RedVDIReadBuf *buf = SPICE_CONTAINEROF(base, RedVDIReadBuf, parent);
g_warn_if_fail(buf->parent.refcount == 0);
ring_add(&buf->dev->priv->read_bufs, (RingItem *)buf);

5
server/smartcard.c
View File

@ -537,8 +537,9 @@ static void smartcard_push_error(RedChannelClient *rcc, uint32_t reader_id, VSCE
smartcard_channel_client_pipe_add_push(rcc, &error_item->base);
}
static void smartcard_free_vsc_msg_item(RedMsgItem *item)
static void smartcard_free_vsc_msg_item(RedPipeItem *base)
{
RedMsgItem *item = SPICE_CONTAINEROF(base, RedMsgItem, base);
free(item->vheader);
free(item);
}
@ -549,7 +550,7 @@ static RedMsgItem *smartcard_get_vsc_msg_item(RedChannelClient *rcc,
RedMsgItem *msg_item = spice_new0(RedMsgItem, 1);
red_pipe_item_init_full(&msg_item->base, RED_PIPE_ITEM_TYPE_SMARTCARD_DATA,
(GDestroyNotify)smartcard_free_vsc_msg_item);
smartcard_free_vsc_msg_item);
msg_item->vheader = vheader;
return msg_item;
}

15
server/stream.c
View File

@ -76,7 +76,7 @@ static RedPipeItem *stream_create_destroy_item_new(StreamAgent *agent, gint type
StreamCreateDestroyItem *item = spice_new0(StreamCreateDestroyItem, 1);
red_pipe_item_init_full(&item->base, type,
(GDestroyNotify)stream_create_destroy_item_release);
stream_create_destroy_item_release);
agent->stream->refs++;
item->agent = agent;
return &item->base;
@ -161,9 +161,10 @@ void stream_agent_unref(DisplayChannel *display, StreamAgent *agent)
stream_unref(display, agent->stream);
}
void red_stream_clip_item_free(RedStreamClipItem *item)
void red_stream_clip_item_free(RedPipeItem *base)
{
g_return_if_fail(item != NULL);
g_return_if_fail(base != NULL);
RedStreamClipItem *item = SPICE_CONTAINEROF(base, RedStreamClipItem, base);
DisplayChannel *display = DCC_TO_DC(item->stream_agent->dcc);
g_return_if_fail(item->base.refcount == 0);
@ -177,7 +178,7 @@ RedStreamClipItem *red_stream_clip_item_new(StreamAgent *agent)
{
RedStreamClipItem *item = spice_new(RedStreamClipItem, 1);
red_pipe_item_init_full((RedPipeItem *)item, RED_PIPE_ITEM_TYPE_STREAM_CLIP,
(GDestroyNotify)red_stream_clip_item_free);
red_stream_clip_item_free);
item->stream_agent = agent;
agent->stream->refs++;
@ -785,8 +786,10 @@ void stream_agent_stop(StreamAgent *agent)
}
}
static void red_upgrade_item_free(RedUpgradeItem *item)
static void red_upgrade_item_free(RedPipeItem *base)
{
RedUpgradeItem *item = SPICE_CONTAINEROF(base, RedUpgradeItem, base);
g_return_if_fail(item != NULL);
g_return_if_fail(item->base.refcount == 0);
@ -836,7 +839,7 @@ static void dcc_detach_stream_gracefully(DisplayChannelClient *dcc,
rcc = RED_CHANNEL_CLIENT(dcc);
upgrade_item = spice_new(RedUpgradeItem, 1);
red_pipe_item_init_full(&upgrade_item->base, RED_PIPE_ITEM_TYPE_UPGRADE,
(GDestroyNotify)red_upgrade_item_free);
red_upgrade_item_free);
upgrade_item->drawable = stream->current;
upgrade_item->drawable->refs++;
n_rects = pixman_region32_n_rects(&upgrade_item->drawable->tree_item.base.rgn);