📄 mediaplayback.cpp
字号:
/**************************************************************************************
* *
* *
**************************************************************************************/
#include "MediaPlayback.h"
#include "DebugFile.h"
DebugFile *debug;
/*
* 音频回调
*
*/
unsigned int PlaybackAudioCallback(void *lpData, void *buffer, unsigned int size);
/*
* 回放类
* --------------
*
* ——为所有媒体类中的项和过滤器提供一个前端处理
*
*/
MediaPlayback::MediaPlayback()
{
this->input = new MediaInput();
this->decaps = new MediaDecaps();
this->videoDecoder = new MediaVideoDecoder();
this->videoBuffer = new MediaVideoBuffer();
this->videoRenderer = new MediaVideoRenderer();
this->audioDecoder = new MediaAudioDecoder();
this->audioRenderer = new MediaAudioRenderer();
this->subtitler = new MediaSubtitler();
this->hasVideo = FALSE;
this->hasAudio = FALSE;
this->hasSubtitles = FALSE;
this->fullscreen = FALSE;
this->fastForward = FALSE;
this->rewind = FALSE;
this->playing = FALSE;
this->paused = FALSE;
this->buffering = FALSE;
this->bufferingProgress = 0;
this->volume = 100;
this->playbackMutex = CreateMutex (NULL, FALSE, NULL);
}
MediaPlayback::~MediaPlayback()
{
delete this->input;
delete this->decaps;
delete this->videoDecoder;
delete this->videoRenderer;
delete this->videoBuffer;
delete this->subtitler;
CloseHandle(this->playbackMutex);
}
MP_RESULT MediaPlayback::OpenMediaSource(char *lpFilename)
{
this->hasVideo = FALSE;
this->fastForward = FALSE;
this->rewind = FALSE;
this->playing = FALSE;
this->paused = FALSE;
this->hasVideo = FALSE;
this->hasAudio = FALSE;
this->hasSubtitles = FALSE;
this->buffering = FALSE;
this->hasToBuffer = FALSE;
this->bufferingProgress = 0;
if(lpFilename) {
if(this->input->Open(lpFilename, INPUT_OPEN_BINARY) == MP_RESULT_OK) {
if(this->input->GetCaps() & MEDIA_CAPS_BUFFERIZE) {
this->buffering = TRUE;
this->bufferingProgress = 0;
}
strcpy(this->filename, lpFilename);
this->filename[strlen(lpFilename)] = '\0';
return MP_RESULT_OK;
}
}
return MP_RESULT_ERROR;
}
MP_RESULT MediaPlayback::OpenMediaFromSource(HWND hwndPlayback)
{
if(this->input && hwndPlayback) {
if(this->input->GetCaps() & MEDIA_CAPS_BUFFERIZE) {
this->buffering = 0;
}
if(this->decaps->Connect(this->input) == MP_RESULT_OK) {
/*
* 视频流
*/
if(this->decaps->GetNumberOfVideoStreams() > 0) {
if(this->videoDecoder->Connect(decaps) == MP_RESULT_OK) {
/*
* 我们有一个有效的解码器，因此现在我们
*尝试建立一个视频补偿器并得到相同的视频模式
*
*/
media_video_mode_t codecMode, rendererMode;
codecMode = this->videoDecoder->GetVideoMode();
if(this->fullscreen) {
if(this->videoRenderer->InitFullscreen(hwndPlayback,
this->decaps->GetVideoWidth(0),
this->decaps->GetVideoHeight(0),
codecMode) == MP_RESULT_OK) {
rendererMode = this->videoRenderer->GetVideoMode();
if(this->videoDecoder->SetVideoMode(rendererMode) == MP_RESULT_OK) {
if(this->videoBuffer->Connect(this->videoDecoder) == MP_RESULT_OK) {
this->hasVideo = TRUE;
this->hwndPlayback = hwndPlayback;
this->end = FALSE;
this->videoRect = NULL;
}
}
}
}
else {
if(this->videoRenderer->Init(hwndPlayback,
this->decaps->GetVideoWidth(0),
this->decaps->GetVideoHeight(0),
codecMode) == MP_RESULT_OK) {
rendererMode = this->videoRenderer->GetVideoMode();
if(this->videoDecoder->SetVideoMode(rendererMode) == MP_RESULT_OK) {
if(this->videoBuffer->Connect(this->videoDecoder) == MP_RESULT_OK) {
this->hasVideo = TRUE;
this->hwndPlayback = hwndPlayback;
this->end = FALSE;
this->videoRect = NULL;
}
}
}
}
}
}
/*
* 音频流
*/
if(this->decaps->GetNumberOfAudioStreams() > 0) {
if(this->audioDecoder->Connect(this->decaps) == MP_RESULT_OK) {
/*
* 我们有一个有效的音频解码器，因此现在我们
* 在给定模式下尝试建立缺省的音频补偿器
*
*/
if(this->audioRenderer->Open(hwndPlayback, this->audioDecoder->GetAudioFormat()) == MP_RESULT_OK) {
/*
* 建立回调
*/
this->audioRenderer->SetVolume(this->volume);
this->audioRenderer->SetCallback((LPVOID) this, PlaybackAudioCallback);
this->hasAudio = TRUE;
}
}
}
/*
* 字幕流
*/
if(this->HasVideo() && !(this->input->GetCaps() & MEDIA_CAPS_BUFFERIZE)) {
char *subFilename;
subFilename = (char *) new char[strlen(this->filename)];
strncpy(subFilename, this->filename, strlen(this->filename) - 4);
subFilename[strlen(this->filename) - 4] = '\0';
strcat(subFilename, ".sub");
if(this->subtitler->Open(subFilename) == MP_RESULT_OK) {
if(this->videoRenderer->Connect(this->subtitler) == MP_RESULT_OK) {
this->hasSubtitles = TRUE;
}
}
}
if(this->hasVideo) {
return MP_RESULT_OK;
}
}
}
return MP_RESULT_ERROR;
}
MP_RESULT MediaPlayback::OpenMedia(char *lpFilename, HWND hwndPlayback)
{
if(lpFilename && hwndPlayback) {
if(this->OpenMediaSource(lpFilename) == MP_RESULT_OK) {
if(this->OpenMediaFromSource(hwndPlayback) == MP_RESULT_OK) {
return MP_RESULT_OK;
}
}
}
this->Close();
return MP_RESULT_ERROR;
}
BOOL MediaPlayback::HasVideo()
{
return this->hasVideo;
}
BOOL MediaPlayback::HasAudio()
{
return this->hasAudio;
}
char *MediaPlayback::GetFilename()
{
if(this->HasAudio() || this->HasVideo()) {
return this->filename;
}
return NULL;
}
unsigned int MediaPlayback::GetVideoWidth()
{
if(this->decaps)
return this->decaps->GetVideoWidth(0);
return 0;
}
unsigned int MediaPlayback::GetVideoHeight()
{
if(this->decaps)
return this->decaps->GetVideoHeight(0);
return 0;
}
unsigned long MediaPlayback::GetVideoTime()
{
if(this->decaps) {
return (unsigned long) ((double) this->videoFrames * 1000.0 / (double) this->decaps->GetVideoFrameRate(0));
}
return 0;
}
unsigned long MediaPlayback::GetAudioTime()
{
return this->audioRenderer->GetAudioTime();
}
double MediaPlayback::GetPlaybackProgress()
{
if(this->HasAudio() || this->HasVideo()) {
return (double) ((double) this->decaps->GetCurrentVideoFrame(0) * 100 / (double) this->decaps->GetTotalVideoFrames(0));
}
return 0;
}
unsigned int MediaPlayback::GetActualTime()
{
if(this->HasVideo()) {
return this->decaps->GetCurrentVideoFrame(0) / this->decaps->GetVideoFrameRate(0);
}
return 0;
}
BOOL MediaPlayback::IsBuffering()
{
return this->buffering;
}
DWORD MediaPlayback::GetBufferingProgress()
{
return this->bufferingProgress;
}
MP_RESULT MediaPlayback::UpdateBuffering()
{
DWORD size;
size = this->input->GetBufferSize();
this->bufferingProgress = size * 100 / this->input->GetBufferingSize();
return MP_RESULT_OK;
}
unsigned int MediaPlayback::GetTotalTime()
{
if(this->HasVideo()) {
return (unsigned int) ( (double) this->decaps->GetTotalVideoFrames(0)/ (double) this->decaps->GetVideoFrameRate(0));
}
return 0;
}
double MediaPlayback::GetCurrentFps()
{
return 0;
}
BOOL MediaPlayback::IsPaused()
{
return (this->paused || this->buffering);
}
BOOL MediaPlayback::IsPlaying()
{
return this->playing;
}
BOOL MediaPlayback::IsInFullscreen()
{
return this->fullscreen;
}
BOOL MediaPlayback::IsOverlay()
{
if(this->videoRenderer) {
return (strstr(this->videoRenderer->GetName(), "Overlay") != NULL);
}
return FALSE;
}
/**************************************************************
* *
* 音频回调方法 *
* ----------------------- *
* *
**************************************************************/
unsigned int PlaybackAudioCallback(void *lpData, void *buffer, unsigned int size)
{
int real_size;
MediaPlayback *playback = (MediaPlayback *) lpData;
if(playback && playback->playing && !playback->paused) {
playback->audioBytes += size;
if(playback->audioDecoder) {
if((real_size = playback->audioDecoder->Decompress(buffer, size)) != size) {
if(playback->input->GetCaps() & MEDIA_CAPS_BUFFERIZE) {
if(!(playback->input->GetBufferSize() >= playback->input->GetSize())) {
playback->hasToBuffer = TRUE;
return real_size;
}
else {
if(!playback->end) {
playback->end = TRUE;
playback->Pause();
playback->decaps->UpdateForSize();
playback->Pause();
return real_size;
}
else {
memset(buffer, 0, size);
return size;
}
}
}
else {
memset(buffer, 0, size);
return size;
}
}
return size;
}
}
else {
memset(buffer, 0, size);
return size;
}
return 0;
}
/**************************************************************
* *
* 视频线程方法 *
* ----------------------- *
* *
**************************************************************/
/*
* 仅有视频的线程
*
*/
DWORD WINAPI PlaybackVideoOnlyThreadFunc( LPVOID lpData)
{
MediaPlayback *playback = (MediaPlayback *) lpData;
int timeDiff;
MediaBuffer *frame = NULL;
if(playback != NULL) {
playback->baseTime = GetTickCount();
while(playback->playing) {
/*
* 检查是否正在缓冲
*
*/
if(playback->input->GetCaps() & MEDIA_CAPS_BUFFERIZE) {
if((playback->input->GetBufferPosition() > 0.95*playback->input->GetBufferSize()) &&
!(playback->input->GetBufferSize() >= playback->input->GetSize())) {
startBuffering:
DWORD size = playback->input->GetBufferSize();
DWORD sizeI = playback->input->GetBufferSize();
/*
* 等待更多缓冲
*/
playback->bufferingProgress = 0;
playback->buffering = TRUE;
while(size < sizeI + playback->input->GetBufferingSize() && !(playback->input->GetBufferSize() >= playback->input->GetSize())) {
Sleep(10);
size = playback->input->GetBufferSize();
playback->bufferingProgress = (size - sizeI) * 100 / playback->input->GetBufferingSize();
}
playback->buffering = FALSE;
playback->decaps->UpdateForSize();
playback->baseTime = GetTickCount();
playback->videoFrames = 0;
RECT rect;
GetClientRect(playback->hwndPlayback, &rect);
InvalidateRect(playback->hwndPlayback, &rect, TRUE);
UpdateWindow(playback->hwndPlayback);
}
}
startPlaying:
frame = NULL;
if(!playback->paused) {
if(playback->fastForward) {
playback->decaps->SeekNextKeyFrame(0);
}
else {
if(playback->rewind) {
playback->decaps->SeekPreviousKeyFrame(0);
}
}
/*
* 合成
*
*/
if(!playback->fastForward && !playback->rewind) {
timeDiff = playback->GetVideoTime() - (GetTickCount() - playback->baseTime);
if(timeDiff > 10) {
Sleep(timeDiff/2);
}
if(timeDiff < -150) {
/*
* 跳过，即不进行补偿
*/
playback->videoBuffer->DropOneFrame();
playback->videoFrames++;
}
if(timeDiff < -230) {
/*
* 跳过，即不进行补偿
*/
playback->videoBuffer->DropOneFrame();
playback->videoFrames++;
}
}
else {
Sleep(80);
}
frame = playback->videoBuffer->GetOneFrame();
playback->videoFrames++;
if(frame == NULL) {
if(playback->input->GetCaps() & MEDIA_CAPS_BUFFERIZE) {
if(playback->input->GetBufferSize() < playback->input->GetSize()) {
goto startBuffering;
}
}
if(!playback->loop) {
SendMessage(playback->hwndPlayback, WM_PLAYA_PLAYBACK_END, 0, 0);
playback->Stop(TRUE);
}
else {
playback->decaps->Rewind(0, 0);
playback->videoBuffer->StopBuffering();
playback->videoBuffer->StartBuffering(playback->decaps->GetVideoWidth(0));
playback->videoFrames = 0;
playback->baseTime = GetTickCount();
goto startPlaying;
}
break;
}
WaitForSingleObject(playback->playbackMutex, INFINITE);
if(!playback->paused) {
if(playback->fullscreen) {
playback->videoRenderer->DrawFullscreen(frame, playback->decaps->GetCurrentVideoFrame(0),
playback->videoDecoder->GetInvertFlag(), playback->desktopMode);
}
else {
playback->videoRenderer->Draw(frame, playback->videoRect, playback->decaps->GetCurrentVideoFrame(0),
playback->videoDecoder->GetInvertFlag());
}
}
ReleaseMutex(playback->playbackMutex);
}
}
}
else {
MessageBox(playback->hwndPlayback, "Playing : NULL playback engine!", "", MB_OK);
}
return 0;
}
/*
* 视频与音频线程（即主线程）同步
*/
DWORD WINAPI PlaybackVideoAndAudioThreadFunc( LPVOID lpData)
{
MediaPlayback *playback = (MediaPlayback *) lpData;
long timeDiff;
MediaBuffer *frame = NULL;
if(playback != NULL)
{
while(playback->playing) {
if(playback->input->GetCaps() & MEDIA_CAPS_BUFFERIZE) {
if(((playback->input->GetBufferPosition() > 0.95*playback->input->GetBufferSize()) &&
!(playback->input->GetBufferSize() >= playback->input->GetSize())) || playback->hasToBuffer) {
startBufferingWAudio:
if(!playback->audioRenderer->paused)
playback->audioRenderer->Pause();
if(playback->input->GetBufferSize() >= playback->input->GetSize()) {
playback->decaps->UpdateForSize();
if(playback->audioRenderer->paused)
playback->audioRenderer->Pause();
goto startPlayingWAudio;
}
DWORD size = playback->input->GetBufferSize();
DWORD sizeI = playback->input->GetBufferSize();
/*
* 等待更多缓冲
*/
playback->bufferingProgress = 0;
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -