。

流类型由文件决定。

已知可读取的文件格式有#xff1a;AVI#xff0c;ASF#xff0c;MOV#xff0c;MP4#xff0c;MPG#xff0c;WMV。

本过滤器读取视频文件输出视频流和音频流。

流类型由文件决定。

已知可读取的文件格式有AVIASFMOVMP4MPGWMV。

过滤器GUID{29001AD7-37A5-45E0-A750-E76453B36E33}

输出引脚1标识Video

过滤器实现了IFileSourceFilter接口用于指定要读取的视频文件。

并在接口的Load方法中确定文件视频流音频流媒体类型设置给视频音频输出引脚并获取文件的时长。

过滤器运行时创建媒体源线程在线程中创建媒体源并获取媒体源事件。

媒体源启动后调用媒体源的Start方法将产生“创建了新流”事件事件值为视频或音频流接口。

获取流接口后创建视频音频工作线程视频音频流线程。

在线程中获取流事件。

请求样本后会产生“产生新样本”事件事件值为样本接口其为媒体基础样本将其转换为引脚样本由引脚向下游发送。

再请求下一个样本。

过滤器停止时调用媒体源接口的Stop方法会产生“流停止”事件收到此事件后退出视频音频工作线程但媒体源线程仍未退出。

再次运行过滤器时再次启动媒体源此时媒体源产生“流已更新”事件事件值为已更新的流接口。

获取流接口后创建视频音频工作线程视频音频流线程。

过滤器更改播放位置时即定位调用媒体源的Start方法在参数中指定新的开始位置媒体源也会产生“流已更新”事件此时只更新流接口不再创建新的视频音频工作线程因为线程已存在。

媒体源会自动寻找关键帧从关键帧开始。

要退出媒体源线程通过销毁过滤器或指定新的要读取的文件方式为发送“退出媒体源线程”事件信号。

IMediaSeeking接口用于调整播放的当前位置定位。

可以在过滤器实现也可以在任一引脚实现。

如果在引脚实现最好在音频引脚。

DLL.h

{29001AD7-37A5-45E0-A750-E76453B36E33}

DEFINE_GUID(CLSID_Reader,//过滤器GUID0x29001ad7,

0x37a5,

pPinName);~CPin1();DECLARE_IUNKNOWNSTDMETHODIMP

NonDelegatingQueryInterface(REFIID

riid,

pPinName);~CPin2();DECLARE_IUNKNOWNSTDMETHODIMP

NonDelegatingQueryInterface(REFIID

riid,

AM_SEEKING_CanGetDuration;HRESULT

STDMETHODCALLTYPE

*phr);DECLARE_IUNKNOWNSTDMETHODIMP

NonDelegatingQueryInterface(REFIID

iid,

GetMediaType();//获取视频音频流媒体类型REFERENCE_TIME

mStart

NULL;//“媒体源已创建”事件句柄STDMETHODIMP

Pause();STDMETHODIMP

NULL;//媒体源接口IMFPresentationDescriptor*

pISourceD

//对象CLSID的指针CFilter::CreateInstance,

};int

AMovieDllRegisterServer2(TRUE);

}STDAPI

AMovieDllRegisterServer2(FALSE);

}extern

