robpktparse.h
上传用户:zhongxx05
上传日期:2007-06-06
资源大小:33641k
文件大小:5k
源码类别:

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. #ifndef _ROBPKTPARSE_H_
  36. #define _ROBPKTPARSE_H_
  37. const int MAX_FRAMES = 0x100; //max frames per cycle
  38. struct SFrameData
  39. {
  40.     IHXBuffer* pPacketBuf;
  41.     UINT32      ulOffset;    
  42.     BOOL        bCont;
  43.     SFrameData* pNext;
  44.     ~SFrameData() { HX_DELETE(pNext); HX_RELEASE(pPacketBuf); }
  45. };
  46. struct SFrameInfo
  47. {    
  48.     int         nIndex;
  49.     UINT32      ulADUSize;
  50.     SFrameData* pFrameData;   
  51.     double      dTime;
  52.     BOOL        bComplete;
  53.     ~SFrameInfo() { HX_DELETE(pFrameData); }
  54. };
  55. struct SCycle
  56. {   
  57.     SFrameInfo* pFrames[MAX_FRAMES];
  58.     int         nCycleIndex;
  59.     int         nMaxIndex;
  60.     double      dStartTime;
  61.     SCycle*     pNext;
  62.     SCycle*     pLast;
  63.     SCycle(int nCycle) : nCycleIndex(nCycle), nMaxIndex(0),
  64.                                  dStartTime(-1), pNext(NULL), pLast(NULL)
  65.     {
  66.         memset(pFrames, 0, sizeof(SFrameInfo*)*MAX_FRAMES); 
  67.     }
  68.     ~SCycle() { for(int i=0;i<=nMaxIndex;i++) { HX_DELETE(pFrames[i]); }}
  69. };
  70. /*******************************************************
  71.  * CCycleList: A simple doubly linked list of SCycle *s
  72.  * Only defines the methods we need.
  73.  */
  74. class CCycleList
  75. {
  76. public:
  77.     CCycleList() : m_pHead(NULL), m_pTail(NULL), m_nCount(0) {}
  78.     ~CCycleList() { DeleteAll(); }
  79.     inline SCycle*  GetHead()               { return m_pHead; }
  80.     inline SCycle*  GetTail()               { return m_pTail; }
  81.     inline SCycle*  RemoveHead();
  82.     inline void     AddTail(SCycle* pCycle);
  83.     
  84.     inline void     DeleteAll();    
  85.     
  86.     inline BOOL     IsEmpty()               { return m_pHead == NULL; }
  87.     inline int      GetCount()              { return m_nCount; }
  88.     
  89.     inline SCycle*  GetNext(SCycle* pCycle) { return pCycle->pNext; }
  90. private:
  91.     SCycle* m_pHead;
  92.     SCycle* m_pTail;
  93.     int     m_nCount;
  94. };
  95. /*
  96.  * CRobustPacketParser: RFC 3119 (audio/mpa-robust)
  97.  */
  98. class CRobustPacketParser : public CPacketParser
  99. {
  100. public:
  101.     CRobustPacketParser();
  102.     virtual ~CRobustPacketParser();
  103.     HX_RESULT   AddPacket   (IHXPacket* pPacket, INT32 streamOffsetTime);
  104.     HX_RESULT   RenderAll   (void);
  105.     void PreSeek            (void);
  106.     void PostSeek     (UINT32 time);
  107.     
  108.     void EndOfPackets       (void);
  109. protected:    
  110.     UINT32 GetFrameInfo(IHXBuffer* pPacket, UINT32 ulOffset, 
  111.                         double dTime = -1);
  112.     UINT32 GetFrame(UCHAR*& pFrameBuffer, double& dTime, BOOL& bLost);  
  113.     
  114.     CHXTimestampConverter* m_pTsConvert;
  115. private:    
  116.     CCycleList      m_Cycles;           // List of cycles.
  117.     UINT32          m_ulIndex;          // Index of next outgoing frame
  118.     BOOL            m_bFirstFrame;      // Waiting for first frame
  119. };
  120. inline SCycle* 
  121. CCycleList::RemoveHead() 
  122.     if(m_pHead == NULL)
  123.     {
  124.         return NULL;
  125.     }
  126.     if(m_pTail == m_pHead)
  127.     {
  128.         m_pTail = NULL;
  129.     }
  130.     
  131.     SCycle* pHead = m_pHead; 
  132.     m_pHead = m_pHead->pNext;
  133.     if(m_pHead != NULL)
  134.     {
  135.         m_pHead->pLast = NULL;
  136.     }
  137.     m_nCount--;
  138.     return pHead;
  139. }
  140. inline void 
  141. CCycleList::AddTail(SCycle* pCycle) 
  142.     pCycle->pNext = NULL;
  143.     pCycle->pLast = m_pTail;
  144.     if(m_pTail)
  145.     {
  146.         m_pTail->pNext = pCycle;
  147.     }
  148.     else
  149.     {
  150.         m_pHead = pCycle;
  151.     }
  152.     m_pTail = pCycle;
  153.     m_nCount++;
  154. }
  155. inline void 
  156. CCycleList::DeleteAll() 
  157.     if(m_pHead == NULL)
  158.     {
  159.         m_nCount = 0;
  160.         m_pTail = NULL;
  161.     }
  162.     else
  163.     { 
  164.         SCycle* pCycle = m_pHead;
  165.         m_pHead = pCycle->pNext;
  166.         delete pCycle;
  167.         DeleteAll();
  168.     }
  169. }
  170. #endif //_ROBPKTPARSE_H_