多媒体编程

开发平台：

Visual C++

BaseMuxerInputPin.h：源码内容

							/* 
 *	Copyright (C) 2003-2005 Gabest
 *	http://www.gabest.org
 *
 *  This Program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2, or (at your option)
 *  any later version.
 *   
 *  This Program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 *  GNU General Public License for more details.
 *   
 *  You should have received a copy of the GNU General Public License
 *  along with GNU Make; see the file COPYING.  If not, write to
 *  the Free Software Foundation, 675 Mass Ave, Cambridge, MA 02139, USA. 
 *  http://www.gnu.org/copyleft/gpl.html
 *
 */
#pragma once
#include "......DSUtilDSMPropertyBag.h"
class CBaseMuxerInputPin;
struct MuxerPacket
{
	CBaseMuxerInputPin* pPin;
	REFERENCE_TIME rtStart, rtStop;
	CArray<BYTE> pData;
	enum flag_t {empty = 0, timevalid = 1, syncpoint = 2, discontinuity = 4, eos = 8, bogus = 16};
	DWORD flags;
	struct MuxerPacket(CBaseMuxerInputPin* pPin) {this->pPin = pPin; rtStart = rtStop = _I64_MIN; flags = empty;}
	bool IsTimeValid() const {return !!(flags & timevalid);}
	bool IsSyncPoint() const {return !!(flags & syncpoint);}
	bool IsDiscontinuity() const {return !!(flags & discontinuity);}
	bool IsEOS() const {return !!(flags & eos);}
	bool IsBogus() const {return !!(flags & bogus);}
};
class CBaseMuxerInputPin : public CBaseInputPin, public IDSMPropertyBagImpl
{
private:
	int m_iID;
	CCritSec m_csReceive;
	REFERENCE_TIME m_rtMaxStart, m_rtDuration;
	bool m_fEOS;
	CCritSec m_csQueue;
	CAutoPtrList<MuxerPacket> m_queue;
	void PushPacket(CAutoPtr<MuxerPacket> pPacket);
	CAutoPtr<MuxerPacket> PopPacket();
	CAMEvent m_evAcceptPacket;
	friend class CBaseMuxerFilter;
public:
	CBaseMuxerInputPin(LPCWSTR pName, CBaseFilter* pFilter, CCritSec* pLock, HRESULT* phr);
	virtual ~CBaseMuxerInputPin();
	DECLARE_IUNKNOWN;
    STDMETHODIMP NonDelegatingQueryInterface(REFIID riid, void** ppv);
	REFERENCE_TIME GetDuration() {return m_rtDuration;}
	int GetID() {return m_iID;}
	CMediaType& CurrentMediaType() {return m_mt;}
	bool IsSubtitleStream();
    HRESULT CheckMediaType(const CMediaType* pmt);
    HRESULT BreakConnect();
    HRESULT CompleteConnect(IPin* pReceivePin);
	HRESULT Active();
	HRESULT Inactive();
    STDMETHODIMP NewSegment(REFERENCE_TIME tStart, REFERENCE_TIME tStop, double dRate);
	STDMETHODIMP Receive(IMediaSample* pSample);
    STDMETHODIMP EndOfStream();
};

						