]>
git.saurik.com Git - wxWidgets.git/blob - src/common/selectdispatcher.cpp
1 ///////////////////////////////////////////////////////////////////////////////
2 // Name: src/common/selectdispatcher.cpp
3 // Purpose: implements dispatcher for select() call
4 // Author: Lukasz Michalski and Vadim Zeitlin
5 // Created: December 2006
7 // Copyright: (c) 2006 Lukasz Michalski
8 // License: wxWindows licence
9 ///////////////////////////////////////////////////////////////////////////////
11 // ============================================================================
13 // ============================================================================
15 // ----------------------------------------------------------------------------
17 // ----------------------------------------------------------------------------
19 // for compilers that support precompilation, includes "wx.h".
20 #include "wx/wxprec.h"
22 #if wxUSE_SELECT_DISPATCHER
24 #include "wx/private/selectdispatcher.h"
25 #include "wx/unix/private.h"
33 #ifdef HAVE_SYS_SELECT_H
35 #include <sys/select.h>
40 #define wxSelectDispatcher_Trace wxT("selectdispatcher")
42 // ============================================================================
44 // ============================================================================
46 // ----------------------------------------------------------------------------
48 // ----------------------------------------------------------------------------
50 int wxSelectSets::ms_flags
[wxSelectSets::Max
] =
57 const char *wxSelectSets::ms_names
[wxSelectSets::Max
] =
64 wxSelectSets::Callback
wxSelectSets::ms_handlers
[wxSelectSets::Max
] =
66 &wxFDIOHandler::OnReadWaiting
,
67 &wxFDIOHandler::OnWriteWaiting
,
68 &wxFDIOHandler::OnExceptionWaiting
,
71 wxSelectSets::wxSelectSets()
73 for ( int n
= 0; n
< Max
; n
++ )
79 bool wxSelectSets::HasFD(int fd
) const
81 for ( int n
= 0; n
< Max
; n
++ )
83 if ( wxFD_ISSET(fd
, (fd_set
*) &m_fds
[n
]) )
90 bool wxSelectSets::SetFD(int fd
, int flags
)
92 wxCHECK_MSG( fd
>= 0, false, _T("invalid descriptor") );
94 for ( int n
= 0; n
< Max
; n
++ )
96 if ( flags
& ms_flags
[n
] )
98 wxFD_SET(fd
, &m_fds
[n
]);
99 wxLogTrace(wxSelectDispatcher_Trace
,
100 _T("Registered fd %d for %s events"), fd
, ms_names
[n
]);
102 else if ( wxFD_ISSET(fd
, (fd_set
*) &m_fds
[n
]) )
104 wxFD_CLR(fd
, &m_fds
[n
]);
105 wxLogTrace(wxSelectDispatcher_Trace
,
106 _T("Unregistered fd %d from %s events"), fd
, ms_names
[n
]);
113 int wxSelectSets::Select(int nfds
, struct timeval
*tv
)
115 return select(nfds
, &m_fds
[Read
], &m_fds
[Write
], &m_fds
[Except
], tv
);
118 void wxSelectSets::Handle(int fd
, wxFDIOHandler
& handler
) const
120 for ( int n
= 0; n
< Max
; n
++ )
122 if ( wxFD_ISSET(fd
, (fd_set
*) &m_fds
[n
]) )
124 wxLogTrace(wxSelectDispatcher_Trace
,
125 _T("Got %s event on fd %d"), ms_names
[n
], fd
);
126 (handler
.*ms_handlers
[n
])();
131 // ----------------------------------------------------------------------------
132 // wxSelectDispatcher
133 // ----------------------------------------------------------------------------
136 wxSelectDispatcher
*wxSelectDispatcher::Create()
138 return new wxSelectDispatcher
;
141 wxSelectDispatcher::wxSelectDispatcher()
146 bool wxSelectDispatcher::RegisterFD(int fd
, wxFDIOHandler
*handler
, int flags
)
148 if ( !wxMappedFDIODispatcher::RegisterFD(fd
, handler
, flags
) )
151 if ( !m_sets
.SetFD(fd
, flags
) )
160 bool wxSelectDispatcher::ModifyFD(int fd
, wxFDIOHandler
*handler
, int flags
)
162 if ( !wxMappedFDIODispatcher::ModifyFD(fd
, handler
, flags
) )
165 wxASSERT_MSG( fd
<= m_maxFD
, _T("logic error: registered fd > m_maxFD?") );
167 return m_sets
.SetFD(fd
, flags
);
170 bool wxSelectDispatcher::UnregisterFD(int fd
)
174 if ( !wxMappedFDIODispatcher::UnregisterFD(fd
) )
177 // remove the handler if we don't need it any more
178 if ( !m_sets
.HasFD(fd
) )
182 // need to find new max fd
184 for ( wxFDIOHandlerMap::const_iterator it
= m_handlers
.begin();
185 it
!= m_handlers
.end();
188 if ( it
->first
> m_maxFD
)
197 void wxSelectDispatcher::ProcessSets(const wxSelectSets
& sets
)
199 for ( int fd
= 0; fd
<= m_maxFD
; fd
++ )
201 if ( !sets
.HasFD(fd
) )
204 wxFDIOHandler
* const handler
= FindHandler(fd
);
207 wxFAIL_MSG( _T("NULL handler in wxSelectDispatcher?") );
211 sets
.Handle(fd
, *handler
);
215 void wxSelectDispatcher::Dispatch(int timeout
)
219 if ( timeout
!= TIMEOUT_INFINITE
)
223 tv
.tv_usec
= timeout
*1000;
230 wxSelectSets sets
= m_sets
;
232 const int ret
= sets
.Select(m_maxFD
+ 1, ptv
);
236 if ( errno
!= EINTR
)
238 wxLogSysError(_("Failed to monitor I/O channels"));
243 // timeout expired without anything happening
251 #endif // wxUSE_SELECT_DISPATCHER