dssend.cpp

MPEG4网络传输(DSnetwork)修改后的cpp和.h文件

//------------------------------------------------------------------------------
// File: DSSend.cpp
//
// Desc: DirectShow sample code - implementation of DSNetwork sample filters
//
// Copyright (c) 2000-2002  Microsoft Corporation.  All rights reserved.
//------------------------------------------------------------------------------

#include "precomp.h"
#include "dsnetifc.h"
#include "netsend.h"
#include "dssend.h"

#define NET_SEND(pf)    (reinterpret_cast <CNetworkSend *> (pf))

//  ---------------------------------------------------------------------------
//  ---------------------------------------------------------------------------

CInputPin::CInputPin (
    IN  TCHAR *         szName,
    IN  CBaseFilter *   pFilter,
    IN  CCritSec *      pLock,
    OUT HRESULT *       pHr,
    IN  LPCWSTR         pszName
    ) : CBaseInputPin   (szName,
                         pFilter,
                         pLock,
                         pHr,
                         pszName
                         )
{
}

CInputPin::~CInputPin (
    )
{
}


HRESULT
CInputPin::GetMediaType (
    IN  int             iPos,
    OUT CMediaType *    pmt
    )
{
    ASSERT (pmt) ;

    if (iPos == 0) {

        pmt -> InitMediaType () ;
////////修改了DSnetwork原有的MPEG2的MEDIATYPE和MEDIASUBTYPE
        pmt -> SetType      (& MEDIATYPE_Video) ;
        pmt -> SetSubtype   (& TIME_FORMAT_NONE) ;//适应任何形式

        return S_OK ;
    }

    return VFW_S_NO_MORE_ITEMS ;
}

HRESULT
CInputPin::CheckMediaType (
    IN  const CMediaType *  pmt
    )
{
////////去除check功能
/*
    if (pmt -> majortype    == MEDIATYPE_Video &&
        pmt -> subtype      == TIME_FORMAT_NONE) {

        return NOERROR ;
    }

    return S_FALSE ;
*/
	return NOERROR ;
}

HRESULT
CInputPin::Receive (
    IN  IMediaSample * pIMediaSample
    )
{
    HRESULT hr ;

    ASSERT (m_pFilter) ;
    ASSERT (pIMediaSample) ;

    NET_SEND (m_pFilter) -> LockReceive () ;

    hr = CBaseInputPin::Receive (pIMediaSample) ;
    if (SUCCEEDED (hr)) {
        hr = NET_SEND (m_pFilter) -> Send (pIMediaSample) ;
    }

    NET_SEND (m_pFilter) -> UnlockReceive () ;

    return hr ;
}

//  ----------------------------------------------------------------------------

CNetworkSend::CNetworkSend (
    IN  TCHAR *     tszName,
    IN  LPUNKNOWN   punk,
    OUT HRESULT *   phr
    ) : CBaseFilter     (
                         tszName,
                         punk,
                         & m_crtFilter,
                         CLSID_DSNetSend
                         ),
        CPersistStream  (punk,
                         phr
                         ),
        m_pInput        (NULL),
        m_ulIP          ((unsigned long) UNDEFINED),
        m_ulNIC         ((unsigned long) UNDEFINED),
        m_pNetSender    (NULL)
{
    DWORD   dw ;

    (* phr) = S_OK ;

    m_pInput = new CInputPin (
                            NAME ("CInputPin"),
                            this,
                            & m_crtFilter,
                            phr,
                            L"Divx"	//修改
                            ) ;
    if (m_pInput == NULL ||
        FAILED (* phr)) {

        (* phr) = FAILED (* phr) ? (* phr) : E_OUTOFMEMORY ;
        goto cleanup ;
    }

    //  integral number of transport packets
    dw = (MAX_IOBUFFER_LENGTH / TS_PACKET_LENGTH) * TS_PACKET_LENGTH ;
    m_pNetSender = new CNetSender (dw, phr) ;
    if (m_pNetSender == NULL ||
        FAILED (* phr)) {

        (* phr) = FAILED (* phr) ? (* phr) : E_OUTOFMEMORY ;
        goto cleanup ;
    }

    cleanup :

    return ;
}