DllEntryPoint((HINSTANCE)(hModule),

dwReason,

MFStartup(MF_VERSION);//初始化媒体基础if

(hr

{SetEvent(hExit);//发送“退出媒体源线程”信号SafeRelease(pVideoType);

SafeRelease(pAudioType);//释放媒体类型if

m_pFileName;MFShutdown();//关闭媒体基础CloseHandle(hSourceThread);

CloseHandle(hExit);

CFilter::CreateInstance(LPUNKNOWN

pUnk,

CFilter::NonDelegatingQueryInterface(REFIID

iid,

GetInterface(static_castIFileSourceFilter*(this),

ppv);}elsereturn

CBaseFilter::NonDelegatingQueryInterface(iid,

ppv);

ERROR_FILENAME_EXCED_RANGE;size_t

len

VFW_E_INVALID_FILE_FORMAT;//设置文件名失败}return

S_OK;

lstrlenW(m_pFileName));*ppszFileName

(*ppszFileName

NULL){CopyMemory(*ppszFileName,

m_pFileName,

CFilter::GetMediaType()//获取视频音频流媒体类型

{DWORD

WaitForSingleObject(hSourceThread,

0);if

WAIT_TIMEOUT)//如果媒体源线程正在运行{SetEvent(hExit);//发送“退出媒体源线程”信号WaitForSingleObject(hSourceThread,

INFINITE);//等待媒体源线程退出}SafeRelease(pVideoType);

SafeRelease(pAudioType);//释放媒体类型IMFPresentationDescriptor*

pSourceD

NULL;//媒体源接口IMFStreamDescriptor*

pStreamD1

NULL;//流1描述符IMFStreamDescriptor*

pStreamD2

NULL;//流2描述符IMFMediaTypeHandler*

pHandle1

NULL;//流1媒体类型处理器IMFMediaTypeHandler*

pHandle2

NULL;//流2媒体类型处理器IMFSourceResolver*

pSourceResolver

MFCreateSourceResolver(pSourceResolver);//创建源解析器MF_OBJECT_TYPE

ObjectType

pSourceResolver-CreateObjectFromURL(//从URL创建媒体源m_pFileName,

//源的URLMF_RESOLUTION_MEDIASOURCE,

//创建源对象NULL,

//接收指向媒体源的指针);}SafeRelease(pSourceResolver);//释放源解析器if

(SUCCEEDED(hr)){hr

pSource-QueryInterface(IID_PPV_ARGS(pMFMediaSource));//获取媒体源接口}SafeRelease(pSource);//释放IUnknown接口if

(SUCCEEDED(hr)){hr

pMFMediaSource-CreatePresentationDescriptor(pSourceD);//获取演示文稿描述符}if

(SUCCEEDED(hr)){hr

pSourceD-GetUINT64(MF_PD_DURATION,

(UINT64*)DUR);//获取文件流的时长100纳秒为单位}BOOL

Selected;if

pSourceD-GetStreamDescriptorByIndex(0,

Selected,

pStreamD1-GetMediaTypeHandler(pHandle1);//获取流1媒体类型处理器}SafeRelease(pStreamD1);//释放流1描述符GUID

guid;if

pHandle1-GetMajorType(guid);//获取流1主要类型}if

(SUCCEEDED(hr)){if

pHandle1-GetCurrentMediaType(pVideoType);//获取视频流的媒体类型}else

(guid

pHandle1-GetCurrentMediaType(pAudioType);//获取音频流的媒体类型}}SafeRelease(pHandle1);//释放流1媒体类型处理器if

(SUCCEEDED(hr)){hr

pSourceD-GetStreamDescriptorByIndex(1,

Selected,

pStreamD2-GetMediaTypeHandler(pHandle2);//获取流2媒体类型处理器}SafeRelease(pStreamD2);//释放流2描述符if

(SUCCEEDED(hr)){hr

pHandle2-GetMajorType(guid);//获取流2主要类型}if

(SUCCEEDED(hr)){if

pHandle2-GetCurrentMediaType(pVideoType);//获取视频流的媒体类型}else

(guid

pHandle2-GetCurrentMediaType(pAudioType);//获取音频流的媒体类型}}SafeRelease(pHandle2);//释放流2媒体类型处理器SafeRelease(pSourceD);//释放演示文稿描述符SafeRelease(pMFMediaSource);//释放媒体源接口return

hr;

WaitForSingleObject(hSourceThread,

0);if

WAIT_OBJECT_0)//如果媒体源线程没有创建或已退出{hSourceThread

CreateThread(NULL,

NULL);//创建媒体源线程WaitForSingleObject(hInit,

0;PROPVARIANT

var;PropVariantInit(var);var.vt

mStart;HRESULT

pIMFMediaSource-Start(pISourceD,

NULL,

var);//启动媒体源PropVariantClear(var);}return

}STDMETHODIMP

NULL;//视频流接口pCFilter-pAudioStream

pSourceResolver

MFCreateSourceResolver(pSourceResolver);//创建源解析器MF_OBJECT_TYPE

ObjectType

pSourceResolver-CreateObjectFromURL(//从URL创建媒体源pCFilter-m_pFileName,

//源的URLMF_RESOLUTION_MEDIASOURCE,

//创建源对象NULL,

//接收指向媒体源的指针);}SafeRelease(pSourceResolver);//释放源解析器if

(SUCCEEDED(hr)){hr

pSource-QueryInterface(IID_PPV_ARGS(pCFilter-pIMFMediaSource));//获取媒体源接口}SafeRelease(pSource);//释放IUnknown接口if

(SUCCEEDED(hr)){hr

pCFilter-pIMFMediaSource-CreatePresentationDescriptor(pCFilter-pISourceD);//获取演示文稿描述符}if

(hr

S_OK){SafeRelease(pCFilter-pIMFMediaSource);//释放媒体源接口return

hr;}SetEvent(pCFilter-hInit);//发送“媒体源已创建”信号Agan:GUID

guid;IMFMediaEvent*

pCFilter-pIMFMediaSource-GetEvent(MF_EVENT_FLAG_NO_WAIT,

pSourceEvent);//获取媒体源事件不等待DWORD

WaitForSingleObject(pCFilter-hExit,

0);//检测“退出媒体源线程”信号if

WAIT_OBJECT_0)//如果有“退出媒体源线程”信号{hr

pCFilter-pIMFMediaSource-Stop();pCFilter-pIMFMediaSource-Shutdown();SafeRelease(pCFilter-pISourceD);//释放演示文稿描述符SafeRelease(pCFilter-pIMFMediaSource);//释放媒体源return

1;//退出线程}if

(SUCCEEDED(hr1))//如果获取媒体源事件成功{MediaEventType

MET;hr2

pSourceEvent-GetType(MET);//获取媒体源事件类型if

pSourceEvent-GetValue(vr);//获取事件值switch

(MET){case

vr.punkVal-QueryInterface(pIMFMediaStream);//获取流接口vr.punkVal-Release();//释放IUnknown接口hr

pIMFMediaStream-GetStreamDescriptor(pIMFStreamDescriptor);//获取流描述符hr

pIMFStreamDescriptor-GetMediaTypeHandler(pHandler);//获取媒体类型处理器SafeRelease(pIMFStreamDescriptor);//释放流描述符hr

pHandler-GetMajorType(guid);//获取主要类型SafeRelease(pHandler);//释放类型处理器if

(guid

MEDIATYPE_Video)//如果是视频流{pCFilter-pVideoStream

pCFilter-pVideoStream-RequestSample(NULL);//视频流请求样本第1个样本pCFilter-hVideoThread

CreateThread(NULL,

MEDIATYPE_Audio)//如果是音频流{pCFilter-pAudioStream

pCFilter-pAudioStream-RequestSample(NULL);//音频流请求样本第1个样本pCFilter-hAudioThread

CreateThread(NULL,

MEUpdatedStream://如果是“流已更新”定位或重启时发送hr

vr.punkVal-QueryInterface(pIMFMediaStream);//获取流接口vr.punkVal-Release();//释放IUnknown接口hr

pIMFMediaStream-GetStreamDescriptor(pIMFStreamDescriptor);//获取流描述符hr

pIMFStreamDescriptor-GetMediaTypeHandler(pHandler);//获取媒体类型处理器SafeRelease(pIMFStreamDescriptor);//释放流描述符hr

pHandler-GetMajorType(guid);//获取主要类型SafeRelease(pHandler);//释放类型处理器if

(guid

MEDIATYPE_Video)//如果是视频流{pCFilter-pVideoStream

pCFilter-pVideoStream-RequestSample(NULL);//视频流请求第1个样本DWORD

WaitForSingleObject(pCFilter-hVideoThread,

0);if

WAIT_OBJECT_0)//如果视频工作线程已退出。

防止在SEEK时创建新线程{pCFilter-hVideoThread

CreateThread(NULL,

MEDIATYPE_Audio)//如果是音频流{pCFilter-pAudioStream

pCFilter-pAudioStream-RequestSample(NULL);//音频流请求第1个样本DWORD

WaitForSingleObject(pCFilter-hAudioThread,

0);if

WAIT_OBJECT_0)//如果音频工作线程已退出。

防止在SEEK时创建新线程{pCFilter-hAudioThread

CreateThread(NULL,

NULL);//创建音频工作线程}}break;}PropVariantClear(vr);}SafeRelease(pSourceEvent);//释放媒体源事件}goto

Agan;

pCFilter-pCPin1-DeliverBeginFlush();Sleep(200);hr

pCFilter-pCPin1-DeliverEndFlush();hr

pCFilter-pCPin1-DeliverNewSegment(0,

pCFilter-DUR

pCFilter-pVideoStream-GetEvent(0,

(hr1

pStreamEvent-GetType(meType);//获取事件类型if

(hr2

pStreamEvent-GetValue(var);//获取事件值switch

(meType){case

var.punkVal-QueryInterface(pIMFSample);//获取样本接口if

(hr

pIMFSample-GetUINT32(MFSampleExtension_CleanPoint,

Discontinuity;hrB

pIMFSample-GetUINT32(MFSampleExtension_Discontinuity,

Discontinuity);//是否包含中断标志LONGLONG

star,

pIMFSample-GetSampleTime(star);hr

pIMFSample-GetSampleDuration(dur);DWORD

len;hr

pIMFSample-GetTotalLength(len);DWORD

Count;hr

pIMFSample-GetBufferCount(Count);IMFMediaBuffer*

pBuffer

pIMFSample-ConvertToContiguousBuffer(pBuffer);//将具有多个缓冲区的样本转换为具有单个缓冲区的样本BYTE*

pData

pCFilter-pCPin1-GetDeliveryBuffer(pOutSample,

NULL,

pOutSample-GetPointer(pOutBuffer);//获取输出引脚样本缓冲区指针if

(pOutBuffer

10000000)CopyMemory(pOutBuffer,

pData,

pOutSample-SetActualDataLength(len);//设置输出引脚样本有效数据长度if

(hrA

pOutSample-SetSyncPoint(TRUE);//设置同步点标志elsehr

pOutSample-SetSyncPoint(FALSE);}if

(hrB

pOutSample-SetDiscontinuity(TRUE);//设置中断标志}elsehr

pOutSample-SetDiscontinuity(FALSE);}hr

pCFilter-pCPin1-Deliver(pOutSample);//输出引脚向下游发送样本pOutSample-Release();//释放输出引脚样本}pBuffer-Unlock();

pCFilter-pVideoStream-RequestSample(NULL);//请求下一个样本}break;case

pCFilter-pCPin1-DeliverEndOfStream();break;case

MEStreamStopped://如果是“流停止”事件PropVariantClear(var);SafeRelease(pStreamEvent);return

1;//终止视频工作线程}PropVariantClear(var);}SafeRelease(pStreamEvent);}goto

Agan;

pCFilter-pCPin2-DeliverBeginFlush();Sleep(100);hr

pCFilter-pCPin2-DeliverEndFlush();hr

pCFilter-pCPin2-DeliverNewSegment(0,

pCFilter-DUR

pCFilter-pAudioStream-GetEvent(0,

(hr1

pStreamEvent-GetType(meType);//获取事件类型if

(hr2

pStreamEvent-GetValue(var);//获取事件值switch

(meType){case

var.punkVal-QueryInterface(pIMFSample);//获取样本接口if

(hr

pIMFSample-GetUINT32(MFSampleExtension_CleanPoint,

Discontinuity;hrB

pIMFSample-GetUINT32(MFSampleExtension_Discontinuity,

Discontinuity);//是否包含中断标志LONGLONG

star,

pIMFSample-GetSampleTime(star);pCFilter-CUR

star;//音频当前位置hr

pIMFSample-GetSampleDuration(dur);DWORD

Count;hr

pIMFSample-GetBufferCount(Count);IMFMediaBuffer*

pBuffer

pIMFSample-ConvertToContiguousBuffer(pBuffer);//将具有多个缓冲区的样本转换为具有单个缓冲区的样本BYTE*

pData

pIMFSample-GetTotalLength(len);IMediaSample

*pOutSample

pCFilter-pCPin2-GetDeliveryBuffer(pOutSample,

NULL,

pOutSample-GetPointer(pOutBuffer);//获取输出引脚样本缓冲区指针if

(pOutBuffer

pOutSample-SetActualDataLength(len);//设置输出引脚样本有效数据长度if

(hrA

pOutSample-SetSyncPoint(TRUE);//设置同步点标志elsehr

pOutSample-SetSyncPoint(FALSE);}if

(hrB

pOutSample-SetDiscontinuity(TRUE);//设置中断标志}elsehr

pOutSample-SetDiscontinuity(FALSE);}hr

pCFilter-pCPin2-Deliver(pOutSample);//输出引脚向下游发送样本pOutSample-Release();//释放输出引脚样本}pBuffer-Unlock();

pCFilter-pAudioStream-RequestSample(NULL);//请求下一个样本}break;case

pCFilter-pCPin2-DeliverEndOfStream();break;case

MEStreamStopped://如果是“流停止”事件PropVariantClear(var);SafeRelease(pStreamEvent);return

1;//终止音频工作线程}PropVariantClear(var);}SafeRelease(pStreamEvent);}goto

Agan;

CPin1::NonDelegatingQueryInterface(REFIID

riid,

CBasePin::NonDelegatingQueryInterface(riid,

ppv);}elsereturn

CBasePin::NonDelegatingQueryInterface(riid,

ppv);

NULL;pCFilter-pVideoType-GetRepresentation(AM_MEDIA_TYPE_REPRESENTATION,

(void**)pMt);//将IMFMediaType表示的媒体类型转换为AM_MEDIA_TYPE结构形式CMediaType

MT(*pMt);if

(pmt-MatchesPartial(MT)){pCFilter-pVideoType-FreeRepresentation(AM_MEDIA_TYPE_REPRESENTATION,

pMt);//释放GetRepresentation分配的内存return

S_OK;}pCFilter-pVideoType-FreeRepresentation(AM_MEDIA_TYPE_REPRESENTATION,

pMt);//释放GetRepresentation分配的内存return

S_FALSE;

NULL;pCFilter-pVideoType-GetRepresentation(AM_MEDIA_TYPE_REPRESENTATION,

(void**)pMt);//将IMFMediaType表示的媒体类型转换为AM_MEDIA_TYPE结构形式pmt-Set(*pMt);pCFilter-pVideoType-FreeRepresentation(AM_MEDIA_TYPE_REPRESENTATION,

pMt);//释放GetRepresentation分配的内存HasSet

TRUE;return

FALSE)//如果GetMediaType函数没有调用{GetMediaType(0,

S_OK;}return

CPin1::DecideBufferSize(IMemAllocator

*pMemAllocator,

ppropInputRequest)//确定输出引脚样本缓冲区大小

{HRESULT

S_OK;ppropInputRequest-cBuffers

1;//1个缓冲区ppropInputRequest-cbBuffer

10000000;//缓冲区的大小10MALLOCATOR_PROPERTIES

Actual;hr

pMemAllocator-SetProperties(ppropInputRequest,

Actual);if

CPin2::NonDelegatingQueryInterface(REFIID

riid,

GetInterface(static_castIMediaSeeking*(this),

ppv);}elsereturn

CBaseOutputPin::NonDelegatingQueryInterface(riid,

ppv);

NULL;pCFilter-pAudioType-GetRepresentation(AM_MEDIA_TYPE_REPRESENTATION,

(void**)pMt);//将IMFMediaType表示的媒体类型转换为AM_MEDIA_TYPE结构形式CMediaType

MT(*pMt);if

(pmt-MatchesPartial(MT)){pCFilter-pAudioType-FreeRepresentation(AM_MEDIA_TYPE_REPRESENTATION,

pMt);//释放GetRepresentation分配的内存return

S_OK;}pCFilter-pAudioType-FreeRepresentation(AM_MEDIA_TYPE_REPRESENTATION,

pMt);//释放GetRepresentation分配的内存return

S_FALSE;

NULL;pCFilter-pAudioType-GetRepresentation(AM_MEDIA_TYPE_REPRESENTATION,

(void**)pMt);//将IMFMediaType表示的媒体类型转换为AM_MEDIA_TYPE结构形式pmt-Set(*pMt);pCFilter-pAudioType-FreeRepresentation(AM_MEDIA_TYPE_REPRESENTATION,

pMt);//释放GetRepresentation分配的内存HasSet

TRUE;return

FALSE)//如果GetMediaType函数没有调用{GetMediaType(0,

S_OK;}return

CPin2::DecideBufferSize(IMemAllocator

*pMemAllocator,

ppropInputRequest)//确定输出引脚样本缓冲区大小

{HRESULT

S_OK;ppropInputRequest-cBuffers

1;//1个缓冲区ppropInputRequest-cbBuffer

1000000;//缓冲区的大小1MALLOCATOR_PROPERTIES

Actual;hr

pMemAllocator-SetProperties(ppropInputRequest,

Actual);if

*pCapabilities)//查询流是否具有指定的Seek功能

E_POINTER);return

CPin2::ConvertTimeFormat(LONGLONG

*pTarget,

*pSourceFormat)//从一种时间格式转换为另一种时间格式

E_POINTER);if

TIME_FORMAT_MEDIA_TIME){*pTarget

Source;return

CPin2::GetCurrentPosition(LONGLONG

{*pCurrent

CPin2::GetStopPosition(LONGLONG

{CheckPointer(pStop,

*pFormat)//确定Seek操作当前是否使用指定的时间格式

E_POINTER);return

CPin2::QueryPreferredFormat(GUID

E_POINTER);*pFormat

AM_SEEKING_PositioningBitsMask;if

(dwCurrentPos

pCFilter-pIMFMediaSource-Pause();//暂停媒体源hr

pCFilter-pCPin1-DeliverBeginFlush();hr

pCFilter-pCPin2-DeliverBeginFlush();Sleep(200);//确保下游解码器丢弃所有样本如果下游解码器残留有样本渲染器会等待其渲染时间时间戳视频将卡在这里hr

pCFilter-pCPin1-DeliverEndFlush();hr

pCFilter-pCPin2-DeliverEndFlush();hr

pCFilter-pCPin1-DeliverNewSegment(0,

pCFilter-DUR

pCFilter-pCPin2-DeliverNewSegment(0,

pCFilter-DUR

var;PropVariantInit(var);var.vt

pCFilter-mStart;hr

pCFilter-pIMFMediaSource-Start(pCFilter-pISourceD,

NULL,

var);//启动媒体源PropVariantClear(var);return

S_OK;}}return