#include "wx/unix/private/epolldispatcher.h"
#include "wx/unix/private/wakeuppipe.h"
#include "wx/private/selectdispatcher.h"
+#include "wx/private/eventloopsourcesmanager.h"
+#include "wx/private/fdioeventloopsourcehandler.h"
+#include "wx/private/eventloopsourcesmanager.h"
#if wxUSE_EVENTLOOP_SOURCE
#include "wx/evtloopsrc.h"
wxConsoleEventLoop::wxConsoleEventLoop()
{
- m_wakeupPipe = new wxWakeUpPipe;
+ m_wakeupPipe = new wxWakeUpPipeMT;
const int pipeFD = m_wakeupPipe->GetReadFd();
if ( pipeFD == wxPipe::INVALID_FD )
{
#if wxUSE_EVENTLOOP_SOURCE
-// This class is a temporary bridge between event loop sources and
-// FDIODispatcher. It is going to be removed soon, when all subject interfaces
-// are modified
-class wxFDIOEventLoopSourceHandler : public wxFDIOHandler
+class wxConsoleEventLoopSourcesManager : public wxEventLoopSourcesManagerBase
{
public:
- wxFDIOEventLoopSourceHandler(wxEventLoopSourceHandler* handler) :
- m_impl(handler) { }
-
- virtual void OnReadWaiting()
- {
- m_impl->OnReadWaiting();
- }
- virtual void OnWriteWaiting()
+ wxEventLoopSource* AddSourceForFD( int fd,
+ wxEventLoopSourceHandler *handler,
+ int flags)
{
- m_impl->OnWriteWaiting();
- }
+ wxCHECK_MSG( fd != -1, NULL, "can't monitor invalid fd" );
- virtual void OnExceptionWaiting()
- {
- m_impl->OnExceptionWaiting();
- }
+ wxLogTrace(wxTRACE_EVT_SOURCE,
+ "Adding event loop source for fd=%d", fd);
-protected:
- wxEventLoopSourceHandler* m_impl;
-};
+ // we need a bridge to wxFDIODispatcher
+ //
+ // TODO: refactor the code so that only wxEventLoopSourceHandler is used
+ wxScopedPtr<wxFDIOHandler>
+ fdioHandler(new wxFDIOEventLoopSourceHandler(handler));
-wxEventLoopSource *
-wxConsoleEventLoop::AddSourceForFD(int fd,
- wxEventLoopSourceHandler *handler,
- int flags)
-{
- wxCHECK_MSG( fd != -1, NULL, "can't monitor invalid fd" );
-
- wxLogTrace(wxTRACE_EVT_SOURCE,
- "Adding event loop source for fd=%d", fd);
+ if ( !wxFDIODispatcher::Get()->RegisterFD(fd, fdioHandler.get(), flags) )
+ return NULL;
- // we need a bridge to wxFDIODispatcher
- //
- // TODO: refactor the code so that only wxEventLoopSourceHandler is used
- wxScopedPtr<wxFDIOHandler>
- fdioHandler(new wxFDIOEventLoopSourceHandler(handler));
+ return new wxUnixEventLoopSource(wxFDIODispatcher::Get(), fdioHandler.release(),
+ fd, handler, flags);
+ }
+};
- if ( !m_dispatcher->RegisterFD(fd, fdioHandler.get(), flags) )
- return NULL;
+wxEventLoopSourcesManagerBase* wxAppTraits::GetEventLoopSourcesManager()
+{
+ static wxConsoleEventLoopSourcesManager s_eventLoopSourcesManager;
- return new wxUnixEventLoopSource(m_dispatcher, fdioHandler.release(),
- fd, handler, flags);
+ return &s_eventLoopSourcesManager;
}
wxUnixEventLoopSource::~wxUnixEventLoopSource()