CNetworkSend::~CNetworkSend ()
{
    delete m_pInput ;
    delete m_pNetSender ;
}

CBasePin *
CNetworkSend::GetPin (
    IN  int Index
    )
{
    CBasePin * pPin ;

    LockFilter () ;

    if (Index == 0) {
        pPin = m_pInput ;
    }
    else {
        pPin = NULL ;
    }

    UnlockFilter () ;

    return pPin ;
}

STDMETHODIMP
CNetworkSend::Pause (
    )
{
    HRESULT hr ;

    LockFilter () ;

    if  (m_State == State_Stopped) {

        //  --------------------------------------------------------------------
        //  stopped -> paused state transition; try to join the multicast

        hr = m_pNetSender -> JoinMulticast (m_ulIP, m_usPort, m_ulNIC) ;
        if (SUCCEEDED (hr)) {
            //  change the state, THEN activate the input pin
            m_State = State_Paused ;

            if (m_pInput &&
                m_pInput -> IsConnected ()) {
                m_pInput -> Active () ;
            }
        }
    }
    else {
        //  --------------------------------------------------------------------
        //  run -> paused transition; just set it

        m_State = State_Paused ;
    }

    UnlockFilter () ;

    return S_OK ;
}

STDMETHODIMP
CNetworkSend::Stop (
    )
{
    HRESULT hr ;

    LockReceive () ;
    LockFilter () ;

    //  inactivate the input pin
    if (m_pInput) {
        m_pInput -> Inactive () ;
    }

    //  leave the multicast
    hr = m_pNetSender -> LeaveMulticast () ;

    //  set the state
    m_State = State_Stopped ;

    UnlockFilter () ;
    UnlockReceive () ;

    return S_OK ;
}

CUnknown *
CNetworkSend::CreateInstance (
    IN  LPUNKNOWN   punk,
    OUT HRESULT *   phr
    )
{
    CNetworkSend * pnf ;

    (* phr) = S_OK ;

    pnf = new CNetworkSend (
                    NAME ("CNetworkSend"),
                    punk,
                    phr
                    ) ;
    if (pnf == NULL) {
        * phr = E_OUTOFMEMORY ;
    }

    if (FAILED (* phr)) {
        DELETE_RESET (pnf) ;
    }

    return pnf ;
}

STDMETHODIMP
CNetworkSend::NonDelegatingQueryInterface (
    IN  REFIID  riid,
    OUT void ** ppv
    )
{
    //  property pages

    if (riid == IID_ISpecifyPropertyPages) {

        return GetInterface (
                    (ISpecifyPropertyPages *) this,
                    ppv
                    ) ;
    }

    //  multicast

    else if (riid == IID_IMulticastConfig) {

        return GetInterface (
                    (IMulticastConfig *) this,
                    ppv
                    ) ;
    }

    //  we do persist

    else if (riid == IID_IPersistStream) {

        return GetInterface (
                    (IPersistStream *) this,
                    ppv
                    ) ;
    }

    //  fallback - call the baseclass

    else {
        return CBaseFilter::NonDelegatingQueryInterface (riid, ppv) ;
    }
}

STDMETHODIMP
CNetworkSend::GetPages (
    IN OUT CAUUID * pPages
    )
{
    pPages -> cElems = 1 ;

    pPages -> pElems = (GUID *) CoTaskMemAlloc (pPages -> cElems * sizeof GUID) ;

    if (pPages -> pElems == NULL) {
        return E_OUTOFMEMORY;
    }

    (pPages -> pElems) [0] = CLSID_IPMulticastSendProppage ;

    return S_OK ;
}

