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 "..\..\..\DSUtil\DSMPropertyBag.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();
};

---