开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 电子书籍 > VC书籍 > 查看源码
CPI_Player_Engine.c
资源名称：VC++视频传输.rar　[点击查看]
上传用户：hxb_1234
上传日期：2010-03-30
资源大小：8328k
文件大小：21k
源码类别：

VC书籍

开发平台：

Visual C++

CPI_Player_Engine.c：源码内容
  1. #include "stdafx.h"
  2. #include "globals.h"
  3. #include "CPI_Player.h"
  4. #include "CPI_Player_Messages.h"
  5. #include "CPI_Player_CoDec.h"
  6. #include "CPI_Player_Output.h"
  7. #include "CPI_Equaliser.h"
  9. typedef struct __CPs_PlayerContext
  10. {
  11.     CPs_PlayEngine* m_pBaseEngineParams;
  12.     CPs_CoDecModule m_CoDecs[CP_CODEC_last+1];
  13.     CPs_OutputModule m_OutputModules[CP_OUTPUT_last+1];
  15.     CPs_OutputModule* m_pCurrentOutputModule;
  16.     BOOL m_bOutputActive;
  17.     DWORD m_dwCurrentOutputModule;
  18.     int m_iInternalVolume;
  20.     int m_iLastSentTime_Secs;
  21.     int m_iLastSentTime_Proportion;
  22.     int m_iProportion_TrackLength;
  24.     int m_iOpenDevice_Freq_Hz;
  25.     BOOL m_bOpenDevice_Stereo;
  26.     BOOL m_bOpenDevice_16bit;
  28.     CPs_EqualiserModule m_Equaliser;
  30. } CPs_PlayerContext;
  32. void UpdateProgress(CPs_PlayerContext* pContext);
  33. void EmptyOutputStream(CPs_PlayerContext* pContext);
  34. void StartPlay(CPs_CoDecModule* pCoDec, CPs_PlayerContext* pContext);
  35. void EnumOutputDevices(CPs_PlayerContext* pContext);
  36. CPs_CoDecModule* OpenCoDec(CPs_PlayerContext* pContext, const char* pcFilename);
  37. void CleanupCoDecs(CPs_PlayerContext* pContext);
  38. void SetCurrentOutputModule(CPs_PlayerContext* pContext, CPs_OutputModule* pNewOuputModule, BOOL* pbForceRefill);
  39. void AssociateFileExtensions(CPs_PlayerContext* pContext);
  40. ////////////////////////////////////////////////////////////////////////////////
  41. DWORD WINAPI CPI_Player__EngineEP(void* pCookie)
  42. {
  43.     BOOL bTerminateThread = FALSE;
  44.     HRESULT hr_ComState;
  45.     CPs_PlayerContext playercontext;
  47.     playercontext.m_pBaseEngineParams = (CPs_PlayEngine*)pCookie;
  48.     playercontext.m_bOutputActive = FALSE;
  49.     playercontext.m_iProportion_TrackLength = 0;
  50.     playercontext.m_iLastSentTime_Secs = -1;
  51.     playercontext.m_iLastSentTime_Proportion = -1;
  52.     playercontext.m_iInternalVolume = 100;
  53.     CP_CHECKOBJECT(playercontext.m_pBaseEngineParams);
  55.     CP_TRACE0("Cooler Engine Startup");
  56.     hr_ComState = CoInitialize(NULL);
  58.     // 为该线程初始化 USER32.DLL 
  59.     {
  60.         MSG msgDummy;
  61.         PeekMessage(&msgDummy, 0, WM_USER, WM_USER, PM_NOREMOVE);
  63.         // 用信号通知此线程已经准备好输入
  64.         SetEvent(playercontext.m_pBaseEngineParams->m_hEvtThreadReady);
  65.     }
  67.     // 初始化 CoDecs
  68.     CP_InitialiseCodec_MPEG(&playercontext.m_CoDecs[CP_CODEC_MPEG]);
  69.     CP_InitialiseCodec_WAV(&playercontext.m_CoDecs[CP_CODEC_WAV]);
  70.  //   CP_InitialiseCodec_OGG(&playercontext.m_CoDecs[CP_CODEC_OGG]);
  71. //    CP_InitialiseCodec_WinAmpPlugin(&playercontext.m_CoDecs[CP_CODEC_WINAMPPLUGIN]);
  73.     // 初始化输出模式
  74.     if(options.decoder_output_mode > CP_OUTPUT_last)
  75.         options.decoder_output_mode = CP_OUTPUT_last;
  76.     playercontext.m_dwCurrentOutputModule = options.decoder_output_mode;
  77.     CPI_Player_Output_Initialise_WaveMapper(&playercontext.m_OutputModules[CP_OUTPUT_WAVE]);
  78.     CPI_Player_Output_Initialise_DirectSound(&playercontext.m_OutputModules[CP_OUTPUT_DIRECTSOUND]);
  79.     CPI_Player_Output_Initialise_File(&playercontext.m_OutputModules[CP_OUTPUT_FILE]);
  80.     playercontext.m_pCurrentOutputModule = &playercontext.m_OutputModules[playercontext.m_dwCurrentOutputModule];
  83.     // 初始化 EQ
  84.     CPI_Player_Equaliser_Initialise_Basic(&playercontext.m_Equaliser);
  86.     do
  87.     {
  88.         // 处理任何未决的消息
  89.         BOOL bForceRefill = FALSE;
  90.         MSG msg;
  91.         DWORD dwWaitResult;
  92.         while(PeekMessage(&msg, NULL, 0, 0, PM_REMOVE))
  93.         {
  94.             // 解码引擎消息
  95.             switch(msg.message)
  96.             {
  97.             case CPTM_QUIT:
  98.                 bTerminateThread = TRUE;
  99.                 break;
  101.             case CPTM_OPENFILE:
  102.                 {
  103.                     char* pcFilename = (char*)msg.wParam;
  105.                     // 如果这里有另一个不定的打开文件，那么忽略此文件。
  106.                     // 当进程没有响应(on an http connect for example)，
  107.                     // 而且用户还在不停的点击播放按钮时，这将非常有用。
  108. //- (这将导致大量的打开/关闭消息被放置倒队列中，而这些消息将占用线程几年的时间）
  109.                     MSG msg2;
  110.                     if(PeekMessage(&msg2, NULL, CPTM_OPENFILE, CPTM_OPENFILE, PM_NOREMOVE) == FALSE)
  111.                     {
  112.                         CPs_CoDecModule* pNewCoDec;
  114.                         // 如果此处有CoDec播放，那么关闭之
  115.                         if(playercontext.m_pCurrentOutputModule->m_pCoDec)
  116.                         {
  117.                             playercontext.m_pCurrentOutputModule->m_pCoDec->CloseFile(playercontext.m_pCurrentOutputModule->m_pCoDec);
  118.                             playercontext.m_pCurrentOutputModule->m_pCoDec = NULL;
  119.                         }
  121.                         CP_TRACE1("Openfile "%s"", pcFilename);
  122.                         pNewCoDec = OpenCoDec(&playercontext, pcFilename);
  124.                         // 如果打开失败，那么从接口申请一个新的流
  125.                         if(pNewCoDec == NULL)
  126.                         {
  127.                             PostMessage(playercontext.m_pBaseEngineParams->m_hWndNotify, CPNM_PLAYERSTATE, (WPARAM)cppsEndOfStream, 0);
  128.                         }
  129.                         // 检查文件格式 - 取样率，声道数或者取样大小是否改变
  130.                         // 然后，清除当前的输出，关闭输出装备 (着将导致一个 gap
  131.                         // - 但仅当格式改变时)
  132.                         else if(playercontext.m_bOutputActive == TRUE)
  133.                         {
  134.                             CPs_FileInfo FileInfo;
  135.                             pNewCoDec->GetFileInfo(pNewCoDec, &FileInfo);
  136.                             if(//FileInfo.m_iFreq_Hz != playercontext.m_iOpenDevice_Freq_Hz
  137.                                     FileInfo.m_bStereo != playercontext.m_bOpenDevice_Stereo
  138.                                     || FileInfo.m_b16bit != playercontext.m_bOpenDevice_16bit
  139. )
  140.                             {
  141.                                 CP_TRACE0("Stream format changes - clearing stream");
  142.                                 EmptyOutputStream(&playercontext);
  143.                                 StartPlay(pNewCoDec, &playercontext);
  144.                                 bForceRefill = TRUE;
  145.                             }
  146.                         }
  148.                         playercontext.m_pCurrentOutputModule->m_pCoDec = pNewCoDec;
  149.                     }
  150. #ifdef _DEBUG
  151.                     else
  152.                     {
  153.                         CP_TRACE1("Openfile of "%s" ignored due to other opens in the queue", pcFilename);
  154.                     }
  155. #endif
  157.                     // 清空
  158.                     free(pcFilename);
  159.                 }
  160.                 break;
  162.             case CPTM_SEEK:
  163.                 if(playercontext.m_bOutputActive == TRUE)
  164.                 {
  165.                     // 如果有另一个消息在此位置，忽略其他的!
  166.                     MSG msg2;
  167.                     if(PeekMessage(&msg2, NULL, CPTM_SEEK, CPTM_SEEK, PM_NOREMOVE) == FALSE)
  168.                     {
  169.                         if(playercontext.m_pCurrentOutputModule->m_pCoDec)
  170.                             playercontext.m_pCurrentOutputModule->m_pCoDec->Seek(playercontext.m_pCurrentOutputModule->m_pCoDec, (int)msg.wParam, (int)msg.lParam);
  171.                         playercontext.m_pCurrentOutputModule->Flush(playercontext.m_pCurrentOutputModule);
  172.                         bForceRefill = TRUE;
  173.                     }
  174.                 }
  175.                 break;
  177.             case CPTM_PLAY:
  178.                 if(playercontext.m_pCurrentOutputModule->m_pCoDec)
  179.                 {
  180.                     // 如果没有输出stage - 马上初始化
  181.                     if(playercontext.m_bOutputActive == FALSE)
  182.                     {
  183.                         StartPlay(playercontext.m_pCurrentOutputModule->m_pCoDec, &playercontext);
  184.                         bForceRefill = TRUE;
  185.                     }
  186.                     playercontext.m_pCurrentOutputModule->SetPause(playercontext.m_pCurrentOutputModule, FALSE);
  187.                     PostMessage(playercontext.m_pBaseEngineParams->m_hWndNotify, CPNM_PLAYERSTATE, (WPARAM)cppsPlaying, 0);
  188.                     playercontext.m_iLastSentTime_Secs = -1;
  189.                     playercontext.m_iLastSentTime_Proportion = -1;
  190.                     UpdateProgress(&playercontext);
  191.                 }
  192.                 break;
  194.             case CPTM_STOP:
  195.                 if(playercontext.m_pCurrentOutputModule->m_pCoDec)
  196.                 {
  197.                     playercontext.m_pCurrentOutputModule->m_pCoDec->CloseFile(playercontext.m_pCurrentOutputModule->m_pCoDec);
  198.                     playercontext.m_pCurrentOutputModule->m_pCoDec = NULL;
  199.                 }
  200.                 if(playercontext.m_bOutputActive == TRUE)
  201.                 {
  202.                     playercontext.m_bOutputActive = FALSE;
  203.                     playercontext.m_pCurrentOutputModule->Uninitialise(playercontext.m_pCurrentOutputModule);
  204.                 }
  205.                 PostMessage(playercontext.m_pBaseEngineParams->m_hWndNotify, CPNM_PLAYERSTATE, (WPARAM)cppsStopped, 0);
  206.                 break;
  208.             case CPTM_PAUSE:
  209.                 CP_TRACE0("Pause");
  210.                 if(playercontext.m_bOutputActive == TRUE)
  211.                     playercontext.m_pCurrentOutputModule->SetPause(playercontext.m_pCurrentOutputModule, TRUE);
  212.                 PostMessage(playercontext.m_pBaseEngineParams->m_hWndNotify, CPNM_PLAYERSTATE, (WPARAM)cppsPaused, 0);
  213.                 break;
  215.             case CPTM_SETPROGRESSTRACKLENGTH:
  216.                 playercontext.m_iProportion_TrackLength = (int)msg.wParam;
  217.                 break;
  219.             case CPTM_SENDSYNCCOOKIE:
  220.                 PostMessage(playercontext.m_pBaseEngineParams->m_hWndNotify, CPNM_SYNCCOOKIE, msg.wParam, 0);
  221.                 break;
  223.             case CPTM_BLOCKMSGUNTILENDOFSTREAM:
  224.                 EmptyOutputStream(&playercontext);
  225.                 break;
  227.             case CPTM_ENUMOUTPUTDEVICES:
  228.                 EnumOutputDevices(&playercontext);
  229.                 break;
  231.             case CPTM_SETEQSETTINGS:
  232.                 {
  233.                     MSG msg2;
  234.                     CPs_EQSettings* pEQ = (CPs_EQSettings*)msg.wParam;
  236.                     // 如果有另一个未决的EQ 消息，不要处理这个(试图减少噪音)
  237.                     if(PeekMessage(&msg2, NULL, CPTM_SETEQSETTINGS, CPTM_OPENFILE, PM_NOREMOVE) == FALSE)
  238.                     {
  239.                         BOOL bEQEnableStateChanged;
  240.                         playercontext.m_Equaliser.ApplySettings(&playercontext.m_Equaliser, pEQ, &bEQEnableStateChanged);
  242.                         // 清空缓存(这将音乐的不连续，但至少
  243. //  EQ 设置会立即改变
  244.                         if(playercontext.m_bOutputActive == TRUE && playercontext.m_pCurrentOutputModule->OnEQChanged)
  245.                             playercontext.m_pCurrentOutputModule->OnEQChanged(playercontext.m_pCurrentOutputModule);
  246.                     }
  247.                     free(pEQ);
  248.                 }
  249.                 break;
  251.             case CPTM_ONOUTPUTMODULECHANGE:
  252.                 {
  253.                     playercontext.m_dwCurrentOutputModule = options.decoder_output_mode;
  254.                     SetCurrentOutputModule(&playercontext, NULL, &bForceRefill);
  255.                 }
  256.                 break;
  258.             case CPTM_ASSOCIATEFILEEXTENSIONS:
  259.                 AssociateFileExtensions(&playercontext);
  260.                 break;
  262.             case CPTM_SETINTERNALVOLUME:
  263.                 playercontext.m_iInternalVolume = (int)msg.wParam;
  264.                 if(playercontext.m_bOutputActive == TRUE && playercontext.m_pCurrentOutputModule->SetInternalVolume)
  265.                     playercontext.m_pCurrentOutputModule->SetInternalVolume(playercontext.m_pCurrentOutputModule, playercontext.m_iInternalVolume);
  266.                 break;
  267.             }
  268.         }
  269.         if(bTerminateThread)
  270.             break;
  272.         // 等待下一个消息或者缓冲区满 (假如有播放器)
  273.         if(playercontext.m_bOutputActive)
  274.         {
  275.             dwWaitResult = 0L;
  276.             if(bForceRefill == FALSE)
  277.             {
  278.                 if(playercontext.m_pCurrentOutputModule->m_evtBlockFree)
  279.                     dwWaitResult = MsgWaitForMultipleObjects(1, &playercontext.m_pCurrentOutputModule->m_evtBlockFree, FALSE, 1000, QS_POSTMESSAGE);
  280.                 else
  281.                     dwWaitResult = WAIT_OBJECT_0;
  282.             }
  284.             // 如果缓冲区消息被发送，那么请求重新填充
  285.             if(bForceRefill == TRUE || dwWaitResult == WAIT_OBJECT_0)
  286.             {
  287.                 if(playercontext.m_pCurrentOutputModule->m_pCoDec)
  288.                 {
  289.                     playercontext.m_pCurrentOutputModule->RefillBuffers(playercontext.m_pCurrentOutputModule);
  290.                     if(playercontext.m_pCurrentOutputModule->m_pCoDec == NULL)
  291.                     {
  292.                         // 通知 UI 需要另一个播放文件
  293.                         PostMessage(playercontext.m_pBaseEngineParams->m_hWndNotify, CPNM_PLAYERSTATE, (WPARAM)cppsEndOfStream, 0);
  294.                     }
  295.                     else
  296.                         UpdateProgress(&playercontext);
  297.                 }
  299.                 // 如果输出结束了应作的每件事，关闭引擎
  300.                 else if(playercontext.m_pCurrentOutputModule->IsOutputComplete(playercontext.m_pCurrentOutputModule) == TRUE)
  301.                 {
  302.                     playercontext.m_bOutputActive = FALSE;
  303.                     playercontext.m_pCurrentOutputModule->Uninitialise(playercontext.m_pCurrentOutputModule);
  304.                     PostMessage(playercontext.m_pBaseEngineParams->m_hWndNotify, CPNM_PLAYERSTATE, (WPARAM)cppsStopped, 0);
  305.                 }
  306.             }
  307.         }
  308.         else
  309.         {
  310.             WaitMessage();
  311.         }
  312.     }
  313.     while(bTerminateThread == FALSE);
  315.     // 清空输出(如果仍然是活跃的)
  316.     if(playercontext.m_pCurrentOutputModule->m_pCoDec)
  317.     {
  318.         playercontext.m_pCurrentOutputModule->m_pCoDec->CloseFile(playercontext.m_pCurrentOutputModule->m_pCoDec);
  319.         playercontext.m_pCurrentOutputModule->m_pCoDec = NULL;
  320.     }
  321.     if(playercontext.m_bOutputActive == TRUE)
  322.         playercontext.m_pCurrentOutputModule->Uninitialise(playercontext.m_pCurrentOutputModule);
  324.     // 清空模板
  325.     playercontext.m_Equaliser.Uninitialise(&playercontext.m_Equaliser);
  326.     CleanupCoDecs(&playercontext);
  328.     if(hr_ComState == S_OK)
  329.         CoUninitialize();
  330.     CP_TRACE0("Cooler Engine terminating");
  331.     return 0;
  332. }
  333. //
  334. //
  335. //
  336. void UpdateProgress(CPs_PlayerContext* pContext)
  337. {
  338.     int iCurrentTime_Secs;
  340.     // 如果文件偏移改变，重新发送通知
  341.     if(pContext->m_bOutputActive == TRUE)
  342.         iCurrentTime_Secs = pContext->m_pCurrentOutputModule->m_pCoDec->GetCurrentPos_secs(pContext->m_pCurrentOutputModule->m_pCoDec);
  343.     else
  344.         iCurrentTime_Secs = 0;
  345.     if(iCurrentTime_Secs != pContext->m_iLastSentTime_Secs)
  346.     {
  347.         CPs_FileInfo* pFileInfo;
  348.         int iFileLength_Secs;
  349.         pContext->m_iLastSentTime_Secs = iCurrentTime_Secs;
  351.         // （重）发文件信息
  352.         pFileInfo = (CPs_FileInfo*)malloc(sizeof(*pFileInfo));
  353.         pContext->m_pCurrentOutputModule->m_pCoDec->GetFileInfo(pContext->m_pCurrentOutputModule->m_pCoDec, pFileInfo);
  354.         iFileLength_Secs = pFileInfo->m_iFileLength_Secs;
  355.         PostMessage(pContext->m_pBaseEngineParams->m_hWndNotify, CPNM_FILEINFO, (WPARAM)pFileInfo, 0);
  357.         // 发送当前进程
  358.         PostMessage(pContext->m_pBaseEngineParams->m_hWndNotify, CPNM_FILEOFFSET_SECS, (WPARAM)iCurrentTime_Secs, 0);
  360.         // Send the proportion along the track (if it has changed)
  361.         if(pContext->m_iProportion_TrackLength != 0 && iFileLength_Secs != 0)
  362.         {
  363.             int iProportionAlongTrack = (int)( ( (float)iCurrentTime_Secs / (float)iFileLength_Secs)
  364.                                                * (float)pContext->m_iProportion_TrackLength );
  366.             if(iProportionAlongTrack != pContext->m_iLastSentTime_Proportion)
  367.             {
  368.                 pContext->m_iLastSentTime_Proportion = iProportionAlongTrack;
  369.                 PostMessage(pContext->m_pBaseEngineParams->m_hWndNotify, CPNM_FILEOFFSET_PROP, (WPARAM)iProportionAlongTrack, 0);
  370.             }
  371.         }
  372.     }
  373. }
  374. //
  375. //
  376. //
  377. void EmptyOutputStream(CPs_PlayerContext* pContext)
  378. {
  379.     if(pContext->m_bOutputActive == FALSE)
  380.         return;
  382.     while(pContext->m_pCurrentOutputModule->IsOutputComplete(pContext->m_pCurrentOutputModule) == FALSE)
  383.     {
  384.         WaitForSingleObject(pContext->m_pCurrentOutputModule->m_evtBlockFree, 1000);
  385.         if(pContext->m_pCurrentOutputModule->m_pCoDec)
  386.             UpdateProgress(pContext);
  387.     }
  389.     pContext->m_bOutputActive = FALSE;
  390.     pContext->m_pCurrentOutputModule->Uninitialise(pContext->m_pCurrentOutputModule);
  391.     PostMessage(pContext->m_pBaseEngineParams->m_hWndNotify, CPNM_PLAYERSTATE, (WPARAM)cppsStopped, 0);
  392. }
  393. //
  394. //
  395. //
  396. void EnumOutputDevices(CPs_PlayerContext* pContext)
  397. {
  398.     int iOutputModuleIDX;
  399.     // 列举输出模板
  400.     for(iOutputModuleIDX = 0; iOutputModuleIDX <= CP_OUTPUT_last; iOutputModuleIDX++)
  401.     {
  402.         const CPs_OutputModule* pOutputModule = pContext->m_OutputModules + iOutputModuleIDX;
  403.         char* pcDeviceName;
  405.         // 缓冲释放
  406.         STR_AllocSetString(&pcDeviceName, pOutputModule->m_pcModuleName, FALSE);
  407.         PostMessage(pContext->m_pBaseEngineParams->m_hWndNotify, CPNM_FOUNDOUTPUTDEVICE, (WPARAM)pcDeviceName, (LPARAM)iOutputModuleIDX);
  408.     }
  409. }
  410. //
  411. //
  412. //
  413. void StartPlay(CPs_CoDecModule* pCoDec, CPs_PlayerContext* pContext)
  414. {
  415.     CPs_FileInfo FileInfo;
  416.     pCoDec->GetFileInfo(pCoDec, &FileInfo);
  417.     pContext->m_bOutputActive = TRUE;
  418.     pContext->m_iOpenDevice_Freq_Hz = FileInfo.m_iFreq_Hz;
  419.     pContext->m_bOpenDevice_Stereo = FileInfo.m_bStereo;
  420.     pContext->m_bOpenDevice_16bit = FileInfo.m_b16bit;
  422.     // 获得模板并初始化
  423.     pContext->m_Equaliser.Initialise(&pContext->m_Equaliser, FileInfo.m_iFreq_Hz, FileInfo.m_b16bit);
  424.     pContext->m_pCurrentOutputModule->Initialise(pContext->m_pCurrentOutputModule, &FileInfo, &pContext->m_Equaliser);
  426.     // 如果音量不是100% 那么设置音量级
  427. //    if(!pContext->m_iInternalVolume)
  428.         pContext->m_pCurrentOutputModule->SetInternalVolume(pContext->m_pCurrentOutputModule, pContext->m_iInternalVolume);
  429. }
  430. //
  431. //
  432. //
  433. CPs_CoDecModule* OpenCoDec(CPs_PlayerContext* pContext, const char* pcFilename)
  434. {
  435. const char* pcLastDot = NULL;
  436. int iCoDecIDX = 0;
  437. BOOL bOpenSucceeded;
  438. DWORD dwCookie=0;
  440. // 查找扩展名
  441. char *extension=NULL;
  442. char *dot=strrchr(pcFilename,'.');
  443. if(dot) extension=dot+1;
  445. /* if(dot)
  446. {
  447. if(CPFA_IsAssociated(&pContext->m_CoDecs[CP_CODEC_WINAMPPLUGIN], extension, &dwCookie) == TRUE)
  448. {
  449. bOpenSucceeded = pContext->m_CoDecs[CP_CODEC_WINAMPPLUGIN].OpenFile(
  450. &pContext->m_CoDecs[CP_CODEC_WINAMPPLUGIN],
  451. pcFilename,
  452. dwCookie,
  453. pContext->m_pBaseEngineParams->m_hWndNotify);
  454. if(bOpenSucceeded == TRUE)
  455. return &pContext->m_CoDecs[CP_CODEC_WINAMPPLUGIN];
  457. }
  458. }
  460. */
  461. // Find a CoDec that wants this association
  462. for(iCoDecIDX =CP_CODEC_WAV; iCoDecIDX <= CP_CODEC_last; iCoDecIDX++)
  463. {
  464. bOpenSucceeded = pContext->m_CoDecs[iCoDecIDX].OpenFile( &pContext->m_CoDecs[iCoDecIDX],
  465. pcFilename,
  466. dwCookie,
  467. pContext->m_pBaseEngineParams->m_hWndNotify);
  468. if(bOpenSucceeded == TRUE)
  469. return &pContext->m_CoDecs[iCoDecIDX];
  472. }
  473. return NULL;
  474. }
  476. //
  477. //
  478. //
  479. void CleanupCoDecs(CPs_PlayerContext* pContext)
  480. {
  481.     int iCoDecIDX = 0;
  482.     for(iCoDecIDX =CP_CODEC_WAV; iCoDecIDX <= CP_CODEC_last; iCoDecIDX++)
  483.         pContext->m_CoDecs[iCoDecIDX].Uninitialise(&pContext->m_CoDecs[iCoDecIDX]);
  484. }
  485. //
  486. //
  487. //
  488. void SetCurrentOutputModule(CPs_PlayerContext* pContext, CPs_OutputModule* pNewOuputModule, BOOL* pbForceRefill)
  489. {
  490.     if(!pNewOuputModule)
  491.         pNewOuputModule = &pContext->m_OutputModules[pContext->m_dwCurrentOutputModule];
  493.     // 如果输出模板改变，那么关闭老的，使用新的
  494.     if(pContext->m_pCurrentOutputModule == pNewOuputModule)
  495.         return;
  497.     // 关闭当前存在的
  498.     if(pContext->m_bOutputActive)
  499.     {
  500.         pContext->m_pCurrentOutputModule->Uninitialise(pContext->m_pCurrentOutputModule);
  501.         pContext->m_bOutputActive = FALSE;
  502.     }
  504.     // 转换解码器到新的输出模板
  505.     pNewOuputModule->m_pCoDec = pContext->m_pCurrentOutputModule->m_pCoDec;
  507.     // 设置新模板为当前使用
  508.     pContext->m_pCurrentOutputModule = pNewOuputModule;
  510.     if(pContext->m_bOutputActive == FALSE && pContext->m_pCurrentOutputModule->m_pCoDec)
  511.     {
  512.         StartPlay(pContext->m_pCurrentOutputModule->m_pCoDec, pContext);
  513.         *pbForceRefill = TRUE;
  514.     }
  515. }
  516. //
  517. //
  518. //
  519. void AssociateFileExtensions(CPs_PlayerContext* pContext)
  520. {
  521.     int iCoDecIDX;
  522.     for(iCoDecIDX =0; iCoDecIDX <= CP_CODEC_last; iCoDecIDX++)
  523.         CPFA_AssociateWithEXE(&pContext->m_CoDecs[iCoDecIDX]);
  524. }
  525. //
  526. //
  527. //