From e2cd71b7060ec2e7be9a39e7e643221f185befff Mon Sep 17 00:00:00 2001 From: Sadie Powell Date: Mon, 8 May 2023 13:44:35 +0100 Subject: Move the contents of thread to threadsocket. --- src/thread.cpp | 62 ---------------------------------------------------- src/threadsocket.cpp | 42 +++++++++++++++++++++++++++++++++++ 2 files changed, 42 insertions(+), 62 deletions(-) delete mode 100644 src/thread.cpp diff --git a/src/thread.cpp b/src/thread.cpp deleted file mode 100644 index d2008e2df..000000000 --- a/src/thread.cpp +++ /dev/null @@ -1,62 +0,0 @@ -/* - * InspIRCd -- Internet Relay Chat Daemon - * - * Copyright (C) 2019 Sadie Powell - * - * This file is part of InspIRCd. InspIRCd is free software: you can - * redistribute it and/or modify it under the terms of the GNU General Public - * License as published by the Free Software Foundation, version 2. - * - * This program is distributed in the hope that it will be useful, but WITHOUT - * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS - * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more - * details. - * - * You should have received a copy of the GNU General Public License - * along with this program. If not, see . - */ - - -#include "inspircd.h" - -bool Thread::Start() -{ - try - { - if (thread) - return false; - - thread = new std::thread(Thread::StartInternal, this); - return true; - } - catch (const std::system_error& err) - { - throw CoreException("Unable to start new thread: " + std::string(err.what())); - } -} - -void Thread::StartInternal(Thread* thread) -{ -#ifndef _WIN32 - // C++ does not have an API for this so we still need to use pthreads. - sigset_t set; - sigemptyset(&set); - sigaddset(&set, SIGPIPE); - pthread_sigmask(SIG_BLOCK, &set, nullptr); -#endif - - thread->OnStart(); -} - -bool Thread::Stop() -{ - if (!thread) - return false; - - OnStop(); - stopping = true; - thread->join(); - - stdalgo::delete_zero(thread); - return true; -} diff --git a/src/threadsocket.cpp b/src/threadsocket.cpp index 89c2ce961..1fa40fbf5 100644 --- a/src/threadsocket.cpp +++ b/src/threadsocket.cpp @@ -23,6 +23,48 @@ #include "inspircd.h" #include "threadsocket.h" +bool Thread::Start() +{ + try + { + if (thread) + return false; + + thread = new std::thread(Thread::StartInternal, this); + return true; + } + catch (const std::system_error& err) + { + throw CoreException("Unable to start new thread: " + std::string(err.what())); + } +} + +void Thread::StartInternal(Thread* thread) +{ +#ifndef _WIN32 + // C++ does not have an API for this so we still need to use pthreads. + sigset_t set; + sigemptyset(&set); + sigaddset(&set, SIGPIPE); + pthread_sigmask(SIG_BLOCK, &set, nullptr); +#endif + + thread->OnStart(); +} + +bool Thread::Stop() +{ + if (!thread) + return false; + + OnStop(); + stopping = true; + thread->join(); + + stdalgo::delete_zero(thread); + return true; +} + #if __has_include() #include -- cgit v1.3.1-10-gc9f91