![Sönke Ludwig](/assets/img/avatar_default.png)
Allows dependent code to still access the driver from within their shared static ~this. vibe-core notably falls into this category.
62 lines
1.6 KiB
D
62 lines
1.6 KiB
D
module eventcore.core;
|
|
|
|
public import eventcore.driver;
|
|
|
|
import eventcore.drivers.posix.select;
|
|
import eventcore.drivers.posix.epoll;
|
|
import eventcore.drivers.posix.kqueue;
|
|
import eventcore.drivers.libasync;
|
|
import eventcore.drivers.winapi.driver;
|
|
|
|
version (EventcoreEpollDriver) alias NativeEventDriver = EpollEventDriver;
|
|
else version (EventcoreKqueueDriver) alias NativeEventDriver = KqueueEventDriver;
|
|
else version (EventcoreWinAPIDriver) alias NativeEventDriver = WinAPIEventDriver;
|
|
else version (EventcoreLibasyncDriver) alias NativeEventDriver = LibasyncEventDriver;
|
|
else version (EventcoreSelectDriver) alias NativeEventDriver = SelectEventDriver;
|
|
else alias NativeEventDriver = EventDriver;
|
|
|
|
@property NativeEventDriver eventDriver()
|
|
@safe @nogc nothrow {
|
|
static if (is(NativeEventDriver == EventDriver))
|
|
assert(s_driver !is null, "setupEventDriver() was not called for this thread.");
|
|
else
|
|
assert(s_driver !is null, "eventcore.core static constructor didn't run!?");
|
|
return s_driver;
|
|
}
|
|
|
|
static if (!is(NativeEventDriver == EventDriver)) {
|
|
static this()
|
|
{
|
|
if (!s_driver) s_driver = new NativeEventDriver;
|
|
}
|
|
|
|
static ~this()
|
|
{
|
|
if (!s_isMainThread)
|
|
s_driver.dispose();
|
|
}
|
|
|
|
shared static this()
|
|
{
|
|
s_driver = new NativeEventDriver;
|
|
s_isMainThread = true;
|
|
}
|
|
|
|
shared static ~this()
|
|
{
|
|
s_driver.dispose();
|
|
}
|
|
} else {
|
|
void setupEventDriver(EventDriver driver)
|
|
{
|
|
assert(driver !is null, "The event driver instance must be non-null.");
|
|
assert(!s_driver, "Can only set up the event driver once per thread.");
|
|
s_driver = driver;
|
|
}
|
|
}
|
|
|
|
private {
|
|
NativeEventDriver s_driver;
|
|
bool s_isMainThread;
|
|
}
|