sinkctl.h
上传用户:zhongxx05
上传日期:2007-06-06
资源大小:33641k
文件大小:11k
- /* ***** BEGIN LICENSE BLOCK *****
- * Version: RCSL 1.0/RPSL 1.0
- *
- * Portions Copyright (c) 1995-2002 RealNetworks, Inc. All Rights Reserved.
- *
- * The contents of this file, and the files included with this file, are
- * subject to the current version of the RealNetworks Public Source License
- * Version 1.0 (the "RPSL") available at
- * http://www.helixcommunity.org/content/rpsl unless you have licensed
- * the file under the RealNetworks Community Source License Version 1.0
- * (the "RCSL") available at http://www.helixcommunity.org/content/rcsl,
- * in which case the RCSL will apply. You may also obtain the license terms
- * directly from RealNetworks. You may not use this file except in
- * compliance with the RPSL or, if you have a valid RCSL with RealNetworks
- * applicable to this file, the RCSL. Please see the applicable RPSL or
- * RCSL for the rights, obligations and limitations governing use of the
- * contents of the file.
- *
- * This file is part of the Helix DNA Technology. RealNetworks is the
- * developer of the Original Code and owns the copyrights in the portions
- * it created.
- *
- * This file, and the files included with this file, is distributed and made
- * available on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
- * EXPRESS OR IMPLIED, AND REALNETWORKS HEREBY DISCLAIMS ALL SUCH WARRANTIES,
- * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY, FITNESS
- * FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
- *
- * Technology Compatibility Kit Test Suite(s) Location:
- * http://www.helixcommunity.org/content/tck
- *
- * Contributor(s):
- *
- * ***** END LICENSE BLOCK ***** */
- #ifndef _SINKCTL_
- #define _SINKCTL_
- struct IHXInterruptState;
- struct IHXClientEngine;
- struct IHXCallback;
- struct IHXScheduler;
- class CHXSimpleList;
- class ErrorCallback;
- class CHXGenericCallback;
- class CHXAdviseSinkControl : public IHXClientAdviseSink, public IHXInterruptSafe
- {
- public:
- CHXAdviseSinkControl();
- ~CHXAdviseSinkControl();
-
- /*
- * IUnknown methods
- */
- STDMETHOD(QueryInterface) (THIS_
- REFIID riid,
- void** ppvObj);
- STDMETHOD_(ULONG32,AddRef) (THIS);
- STDMETHOD_(ULONG32,Release) (THIS);
- /*
- * IHXClientAdviseSink methods
- */
- /************************************************************************
- * Method:
- * IHXClientAdviseSink::OnPosLength
- * Purpose:
- * Called to advise the client that the position or length of the
- * current playback context has changed.
- */
- STDMETHOD(OnPosLength) (THIS_
- UINT32 ulPosition,
- UINT32 ulLength);
- /************************************************************************
- * Method:
- * IHXClientAdviseSink::OnPresentationOpened
- * Purpose:
- * Called to advise the client a presentation has been opened.
- */
- STDMETHOD(OnPresentationOpened) (THIS);
- /************************************************************************
- * Method:
- * IHXClientAdviseSink::OnPresentationClosed
- * Purpose:
- * Called to advise the client a presentation has been closed.
- */
- STDMETHOD(OnPresentationClosed) (THIS);
- /************************************************************************
- * Method:
- * IHXClientAdviseSink::OnStatisticsChanged
- * Purpose:
- * Called to advise the client that the presentation statistics
- * have changed.
- */
- STDMETHOD(OnStatisticsChanged) (THIS);
- /************************************************************************
- * Method:
- * IHXClientAdviseSink::OnPreSeek
- * Purpose:
- * Called by client engine to inform the client that a seek is
- * about to occur. The render is informed the last time for the
- * stream's time line before the seek, as well as the first new
- * time for the stream's time line after the seek will be completed.
- *
- */
- STDMETHOD (OnPreSeek) (THIS_
- ULONG32 ulOldTime,
- ULONG32 ulNewTime);
- /************************************************************************
- * Method:
- * IHXClientAdviseSink::OnPostSeek
- * Purpose:
- * Called by client engine to inform the client that a seek has
- * just occured. The render is informed the last time for the
- * stream's time line before the seek, as well as the first new
- * time for the stream's time line after the seek.
- *
- */
- STDMETHOD (OnPostSeek) (THIS_
- ULONG32 ulOldTime,
- ULONG32 ulNewTime);
- /************************************************************************
- * Method:
- * IHXClientAdviseSink::OnStop
- * Purpose:
- * Called by client engine to inform the client that a stop has
- * just occured.
- *
- */
- STDMETHOD (OnStop) (THIS);
- /************************************************************************
- * Method:
- * IHXClientAdviseSink::OnPause
- * Purpose:
- * Called by client engine to inform the client that a pause has
- * just occured. The render is informed the last time for the
- * stream's time line before the pause.
- *
- */
- STDMETHOD (OnPause) (THIS_
- ULONG32 ulTime);
- /************************************************************************
- * Method:
- * IHXClientAdviseSink::OnBegin
- * Purpose:
- * Called by client engine to inform the client that a begin or
- * resume has just occured. The render is informed the first time
- * for the stream's time line after the resume.
- *
- */
- STDMETHOD (OnBegin) (THIS_
- ULONG32 ulTime);
- /************************************************************************
- * Method:
- * IHXClientAdviseSink::OnBuffering
- * Purpose:
- * Called by client engine to inform the client that buffering
- * of data is occuring. The render is informed of the reason for
- * the buffering (start-up of stream, seek has occured, network
- * congestion, etc.), as well as percentage complete of the
- * buffering process.
- *
- */
- STDMETHOD (OnBuffering) (THIS_
- ULONG32 ulFlags,
- UINT16 unPercentComplete);
- /************************************************************************
- * Method:
- * IHXClientAdviseSink::OnContacting
- * Purpose:
- * Called by client engine to inform the client is contacting
- * hosts(s).
- *
- */
- STDMETHOD (OnContacting) (THIS_
- const char* pHostName);
- /*
- IHXInteruptSafe methods.
- */
-
- STDMETHOD_(BOOL,IsInterruptSafe) (THIS);
- /*
- * CHXAdviseSinkControl methods
- */
- HX_RESULT AddAdviseSink(IHXClientAdviseSink* pAdviseSink);
- HX_RESULT RemoveAdviseSink(IHXClientAdviseSink* pAdviseSink);
- void Init(IHXClientEngine* pEngine);
- private:
- CHXSimpleList m_pSinkList;
- LONG32 m_lRefCount;
- IHXInterruptState* m_pInterruptState;
- IHXScheduler* m_pScheduler;
- struct PlayerAdviseSink;
- friend struct PlayerAdviseSink;
- struct PlayerAdviseSink
- {
- PlayerAdviseSink(IHXClientAdviseSink* pAdviseSink,
- BOOL bInterruptSafe);
- ~PlayerAdviseSink();
-
- IHXClientAdviseSink* m_pAdviseSink;
- BOOL m_bInterruptSafe;
- CHXSimpleList* m_pPendingAdviseList;
- };
- typedef enum
- {
- ONPOSLENGTH = 0
- , ONPRESENTATIONOPENED
- , ONPRESENTATIONCLOSED
- , ONSTATISTICSCHANGED
- , ONPRESEEK
- , ONPOSTSEEK
- , ONSTOP
- , ONPAUSE
- , ONBEGIN
- , ONBUFFERING
- , ONCONTACTING
- } AdviseType;
- struct PendingAdvise;
- friend struct PendingAdvise;
- struct PendingAdvise
- {
- PendingAdvise()
- {
- m_pHostName = NULL;
- }
- ~PendingAdvise()
- {
- if (m_pHostName)
- {
- delete [] m_pHostName;
- }
- }
- AdviseType m_AdviseType;
- UINT32 m_ulArg1;
- UINT32 m_ulArg2;
- char* m_pHostName;
- };
- void AddToPendingList(PlayerAdviseSink* pPlayerAdviseSink,
- AdviseType type,
- UINT32 ulArg1 = 0,
- UINT32 ulArg2 = 0,
- char* pHostName = NULL);
- void ProcessPendingRequests(PlayerAdviseSink* pPlayerAdviseSink);
- void ProcessAllRequests(void);
- CHXGenericCallback* m_pCallback;
- static void AdviseSinkCallback(void* pParam);
- };
- struct ErrorReport
- {
- ErrorReport()
- {
- m_unSeverity = 0;
- m_ulHXCode = 0;
- m_ulUserCode = 0;
- m_pUserString = NULL;
- m_pMoreInfoURL = NULL;
- }
- ~ErrorReport()
- {
- m_unSeverity = 0;
- m_ulHXCode = 0;
- m_ulUserCode = 0;
- HX_VECTOR_DELETE(m_pUserString);
- HX_VECTOR_DELETE(m_pMoreInfoURL);
- }
- UINT8 m_unSeverity;
- HX_RESULT m_ulHXCode;
- ULONG32 m_ulUserCode;
- char* m_pUserString;
- char* m_pMoreInfoURL;
- };
- class CHXErrorSinkControl : public IHXErrorSinkControl
- {
- public:
- CHXErrorSinkControl();
- ~CHXErrorSinkControl();
- /*
- * IHXErrorSinkControl methods
- */
- STDMETHOD(AddErrorSink) (THIS_
- IHXErrorSink* pErrorSink,
- const UINT8 unLowSeverity,
- const UINT8 unHighSeverity);
- STDMETHOD(RemoveErrorSink) (THIS_ IHXErrorSink* pErrorSink);
- /*
- * IUnknown methods
- */
- STDMETHOD(QueryInterface) (THIS_ REFIID riid, void** ppvObj);
- STDMETHOD_(ULONG32,AddRef) (THIS);
- STDMETHOD_(ULONG32,Release) (THIS);
-
- //get the severity range for pErrorSink
- void GetSeverityRange(IHXErrorSink* pErrorSink, UINT8& unLowSeverity,
- UINT8& unHighSeverity);
- void Init(IHXClientEngine* pEngine);
- void Close();
-
- HX_RESULT ErrorOccurred(const UINT8 unSeverity,
- const ULONG32 ulHXCode,
- const ULONG32 ulUserCode,
- const char* pUserString,
- const char* pMoreInfoURL
- );
- struct PlayerErrorSink
- {
- PlayerErrorSink(IHXErrorSink* pErrorSink,
- const UINT8 unLowSeverity,
- const UINT8 unHighSeverity)
- {
- m_pErrorSink = pErrorSink;
- m_unLowSeverity = unLowSeverity;
- m_unHighSeverity = unHighSeverity;
- };
-
- IHXErrorSink* m_pErrorSink;
- UINT8 m_unLowSeverity;
- UINT8 m_unHighSeverity;
- };
-
- public:
- CHXSimpleList m_pSinkList;
-
- private:
- HX_RESULT CallReport(
- const UINT8 unSeverity,
- HX_RESULT ulHXCode,
- const ULONG32 ulUserCode,
- const char* pUserString,
- const char* pMoreInfoURL);
- void ReportPendingErrors(void);
-
- friend class ErrorCallback;
- LONG32 m_lRefCount;
- IHXInterruptState* m_pInterruptState;
- IHXScheduler* m_pScheduler;
- CHXSimpleList* m_pPendingErrorList;
- CHXGenericCallback* m_pErrorCallback;
- static void ErrorCallback(void* pParam);
- };
- #endif /* _SINKCTL_ */