summaryrefslogtreecommitdiff
path: root/src/managers/EventManager.cpp
diff options
context:
space:
mode:
authorvaxerski <43317083+vaxerski@users.noreply.github.com>2022-11-02 21:28:00 +0000
committervaxerski <43317083+vaxerski@users.noreply.github.com>2022-11-02 21:28:08 +0000
commit6ddfae0a077b2659179c4bb2fc1ae0691b984ccc (patch)
treee7f61068a0bcfb4091cf6ecd84817f6bfb2bdc01 /src/managers/EventManager.cpp
parent0d7176792b6ceed2ade337278f54e1112cdc957e (diff)
remove ensureFDsValid, legacy
Diffstat (limited to 'src/managers/EventManager.cpp')
-rw-r--r--src/managers/EventManager.cpp23
1 files changed, 0 insertions, 23 deletions
diff --git a/src/managers/EventManager.cpp b/src/managers/EventManager.cpp
index fd579ac0..e1b3d26b 100644
--- a/src/managers/EventManager.cpp
+++ b/src/managers/EventManager.cpp
@@ -72,8 +72,6 @@ void CEventManager::startThread() {
// add to event loop so we can close it when we need to
m_dAcceptedSocketFDs.push_back({ACCEPTEDCONNECTION, wl_event_loop_add_fd(g_pCompositor->m_sWLEventLoop, ACCEPTEDCONNECTION, WL_EVENT_READABLE, fdHandleWrite, &m_dAcceptedSocketFDs)});
}
-
- ensureFDsValid();
}
close(SOCKET);
@@ -82,28 +80,7 @@ void CEventManager::startThread() {
m_tThread.detach();
}
-void CEventManager::ensureFDsValid() {
- static char readBuf[1024] = {0};
-
- // pong if all FDs valid
- for (auto it = m_dAcceptedSocketFDs.begin(); it != m_dAcceptedSocketFDs.end();) {
- auto sizeRead = recv(it->first, &readBuf, 1024, 0);
-
- if (sizeRead != 0) {
- it++;
- continue;
- }
-
- // invalid!
- Debug::log(LOG, "Removed invalid socket (2) FD: %d", *it);
- it = m_dAcceptedSocketFDs.erase(it);
- }
-}
-
void CEventManager::flushEvents() {
-
- ensureFDsValid();
-
eventQueueMutex.lock();
for (auto& ev : m_dQueuedEvents) {