remote_logger.cpp
上传用户:zhongxx05
上传日期:2007-06-06
资源大小:33641k
文件大小:10k
源码类别:

Symbian

开发平台:

C/C++

  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. #include "remote_logger.h"
  36. class HXLogMesg
  37. {
  38. public:
  39.     HXLogMesg(HXLogMesgType type,
  40.       IHXBuffer* pPayload);
  41.     ~HXLogMesg();
  42.     
  43.     HXLogMesgType Type() const;
  44.     IHXBuffer* Payload();
  45. private:
  46.     HXLogMesgType m_type;
  47.     IHXBuffer* m_pPayload;
  48. };
  49. HXLogMesg::HXLogMesg(HXLogMesgType type,
  50.      IHXBuffer* pPayload) :
  51.     m_type(type),
  52.     m_pPayload(pPayload)
  53. {
  54.     if (m_pPayload)
  55.     {
  56. m_pPayload->AddRef();
  57.     }
  58. }
  59. HXLogMesg::~HXLogMesg()
  60. {
  61.     HX_RELEASE(m_pPayload);
  62. }
  63.     
  64. HXLogMesgType HXLogMesg::Type() const
  65. {
  66.     return m_type;
  67. }
  68. IHXBuffer* HXLogMesg::Payload()
  69. {
  70.     IHXBuffer* pRet = m_pPayload;
  71.     if (pRet)
  72.     {
  73. pRet->AddRef();
  74.     }
  75.     return pRet;
  76. }
  77. HXRemoteLogger::HXRemoteLogger() :
  78.     m_lRefCount(0),
  79.     m_pCCF(0),
  80.     m_pNetSvc(0),
  81.     m_pSocket(0),
  82.     m_pRemoteHost(0),
  83.     m_remotePort(0),
  84.     m_state(HXLogClosed),
  85.     m_seq(0)
  86. {}
  87. HXRemoteLogger::~HXRemoteLogger()
  88. {
  89.     Close();
  90. }
  91. HX_RESULT HXRemoteLogger::Init(IUnknown* pContext, 
  92.        const char* pRemoteHost,
  93.        UINT16 nRemotePort,
  94.        const char* pLogFilename)
  95. {
  96.     HX_RESULT res = HXR_FAILED;
  97.     if (pContext && pLogFilename && (strlen(pLogFilename) > 0))
  98.     {
  99. Close();
  100. pContext->QueryInterface(IID_IHXCommonClassFactory, (void**)&m_pCCF);
  101. pContext->QueryInterface(IID_IHXNetworkServices, (void**)&m_pNetSvc);
  102. m_pRemoteHost = CopyBuffer(pRemoteHost, strlen(pRemoteHost) + 1);
  103. m_remotePort = nRemotePort;
  104. IHXBuffer* pFilename = CopyBuffer(pLogFilename, 
  105.   strlen(pLogFilename) + 1);
  106. if (m_pCCF && m_pNetSvc && m_pRemoteHost && pFilename)
  107. {
  108.     // Enqueue Log open message to be sent when 
  109.     // we are connected
  110.     QueueMesg(HXLogOpen, pFilename);
  111.     res = HXR_OK;
  112. }
  113. HX_RELEASE(pFilename);
  114.     }
  115.     return res;
  116. }
  117. void HXRemoteLogger::Log( const char* pLogStr)
  118. {
  119.     BOOL bEnqueueMesg = FALSE;
  120.     switch(m_state) {
  121.     case HXLogClosed:
  122.     {
  123. // Try to connect
  124. if (m_pNetSvc &&
  125.     (HXR_OK == m_pNetSvc->CreateTCPSocket(&m_pSocket)) &&
  126.     m_pSocket &&
  127.     (HXR_OK == m_pSocket->Init(this)) &&
  128.     m_pRemoteHost &&
  129.     (HXR_OK == m_pSocket->Connect((const char*)m_pRemoteHost->GetBuffer(),
  130.   m_remotePort)))
  131. {
  132.     m_state = HXLogConnecting;
  133.     bEnqueueMesg = TRUE;
  134. }
  135. else
  136. {
  137.     OnError();
  138. }
  139.     } break;
  140.     case HXLogConnecting:
  141.     {
  142. // We are in the process of connecting
  143. // Just enqueue the message
  144. bEnqueueMesg = TRUE;
  145.     } break;
  146.     case HXLogConnected:
  147.     {
  148. IHXBuffer* pPayload = CopyBuffer(pLogStr, strlen(pLogStr));
  149. if (pPayload &&
  150.     (HXR_OK != SendMesg(HXLogEntry, pPayload)))
  151. {
  152.     OnError();
  153. }
  154. HX_RELEASE(pPayload);
  155.     }
  156.     default:
  157. // Ignore the string
  158. break;
  159.     };
  160.     if (bEnqueueMesg)
  161.     {
  162. IHXBuffer* pPayload = CopyBuffer(pLogStr, strlen(pLogStr));
  163. if (pPayload)
  164. {
  165.     QueueMesg(HXLogEntry, pPayload);
  166. }
  167. HX_RELEASE(pPayload);
  168.     }
  169. }
  170. void HXRemoteLogger::Close()
  171. {
  172.     HX_RELEASE(m_pSocket);
  173.     HX_RELEASE(m_pNetSvc);
  174.     HX_RELEASE(m_pCCF);
  175.     HX_RELEASE(m_pRemoteHost);
  176.     m_seq = 0;
  177.     ClearMesgQueue();
  178. }
  179.     /*
  180.      *  IUnknown methods
  181.      */
  182. STDMETHODIMP HXRemoteLogger::QueryInterface(THIS_
  183.     REFIID riid,
  184.     void** ppvObj)
  185. {
  186.     if (IsEqualIID(riid, IID_IHXTCPResponse))
  187.     {
  188.         AddRef();
  189.         *ppvObj = (IHXTCPResponse*)this;
  190.         return HXR_OK;
  191.     }
  192.     else if (IsEqualIID(riid, IID_IUnknown))
  193.     {
  194.         AddRef();
  195.         *ppvObj = this;
  196.         return HXR_OK;
  197.     }
  198.     *ppvObj = NULL;
  199.     return HXR_NOINTERFACE;
  200. }
  201. STDMETHODIMP_(ULONG32) HXRemoteLogger::AddRef(THIS)
  202. {
  203.     return InterlockedIncrement(&m_lRefCount);
  204. }
  205. STDMETHODIMP_(ULONG32) HXRemoteLogger::Release(THIS)
  206. {
  207.     if (InterlockedDecrement(&m_lRefCount) > 0)
  208.     {
  209.         return m_lRefCount;
  210.     }
  211.     delete this;
  212.     return 0;
  213. }
  214.     /*
  215.      * IHXTCPResponse methods
  216.      */
  217.     /************************************************************************
  218.      * Method:
  219.      *     IHXTCPResponse::ConnectDone
  220.      * Purpose:
  221.      *     A Connect operation has been completed or an error has occurred.
  222.      */
  223. STDMETHODIMP HXRemoteLogger::ConnectDone(THIS_
  224.  HX_RESULT status)
  225. {
  226.     if (HXR_OK == status)
  227.     {
  228. m_state = HXLogConnected;
  229. SendQueuedMesgs();
  230.     }
  231.     else
  232.     {
  233. OnError();
  234.     }
  235.     return HXR_OK;
  236. }
  237.     /************************************************************************
  238.      * Method:
  239.      *     IHXTCPResponse::ReadDone
  240.      * Purpose:
  241.      *     A Read operation has been completed or an error has occurred.
  242.      *     The data is returned in the IHXBuffer.
  243.      */
  244. STDMETHODIMP HXRemoteLogger::ReadDone(THIS_
  245.       HX_RESULT status,
  246.       IHXBuffer* pBuffer)
  247. {
  248.     if (status != HXR_OK)
  249.     {
  250. OnError();
  251.     }
  252.     return HXR_OK;
  253. }
  254.     /************************************************************************
  255.      * Method:
  256.      *     IHXTCPResponse::WriteReady
  257.      * Purpose:
  258.      *     This is the response method for WantWrite.
  259.      *     If HX_RESULT is ok, then the TCP channel is ok to Write to.
  260.      */
  261. STDMETHODIMP HXRemoteLogger::WriteReady(THIS_
  262. HX_RESULT status)
  263. {
  264.     if (status != HXR_OK)
  265.     {
  266. OnError();
  267.     }
  268.     return HXR_OK;
  269. }
  270.     /************************************************************************
  271.      * Method:
  272.      *     IHXTCPResponse::Closed
  273.      * Purpose:
  274.      *     This method is called to inform you that the TCP channel has
  275.      *     been closed by the peer or closed due to error.
  276.      */
  277. STDMETHODIMP HXRemoteLogger::Closed(THIS_
  278.     HX_RESULT status)
  279. {
  280.     HX_RELEASE(m_pSocket);
  281.     m_state = HXLogClosed;
  282.     return HXR_OK;
  283. }
  284. IHXBuffer* HXRemoteLogger::CopyBuffer(const char* pStr,
  285.       UINT32 ulLength) const
  286. {
  287.     IHXBuffer* pRet = 0;
  288.     if (m_pCCF && pStr &&
  289. (HXR_OK == m_pCCF->CreateInstance(CLSID_IHXBuffer, (void**)(&pRet))))
  290.     {
  291. if (HXR_OK != pRet->Set((const UCHAR*)pStr, ulLength))
  292. {
  293.     HX_RELEASE(pRet);
  294. }
  295.     }
  296.     return pRet;
  297. }
  298. void HXRemoteLogger::ClearMesgQueue()
  299. {
  300.     while(!m_mesgList.IsEmpty())
  301.     {
  302. HXLogMesg* pMesg = (HXLogMesg*)m_mesgList.RemoveHead();
  303. HX_DELETE(pMesg);
  304.     }
  305.     m_state = HXLogClosed;
  306. }
  307. void HXRemoteLogger::OnError()
  308. {
  309.     HX_RELEASE(m_pSocket);
  310.     m_state = HXLogError;
  311.     ClearMesgQueue();
  312. }
  313. HX_RESULT HXRemoteLogger::QueueMesg(HXLogMesgType type, IHXBuffer* pPayload)
  314. {
  315.     HX_RESULT res = HXR_FAILED;
  316.     HXLogMesg* pMesg = new HXLogMesg(type, pPayload);
  317.     if (pMesg)
  318.     {
  319. m_mesgList.AddTail(pMesg);
  320. res = HXR_OK;
  321.     }
  322.     return res;
  323. }
  324. void HXRemoteLogger::SendQueuedMesgs()
  325. {
  326.     while(!m_mesgList.IsEmpty())
  327.     {
  328. HXLogMesg* pMesg = (HXLogMesg*)m_mesgList.RemoveHead();
  329. HXLogMesgType type = pMesg->Type();
  330. IHXBuffer* pPayload = pMesg->Payload();
  331. HX_DELETE(pMesg);
  332. if (HXR_OK != SendMesg(type, pPayload))
  333. {
  334.     OnError();
  335. }
  336. HX_RELEASE(pPayload);
  337.     }
  338. }
  339. void HXRemoteLogger::PackUInt32(UCHAR* pBuf, UINT32 ulVal) const
  340. {
  341.     pBuf[0] = (UCHAR)((ulVal >> 24) & 0xff);
  342.     pBuf[1] = (UCHAR)((ulVal >> 16) & 0xff);
  343.     pBuf[2] = (UCHAR)((ulVal >> 8) & 0xff);
  344.     pBuf[3] = (UCHAR)((ulVal) & 0xff);
  345. }
  346. HX_RESULT HXRemoteLogger::SendMesg(HXLogMesgType type, IHXBuffer* pPayload)
  347. {
  348.     HX_RESULT res = HXR_FAILED;
  349.     
  350.     IHXBuffer* pHdr = 0;
  351.     if ((m_state == HXLogConnected) &&
  352. pPayload && m_pCCF && m_pSocket &&
  353. (HXR_OK == m_pCCF->CreateInstance(CLSID_IHXBuffer, (void**)&pHdr)) &&
  354. (HXR_OK == pHdr->SetSize(16)))
  355.     {
  356. UCHAR* pHdrBuf = pHdr->GetBuffer();
  357. PackUInt32(pHdrBuf, 0xff4d48ff);
  358. PackUInt32(pHdrBuf + 4, (UINT32)type);
  359. PackUInt32(pHdrBuf + 8, m_seq);
  360. PackUInt32(pHdrBuf + 12, pPayload->GetSize());
  361. if ((HXR_OK == m_pSocket->Write(pHdr)) &&
  362.     (HXR_OK == m_pSocket->Write(pPayload)))
  363. {
  364.     res = HXR_OK;
  365. }
  366.     }
  367.     HX_RELEASE(pHdr);
  368.     return res;
  369. }