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

sysprof-cat: load document asynchronously from load fiber

Browse Source
This commit is contained in:
Christian Hergert
2024-10-23 11:38:46 -07:00
parent 051559dbca
commit 6d10a4337f
1 changed files with 24 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/sysprof-cat/sysprof-cat.c
View File

@ -389,6 +389,29 @@ end_document (SysprofDocument *document)
g_print ("}\n"); g_print ("}\n");
} }
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_cat_fiber (gpointer data) sysprof_cat_fiber (gpointer data)
{ {
@ -401,7 +424,7 @@ sysprof_cat_fiber (gpointer data)
loader = sysprof_document_loader_new (filename); loader = sysprof_document_loader_new (filename);
if (!(document = sysprof_document_loader_load (loader, NULL, &error))) if (!(document = dex_await_object (load_document (loader), &error)))
return dex_future_new_for_error (g_steal_pointer (&error)); return dex_future_new_for_error (g_steal_pointer (&error));
begin_document (document); begin_document (document);