mirror of
https://github.com/Icinga/icinga2.git
synced 2025-07-26 15:14:07 +02:00
parent
172b57e895
commit
60c52f2109
@ -55,6 +55,9 @@ void SocketEventEnginePoll::ThreadProc(int tid)
|
|||||||
typedef std::map<SOCKET, SocketEventDescriptor>::value_type kv_pair;
|
typedef std::map<SOCKET, SocketEventDescriptor>::value_type kv_pair;
|
||||||
|
|
||||||
BOOST_FOREACH(const kv_pair& desc, m_Sockets[tid]) {
|
BOOST_FOREACH(const kv_pair& desc, m_Sockets[tid]) {
|
||||||
|
if (desc.second.Events == 0)
|
||||||
|
continue;
|
||||||
|
|
||||||
if (desc.second.EventInterface)
|
if (desc.second.EventInterface)
|
||||||
desc.second.EventInterface->m_EnginePrivate = &pfds[i];
|
desc.second.EventInterface->m_EnginePrivate = &pfds[i];
|
||||||
|
|
||||||
@ -65,6 +68,8 @@ void SocketEventEnginePoll::ThreadProc(int tid)
|
|||||||
i++;
|
i++;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pfds.resize(i);
|
||||||
|
|
||||||
m_FDChanged[tid] = false;
|
m_FDChanged[tid] = false;
|
||||||
m_CV[tid].notify_all();
|
m_CV[tid].notify_all();
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user