mirror of
https://github.com/matrix-construct/construct
synced 2024-11-05 05:18:54 +01:00
59 lines
1.6 KiB
C++
59 lines
1.6 KiB
C++
|
// Matrix Construct
|
||
|
|
//
|
||
|
|
// Copyright (C) Matrix Construct Developers, Authors & Contributors
|
||
|
|
// Copyright (C) 2016-2018 Jason Volk <jason@zemos.net>
|
||
|
|
//
|
||
|
|
// Permission to use, copy, modify, and/or distribute this software for any
|
||
|
|
// purpose with or without fee is hereby granted, provided that the above
|
||
|
|
// copyright notice and this permission notice is present in all copies. The
|
||
|
|
// full license for this software is available in the LICENSE file.
|
||
|
|
|
||
|
|
#include <ircd/asio.h>
|
||
|
|
|
||
|
|
/// Record of the ID of the thread static initialization took place on.
|
||
|
|
decltype(ircd::ios::static_thread_id)
|
||
|
|
ircd::ios::static_thread_id
|
||
|
|
{
|
||
|
|
std::this_thread::get_id()
|
||
|
|
};
|
||
|
|
|
||
|
|
/// "main" thread for IRCd; the one the main context landed on.
|
||
|
|
decltype(ircd::ios::main_thread_id)
|
||
|
|
ircd::ios::main_thread_id;
|
||
|
|
|
||
|
|
decltype(ircd::ios::user)
|
||
|
|
ircd::ios::user;
|
||
|
|
|
||
|
|
void
|
||
|
|
ircd::ios::init(asio::io_context &user)
|
||
|
|
{
|
||
|
|
// Sample the ID of this thread. Since this is the first transfer of
|
||
|
|
// control to libircd after static initialization we have nothing to
|
||
|
|
// consider a main thread yet. We need something set for many assertions
|
||
|
|
// to pass until ircd::main() is entered which will reset this to where
|
||
|
|
// ios.run() is really running.
|
||
|
|
main_thread_id = std::this_thread::get_id();
|
||
|
|
|
||
|
|
// Set a reference to the user's ios_service
|
||
|
|
ios::user = &user;
|
||
|
|
}
|
||
|
|
|
||
|
|
void
|
||
|
|
ircd::ios::post(std::function<void ()> function)
|
||
|
|
{
|
||
|
|
boost::asio::post(get(), std::move(function));
|
||
|
|
}
|
||
|
|
|
||
|
|
void
|
||
|
|
ircd::ios::dispatch(std::function<void ()> function)
|
||
|
|
{
|
||
|
|
boost::asio::dispatch(get(), std::move(function));
|
||
|
|
}
|
||
|
|
|
||
|
|
boost::asio::io_context &
|
||
|
|
ircd::ios::get()
|
||
|
|
{
|
||
|
|
assert(user);
|
||
|
|
return *user;
|
||
|
|
}
|