tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-07-27 07:34:15 +02:00
Code Issues Packages Projects Releases Wiki Activity

Rename the IOTHREADS macro

Browse Source 
refs #11014
This commit is contained in:
Gunnar Beutner 2016-02-16 13:30:55 +01:00
parent 9e9298f4fa
commit 9a8458fd67
1 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
lib/base/socketevents.cpp
View File

@ -53,24 +53,24 @@ struct EventDescription
Object::Ptr LifesupportReference; Object::Ptr LifesupportReference;
}; };
#define IOTHREADS 8 #define SOCKET_IOTHREADS 8
static boost::once_flag l_SocketIOOnceFlag = BOOST_ONCE_INIT; static boost::once_flag l_SocketIOOnceFlag = BOOST_ONCE_INIT;
static boost::thread l_SocketIOThreads[IOTHREADS]; static boost::thread l_SocketIOThreads[SOCKET_IOTHREADS];
#ifdef __linux__ #ifdef __linux__
static SOCKET l_SocketIOPollFDs[IOTHREADS]; static SOCKET l_SocketIOPollFDs[SOCKET_IOTHREADS];
#endif /* __linux__ */ #endif /* __linux__ */
static SOCKET l_SocketIOEventFDs[IOTHREADS][2]; static SOCKET l_SocketIOEventFDs[SOCKET_IOTHREADS][2];
static bool l_SocketIOFDChanged[IOTHREADS]; static bool l_SocketIOFDChanged[SOCKET_IOTHREADS];
static boost::mutex l_SocketIOMutex[IOTHREADS]; static boost::mutex l_SocketIOMutex[SOCKET_IOTHREADS];
static boost::condition_variable l_SocketIOCV[IOTHREADS]; static boost::condition_variable l_SocketIOCV[SOCKET_IOTHREADS];
static std::map<SOCKET, SocketEventDescriptor> l_SocketIOSockets[IOTHREADS]; static std::map<SOCKET, SocketEventDescriptor> l_SocketIOSockets[SOCKET_IOTHREADS];
int SocketEvents::m_NextID = 0; int SocketEvents::m_NextID = 0;
void SocketEvents::InitializeThread(void) void SocketEvents::InitializeThread(void)
{ {
for (int i = 0; i < IOTHREADS; i++) { for (int i = 0; i < SOCKET_IOTHREADS; i++) {
#ifdef __linux__ #ifdef __linux__
l_SocketIOPollFDs[i] = epoll_create1(EPOLL_CLOEXEC); l_SocketIOPollFDs[i] = epoll_create1(EPOLL_CLOEXEC);
#endif /* __linux__ */ #endif /* __linux__ */
@ -259,7 +259,7 @@ void SocketEvents::ThreadProc(int tid)
void SocketEvents::WakeUpThread(bool wait) void SocketEvents::WakeUpThread(bool wait)
{ {
int tid = m_ID % IOTHREADS; int tid = m_ID % SOCKET_IOTHREADS;
if (boost::this_thread::get_id() == l_SocketIOThreads[tid].get_id()) if (boost::this_thread::get_id() == l_SocketIOThreads[tid].get_id())
return; return;
@ -301,7 +301,7 @@ SocketEvents::~SocketEvents(void)
void SocketEvents::Register(Object *lifesupportObject) void SocketEvents::Register(Object *lifesupportObject)
{ {
int tid = m_ID % IOTHREADS; int tid = m_ID % SOCKET_IOTHREADS;
{ {
boost::mutex::scoped_lock lock(l_SocketIOMutex[tid]); boost::mutex::scoped_lock lock(l_SocketIOMutex[tid]);
@ -339,7 +339,7 @@ void SocketEvents::Register(Object *lifesupportObject)
void SocketEvents::Unregister(void) void SocketEvents::Unregister(void)
{ {
int tid = m_ID % IOTHREADS; int tid = m_ID % SOCKET_IOTHREADS;
{ {
boost::mutex::scoped_lock lock(l_SocketIOMutex[tid]); boost::mutex::scoped_lock lock(l_SocketIOMutex[tid]);
@ -366,7 +366,7 @@ void SocketEvents::ChangeEvents(int events)
if (m_FD == INVALID_SOCKET) if (m_FD == INVALID_SOCKET)
BOOST_THROW_EXCEPTION(std::runtime_error("Tried to read/write from a closed socket.")); BOOST_THROW_EXCEPTION(std::runtime_error("Tried to read/write from a closed socket."));
int tid = m_ID % IOTHREADS; int tid = m_ID % SOCKET_IOTHREADS;
#ifdef __linux__ #ifdef __linux__
epoll_event event; epoll_event event;
@ -400,7 +400,7 @@ void SocketEvents::ChangeEvents(int events)
bool SocketEvents::IsHandlingEvents(void) const bool SocketEvents::IsHandlingEvents(void) const
{ {
int tid = m_ID % IOTHREADS; int tid = m_ID % SOCKET_IOTHREADS;
boost::mutex::scoped_lock lock(l_SocketIOMutex[tid]); boost::mutex::scoped_lock lock(l_SocketIOMutex[tid]);
return m_Events; return m_Events;
} }