guiwf/lix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

libutil: add a type-mapping TRY_AWAIT

Browse Source 
mapping the result of an await operation before unpacking it lets us
inject rpc type conversion functions without duplicating all that is
needed for proper exception wrapping and async error traces support.

Change-Id: Ibcba1cc6d2b275757e3475881ef20f95dd4d684f
This commit is contained in:
eldritch horrors
2025-07-15 06:40:48 +00:00
parent e01ae1f453
commit 07ba511921
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lix/libutil/async.hh
+7 -4
View File
@@ -129,24 +129,27 @@ auto runAsyncInNewThread(std::invocable<AsyncIoRoot &> auto fn)
return AIOROOT.blockOn(__VA_ARGS__); \
})
#define LIX_TRY_AWAIT_CONTEXT(ctx, ...) \
#define LIX_TRY_AWAIT_CONTEXT_MAP(_l_ctx, _l_map, ...) \
({ \
auto _lix_awaited = co_await (__VA_ARGS__); \
auto _lix_awaited = (_l_map) (co_await (__VA_ARGS__)); \
if (_lix_awaited.has_error()) { \
try { \
_lix_awaited.value(); \
} catch (::nix::BaseException & e) { \
e.addAsyncTrace(::std::source_location::current(), ctx()); \
e.addAsyncTrace(::std::source_location::current(), _l_ctx()); \
throw; \
} catch (::std::exception & e) { /* NOLINT(lix-foreign-exceptions) */ \
::nix::ForeignException fe(e); \
fe.addAsyncTrace(::std::source_location::current(), ctx()); \
fe.addAsyncTrace(::std::source_location::current(), _l_ctx()); \
throw fe; \
} \
} \
::nix::detail::materializeResult(std::move(_lix_awaited)); \
})
#define LIX_TRY_AWAIT_CONTEXT(_l_ctx, ...) \
LIX_TRY_AWAIT_CONTEXT_MAP(_l_ctx, (std::identity{}), __VA_ARGS__)
/**
* Magic name used by `LIX_TRY_AWAIT` to insert additional context into an
* async trace frame. This name will be looked up in the local scope every