X-Git-Url: https://git.saurik.com/wxWidgets.git/blobdiff_plain/ad8d42f83cdf7a4f26969957e94ed166a1a5710e..9d5507f7a2701395e1d5c121bd877bb9066ee6ea:/src/unix/epolldispatcher.cpp diff --git a/src/unix/epolldispatcher.cpp b/src/unix/epolldispatcher.cpp index 533d15b45a..6f36836f0f 100644 --- a/src/unix/epolldispatcher.cpp +++ b/src/unix/epolldispatcher.cpp @@ -19,11 +19,10 @@ // for compilers that support precompilation, includes "wx.h". #include "wx/wxprec.h" -#ifdef HAVE_SYS_EPOLL_H +#if wxUSE_EPOLL_DISPATCHER #include "wx/unix/private/epolldispatcher.h" #include "wx/unix/private.h" -#include "wx/module.h" #ifndef WX_PRECOMP #include "wx/log.h" @@ -32,18 +31,17 @@ #include #include +#include #define wxEpollDispatcher_Trace wxT("epolldispatcher") -static wxEpollDispatcher *gs_epollDispatcher = NULL; - // ============================================================================ // implementation // ============================================================================ // helper: return EPOLLxxx mask corresponding to the given flags (and also log // debugging messages about it) -static uint32_t GetEpollMask(int flags, int fd) +static uint32_t GetEpollMask(int flags, int WXUNUSED_UNLESS_DEBUG(fd)) { uint32_t ep = 0; @@ -75,12 +73,31 @@ static uint32_t GetEpollMask(int flags, int fd) // wxEpollDispatcher // ---------------------------------------------------------------------------- -wxEpollDispatcher::wxEpollDispatcher() +/* static */ +wxEpollDispatcher *wxEpollDispatcher::Create() { - m_epollDescriptor = epoll_create(1024); - if ( m_epollDescriptor == -1 ) + int epollDescriptor = epoll_create(1024); + if ( epollDescriptor == -1 ) { wxLogSysError(_("Failed to create epoll descriptor")); + return NULL; + } + + return new wxEpollDispatcher(epollDescriptor); +} + +wxEpollDispatcher::wxEpollDispatcher(int epollDescriptor) +{ + wxASSERT_MSG( epollDescriptor != -1, _T("invalid descriptor") ); + + m_epollDescriptor = epollDescriptor; +} + +wxEpollDispatcher::~wxEpollDispatcher() +{ + if ( close(m_epollDescriptor) != 0 ) + { + wxLogSysError(_("Error closing epoll descriptor")); } } @@ -120,7 +137,7 @@ bool wxEpollDispatcher::ModifyFD(int fd, wxFDIOHandler* handler, int flags) return true; } -bool wxEpollDispatcher::UnregisterFD(int fd, int flags) +bool wxEpollDispatcher::UnregisterFD(int fd) { epoll_event ev; ev.events = 0; @@ -135,7 +152,7 @@ bool wxEpollDispatcher::UnregisterFD(int fd, int flags) return true; } -void wxEpollDispatcher::RunLoop(int timeout) +void wxEpollDispatcher::Dispatch(int timeout) { epoll_event events[16]; @@ -168,46 +185,11 @@ void wxEpollDispatcher::RunLoop(int timeout) if ( p->events & EPOLLIN ) handler->OnReadWaiting(); - - if ( p->events & EPOLLOUT ) + else if ( p->events & EPOLLOUT ) handler->OnWriteWaiting(); - - if ( p->events & (EPOLLERR | EPOLLHUP) ) + else if ( p->events & (EPOLLERR | EPOLLHUP) ) handler->OnExceptionWaiting(); } } -/* static */ -wxEpollDispatcher *wxEpollDispatcher::Get() -{ - if ( !gs_epollDispatcher ) - { - gs_epollDispatcher = new wxEpollDispatcher; - if ( !gs_epollDispatcher->IsOk() ) - { - delete gs_epollDispatcher; - gs_epollDispatcher = NULL; - } - } - - return gs_epollDispatcher; -} - -// ---------------------------------------------------------------------------- -// wxEpollDispatcherModule -// ---------------------------------------------------------------------------- - -class wxEpollDispatcherModule : public wxModule -{ -public: - wxEpollDispatcherModule() { } - - virtual bool OnInit() { return true; } - virtual void OnExit() { wxDELETE(gs_epollDispatcher); } - - DECLARE_DYNAMIC_CLASS(wxEpollDispatcherModule) -}; - -IMPLEMENT_DYNAMIC_CLASS(wxEpollDispatcherModule, wxModule) - -#endif // HAVE_SYS_EPOLL_H +#endif // wxUSE_EPOLL_DISPATCHER