Revert "event/Thread: start the thread in the constructor"

This reverts commit b49cfe96f406bf0b750b7a1ea73609905d606335.  It was
a bad idea because it broke signal handlers.  I need to find a better
way to fix io_uring intialization.
This commit is contained in:
Max Kellermann 2025-01-30 19:50:35 +01:00
parent 30bd70939a
commit 838398103c
13 changed files with 22 additions and 4 deletions

@ -329,6 +329,9 @@ MainConfigured(const CommandLineOptions &options,
Instance instance;
global_instance = &instance;
instance.io_thread.Start();
instance.rtio_thread.Start();
#ifdef ENABLE_NEIGHBOR_PLUGINS
instance.neighbors = std::make_unique<NeighborGlue>();
instance.neighbors->Init(raw_config,

@ -20,9 +20,7 @@ class EventThread final {
public:
explicit EventThread(bool _realtime=false)
:event_loop(ThreadId::Null()), thread(BIND_THIS_METHOD(Run)),
realtime(_realtime) {
Start();
}
realtime(_realtime) {}
~EventThread() noexcept {
Stop();
@ -32,11 +30,11 @@ public:
return event_loop;
}
private:
void Start();
void Stop() noexcept;
private:
void Run() noexcept;
};

@ -28,6 +28,12 @@ class GlobalInit {
EventThread io_thread;
public:
GlobalInit() {
io_thread.Start();
}
~GlobalInit() = default;
EventLoop &GetEventLoop() {
return io_thread.GetEventLoop();
}

@ -24,6 +24,7 @@ try {
const char *path = argv[1];
EventThread io_thread;
io_thread.Start();
const ScopeInputPluginsInit input_plugins_init(ConfigData(),
io_thread.GetEventLoop());

@ -84,6 +84,8 @@ public:
input_plugins_init(config, io_thread.GetEventLoop()),
decoder_plugins_init(config)
{
io_thread.Start();
pcm_convert_global_init(config);
}
};

@ -47,6 +47,7 @@ try {
const auto config = AutoLoadConfigFile(config_path);
EventThread io_thread;
io_thread.Start();
const ScopeInputPluginsInit input_plugins_init(config, io_thread.GetEventLoop());
const ScopePlaylistPluginsInit playlist_plugins_init(config);

@ -34,6 +34,7 @@ public:
explicit GlobalInit(Path config_path)
:config(AutoLoadConfigFile(config_path))
{
io_thread.Start();
}
};

@ -86,6 +86,7 @@ try {
const char *path = argv[2];
EventThread io_thread;
io_thread.Start();
const ScopeInputPluginsInit input_plugins_init(ConfigData(),
io_thread.GetEventLoop());

@ -91,6 +91,7 @@ public:
input_plugins_init(config, io_thread.GetEventLoop()),
decoder_plugins_init(config)
{
io_thread.Start();
}
};

@ -130,6 +130,7 @@ public:
explicit GlobalInit(Path config_path)
:config(AutoLoadConfigFile(config_path))
{
io_thread.Start();
}
};

@ -158,6 +158,7 @@ try {
const auto config = AutoLoadConfigFile(c.config_path);
EventThread io_thread;
io_thread.Start();
/* initialize the audio output */

@ -114,6 +114,7 @@ public:
GlobalInit(Path config_path)
:config(AutoLoadConfigFile(config_path))
{
io_thread.Start();
}
EventLoop &GetEventLoop() noexcept {

@ -35,6 +35,7 @@ public:
explicit GlobalInit(Path config_path)
:config(AutoLoadConfigFile(config_path))
{
io_thread.Start();
}
};