1 /////////////////////////////////////////////////////////////////////////////
3 // Purpose: Socket internal classes
4 // Author: Guilhem Lavaux
8 // Copyright: (c) Guilhem Lavaux
9 // Licence: wxWindows licence
10 /////////////////////////////////////////////////////////////////////////////
11 #ifndef _WX_NETWORK_SOCKET_INT_H
12 #define _WX_NETWORK_SOCKET_INT_H
20 #include <wx/object.h>
22 #include <wx/socket.h>
23 #include <wx/thread.h>
29 // TRUE if the background notifyier is on.
31 // Specifies which events we want to be notified.
32 wxSocketBase::wxRequestNotify evt_notify_state
;
34 wxSocketBase::wxSockFlags socket_flags
;
35 // Pointer to the C callback function.
36 wxSocketBase::wxSockCbk c_callback
;
37 char *c_callback_data
;
44 // Buffer where to get/put data.
46 // Size of the buffer.
48 // Number of bytes really read/written.
52 // Type of the request.
53 wxSocketBase::wxRequestNotify type
;
54 // Timeout (in milliseconds).
56 // TRUE if the buffer has been processed.
58 // TRUE if we must wait for the request completion, in the other case an
59 // event will be sent to the main thread when the request is finished.
63 class wxSocketInternal
;
64 class SocketWaiter
: public wxThread
{
66 SocketWaiter(wxSocketBase
*socket
, wxSocketInternal
*internal
);
71 virtual void *Entry();
74 void ProcessReadEvent();
75 void ProcessWriteEvent();
78 wxSocketBase
*m_socket
;
79 wxSocketInternal
*m_internal
;
83 class SocketRequester
: public wxThread
{
85 SocketRequester(wxSocketBase
*socket
, wxSocketInternal
*internal
);
88 void ProcessWaitEvent(SockRequest
*req
);
89 void ProcessReadEvent(SockRequest
*req
);
90 void ProcessWriteEvent(SockRequest
*req
);
92 bool WaitFor(wxSocketBase::wxRequestNotify req
, int millisec
);
96 virtual void *Entry();
99 wxSocketBase
*m_socket
;
100 wxSocketInternal
*m_internal
;
104 class wxSocketInternal
{
106 wxSocketInternal(wxSocketBase
*socket
);
109 // wxSocket thread manager
110 // -----------------------
116 int GetFD() { return m_fd
; }
120 void ResumeRequester();
121 void StopRequester();
123 void QueueRequest(SockRequest
*request
, bool async
);
124 void WaitForEnd(SockRequest
*request
);
126 SockRequest
*WaitForReq();
127 void EndRequest(SockRequest
*req
);
129 wxMutex m_socket_locker
, m_fd_locker
, m_request_locker
;
130 wxCondition m_socket_cond
;
131 wxSocketBase
*m_socket
;
132 SocketWaiter
*m_thread_waiter
;
133 SocketRequester
*m_thread_requester
;
142 // _WX_NETWORK_SOCKET_INT_H