varun-r-mallya/sysprof
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/sysprof.git synced 2026-02-10 07:00:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

libsysprof: flush incoming events when finalizing ring source

Browse Source 
This just helps ensure we've not lost anything during the shutdown of the
profiler here.
This commit is contained in:
Christian Hergert
2023-08-15 15:38:02 -07:00
parent c45aba997d
commit 3598755963
1 changed files with 21 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
src/libsysprof/mapped-ring-buffer-source.c
View File

@ -26,8 +26,11 @@
typedef struct _MappedRingSource typedef struct _MappedRingSource
{ {
GSource source; GSource source;
MappedRingBuffer *buffer; MappedRingBuffer *buffer;
MappedRingBufferCallback callback;
gpointer callback_data;
GDestroyNotify callback_data_destroy;
} MappedRingSource; } MappedRingSource;
static gboolean static gboolean
@ -39,9 +42,7 @@ mapped_ring_source_dispatch (GSource *source,
g_assert (source != NULL); g_assert (source != NULL);
return mapped_ring_buffer_drain (real_source->buffer, return mapped_ring_buffer_drain (real_source->buffer, real_source->callback, real_source->callback_data);
(MappedRingBufferCallback)callback,
user_data);
} }
static void static void
@ -50,7 +51,18 @@ mapped_ring_source_finalize (GSource *source)
MappedRingSource *real_source = (MappedRingSource *)source; MappedRingSource *real_source = (MappedRingSource *)source;
if (real_source != NULL) if (real_source != NULL)
g_clear_pointer (&real_source->buffer, mapped_ring_buffer_unref); {
mapped_ring_buffer_drain (real_source->buffer, real_source->callback, real_source->callback_data);
if (real_source->callback_data_destroy)
real_source->callback_data_destroy (real_source->callback_data);
real_source->callback = NULL;
real_source->callback_data = NULL;
real_source->callback_data_destroy = NULL;
g_clear_pointer (&real_source->buffer, mapped_ring_buffer_unref);
}
} }
static gboolean static gboolean
@ -103,7 +115,9 @@ mapped_ring_buffer_create_source_full (int priority,
source = (MappedRingSource *)g_source_new (&mapped_ring_source_funcs, sizeof (MappedRingSource)); source = (MappedRingSource *)g_source_new (&mapped_ring_source_funcs, sizeof (MappedRingSource));
source->buffer = mapped_ring_buffer_ref (self); source->buffer = mapped_ring_buffer_ref (self);
g_source_set_callback ((GSource *)source, (GSourceFunc)source_func, user_data, destroy); source->callback = source_func;
source->callback_data = user_data;
source->callback_data_destroy = destroy;
g_source_set_static_name ((GSource *)source, "MappedRingSource"); g_source_set_static_name ((GSource *)source, "MappedRingSource");
g_source_set_priority ((GSource *)source, priority); g_source_set_priority ((GSource *)source, priority);
ret = g_source_attach ((GSource *)source, g_main_context_default ()); ret = g_source_attach ((GSource *)source, g_main_context_default ());