开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 通讯/手机编程 > Symbian > 查看源码
hxcloakedtcp.h
资源名称：helix.src.0812.rar　[点击查看]
上传用户：zhongxx05
上传日期：2007-06-06
资源大小：33641k
文件大小：10k
源码类别：

Symbian

开发平台：

C/C++

hxcloakedtcp.h：源码内容
  1. /* ***** BEGIN LICENSE BLOCK ***** 
  2.  * Version: RCSL 1.0/RPSL 1.0 
  3.  *  
  4.  * Portions Copyright (c) 1995-2002 RealNetworks, Inc. All Rights Reserved. 
  5.  *      
  6.  * The contents of this file, and the files included with this file, are 
  7.  * subject to the current version of the RealNetworks Public Source License 
  8.  * Version 1.0 (the "RPSL") available at 
  9.  * http://www.helixcommunity.org/content/rpsl unless you have licensed 
  10.  * the file under the RealNetworks Community Source License Version 1.0 
  11.  * (the "RCSL") available at http://www.helixcommunity.org/content/rcsl, 
  12.  * in which case the RCSL will apply. You may also obtain the license terms 
  13.  * directly from RealNetworks.  You may not use this file except in 
  14.  * compliance with the RPSL or, if you have a valid RCSL with RealNetworks 
  15.  * applicable to this file, the RCSL.  Please see the applicable RPSL or 
  16.  * RCSL for the rights, obligations and limitations governing use of the 
  17.  * contents of the file.  
  18.  *  
  19.  * This file is part of the Helix DNA Technology. RealNetworks is the 
  20.  * developer of the Original Code and owns the copyrights in the portions 
  21.  * it created. 
  22.  *  
  23.  * This file, and the files included with this file, is distributed and made 
  24.  * available on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER 
  25.  * EXPRESS OR IMPLIED, AND REALNETWORKS HEREBY DISCLAIMS ALL SUCH WARRANTIES, 
  26.  * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY, FITNESS 
  27.  * FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT. 
  28.  * 
  29.  * Technology Compatibility Kit Test Suite(s) Location: 
  30.  *    http://www.helixcommunity.org/content/tck 
  31.  * 
  32.  * Contributor(s): 
  33.  *  
  34.  * ***** END LICENSE BLOCK ***** */ 
  35. #ifndef HXCLOAKEDTCP_H
  36. #define HXCLOAKEDTCP_H
  38. #include "hxtypes.h"
  39. #include "hxcom.h"
  40. #include "hxengin.h"
  41. #include "hxpnets.h"
  42. #include "hxauthn.h"
  43. #include "hxpreftr.h"
  45. #include "hxstring.h"
  46. #include "hxslist.h"
  47. #include "growingq.h"
  48. #include "smartptr.h"
  49. #include "hxathsp.h"
  50. #include "hxsockcallback.h"
  52. class  HTTPResponseMessage;
  53. class HXMutex;
  55. class HXClientCloakedTCPSocket : public IHXTCPSocket, 
  56.  public IHXCloakedTCPSocket,
  57.  public IHXHTTPProxy, 
  58.  public SocketCallbackInterface,
  59.  public IHXClientAuthResponse
  60. {
  61. public:
  62. HXClientCloakedTCPSocket(IUnknown* pContext);
  63. ~HXClientCloakedTCPSocket();
  64.     
  65.     /* IUnknown interface */
  66.     STDMETHOD(QueryInterface)   (THIS_ 
  67. REFIID riid, void** ppvObj);
  69.     STDMETHOD_(ULONG32,AddRef)  (THIS);
  71.     STDMETHOD_(ULONG32,Release) (THIS);
  73.    /* SocketCallbackInterface interface */
  74.   enum {
  75. CLOAKED_TCP_READ_COMMAND,
  76. CLOAKED_TCP_GETWRITE_COMMAND,
  77. CLOAKED_TCP_PUTWRITE_COMMAND,
  78. CLOAKED_TCP_PUTRESPONSE_TIMEOUT_COMMAND
  79. };
  80. STDMETHODIMP HandleCallback(INT32 theCommand, HX_RESULT theError);
  82.     /*
  83.      *  IHXTCPSocket methods
  84.      */
  86.     STDMETHOD(Init) (THIS_
  87. IHXTCPResponse*    /*IN*/  pTCPResponse);
  89.     STDMETHOD(SetResponse) (THIS_
  90. IHXTCPResponse*    /*IN*/  pTCPResponse);
  92.     STDMETHOD(Bind) (THIS_
  93. UINT32     ulLocalAddr,
  94. UINT16      nPort);
  96.     STDMETHOD(Connect) (THIS_
  97. const char*     pDestination,
  98. UINT16     nPort);
  100.     STDMETHOD(Read) (THIS_
  101. UINT16     uSize);
  103.     STDMETHOD(Write) (THIS_
  104. IHXBuffer*     pBuffer);
  106.     STDMETHOD(WantWrite) (THIS);
  108.     STDMETHOD(GetLocalAddress) (THIS_
  109. UINT32&     lAddress);
  110.     STDMETHOD(GetForeignAddress)(THIS_
  111. UINT32&     lAddress);
  112.     STDMETHOD(GetLocalPort) (THIS_
  113.      UINT16&     nPort);
  114.     STDMETHOD(GetForeignPort) (THIS_
  115.      UINT16&     nPort);
  117.     // IHXClientAuthResponse
  118.     
  119.     STDMETHOD(ResponseReady) (THIS_
  120.      HX_RESULT   HX_RESULTStatus,
  121. IHXRequest* pIHXRequestResponse);
  122.     
  123.     /*
  124.      * IHXHTTPProxy methods
  125.      *
  126.      *  Network addresses and ports are in native byte order
  127.      *  
  128.      */
  130.     STDMETHOD(SetProxy) (THIS_
  131. const char* /*IN*/  pProxyHostName,
  132. UINT16     /*IN*/  nPort);
  134.     /************************************************************************
  135.      * Method:
  136.      *     IHXCloakedTCPSocket::InitCloak
  137.      */
  138.     STDMETHOD(InitCloak) (THIS_
  139. IHXValues* /*IN*/  pValues,
  140. IUnknown* pUnknown);
  142.     class HTTPCloakTCPResponse : public IHXTCPResponse,
  143.  public IHXInterruptSafe
  144.     {
  145.     public:
  147. HTTPCloakTCPResponse(HXClientCloakedTCPSocket* pOwner, BOOL bIsRead);
  148. ~HTTPCloakTCPResponse();
  149. /*
  150.  *  IUnknown methods
  151.  */
  152. STDMETHOD(QueryInterface) (THIS_
  153.     REFIID riid,
  154.     void** ppvObj);
  156. STDMETHOD_(ULONG32,AddRef) (THIS);
  158. STDMETHOD_(ULONG32,Release) (THIS);
  160. /*
  161.  * IHXTCPResponse methods
  162.  */
  164. STDMETHOD(ConnectDone) (THIS_
  165. HX_RESULT status);
  167. STDMETHOD(ReadDone) (THIS_
  168.  HX_RESULT status,
  169.  IHXBuffer* pBuffer);
  171. STDMETHOD(WriteReady) (THIS_
  172.      HX_RESULT status);
  174. STDMETHOD(Closed) (THIS_
  175.  HX_RESULT status);
  176.      /*
  177.        * IHXInterruptSafe methods
  178.        */
  179. STDMETHOD_(BOOL,IsInterruptSafe) (THIS) {return TRUE;};
  181.     private:
  182. LONG32     m_lRefCount;
  183. HXClientCloakedTCPSocket*  m_pOwner;
  184. BOOL     m_bIsRead;
  185.     };
  187.     friend class HTTPCloakTCPResponse;
  189. private:
  190.     void TransferBuffers();
  192.     HX_RESULT DoRead();
  193.     HX_RESULT DoGetReadDone(HX_RESULT status, IHXBuffer* pBuffer);
  194.     HX_RESULT DoPutReadDone(HX_RESULT status, IHXBuffer* pBuffer);
  195.     HX_RESULT DoGetWrite();
  196.     void GetConnectDone(BOOL bResult);
  197.     
  198.     HX_RESULT DoPutWrite(); /* only used by m_pWriteCtrl*/
  199.     void PutConnectDone(BOOL bResult);
  201.     HX_RESULT PreparePostMessage(const UCHAR *inData, UINT16 inLength);
  202.     HX_RESULT EncodeBase64(const UCHAR* inData, UINT16 inLength, UCHAR* outData, UINT16& outLength);
  203.     HX_RESULT PrepareGetMessage(void);
  204.     void CreateGuid(void);
  205.     HX_RESULT HandleHTTPResponse(UCHAR response);
  206.     BOOL IsSafe();
  208.     void FlushQueues(void);
  209.     void SendHTTPDone(void);
  210.     HX_RESULT ActualConnect(void);
  211.     HX_RESULT GetServerIPFromResponse(BOOL bGetResponse, const char* pszInBuffer);    
  212.     HX_RESULT CleanUpAndReInitializeStuff(void);
  213.     HX_RESULT ReconnectToSameServerIP(void);
  215.     BOOL AuthenticationRequired(HX_RESULT   status, IHXBuffer* pInBuffer);
  216.     void ObtainAuthenticationInformation(CHXString& strAuth);
  218.     HX_RESULT HandleAuthentication(IHXRequest* pRequest, HTTPResponseMessage* pMessage,
  219.      const char* pHost, const char* pProxyHost);
  221.     LONG32                      m_lRefCount;
  222.     IUnknown* m_pContext;
  223.     IHXScheduler* m_pScheduler;
  224.     IHXTCPResponse* m_pTCPResponse;
  225.     IHXNetworkServices* m_pNetworkServices;    
  226.     IHXTCPSocket* m_pGetCtrl;
  227.     IHXTCPSocket* m_pPutCtrl;
  228.     HTTPCloakTCPResponse* m_pGetCtrlResponse;
  229.     HTTPCloakTCPResponse* m_pPutCtrlResponse;
  230.     char* m_pForiegnHost;
  231.     UINT32 m_lForeignAddress;
  232.     UINT16 m_nForeignPort : 16;
  233.     UINT16 m_nRequired : 16;
  234.     CByteGrowingQueue* m_pSendTCP;
  235.     CByteGrowingQueue* m_pReceiveGetTCP;
  236.     CByteGrowingQueue* m_pReceivePutTCP;
  237.     CByteGrowingQueue* m_pPreEncodedSendHTTP;
  238.     CByteGrowingQueue* m_pPostEncodedSendHTTP;
  239.     CHXSimpleList m_PendingWriteBuffers;
  240.     char* m_pOutBuf;
  241.     char* m_pOutEncodedBuf;
  242.     char* m_pInBuf;
  243.     char* m_pGuid;
  244.     HX_BITFIELD m_bGetReadPending : 1;
  245.     HX_BITFIELD m_bPutReadPending : 1;
  246.     HX_BITFIELD m_bPutWantWritePending : 1;
  247.     HX_BITFIELD m_bReadPending : 1;
  248.     HX_BITFIELD m_bConnected : 1;
  249.     HX_BITFIELD m_bGetConnectDone : 1;
  250.     HX_BITFIELD m_bPutConnectDone : 1;
  251.     HX_BITFIELD m_bGetConnectSuccessful : 1;
  252.     HX_BITFIELD m_bPutConnectSuccessful : 1;
  253.     HX_BITFIELD m_bConnectResponsePending : 1;
  254.     HX_BITFIELD m_bOptionsReceived : 1;
  256.     HX_BITFIELD m_bUseExactContentLength : 1;
  257.     /* == 1, close connection after write completes */
  258.     HX_BITFIELD m_bCloseHttpAfterWrite : 1;
  259.     /* == 1 we must close the HTTP POST connection */
  260.     HX_BITFIELD m_bMustCloseHTTP : 1;
  261.     HX_BITFIELD m_bHttpInitialized : 1;
  262.     HX_BITFIELD m_bInitComplete : 1;
  264.     HX_BITFIELD m_bInDestructor : 1;
  266.     HX_BITFIELD m_bInDoRead: 1;
  267.     HX_BITFIELD m_bInDoGetWrite : 1;
  268.     HX_BITFIELD m_bInDoPutWrite : 1;
  269.     HX_BITFIELD m_bInTransferBuffers : 1;
  270.     HX_BITFIELD m_bDeletePadding : 1;
  271.     
  272.     HX_BITFIELD m_bGetResponsed : 1;
  273.     HX_BITFIELD m_bPutResponsed : 1;
  274.     char* m_pszGetServerIP;
  275.     char* m_pszPutServerIP;
  276.     HX_BITFIELD m_bReconnectToSameServerIP : 1;
  277.     HX_BITFIELD m_bConnectToSameServerIP : 1;
  279.     HX_BITFIELD m_bHTTPGetHeaderReadDone : 1;
  280.     HX_BITFIELD m_bHTTPPutHeaderReadDone : 1;
  281.     HX_RESULT m_LastError;
  282.     char* m_pHTTPHeaderBuffer;
  283.     UINT16 m_nHTTPHeaderBufferLength;
  285.     UINT16 m_nProxyPortNumber;
  286.     char* m_pProxyHostName;
  288.     UINT16 m_uPadLength;
  290.     ScheduledSocketCallback* m_pSchedulerCallback;
  291.     ScheduledSocketCallback* m_pNonInterruptCallback;
  292.     IHXInterruptState* m_pInterruptState;
  293.     IHXInterruptSafe* m_pResponseInterruptSafe;
  294.     HXMutex* m_pMutex;
  296.     IHXValues* m_pCloakValues;
  297.     IUnknown* m_pCloakContext;
  298.     IHXPreferredTransport* m_pPreferredTransport;
  299.     IHXPreferredTransportManager* m_pPreferredTransportManager;
  302. #ifdef _MACINTOSH
  303.     class MacCloakedTCPSocketAuthenticationCallback : public IHXCallback
  304.     {
  305.     private:
  306. LONG32 m_lRefCount;
  308. ~MacCloakedTCPSocketAuthenticationCallback();
  309. PRIVATE_DESTRUCTORS_ARE_NOT_A_CRIME
  311.     public:
  312. MacCloakedTCPSocketAuthenticationCallback(
  313. HXClientCloakedTCPSocket* pSocket);
  315. // IUnknown methods
  316. STDMETHOD(QueryInterface) (THIS_ REFIID riid, void** ppvObj);
  317. STDMETHOD_(ULONG32, AddRef) (THIS);
  318. STDMETHOD_(ULONG32, Release) (THIS);
  320. // IHXCallback methods
  321. STDMETHOD(Func) (THIS);
  323. // callback specific stuff
  324. CallbackHandle m_ulPendingCallbackID;
  325. HXClientCloakedTCPSocket* m_pSocket;
  326. HX_RESULT m_Status;
  327. IHXBuffer* m_pInBuffer;
  328.     };
  329.     
  330.     friend class MacCloakedTCPSocketAuthenticationCallback;
  331.     
  332.     MacCloakedTCPSocketAuthenticationCallback* m_pAuthenticationCallback;
  333. #endif
  335.     BOOL m_bInAuthenticationKludge;
  337.     DECLARE_SMART_POINTER
  338.     (
  339. IHXClientAuthConversation
  340.     ) spClientAuthConversationAuthenticator;
  342. };
  344. #endif /* HXCLOAKEDTCP_H */