diff options
| author | vaxerski <43317083+vaxerski@users.noreply.github.com> | 2022-11-02 21:28:00 +0000 |
|---|---|---|
| committer | vaxerski <43317083+vaxerski@users.noreply.github.com> | 2022-11-02 21:28:08 +0000 |
| commit | 6ddfae0a077b2659179c4bb2fc1ae0691b984ccc (patch) | |
| tree | e7f61068a0bcfb4091cf6ecd84817f6bfb2bdc01 /src/managers/EventManager.cpp | |
| parent | 0d7176792b6ceed2ade337278f54e1112cdc957e (diff) | |
remove ensureFDsValid, legacy
Diffstat (limited to 'src/managers/EventManager.cpp')
| -rw-r--r-- | src/managers/EventManager.cpp | 23 |
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) { |
