// For compilers that support precompilation, includes "wx.h".
#include "wx/wxprec.h"
-#include "wx/evtloop.h"
+#if wxUSE_CONSOLE_EVENTLOOP
#ifndef WX_PRECOMP
#include "wx/app.h"
#endif
#include <errno.h>
+#include "wx/apptrait.h"
+#include "wx/evtloop.h"
#include "wx/thread.h"
#include "wx/module.h"
#include "wx/unix/private/timer.h"
#define TRACE_EVENTS _T("events")
-//this code should not be compiled when GUI is defined
-//(monolithic build issue)
-#if !wxUSE_GUI
-
// ===========================================================================
// wxEventLoop::PipeIOHandler implementation
// ===========================================================================
void wxConsoleEventLoop::PipeIOHandler::OnReadWaiting()
{
// got wakeup from child thread: read all data available in pipe just to
- // make it empty (evevn though we write one byte at a time from WakeUp(),
+ // make it empty (even though we write one byte at a time from WakeUp(),
// it could have been called several times)
char buf[4];
for ( ;; )
}
}
- wxTheApp->ProcessPendingEvents();
+ // writing to the wake up pipe will make wxConsoleEventLoop return from
+ // wxFDIODispatcher::Dispatch() it might be currently blocking in, nothing
+ // else needs to be done
}
// ===========================================================================
return;
}
-#ifdef HAVE_SYS_EPOLL_H
- m_dispatcher = wxEpollDispatcher::Get();
+ m_dispatcher = wxFDIODispatcher::Get();
if ( !m_dispatcher )
-#endif // HAVE_SYS_EPOLL_H
- {
- m_dispatcher = wxSelectDispatcher::Get();
- }
-
- wxCHECK_RET( m_dispatcher, _T("failed to create IO dispatcher") );
+ return;
m_dispatcher->RegisterFD
(
&m_wakeupPipe,
wxFDIO_INPUT
);
-};
+}
//-----------------------------------------------------------------------------
// events dispatch and loop handling
bool wxConsoleEventLoop::Pending() const
{
- return wxTheApp->HasPendingEvents();
+ if ( m_dispatcher->HasPending() )
+ return true;
+
+#if wxUSE_TIMER
+ wxUsecClock_t nextTimer;
+ if ( wxTimerScheduler::Get().GetNext(&nextTimer) &&
+ !wxMilliClockToLong(nextTimer) )
+ return true;
+#endif // wxUSE_TIMER
+
+ return false;
}
bool wxConsoleEventLoop::Dispatch()
{
- wxTheApp->ProcessPendingEvents();
- return true;
-}
+ DispatchTimeout(wxFDIODispatcher::TIMEOUT_INFINITE);
-void wxConsoleEventLoop::WakeUp()
-{
- m_wakeupPipe.WakeUp();
+ return true;
}
-void wxConsoleEventLoop::OnNextIteration()
+int wxConsoleEventLoop::DispatchTimeout(unsigned long timeout)
{
- // calculate the timeout until the next timer expiration
- int timeout;
-
#if wxUSE_TIMER
+ // check if we need to decrease the timeout to account for a timer
wxUsecClock_t nextTimer;
if ( wxTimerScheduler::Get().GetNext(&nextTimer) )
{
- // timeout is in ms
- timeout = (nextTimer / 1000).ToLong();
+ unsigned long timeUntilNextTimer = wxMilliClockToLong(nextTimer / 1000);
+ if ( timeUntilNextTimer < timeout )
+ timeout = timeUntilNextTimer;
}
- else // no timers, we can block forever
#endif // wxUSE_TIMER
- {
- timeout = wxFDIODispatcher::TIMEOUT_INFINITE;
- }
- m_dispatcher->RunLoop(timeout);
+ bool hadEvent = m_dispatcher->Dispatch(timeout) > 0;
#if wxUSE_TIMER
- wxTimerScheduler::Get().NotifyExpired();
-#endif
+ if ( wxTimerScheduler::Get().NotifyExpired() )
+ hadEvent = true;
+#endif // wxUSE_TIMER
+
+ return hadEvent ? 1 : -1;
+}
+void wxConsoleEventLoop::WakeUp()
+{
+ m_wakeupPipe.WakeUp();
+}
+
+void wxConsoleEventLoop::OnNextIteration()
+{
// call the signal handlers for any signals we caught recently
wxTheApp->CheckSignal();
}
-#endif // !wxUSE_GUI
+
+wxEventLoopBase *wxConsoleAppTraits::CreateEventLoop()
+{
+ return new wxEventLoop();
+}
+
+#endif // wxUSE_CONSOLE_EVENTLOOP