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

sysprof-diff: load document asynchronously

Browse Source
This commit is contained in:
Christian Hergert
2024-10-23 11:56:30 -07:00
parent d5d3c71879
commit ef32a3c921
1 changed files with 25 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
src/sysprof-diff/sysprof-diff.c
View File

@ -169,6 +169,29 @@ diff (SysprofCallgraphNode *left,
} }
} }
static void
load_document_cb (GObject *object,
GAsyncResult *result,
gpointer user_data)
{
g_autoptr(DexPromise) promise = user_data;
SysprofDocument *document;
GError *error = NULL;
if ((document = sysprof_document_loader_load_finish (SYSPROF_DOCUMENT_LOADER (object), result, &error)))
dex_promise_resolve_object (promise, document);
else
dex_promise_reject (promise, error);
}
static DexFuture *
load_document (SysprofDocumentLoader *loader)
{
DexPromise *promise = dex_promise_new ();
sysprof_document_loader_load_async (loader, NULL, load_document_cb, dex_ref (promise));
return DEX_FUTURE (promise);
}
static DexFuture * static DexFuture *
sysprof_diff_fiber (gpointer data) sysprof_diff_fiber (gpointer data)
{ {
@ -192,7 +215,7 @@ sysprof_diff_fiber (gpointer data)
loader2 = sysprof_document_loader_new (filenames[1]); loader2 = sysprof_document_loader_new (filenames[1]);
g_printerr ("Loading %s...\n", filenames[0]); g_printerr ("Loading %s...\n", filenames[0]);
if (!(document1 = sysprof_document_loader_load (loader1, NULL, &error))) if (!(document1 = dex_await_object (load_document (loader1), &error)))
return dex_future_new_for_error (g_steal_pointer (&error)); return dex_future_new_for_error (g_steal_pointer (&error));
traceables1 = sysprof_document_list_samples (document1); traceables1 = sysprof_document_list_samples (document1);
@ -201,7 +224,7 @@ sysprof_diff_fiber (gpointer data)
return dex_future_new_for_error (g_steal_pointer (&error)); return dex_future_new_for_error (g_steal_pointer (&error));
g_printerr ("Loading %s...\n", filenames[1]); g_printerr ("Loading %s...\n", filenames[1]);
if (!(document2 = sysprof_document_loader_load (loader2, NULL, &error))) if (!(document2 = dex_await_object (load_document (loader2), &error)))
return dex_future_new_for_error (g_steal_pointer (&error)); return dex_future_new_for_error (g_steal_pointer (&error));
traceables2 = sysprof_document_list_samples (document2); traceables2 = sysprof_document_list_samples (document2);