HRESULT
CNetworkSend::Send (
    IN  IMediaSample * pIMediaSample
    )
{
    BYTE *  pbBuffer ;
    HRESULT hr ;

    //  should have the receiver lock

    //  recover the buffer pointer and send it out
    hr = pIMediaSample -> GetPointer (& pbBuffer) ;
    if (SUCCEEDED (hr)) {
        hr = m_pNetSender -> Send (
                                pbBuffer,
                                pIMediaSample -> GetActualDataLength ()
                                ) ;
    }

    return hr ;
}

STDMETHODIMP
CNetworkSend::SetNetworkInterface (
    IN  ULONG   ulNIC
    )
{
    HRESULT hr ;

    if (m_State != State_Stopped) {
        //  can only set this if we're stopped
        hr = E_UNEXPECTED ;
    }
    else if (IsUnicastIP (ulNIC) ||
             ulNIC == INADDR_ANY) {

        //  looks like a valid NIC; set it
        m_ulNIC = ulNIC ;
        hr = S_OK ;
    }
    else {
        hr = E_INVALIDARG ;
    }

    return hr ;
}

STDMETHODIMP
CNetworkSend::GetNetworkInterface (
    OUT ULONG * pulNIC
    )
{
    HRESULT hr ;

    if (pulNIC) {
        (* pulNIC) = m_ulNIC ;
        hr = S_OK ;
    }
    else {
        hr = E_INVALIDARG ;
    }

    return hr ;
}

STDMETHODIMP
CNetworkSend::SetMulticastGroup (
    IN  ULONG   ulIP,
    IN  USHORT  usPort
    )
{
    HRESULT hr ;

    if (m_State != State_Stopped) {
        //  can only do this when stopped
        hr = E_UNEXPECTED ;
    }
    else if (IsMulticastIP (ulIP)) {

        //  looks like a valid multicast IP address; we place no restrictions
        //  on the port

        m_ulIP      = ulIP ;
        m_usPort    = usPort ;

        hr = S_OK ;
    }
    else {
        hr = E_INVALIDARG ;
    }

    return hr ;
}

STDMETHODIMP
CNetworkSend::GetMulticastGroup (
    OUT ULONG *     pIP,
    OUT USHORT  *   pPort
    )
{
    HRESULT hr ;

    if (pIP == NULL ||
        pPort == NULL) {

        hr = E_INVALIDARG ;
    }
    else {
        (* pIP)     = m_ulIP ;
        (* pPort)   = m_usPort ;

        hr = S_OK ;
    }

    return hr ;
}

STDMETHODIMP
CNetworkSend::GetClassID (
    OUT CLSID * pCLSID
    )
{
    (* pCLSID) = CLSID_DSNetSend ;
    return S_OK ;
}

HRESULT
CNetworkSend::WriteToStream (
    IN  IStream *   pIStream
    )
{
    HRESULT hr ;

    LockFilter () ;

    hr = pIStream -> Write ((BYTE *) & m_ulIP, sizeof m_ulIP, NULL) ;
    if (SUCCEEDED (hr)) {
        hr = pIStream -> Write ((BYTE *) & m_usPort, sizeof m_usPort, NULL) ;
        if (SUCCEEDED (hr)) {
            hr = pIStream -> Write ((BYTE *) & m_ulNIC, sizeof m_ulNIC, NULL) ;
        }
    }

    UnlockFilter () ;

    return hr ;
}

HRESULT
CNetworkSend::ReadFromStream (
    IN  IStream *   pIStream
    )
{
    HRESULT hr ;

    LockFilter () ;

    hr = pIStream -> Read ((BYTE *) & m_ulIP, sizeof m_ulIP, NULL) ;
    if (SUCCEEDED (hr)) {
        hr = pIStream -> Read ((BYTE *) & m_usPort, sizeof m_usPort, NULL) ;
        if (SUCCEEDED (hr)) {
            hr = pIStream -> Read ((BYTE *) & m_ulNIC, sizeof m_ulNIC, NULL) ;
        }
    }

    UnlockFilter () ;

    return hr ;
}