#include "wx/app.h"
#endif
-#include "wx/timer.h"
-#include "wx/private/socketevtdispatch.h"
+#include "wx/thread.h"
+#include "wx/generic/private/timer.h"
+#include "wx/private/selectdispatcher.h"
#include "wx/dfb/private.h"
+#include "wx/nonownedwnd.h"
-#define TRACE_EVENTS _T("events")
+#define TRACE_EVENTS "events"
// ===========================================================================
// implementation
// wxEventLoop initialization
//-----------------------------------------------------------------------------
-wxIDirectFBEventBufferPtr wxEventLoop::ms_buffer;
+wxIDirectFBEventBufferPtr wxGUIEventLoop::ms_buffer;
-wxEventLoop::wxEventLoop()
+wxGUIEventLoop::wxGUIEventLoop()
{
if ( !ms_buffer )
InitBuffer();
}
/* static */
-void wxEventLoop::InitBuffer()
+void wxGUIEventLoop::InitBuffer()
{
ms_buffer = wxIDirectFB::Get()->CreateEventBuffer();
}
/* static */
-void wxEventLoop::CleanUp()
+void wxGUIEventLoop::CleanUp()
{
ms_buffer.Reset();
}
/* static */
-wxIDirectFBEventBufferPtr wxEventLoop::GetDirectFBEventBuffer()
+wxIDirectFBEventBufferPtr wxGUIEventLoop::GetDirectFBEventBuffer()
{
if ( !ms_buffer )
InitBuffer();
// events dispatch and loop handling
//-----------------------------------------------------------------------------
-bool wxEventLoop::Pending() const
+bool wxGUIEventLoop::Pending() const
{
- wxCHECK_MSG( ms_buffer, false, _T("invalid event buffer") );
+ wxCHECK_MSG( ms_buffer, false, "invalid event buffer" );
return ms_buffer->HasEvent();
}
-bool wxEventLoop::Dispatch()
+bool wxGUIEventLoop::Dispatch()
{
- wxCHECK_MSG( ms_buffer, false, _T("invalid event buffer") );
+ wxCHECK_MSG( ms_buffer, false, "invalid event buffer" );
// NB: we don't block indefinitely waiting for an event, but instead
// time out after a brief period in order to make sure that
// OnNextIteration() will be called frequently enough
- //
- // FIXME: call NotifyTimers() and wxSocketEventDispatcher::RunLoop() from here
- // (and loop) instead?
const int TIMEOUT = 100;
- if ( ms_buffer->WaitForEventWithTimeout(0, TIMEOUT) )
+ // release the GUI mutex so that other threads have a chance to post
+ // events:
+ wxMutexGuiLeave();
+
+ bool rv = ms_buffer->WaitForEventWithTimeout(0, TIMEOUT);
+
+ // and acquire it back before calling any event handlers:
+ wxMutexGuiEnter();
+
+ if ( rv )
{
switch ( ms_buffer->GetLastResult() )
{
return true;
}
-void wxEventLoop::WakeUp()
+void wxGUIEventLoop::WakeUp()
{
- wxCHECK_RET( ms_buffer, _T("invalid event buffer") );
+ wxCHECK_RET( ms_buffer, "invalid event buffer" );
ms_buffer->WakeUp();
}
-void wxEventLoop::OnNextIteration()
+void wxGUIEventLoop::OnNextIteration()
{
- // see the comment in Dispatch
-
#if wxUSE_TIMER
- wxTimer::NotifyTimers();
+ wxGenericTimerImpl::NotifyTimers();
#endif
#if wxUSE_SOCKETS
// handle any pending socket events:
- wxSocketEventDispatcher::Get().RunLoop();
+ wxSelectDispatcher::DispatchPending();
#endif
}
+void wxGUIEventLoop::Yield()
+{
+ // process all pending events:
+ while ( Pending() )
+ Dispatch();
+
+ // handle timers, sockets etc.
+ OnNextIteration();
+}
+
//-----------------------------------------------------------------------------
// DirectFB -> wxWidgets events translation
//-----------------------------------------------------------------------------
-void wxEventLoop::HandleDFBEvent(const wxDFBEvent& event)
+void wxGUIEventLoop::HandleDFBEvent(const wxDFBEvent& event)
{
switch ( event.GetClass() )
{
case DFEC_WINDOW:
{
wxDFBWindowEvent winevent(((const DFBEvent&)event).window);
- wxTopLevelWindowDFB::HandleDFBWindowEvent(winevent);
+ wxNonOwnedWindow::HandleDFBWindowEvent(winevent);
break;
}
#endif
{
wxLogTrace(TRACE_EVENTS,
- _T("ignoring event of unsupported class %i"),
+ "ignoring event of unsupported class %i",
(int)event.GetClass());
}
}