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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > P2P编程 > 查看源码
InfAnime.cpp
资源名称：p2p_vod.rar　[点击查看]
上传用户：liguizhu
上传日期：2015-11-01
资源大小：2422k
文件大小：4k
源码类别：

P2P编程

开发平台：

Visual C++

InfAnime.cpp：源码内容
  1. #include "stdafx.h"
  2. #include ".infanime.h"
  3. #include "zzlfilereader.h"
  5. extern HANDLE g_hModule;
  7. InfAnime::InfAnime(void):
  8. m_useproxymedia(true),pTipFileReader(NULL),m_animetype(REQUEST_NOPP),m_needvideotype(false),m_needaudiotype(false),
  9. m_accumulatevideotime(0) ,m_accumulateaudiotime(0)
  10. {
  11. }
  13. InfAnime::~InfAnime(void)
  14. {
  15.     delete pTipFileReader;
  16. }
  18. bool InfAnime::IsProxyAvaible()
  19. {
  20.     return m_useproxymedia;
  21. }
  23. bool InfAnime::StartProxy(ANIME_TYPE anime_type)
  24. {
  25.     if(!m_useproxymedia)
  26.         return false;
  28.     if(m_animetype == anime_type)
  29.         return true;
  31.     delete pTipFileReader;
  32.     pTipFileReader = new ZZLFileReader();
  34.     bool ret = false;
  36. TCHAR lpModulePath[MAX_PATH_EX] = _T("");
  37. DWORD dwLen = GetModuleFileName((HMODULE)g_hModule, lpModulePath, MAX_PATH_EX);
  38. if(dwLen == 0)
  39. return false;
  40. TCHAR* idx = _tcsrchr(lpModulePath, _T('\'));
  41. if(idx == NULL)
  42. return false;
  43. *(idx+1) = _T('');
  45.     string path = lpModulePath;
  46.     path += _T("\clip01.zzl");
  48.     switch(anime_type)
  49.     {
  50.     case  REQUEST_FAIL:
  51.         ret = pTipFileReader->Init(path.data());
  52.         break;
  53.     case    REQUEST_PROCESS:
  54.         ret = pTipFileReader->Init(path.data());
  55.         break;
  56.     case    REQUEST_BUFFER:
  57.         ret = pTipFileReader->Init(path.data());
  58.         break;
  59.     default:
  60.         assert(0);
  61.         return false;
  62.     }
  64.     if(ret == false)
  65.     {
  66.         delete pTipFileReader;
  67.         pTipFileReader = NULL;
  68.         return false;
  69.     }
  71.     m_needvideotype = true;
  72.     m_needaudiotype = true;
  73.     m_animetype = anime_type;
  74.     return true;
  75. }
  77. void InfAnime::EndProxy()
  78. {
  79.     m_animetype = REQUEST_NOPP;
  80. }
  82. P2P_RETURN_TYPE InfAnime::SetProxyMediaType(SampleHeader& header, PBYTE& pData, const UINT maxSize, const bool bAudio, const bool bKeySample)
  83. {
  84.     memset(&header, 0, sizeof(SampleHeader));
  85.     if(maxSize < sizeof(TVMEDIATYPESECTION))
  86.     {
  87.        assert(0);
  88.        return PRT_SYS;
  89.     }
  91.     if(pTipFileReader->GetMediaType(*((TVMEDIATYPESECTION*) pData), bAudio) == FALSE)
  92.         return PRT_SYS;
  94.     TVMEDIATYPESECTION* ptvmedia = (TVMEDIATYPESECTION*) pData;
  95.     header.size = sizeof(TVMEDIATYPESECTION) + ptvmedia->cbFormat;
  96.     if(maxSize < header.size)
  97.     {
  98.        assert(0);
  99.        return PRT_SYS;
  100.     }
  102.     if(pTipFileReader->GetMediaData(pData + sizeof(TVMEDIATYPESECTION), bAudio) == FALSE)
  103.         return PRT_SYS;
  105.     m_accumulateaudiotime = 0; 
  106.     m_accumulatevideotime = 0;
  108.     if(bAudio)
  109.         m_needaudiotype = false;
  110.     else
  111.         m_needvideotype = false;
  112.     return PRT_OK;
  113. }
  115. P2P_RETURN_TYPE InfAnime::ProxyGetData(SampleHeader& header, PBYTE& pData, const UINT maxSize, const bool bAudio, const bool bKeySample)
  116. {
  117.     if(!m_useproxymedia || pTipFileReader == NULL)
  118.         return PRT_SYS;
  120.     if(bAudio && m_needaudiotype)  //如果是刚刚重新初始化, 需要把媒体类型送出以进行切换
  121.     {
  122.         return SetProxyMediaType(header, pData, maxSize, bAudio, bKeySample);
  123.     }
  124.     if((!bAudio) && m_needvideotype)
  125.     {
  126.         return SetProxyMediaType(header, pData, maxSize, bAudio, bKeySample);
  127.     }
  129.     header.bAudioSample = bAudio;
  130.     P2P_RETURN_TYPE ret = pTipFileReader->GetSample(header, pData, maxSize, _I64_MAX);
  132.     if(ret >= PRT_OK)
  133.     { 
  134.         //将时间戳加上累积循环播放的时间
  135.         if(bAudio)
  136.             header.start += m_accumulateaudiotime;
  137.         else
  138.             header.start += m_accumulatevideotime;
  139.         return PRT_OK;
  140.     }
  141.     else if(ret == PRT_ENDOFFILE)    //已经到头了
  142.     {
  143.         LONGLONG tmp = 0;
  144.         if(bAudio)
  145.         {
  146.             m_accumulateaudiotime += pTipFileReader->TryGetExplictEndTime(bAudio);
  147.             pTipFileReader->SeekAudioTo(tmp);
  148.         }
  149.         else
  150.         {
  151.             m_accumulatevideotime += pTipFileReader->TryGetExplictEndTime(bAudio);
  152.             pTipFileReader->SeekVideoTo(tmp);
  153.         }
  154.         header.bAudioSample = bAudio;
  155.         return ProxyGetData(header, pData, maxSize, bAudio, bKeySample);
  156.     }
  157.     else
  158.     {
  159.         return PRT_SYS;
  160.     }
  161. }