Rename the IOTHREADS macro

refs #11014

diff --git a/lib/base/socketevents.cpp b/lib/base/socketevents.cpp
index fbcca5d6a342911e3cd6a42eccac15ea2f448f41..0a350b25303d08b7a9fb1fc7226fab1959615a13 100644 (file)
--- a/lib/base/socketevents.cpp
+++ b/lib/base/socketevents.cpp
@@ -53,24 +53,24 @@ struct EventDescription
        Object::Ptr LifesupportReference;
 };
 
-#define IOTHREADS 8
+#define SOCKET_IOTHREADS 8
 
 static boost::once_flag l_SocketIOOnceFlag = BOOST_ONCE_INIT;
-static boost::thread l_SocketIOThreads[IOTHREADS];
+static boost::thread l_SocketIOThreads[SOCKET_IOTHREADS];
 #ifdef __linux__
-static SOCKET l_SocketIOPollFDs[IOTHREADS];
+static SOCKET l_SocketIOPollFDs[SOCKET_IOTHREADS];
 #endif /* __linux__ */
-static SOCKET l_SocketIOEventFDs[IOTHREADS][2];
-static bool l_SocketIOFDChanged[IOTHREADS];
-static boost::mutex l_SocketIOMutex[IOTHREADS];
-static boost::condition_variable l_SocketIOCV[IOTHREADS];
-static std::map<SOCKET, SocketEventDescriptor> l_SocketIOSockets[IOTHREADS];
+static SOCKET l_SocketIOEventFDs[SOCKET_IOTHREADS][2];
+static bool l_SocketIOFDChanged[SOCKET_IOTHREADS];
+static boost::mutex l_SocketIOMutex[SOCKET_IOTHREADS];
+static boost::condition_variable l_SocketIOCV[SOCKET_IOTHREADS];
+static std::map<SOCKET, SocketEventDescriptor> l_SocketIOSockets[SOCKET_IOTHREADS];
 
 int SocketEvents::m_NextID = 0;
 
 void SocketEvents::InitializeThread(void)
 {
-       for (int i = 0; i < IOTHREADS; i++) {
+       for (int i = 0; i < SOCKET_IOTHREADS; i++) {
 #ifdef __linux__
                l_SocketIOPollFDs[i] = epoll_create1(EPOLL_CLOEXEC);
 #endif /* __linux__ */
@@ -259,7 +259,7 @@ void SocketEvents::ThreadProc(int tid)
 
 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())
                return;
@@ -301,7 +301,7 @@ SocketEvents::~SocketEvents(void)
 
 void SocketEvents::Register(Object *lifesupportObject)
 {
-       int tid = m_ID % IOTHREADS;
+       int tid = m_ID % SOCKET_IOTHREADS;
 
        {
                boost::mutex::scoped_lock lock(l_SocketIOMutex[tid]);
@@ -339,7 +339,7 @@ void SocketEvents::Register(Object *lifesupportObject)
 
 void SocketEvents::Unregister(void)
 {
-       int tid = m_ID % IOTHREADS;
+       int tid = m_ID % SOCKET_IOTHREADS;
 
        {
                boost::mutex::scoped_lock lock(l_SocketIOMutex[tid]);
@@ -366,7 +366,7 @@ void SocketEvents::ChangeEvents(int events)
        if (m_FD == INVALID_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__
        epoll_event event;
@@ -400,7 +400,7 @@ void SocketEvents::ChangeEvents(int events)
 
 bool SocketEvents::IsHandlingEvents(void) const
 {
-       int tid = m_ID % IOTHREADS;
+       int tid = m_ID % SOCKET_IOTHREADS;
        boost::mutex::scoped_lock lock(l_SocketIOMutex[tid]);
        return m_Events;
 }