varun-r-mallya/sysprof
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/sysprof.git synced 2025-12-31 20:36:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

libsysprof-profile: add SysprofInstrument record vfunc

Browse Source
This commit is contained in:
Christian Hergert
2023-05-26 16:05:30 -07:00
parent 1e3ad3982d
commit 4d54aa6a51
2 changed files with 51 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/libsysprof-profile/sysprof-instrument-private.h
View File

@ -41,11 +41,17 @@ struct _SysprofInstrumentClass
char **(*list_required_policy) (SysprofInstrument *self);
DexFuture *(*prepare) (SysprofInstrument *self,
SysprofRecording *recording);
DexFuture *(*record) (SysprofInstrument *self,
SysprofRecording *recording,
GCancellable *cancellable);
};
DexFuture * _sysprof_instruments_acquire_policy (GPtrArray *instruments,
SysprofRecording *recording);
DexFuture *_sysprof_instruments_prepare (GPtrArray *instruments,
SysprofRecording *recording);
DexFuture *_sysprof_instruments_record (GPtrArray *instruments,
SysprofRecording *recording,
GCancellable *cancellable);
G_END_DECLS

46
src/libsysprof-profile/sysprof-instrument.c
View File

@ -26,8 +26,10 @@
G_DEFINE_ABSTRACT_TYPE (SysprofInstrument, sysprof_instrument, G_TYPE_OBJECT)
static char **
sysprof_instrument_real_list_required_policy (SysprofInstrument *self)
sysprof_instrument_real_list_required_policy (SysprofInstrument *instrument)
{
g_assert (SYSPROF_IS_INSTRUMENT (instrument));
return NULL;
}
@ -35,6 +37,21 @@ static DexFuture *
sysprof_instrument_real_prepare (SysprofInstrument *instrument,
SysprofRecording *recording)
{
g_assert (SYSPROF_IS_INSTRUMENT (instrument));
g_assert (SYSPROF_IS_RECORDING (recording));
return dex_future_new_for_boolean (TRUE);
}
static DexFuture *
sysprof_instrument_real_record (SysprofInstrument *instrument,
SysprofRecording *recording,
GCancellable *cancellable)
{
g_assert (SYSPROF_IS_INSTRUMENT (instrument));
g_assert (SYSPROF_IS_RECORDING (recording));
g_assert (!cancellable || G_IS_CANCELLABLE (cancellable));
return dex_future_new_for_boolean (TRUE);
}
@ -43,6 +60,7 @@ sysprof_instrument_class_init (SysprofInstrumentClass *klass)
{
klass->list_required_policy = sysprof_instrument_real_list_required_policy;
klass->prepare = sysprof_instrument_real_prepare;
klass->record = sysprof_instrument_real_record;
}
static void
@ -146,3 +164,29 @@ _sysprof_instruments_prepare (GPtrArray *instruments,
return dex_future_allv ((DexFuture **)futures->pdata, futures->len);
}
DexFuture *
_sysprof_instruments_record (GPtrArray *instruments,
SysprofRecording *recording,
GCancellable *cancellable)
{
g_autoptr(GPtrArray) futures = NULL;
g_return_val_if_fail (instruments != NULL, NULL);
g_return_val_if_fail (SYSPROF_IS_RECORDING (recording), NULL);
futures = g_ptr_array_new_with_free_func (dex_unref);
for (guint i = 0; i < instruments->len; i++)
{
SysprofInstrument *instrument = g_ptr_array_index (instruments, i);
g_ptr_array_add (futures,
SYSPROF_INSTRUMENT_GET_CLASS (instrument)->record (instrument, recording, cancellable));
}
if (futures->len == 0)
return dex_future_new_for_boolean (TRUE);
return dex_future_allv ((DexFuture **)futures->pdata, futures->len);
}