X-Git-Url: https://git.saurik.com/wxWidgets.git/blobdiff_plain/d80170bd4d3fa22bdd3e30f2d009f3fd8e9a8b4e..613de0e89efab1cbf8463ea06e0cf0b2914fbce9:/include/wx/msw/gsockmsw.h?ds=inline diff --git a/include/wx/msw/gsockmsw.h b/include/wx/msw/gsockmsw.h index ea5fc11fe4..fe5d5a2942 100644 --- a/include/wx/msw/gsockmsw.h +++ b/include/wx/msw/gsockmsw.h @@ -1,12 +1,15 @@ -/* ------------------------------------------------------------------------- - * Project: GSocket (Generic Socket) for WX - * Name: gsockmsw.h - * Copyright: (c) Guilhem Lavaux - * Licence: wxWindows Licence - * Purpose: GSocket MSW header - * CVSID: $Id$ - * ------------------------------------------------------------------------- - */ +///////////////////////////////////////////////////////////////////////////// +// Name: wx/msw/gsockmsw.h +// Purpose: MSW-specific socket implementation +// Authors: Guilhem Lavaux, Guillermo Rodriguez Garcia, Vadim Zeitlin +// Created: April 1997 +// Copyright: (C) 1999-1997, Guilhem Lavaux +// (C) 1999-2000, Guillermo Rodriguez Garcia +// (C) 2008 Vadim Zeitlin +// RCS_ID: $Id$ +// License: wxWindows licence +///////////////////////////////////////////////////////////////////////////// + #ifndef _WX_MSW_GSOCKMSW_H_ #define _WX_MSW_GSOCKMSW_H_ @@ -20,85 +23,50 @@ #endif #if defined(__WXWINCE__) || defined(__CYGWIN__) -#include + #include #endif -/* Definition of GSocket */ -class GSocket +// ---------------------------------------------------------------------------- +// MSW-specific socket implementation +// ---------------------------------------------------------------------------- + +class wxSocketImplMSW : public wxSocketImpl { public: - GSocket(); - ~GSocket(); - bool IsOk() { return m_ok; } - void Close(); - void Shutdown(); - GSocketError SetLocal(GAddress *address); - GSocketError SetPeer(GAddress *address); - GAddress *GetLocal(); - GAddress *GetPeer(); - GSocketError SetServer(); - GSocket *WaitConnection(); - // not used under MSW - void Notify(bool) { } - bool SetReusable(); - bool SetBroadcast(); - bool DontDoBind(); - GSocketError Connect(GSocketStream stream); - GSocketError SetNonOriented(); - int Read(char *buffer, int size); - int Write(const char *buffer, int size); - GSocketEventFlags Select(GSocketEventFlags flags); - void SetNonBlocking(bool non_block); - void SetTimeout(unsigned long millis); - GSocketError WXDLLIMPEXP_NET GetError(); - void SetCallback(GSocketEventFlags flags, - GSocketCallback callback, char *cdata); - void UnsetCallback(GSocketEventFlags flags); - GSocketError GetSockOpt(int level, int optname, - void *optval, int *optlen); - GSocketError SetSockOpt(int level, int optname, - const void *optval, int optlen); - - void SetInitialSocketBuffers(int recv, int send) - { - m_initialRecvBufferSize = recv; - m_initialSendBufferSize = send; - } - -protected: - GSocketError Input_Timeout(); - GSocketError Output_Timeout(); - GSocketError Connect_Timeout(); - int Recv_Stream(char *buffer, int size); - int Recv_Dgram(char *buffer, int size); - int Send_Stream(const char *buffer, int size); - int Send_Dgram(const char *buffer, int size); - bool m_ok; - int m_initialRecvBufferSize; - int m_initialSendBufferSize; - -/* TODO: Make these protected */ -public: - SOCKET m_fd; - GAddress *m_local; - GAddress *m_peer; - GSocketError m_error; - - /* Attributes */ - bool m_non_blocking; - bool m_server; - bool m_stream; - bool m_establishing; - bool m_reusable; - bool m_broadcast; - bool m_dobind; - struct timeval m_timeout; - - /* Callbacks */ - GSocketEventFlags m_detected; - GSocketCallback m_cbacks[GSOCK_MAX_EVENT]; - char *m_data[GSOCK_MAX_EVENT]; - int m_msgnumber; + wxSocketImplMSW(wxSocketBase& wxsocket); + + virtual ~wxSocketImplMSW(); + + virtual wxSocketImpl *WaitConnection(wxSocketBase& wxsocket); + + + int Read(char *buffer, int size); + int Write(const char *buffer, int size); + +private: + virtual wxSocketError DoHandleConnect(int ret); + virtual void DoClose(); + + virtual void UnblockAndRegisterWithEventLoop() + { + // no need to make the socket non-blocking, Install_Callback() will do + // it + wxSocketManager::Get()->Install_Callback(this); + } + + wxSocketError Input_Timeout(); + wxSocketError Output_Timeout(); + wxSocketError Connect_Timeout(); + int Recv_Stream(char *buffer, int size); + int Recv_Dgram(char *buffer, int size); + int Send_Stream(const char *buffer, int size); + int Send_Dgram(const char *buffer, int size); + + int m_msgnumber; + + friend class wxSocketMSWManager; + + DECLARE_NO_COPY_CLASS(wxSocketImplMSW) }; #endif /* _WX_MSW_GSOCKMSW_H_ */