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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 通讯/手机编程 > Symbian > 查看源码
hxntsrc.h
资源名称：142_61_thumb_advanced.rar　[点击查看]
上传用户：dangjiwu
上传日期：2013-07-19
资源大小：42019k
文件大小：16k
源码类别：

Symbian

开发平台：

Visual C++

hxntsrc.h：源码内容
  1. /* ***** BEGIN LICENSE BLOCK *****
  2.  * Source last modified: $Id: hxntsrc.h,v 1.15.2.1 2004/07/09 02:05:57 hubbe Exp $
  3.  * 
  4.  * Portions Copyright (c) 1995-2004 RealNetworks, Inc. All Rights Reserved.
  5.  * 
  6.  * The contents of this file, and the files included with this file,
  7.  * are subject to the current version of the RealNetworks Public
  8.  * Source License (the "RPSL") available at
  9.  * http://www.helixcommunity.org/content/rpsl unless you have licensed
  10.  * the file under the current version of the RealNetworks Community
  11.  * Source License (the "RCSL") available at
  12.  * http://www.helixcommunity.org/content/rcsl, in which case the RCSL
  13.  * will apply. You may also obtain the license terms directly from
  14.  * RealNetworks.  You may not use this file except in compliance with
  15.  * the RPSL or, if you have a valid RCSL with RealNetworks applicable
  16.  * to this file, the RCSL.  Please see the applicable RPSL or RCSL for
  17.  * the rights, obligations and limitations governing use of the
  18.  * contents of the file.
  19.  * 
  20.  * Alternatively, the contents of this file may be used under the
  21.  * terms of the GNU General Public License Version 2 or later (the
  22.  * "GPL") in which case the provisions of the GPL are applicable
  23.  * instead of those above. If you wish to allow use of your version of
  24.  * this file only under the terms of the GPL, and not to allow others
  25.  * to use your version of this file under the terms of either the RPSL
  26.  * or RCSL, indicate your decision by deleting the provisions above
  27.  * and replace them with the notice and other provisions required by
  28.  * the GPL. If you do not delete the provisions above, a recipient may
  29.  * use your version of this file under the terms of any one of the
  30.  * RPSL, the RCSL or the GPL.
  31.  * 
  32.  * This file is part of the Helix DNA Technology. RealNetworks is the
  33.  * developer of the Original Code and owns the copyrights in the
  34.  * portions it created.
  35.  * 
  36.  * This file, and the files included with this file, is distributed
  37.  * and made available on an 'AS IS' basis, WITHOUT WARRANTY OF ANY
  38.  * KIND, EITHER EXPRESS OR IMPLIED, AND REALNETWORKS HEREBY DISCLAIMS
  39.  * ALL SUCH WARRANTIES, INCLUDING WITHOUT LIMITATION, ANY WARRANTIES
  40.  * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, QUIET
  41.  * ENJOYMENT OR NON-INFRINGEMENT.
  42.  * 
  43.  * Technology Compatibility Kit Test Suite(s) Location:
  44.  *    http://www.helixcommunity.org/content/tck
  45.  * 
  46.  * Contributor(s):
  47.  * 
  48.  * ***** END LICENSE BLOCK ***** */
  50. #ifndef _HX_NET_SOURCE_
  51. #define _HX_NET_SOURCE_
  53. struct IHXPacket;
  54. struct IHXPendingStatus;
  55. #include "hxpac.h"
  56. #include "pacutil.h"
  57. #include "ihxcookies.h"
  58. #include "ihxcookies2.h"
  59. #include "hxbsrc.h"
  60. #include "hxsrc.h"
  61. #include "hxprotocol.h"
  62. #include "hxstrutl.h"
  63. #include "hxbufctl.h"
  65. typedef enum
  66. {
  67.     NETSRC_READY,
  68.     // PAC
  69.     NETSRC_PACREADY,
  70.     NETSRC_PACPENDING,
  71.     // Preferred Transport
  72.     NETSRC_TRANSPORTREADY,
  73.     NETSRC_TRANSPORTPENDING,
  74.     // Reconnect
  75.     NETSRC_RECONNECTSTARTED,
  76.     NETSRC_RECONNECTPENDING,
  77.     NETSRC_RECONNECTFORCED
  78. } NetSourceState;
  80. typedef enum
  81. {
  82.     PUSHDOWN_NONE = 0,
  83.     PUSHDOWN_AUDIO_DONE,
  84.     PUSHDOWN_VIDEO_DONE,
  85.     PUSHDOWN_ALL_DONE
  86. } PushDownStatus;
  88. class ReconnectCallback;
  90. class HXNetSource :  public HXSource
  91.      ,public IHXPreferredTransportSink
  92.      ,public IHXProxyAutoConfigCallback
  93. {
  94. public:
  95. HXNetSource(void);
  97. STDMETHOD(QueryInterface) (THIS_
  98. REFIID riid,
  99. void** ppvObj);
  101. STDMETHOD_(ULONG32,AddRef) (THIS);
  103. STDMETHOD_(ULONG32,Release) (THIS);
  105. // IHXPendingStatus methods
  107. /************************************************************************
  108. * Method:
  109. *     IHXPendingStatus::GetStatus
  110. * Purpose:
  111. *     Called by the user to get the current pending status from an object
  112. */
  113. STDMETHOD(GetStatus) (THIS_
  114. REF(UINT16) uStatusCode, 
  115. REF(IHXBuffer*) pStatusDesc, 
  116. REF(UINT16) ulPercentDone);
  117. /*
  118.  * IHXRegistryID methods
  119.  */
  121. /************************************************************************
  122.  * Method:
  123.  *     IHXRegistryID::GetID
  124.  * Purpose:
  125.  *     Get registry ID(hash_key) of the objects(player, source and stream)
  126.  *
  127.  */
  128. STDMETHOD(GetID) (THIS_
  129. REF(UINT32) /*OUT*/  ulRegistryID);
  131. /************************************************************************
  132.  * Method:
  133.  *     IHXInfoLogger::LogInformation
  134.  * Purpose:
  135.  *     Logs any user defined information in form of action and 
  136.  *     associated data.
  137.  */
  138. STDMETHOD(LogInformation)     (THIS_
  139.     const char* /*IN*/ pAction,
  140.     const char* /*IN*/ pData);
  142. /*
  143.  * IHXPreferredTransportSink methods
  144.  */
  145. STDMETHOD(TransportSucceeded)     (TransportMode /* IN */   prefTransportType,
  146.     UINT16 /* IN */   uCloakPort);
  148. STDMETHOD(TransportFailed)     (THIS);
  150. HX_RESULT Setup(  const char* host, 
  151. const char* resource,
  152. UINT16  port, 
  153. BOOL  LossCorrection,
  154. const CHXURL* pURL,
  155. BOOL bAltURL);
  157.         /************************************************************************
  158.          * Method:
  159.          *     IHXSourceBufferingStats::GetCurrentBuffering
  160.          * Purpose:
  161.          *     Get the current buffering information
  162.          */
  164.         STDMETHOD(GetCurrentBuffering) (THIS_ 
  165.                                         UINT16  uStreamNumber,
  166.                                         REF(INT64)  llLowestTimestamp, 
  167.                                         REF(INT64)  llHighestTimestamp,
  168.                                         REF(UINT32) ulNumBytes,
  169.                                         REF(BOOL)   bDone);
  171. /*
  172.  *  IHXProxyAutoConfigCallback methods
  173.  */
  174. /************************************************************************
  175. *  Method:
  176. *      IHXProxyAutoConfigCallback::GetProxyInfoDone
  177. *  Purpose:
  178. */
  179. STDMETHOD(GetProxyInfoDone) (THIS_
  180. HX_RESULT   status,
  181. char*     pszProxyInfo);
  183. HXNetSource(HXPlayer* player);
  185.         virtual HX_RESULT DoCleanup(EndCode endCode = END_STOP);
  187. virtual HX_RESULT DoSeek(ULONG32 seekTime);
  189. virtual HX_RESULT DoPause(void);
  191. virtual HX_RESULT DoResume(void);
  193. virtual HX_RESULT StartInitialization(void);
  195. virtual UINT16 GetNumStreams(void);
  197. virtual HX_RESULT GetStreamInfo(ULONG32 ulStreamNumber,
  198.       STREAM_INFO*& theStreamInfo);
  200. virtual HX_RESULT GetEvent(UINT16 usStreamNumber, CHXEvent*& theEvent);
  202. ////// Interface to the Protocol object...
  203. virtual HX_RESULT FileHeaderReady(IHXValues* pHeader);
  205. virtual HX_RESULT TACInfoFromHeader(IHXValues* pValues);
  207.         BOOL CanSendToDataCallback(IHXPacket* packet) const;
  208. virtual HX_RESULT DataCallback(IHXPacket* packet);
  210. virtual HX_RESULT HeaderCallback(IHXValues* header);
  212. // tell about end of source...
  213. virtual void SetEndOfClip(BOOL bForcedEndofClip = FALSE);
  215. // The protocol object needs to know the current playback time
  216. // for a retry()
  217. virtual ULONG32 GetCurrentPlayTime(void);
  219. // set various options received from server...
  220. virtual HX_RESULT SetOption(UINT16 option, void* value);
  222. virtual HX_RESULT SetCookie(IHXBuffer* pCookie);
  224. // for auto transport switch... protocol object needs to tell
  225. // what protocol are we actually using to get data...
  226. virtual HX_RESULT TransportStarted(TransportMode mode);
  228. virtual HX_RESULT HandleRetry(char* pszHost, UINT16 ulPort);
  230. virtual BOOL CheckTransportTimeout(ULONG32 ulTime);
  231. ////// End of Interface to the Protocol object...
  233. virtual BOOL IsLocalSource() { return FALSE; };
  234. virtual BOOL IsPNAProtocol()  {return (BOOL) (!m_bRTSPProtocol);};
  236. virtual void StartDataWait(BOOL bConnectionWait = FALSE);
  237. virtual void StopDataWait();
  238. virtual void FirstDataArrives();
  240. HX_RESULT SetRedirectURL(char* pHost, UINT16 nPort, char* pPath, CHXURL* pURL);
  241. HX_RESULT SetReconnectInfo(IHXValues* pValues);
  243.         BOOL IsSourceDone(void);
  244. BOOL IsPlaying();
  246. void SetNoLatency();
  248. void EnterBufferedPlay(void);
  249. void LeaveBufferedPlay(void);
  251. void statistics_cat(char* stats,LONG32 Data);
  253. void Initialize();
  255. void SetAuthenicationInfo(const char* pszUserName, const char* pszPassword)
  256. {
  257.     memset(m_szUserName, 0, MAX_DISPLAY_NAME);
  258.     memset(m_szPassword, 0, MAX_DISPLAY_NAME);
  260.     if (pszUserName) SafeStrCpy(m_szUserName, pszUserName, MAX_DISPLAY_NAME);
  261.     if (pszPassword) SafeStrCpy(m_szPassword, pszPassword, MAX_DISPLAY_NAME);
  262. };
  264. void GetAuthenicationInfo(char** pszUserName, char** pszPassword)
  265.      {
  266.     *pszUserName = &m_szUserName[0];
  267.     *pszPassword = &m_szPassword[0];
  269.     m_bResendAuthenticationInfo = FALSE;
  270. };
  272. BOOL IsAuthenticationInfoResended(void)
  273. {
  274.     return m_bResendAuthenticationInfo;
  275. };
  278. void AdjustClipBandwidthStats(BOOL bActivate = FALSE);
  280. BOOL CanBeResumed(void);
  282. virtual HX_RESULT UpdateRegistry(UINT32 ulRegistryID);
  283. virtual void LeavePrefetch(void);
  284. virtual BOOL IsPrefetchDone(void) { return !m_bPrefetch; };
  286. virtual void EnterFastStart(void);
  287. virtual void LeaveFastStart(TurboPlayOffReason leftReason);
  288. virtual BOOL CanBeFastStarted(void);
  290. virtual HX_RESULT FillRecordControl();
  292. protected:
  294. virtual  ~HXNetSource(void);
  296. PRIVATE_DESTRUCTORS_ARE_NOT_A_CRIME
  298. HX_RESULT UpdateStatistics(void);
  300. HX_RESULT _ProcessIdle(BOOL atInterrupt = 0);
  302. virtual HX_RESULT   _ProcessIdleExt(BOOL atInterrupt = 0);
  303. virtual HX_RESULT   PreFileHeaderReadyExt(IHXValues* pHeader);
  304. virtual HX_RESULT   PostFileHeaderReadyExt(void);
  305. virtual HX_RESULT   PreHeaderCallbackExt(IHXValues* theHeader);
  306. virtual HX_RESULT   PostHeaderCallbackExt(IHXValues* theHeader);
  308. HX_RESULT     ReadPreferences(void);
  310. HX_RESULT     CreateProtocol();
  312. HX_RESULT InitializeProtocol(void);
  314. HX_RESULT set_proxy(const char* proxy,UINT16 port);
  315. HX_RESULT cleanup_proxy(void);
  317. HX_RESULT _Initialize(void);
  319. void CalculateCurrentBuffering(void);
  320. UINT32 AdjustEventTime(STREAM_INFO* pStreamInfo, UINT32 ulTime);
  322.         void ReBuffer(void);
  324. void ResetASMSource(void);
  326. BOOL IsInCloakPortList(UINT16 uPort);
  327. BOOL IsPrefetchEnded(void);
  329. HX_RESULT IsFaststartPushdownFullfilled(REF(UINT16) uStatusCode, 
  330.       REF(UINT16) ulPercentDone);
  331. BOOL IsRARVSource(void);
  333. HX_RESULT GetEventFromProtocol(UINT16 usStreamNumber, CHXEvent*& theEvent);
  334. HX_RESULT GetEventFromRecordControl(UINT16 usStreamNumber, CHXEvent*& theEvent);
  336. // stream thinning
  337. BOOL mServerSelRecordSupport;
  338. BOOL mInterframeControlSupport;
  339. BOOL mServerHasBandwidthReport;
  340. BOOL mServerHasFrameControl;
  342. // setup parameters...
  343. char* m_pHost;
  344. char* m_pPath;
  345. char* m_pResource;
  346. UINT16 m_uPort;
  348. // proxy stuff
  349. char* m_pProxy; // host string of proxy
  350. UINT16 m_uProxyPort; // host port of proxy
  351. BOOL m_bUseProxy; // == 1, connect to proxy first
  353. char mClientID[64]; /* Flawfinder: ignore */
  354. CHXSimpleList* m_pUDPPortList;
  356. HXProtocol* m_pProto;
  358. ULONG32 m_ulStartBuffering;
  360. ULONG32 m_ulServerTimeOut;
  361. ULONG32 m_ulConnectionTimeout;
  363. float m_fReBufferPercent;
  365. // level 1, 2 stats
  366. INT32 m_lRAStreamNumber;
  368. // level 3 stats
  369. CHXSimpleList* m_pLogInfoList;
  370. UINT32 m_ulLogInfoLength;
  372. // authenication info.
  373. char m_szUserName[MAX_DISPLAY_NAME]; /* Flawfinder: ignore */
  374. char m_szPassword[MAX_DISPLAY_NAME]; /* Flawfinder: ignore */
  375. UINT16 m_uLastBuffering;
  376.         UINT16          m_uLastStatusCode;
  377. ULONG32 m_ulPerfectPlayDownloadTime;
  379. // reconnect information
  380. BOOL m_bAttemptReconnect;
  381. char* m_pszReconnectServer;
  382. char* m_pszReconnectProxy;
  383. char* m_pszReconnectURL;
  384. UINT32 m_ulReconnectProxyPort;
  385. UINT32 m_ulReconnectServerPort;
  387. // redirect information
  388. char* m_pszRedirectServer;
  389. char* m_pszRedirectResource;
  390. char* m_pszRedirectURL;
  391. UINT32 m_ulRedirectServerPort;
  393. IHXPendingStatus* m_pProtocolStatus;
  394. IHXCookies* m_pCookies;
  395. IHXCookies2* m_pCookies2;
  397. //////////////////////////////////////////////
  398. // Automatic Transport Switching Support...
  399. public:
  400.         ULONG32 m_ulUDPTimeout;
  402. protected:
  403. ULONG32 m_ulMulticastTimeout;
  404. UINT32 m_ulTCPTimeout;
  405. ULONG32 m_ulStartDataWait;
  406. ULONG32 m_ulFirstDataArrives;
  407. ULONG32 m_ulSendStatsMask;
  408. ULONG32 m_ulStatsInterval;
  409. UINT32 m_ulSeekPendingTime;
  410. UINT32 m_ulServerVersion;
  411. UINT32 m_ulTransportPrefMask;
  412.         UINT16          m_uProtocolType;
  413. TransportMode m_PreferredTransport;
  414. TransportMode m_CurrentTransport;
  416. HX_BITFIELD m_bLossCorrection : 1;
  417. HX_BITFIELD m_bAltURL : 1;
  418. HX_BITFIELD m_bRTSPProtocol : 1;
  419. HX_BITFIELD m_bDataWaitStarted : 1;
  420. HX_BITFIELD m_bConnectionWait : 1;
  421. BOOL         m_bSendStatistics;
  422. BOOL     m_bUseUDPPort;
  423. HX_BITFIELD m_bResendAuthenticationInfo : 1;
  424. HX_BITFIELD m_bTimeBased : 1;
  425. HX_BITFIELD m_bUserHasCalledResume : 1;
  426. HX_BITFIELD m_bUserHasCalledStartInit : 1;
  427. HX_BITFIELD m_bAtInterrupt : 1;
  428. HX_BITFIELD m_bBruteForceReconnected : 1;
  429. HX_BITFIELD m_bBruteForceConnectToBeDone : 1;
  430. HX_BITFIELD m_bReconnect : 1;
  431. BOOL     m_bNoLatency;
  432. HX_BITFIELD m_bNoLatencySet : 1;
  433. HX_BITFIELD m_bPerfectPlayPreferenceRead : 1;
  434. BOOL     m_bPerfectPlayErrorChecked;
  435. HX_BITFIELD m_bServerHasPerfectPlay : 1;
  436. HX_BITFIELD m_bServerHasResend : 1;
  437. HX_BITFIELD m_bInRetryMode : 1;
  438. HX_BITFIELD m_bPushDownSet : 1;
  440. HX_BITFIELD m_bRARVSource : 1;
  441. HX_BITFIELD m_bRARVSourceVerified : 1;
  443. PushDownStatus m_pushDownStatus;
  445. BOOL m_bForcePerfectPlay;
  446. BOOL m_bServerHasTransportSwitching;
  447. BOOL m_bSeekPending;
  448. UINT16* m_pCloakPortList;
  449. UINT8 m_nNumberOfCloakPorts;
  450. UINT8 m_nCurrPortIdx;
  451. UINT16 m_uCurrCloakedPort;
  453. PreferredTransportState m_prefTransportState;
  454. IHXPreferredTransport* m_pPreferredTransport;
  455. IHXPreferredTransportManager* m_pPreferredTransportManager;
  457. ReconnectCallback* m_pReconnectCallback;
  458. #if defined(HELIX_FEATURE_STATS) && defined(HELIX_FEATURE_REGISTRY)
  459. ReconnectCallback* m_pStatsCallback;
  460. #endif /* HELIX_FEATURE_STATS && HELIX_FEATURE_REGISTRY */
  462. // PAC
  463. IHXProxyAutoConfig* m_pPAC;
  464. CHXSimpleList* m_pPACInfoList;
  465. LISTPOSITION m_PACInfoPosition;
  467. NetSourceState m_state;
  469. friend class ReconnectCallback;
  471. private:
  472.         IHXBufferControl*                m_pBufferCtl;
  473.         IHXWatermarkBufferControl*       m_pWMBufferCtl;
  475. public:
  476. HX_RESULT FinishSetup();
  477. void ReSetup();
  478. void Reset();
  479.     
  480. char* GetAltURL(BOOL& bDefault);
  482. HX_RESULT switch_out_of_perfectplay();
  484. HX_RESULT handleTransportSwitch(void);
  485. HX_RESULT handleProxySwitch(HX_RESULT inError);
  486. HX_RESULT handleRedirect(void);
  487. HX_RESULT handleReconnect(void);
  489. BOOL IsNetworkAvailable();
  490. HX_RESULT AttemptReconnect();
  491. HX_RESULT StartReconnect();
  492. HX_RESULT ReportStats();
  493. HX_RESULT ProcessReconnect(STREAM_INFO* pStreamInfo);
  494. HX_RESULT EndReconnect();
  495. HX_RESULT AddToPreReconnectEventList(STREAM_INFO* pStreamInfo, CHXEvent* pEvent);
  496. void UpdateReconnectInfo(UINT32 ulPacketTime, 
  497.     BOOL& bFirstEvent,
  498.     UINT32& ulPrevPacketTime,
  499.     UINT32& ulLargestGapInPacketTime,
  500.     UINT32& ulLastPacketTime);
  502. char* GetHost() {return m_pHost;};
  504. INT32 GetRAStreamNumber()
  505. {
  506.     return m_lRAStreamNumber;
  507. };
  509. UINT32 GetFirstDataArriveTime()
  510. {
  511.     return m_ulFirstDataArrives;
  512. };
  514. UINT32 GetLogInfo(CHXSimpleList*& pLogInfoList)
  515. {
  516.     pLogInfoList = m_pLogInfoList;
  517.     return m_ulLogInfoLength;
  518. };
  520. void ReportError (HX_RESULT theErr);
  522. HX_RESULT switch_to_next_transport(HX_RESULT incomingError);
  523. void set_transport(TransportMode mode);
  525. void WritePerfectPlayToRegistry();
  526. void CreateCloakedPortList();
  528. };
  530. class ReconnectCallback : public IHXCallback
  531. {
  532. public:
  533.     HXNetSource* m_pSource;
  534.     CallbackHandle m_PendingHandle;
  535.     BOOL m_bIsStatsReportingCallback;
  536.     IHXScheduler* m_pScheduler;
  537.     UINT32 m_ulScheduleTime;
  538.     UINT32 m_ulTimeout;
  539.     BOOL m_bPaused;
  541. ReconnectCallback(HXNetSource* pSource, 
  542.   BOOL bIsStatsCallback = FALSE);
  543.     HX_RESULT ScheduleCallback(UINT32 uTimeout);
  544.     HX_RESULT PauseCallback();
  545.     HX_RESULT ResumeCallback();
  546.     HX_RESULT CancelCallback();
  547.     BOOL IsPaused() {return m_bPaused;};
  549.     /*
  550.      * IUnknown methods
  551.      */
  552.     STDMETHOD(QueryInterface) (THIS_
  553.     REFIID riid,
  554.     void** ppvObj);
  556.     STDMETHOD_(ULONG32,AddRef) (THIS);
  558.     STDMETHOD_(ULONG32,Release) (THIS);
  560.     /*
  561.      * IHXCallback methods
  562.      */
  563.     STDMETHOD(Func) (THIS);
  565. protected:
  566. ~ReconnectCallback();
  568.     LONG32 m_lRefCount;
  569. };
  570. #endif // _HX_NET_SOURCE