home *** CD-ROM | disk | FTP | other *** search
/ Computer Shopper 217 / DPCS0306DVD.ISO / Toolkit / Internet / FileZilla / Server / FileZilla_Server-0.9.11.exe / source / AsyncSocketExLayer.h < prev    next >
Encoding:
C/C++ Source or Header  |  2005-02-27  |  7.0 KB  |  176 lines
  1. /*CAsyncSocketEx by Tim Kosse (Tim.Kosse@gmx.de)
  2.             Version 1.1 (2002-11-01)
  3. --------------------------------------------------------
  4.  
  5. Introduction:
  6. -------------
  7.  
  8. CAsyncSocketEx is a replacement for the MFC class CAsyncSocket.
  9. This class was written because CAsyncSocket is not the fastest WinSock
  10. wrapper and it's very hard to add new functionality to CAsyncSocket
  11. derived classes. This class offers the same functionality as CAsyncSocket.
  12. Also, CAsyncSocketEx offers some enhancements which were not possible with
  13. CAsyncSocket without some tricks.
  14.  
  15. How do I use it?
  16. ----------------
  17. Basically exactly like CAsyncSocket.
  18. To use CAsyncSocketEx, just replace all occurrences of CAsyncSocket in your
  19. code with CAsyncSocketEx, if you did not enhance CAsyncSocket yourself in
  20. any way, you won't have to change anything else in your code.
  21.  
  22. Why is CAsyncSocketEx faster?
  23. -----------------------------
  24.  
  25. CAsyncSocketEx is slightly faster when dispatching notification event messages.
  26. First have a look at the way CAsyncSocket works. For each thread that uses
  27. CAsyncSocket, a window is created. CAsyncSocket calls WSAAsyncSelect with
  28. the handle of that window. Until here, CAsyncSocketEx works the same way.
  29. But CAsyncSocket uses only one window message (WM_SOCKET_NOTIFY) for all
  30. sockets within one thread. When the window recieve WM_SOCKET_NOTIFY, wParam
  31. contains the socket handle and the window looks up an CAsyncSocket instance
  32. using a map. CAsyncSocketEx works differently. It's helper window uses a
  33. wide range of different window messages (WM_USER through 0xBFFF) and passes
  34. a different message to WSAAsyncSelect for each socket. When a message in
  35. the specified range is received, CAsyncSocketEx looks up the pointer to a
  36. CAsyncSocketEx instance in an Array using the index of message - WM_USER.
  37. As you can see, CAsyncSocketEx uses the helper window in a more efficient
  38. way, as it don't have to use the slow maps to lookup it's own instance.
  39. Still, speed increase is not very much, but it may be noticeable when using
  40. a lot of sockets at the same time.
  41. Please note that the changes do not affect the raw data throughput rate,
  42. CAsyncSocketEx only dispatches the notification messages faster.
  43.  
  44. What else does CAsyncSocketEx offer?
  45. ------------------------------------
  46.  
  47. CAsyncSocketEx offers a flexible layer system. One example is the proxy layer.
  48. Just create an instance of the proxy layer, configure it and add it to the layer
  49. chain of your CAsyncSocketEx instance. After that, you can connect through
  50. proxies.
  51. Benefit: You don't have to change much to use the layer system.
  52. Another layer that is currently in development is the SSL layer to establish
  53. SSL encrypted connections.
  54.  
  55. License
  56. -------
  57.  
  58. Feel free to use this class, as long as you don't claim that you wrote it
  59. and this copyright notice stays intact in the source files.
  60. If you use this class in commercial applications, please send a short message
  61. to tim.kosse@gmx.de
  62.  
  63. */#if !defined(AFX_ASYNCSOCKETEXLAYER_H__90C7FDB6_F3F1_4CC0_B77B_858458A563F3__INCLUDED_)
  64. #define AFX_ASYNCSOCKETEXLAYER_H__90C7FDB6_F3F1_4CC0_B77B_858458A563F3__INCLUDED_
  65.  
  66. #include "AsyncSocketEx.h"    // Hinzugefⁿgt von der Klassenansicht
  67. #if _MSC_VER > 1000
  68. #pragma once
  69. #endif // _MSC_VER > 1000
  70.  
  71. class CAsyncSocketEx;
  72. class CAsyncSocketExLayer
  73. {
  74.     friend CAsyncSocketEx;
  75.     friend CAsyncSocketExHelperWindow;
  76. protected:
  77.     //Protected constructor so that CAsyncSocketExLayer can't be instantiated
  78.     CAsyncSocketExLayer();
  79.     virtual ~CAsyncSocketExLayer();
  80.  
  81.     //Notification event handlers
  82.     virtual void OnAccept(int nErrorCode);
  83.     virtual void OnClose(int nErrorCode);
  84.     virtual void OnConnect(int nErrorCode);
  85.     virtual void OnReceive(int nErrorCode);
  86.     virtual void OnSend(int nErrorCode);
  87.  
  88.     //Operations
  89.     virtual BOOL Accept( CAsyncSocketEx& rConnectedSocket, SOCKADDR* lpSockAddr = NULL, int* lpSockAddrLen = NULL );
  90.     virtual void Close();
  91.     virtual BOOL Connect(LPCTSTR lpszHostAddress, UINT nHostPort);
  92.     virtual BOOL Connect( const SOCKADDR* lpSockAddr, int nSockAddrLen );
  93.     virtual BOOL Create(UINT nSocketPort = 0, int nSocketType = SOCK_STREAM,
  94.                 long lEvent = FD_READ | FD_WRITE | FD_OOB | FD_ACCEPT |
  95.                             FD_CONNECT | FD_CLOSE,
  96.                 LPCTSTR lpszSocketAddress = NULL, int nFamily = AF_INET);
  97.     virtual BOOL GetPeerName( SOCKADDR* lpSockAddr, int* lpSockAddrLen );
  98.     virtual BOOL GetSockName( SOCKADDR* lpSockAddr, int* lpSockAddrLen );
  99. #ifdef _AFX
  100.     virtual BOOL GetPeerName( CString& rPeerAddress, UINT& rPeerPort );
  101.     virtual BOOL GetSockName( CString& rPeerAddress, UINT& rPeerPort );
  102. #endif
  103.     virtual BOOL Listen( int nConnectionBacklog);
  104.     virtual int Receive(void* lpBuf, int nBufLen, int nFlags = 0);
  105.     virtual int Send(const void* lpBuf, int nBufLen, int nFlags = 0);
  106.     virtual BOOL ShutDown( int nHow = sends );
  107.     enum { receives = 0, sends = 1, both = 2 };
  108.  
  109.     //Functions that will call next layer
  110.     BOOL ShutDownNext( int nHow = sends );
  111.     BOOL AcceptNext( CAsyncSocketEx& rConnectedSocket, SOCKADDR* lpSockAddr = NULL, int* lpSockAddrLen = NULL );
  112.     void CloseNext();
  113.     BOOL ConnectNext(LPCTSTR lpszHostAddress, UINT nHostPort);
  114.     BOOL ConnectNext( const SOCKADDR* lpSockAddr, int nSockAddrLen );
  115.     BOOL CreateNext(UINT nSocketPort, int nSocketType, long lEvent, LPCTSTR lpszSocketAddress, int nFamily = AF_INET);
  116.     BOOL GetPeerNameNext( SOCKADDR* lpSockAddr, int* lpSockAddrLen );
  117.     BOOL GetSockNameNext( SOCKADDR* lpSockAddr, int* lpSockAddrLen );
  118.     #ifdef _AFX
  119.         BOOL GetPeerNameNext( CString& rPeerAddress, UINT& rPeerPort );
  120.         BOOL GetSockNameNext( CString& rPeerAddress, UINT& rPeerPort );
  121.     #endif
  122.     BOOL ListenNext( int nConnectionBacklog);
  123.     int ReceiveNext(void *lpBuf, int nBufLen, int nFlags = 0);
  124.     int SendNext(const void *lpBuf, int nBufLen, int nFlags = 0);
  125.  
  126.     CAsyncSocketEx *m_pOwnerSocket;
  127.  
  128.     //Calls OnLayerCallback on owner socket
  129.     int DoLayerCallback(int nType, int nParam1, int nParam2, char* str = 0);
  130.  
  131.     int GetLayerState();
  132.     BOOL TriggerEvent(long lEvent, int nErrorCode, BOOL bPassThrough = FALSE );
  133.  
  134.     //Gets the socket family
  135.     int GetFamily() const;
  136.  
  137.     //Sets the socket family
  138.     bool SetFamily(int nFamily);
  139.  
  140.     // Iterate through protocols
  141.     bool TryNextProtocol();
  142.  
  143. private:
  144.     //Layer state can't be set directly from derived classes
  145.     void SetLayerState(int nLayerState);
  146.     int m_nLayerState;
  147.  
  148.     int m_nFamily;
  149.     int m_lEvent;
  150.     LPTSTR m_lpszSocketAddress;
  151.     UINT m_nSocketPort;
  152.  
  153.     addrinfo *m_addrInfo, *m_nextAddr;
  154.  
  155.     //Called by helper window, dispatches event notification and updated layer state
  156.     void CallEvent(int nEvent, int nErrorCode);
  157.  
  158.     int m_nPendingEvents;
  159.     int m_nCriticalError;
  160.  
  161.     void Init(CAsyncSocketExLayer *pPrevLayer, CAsyncSocketEx *pOwnerSocket);
  162.     CAsyncSocketExLayer *AddLayer(CAsyncSocketExLayer *pLayer, CAsyncSocketEx *pOwnerSocket);
  163.  
  164.     CAsyncSocketExLayer *m_pNextLayer;
  165.     CAsyncSocketExLayer *m_pPrevLayer;
  166.  
  167.     struct t_LayerNotifyMsg
  168.     {
  169.         SOCKET hSocket;
  170.         CAsyncSocketExLayer *pLayer;
  171.         long lEvent;
  172.     };
  173. };
  174.  
  175. #endif // !defined(AFX_ASYNCSOCKETEXLAYER_H__90C7FDB6_F3F1_4CC0_B77B_858458A563F3__INCLUDED_)
  176.