MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-11-25 08:12:37 +01:00
Code Issues Releases Wiki Activity

ircd::ctx::ole: Add options structure; minor cleanup.

Browse source
This commit is contained in:
Jason Volk 2019-07-11 14:31:48 -07:00
parent d19e960c58
commit ae071552fb
2 changed files with 28 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
include/ircd/ctx/ole.h
View file

@ -20,8 +20,11 @@
namespace ircd::ctx::ole
{
struct init;
struct opts;
struct control;
using closure = std::function<void ()>;
void offload(const std::function<void ()> &);
void offload(const opts &, const closure &);
}
namespace ircd::ctx
@ -29,6 +32,18 @@ namespace ircd::ctx
using ole::offload;
}
struct ircd::ctx::ole::opts
{
/// Optionally give this offload task a name for any tasklist.
string_view name;
/// The function will be executed on each thread.
size_t concurrency {1};
/// Queuing priority; in the form of a nice value.
int8_t prio {0};
};
struct ircd::ctx::ole::init
{
init();

20
ircd/ctx_ole.cc
View file

@ -13,8 +13,6 @@
namespace ircd::ctx::ole
{
using closure = std::function<void ()>;
extern conf::item<size_t> thread_max;
std::mutex mutex;
@ -54,8 +52,11 @@ noexcept
}
void
ircd::ctx::ole::offload(const std::function<void ()> &func)
ircd::ctx::ole::offload(const opts &opts,
const closure &func)
{
assert(opts.concurrency == 1); // not yet implemented
bool done(false);
auto *const context(current);
const auto kick([&context, &done]
@ -85,6 +86,10 @@ ircd::ctx::ole::offload(const std::function<void ()> &func)
// to another thread. This context must stay right here and not disappear
// until the other thread signals back. Note that the destructor is
// capable of throwing an interrupt that was received during this scope.
//
// Don't throw any exception if there is a pending interrupt for this ctx.
// Two exceptions will be thrown in that case and if there's an interrupt
// we don't care about eptr anyway.
const uninterruptible uninterruptible;
push(std::move(closure)); do
@ -93,13 +98,12 @@ ircd::ctx::ole::offload(const std::function<void ()> &func)
}
while(!done);
// Don't throw any exception if there is a pending interrupt for this ctx.
// Two exceptions will be thrown in that case and if there's an interrupt
// we don't care about eptr anyway.
if(eptr && likely(!interruption_requested()))
if(unlikely(interruption_requested()))
return;
if(eptr)
std::rethrow_exception(eptr);
}
void
ircd::ctx::ole::push(closure &&func)
{