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-profile: handle GIOStream properly

Browse Source
This commit is contained in:
Christian Hergert
2023-06-02 16:49:56 -07:00
parent 390e764aa7
commit ff490eb1fd
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/libsysprof-profile/sysprof-controlfd-instrument.c
View File

@ -141,7 +141,7 @@ finish:
typedef struct _SysprofControlfdRecording typedef struct _SysprofControlfdRecording
{ {
GInputStream *stream; GIOStream *stream;
SysprofRecording *recording; SysprofRecording *recording;
DexFuture *cancellable; DexFuture *cancellable;
GArray *source_ids; GArray *source_ids;
@ -189,15 +189,18 @@ sysprof_controlfd_instrument_record_fiber (gpointer user_data)
{ {
SysprofControlfdRecording *state = user_data; SysprofControlfdRecording *state = user_data;
g_autoptr(GError) error = NULL; g_autoptr(GError) error = NULL;
GInputStream *input;
g_assert (state != NULL); g_assert (state != NULL);
g_assert (SYSPROF_IS_RECORDING (state->recording)); g_assert (SYSPROF_IS_RECORDING (state->recording));
g_assert (DEX_IS_CANCELLABLE (state->cancellable)); g_assert (DEX_IS_CANCELLABLE (state->cancellable));
g_assert (state->source_ids != NULL); g_assert (state->source_ids != NULL);
input = g_io_stream_get_input_stream (G_IO_STREAM (state->stream));
for (;;) for (;;)
{ {
g_autoptr(DexFuture) future = dex_input_stream_read_bytes (state->stream, 10, 0); g_autoptr(DexFuture) future = dex_input_stream_read_bytes (input, 10, 0);
g_autoptr(MappedRingBuffer) ring_buffer = NULL; g_autoptr(MappedRingBuffer) ring_buffer = NULL;
g_autoptr(GBytes) bytes = NULL; g_autoptr(GBytes) bytes = NULL;
const guint8 *data; const guint8 *data;
@ -278,6 +281,7 @@ sysprof_controlfd_instrument_record (SysprofInstrument *instrument,
state = g_new0 (SysprofControlfdRecording, 1); state = g_new0 (SysprofControlfdRecording, 1);
state->recording = g_object_ref (recording); state->recording = g_object_ref (recording);
state->stream = g_object_ref (G_IO_STREAM (self->connection));
state->cancellable = dex_cancellable_new_from_cancellable (cancellable); state->cancellable = dex_cancellable_new_from_cancellable (cancellable);
state->source_ids = g_array_new (FALSE, FALSE, sizeof (guint)); state->source_ids = g_array_new (FALSE, FALSE, sizeof (guint));
g_array_set_clear_func (state->source_ids, _g_clear_source); g_array_set_clear_func (state->source_ids, _g_clear_source);