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

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

P2P编程

开发平台：

Visual C++

MMSPool.cpp：源码内容
  1. /*
  2.  *  Openmysee
  3.  *
  4.  *  This program is free software; you can redistribute it and/or modify
  5.  *  it under the terms of the GNU General Public License as published by
  6.  *  the Free Software Foundation; either version 2 of the License, or
  7.  *  (at your option) any later version.
  8.  *
  9.  *  This program is distributed in the hope that it will be useful,
  10.  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  11.  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12.  *  GNU General Public License for more details.
  13.  *
  14.  *  You should have received a copy of the GNU General Public License
  15.  *  along with this program; if not, write to the Free Software
  16.  *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  17.  *
  18.  */
  19. #include "stdafx.h"
  20. #include "mmspool.h"
  22. BOOL CMMSPool::AddNewMMS(string strChannel, string strMMSAddr)
  23. {
  24. HRESULT hr;
  25.     CMMSGraph *pMMS = new CMMSGraph(strChannel, strMMSAddr, &hr) ; 
  26.      
  28. if(FAILED(hr))
  29. {
  30. if(pMMS)
  31. delete pMMS;
  33. return FALSE;
  34. }
  36. EnterCriticalSection(&m_csList);
  37. m_listGraph.push_back(pMMS);
  38. LeaveCriticalSection(&m_csList);
  40. return TRUE;
  41. }
  43. BOOL CMMSPool::RemoveMMS(string strChannel)
  44. {
  45. EnterCriticalSection(&m_csList);
  47. BOOL bFinded = FALSE;
  48. list<CMMSGraph*>::iterator it = m_listGraph.begin();
  49. for(; it != m_listGraph.end(); it++) 
  50. {
  51. CMMSGraph* temp = *it;
  52. if(temp->GetChannelName() == strChannel) 
  53. {
  54. bFinded = TRUE;
  55. m_listGraph.erase(it);
  56. delete temp;
  57. break;
  58. }
  59. }
  60. LeaveCriticalSection(&m_csList);
  62. if(bFinded)
  63. return TRUE;
  64. else
  65. return FALSE;
  66. }
  68. BOOL CMMSPool::RunMMS(string strChannel)
  69. {
  70. EnterCriticalSection(&m_csList);
  72. if(SUCCEEDED(GetMMSByChannel(strChannel)->Run()))
  73. {
  74. LeaveCriticalSection(&m_csList);
  75. return TRUE;
  76. }
  77. else
  78. {
  79. LeaveCriticalSection(&m_csList);
  80. return FALSE;
  81. }
  83. LeaveCriticalSection(&m_csList);
  84. }
  86. BOOL CMMSPool::StopMMS(string strChannel)
  87. {
  88. EnterCriticalSection(&m_csList);
  90. if(NULL ==GetMMSByChannel(strChannel))
  91. return FALSE;
  93. if(SUCCEEDED(GetMMSByChannel(strChannel)->Stop()))
  94. {
  95. LeaveCriticalSection(&m_csList);
  96. return TRUE;
  97. }
  98. else
  99. {
  100. LeaveCriticalSection(&m_csList);
  101. return FALSE;
  102. }
  104. LeaveCriticalSection(&m_csList);
  105. }
  107. BOOL CMMSPool::PauseMMS(string strChannel)
  108. {
  109. EnterCriticalSection(&m_csList);
  110.      
  111. if(NULL ==GetMMSByChannel(strChannel))
  112.      return FALSE ;
  114. if(SUCCEEDED(GetMMSByChannel(strChannel)->Pause()))
  115. {
  116. LeaveCriticalSection(&m_csList);
  117. return TRUE;
  118. }
  119. else
  120. {
  121. LeaveCriticalSection(&m_csList);
  122. return FALSE;
  123. }
  125. LeaveCriticalSection(&m_csList);
  126. }
  128. MMSGRAPHINFO* CMMSPool::GetMMSGraphInfo(string strChannel)
  129. {
  130. MMSGRAPHINFO* pMMSInfo = NULL;
  131. EnterCriticalSection(&m_csList);
  133. CMMSGraph *pMMSGB = GetMMSByChannel(strChannel);
  134. if(pMMSGB)
  135. pMMSInfo = pMMSGB->GetMMSGraphInfo();
  137. LeaveCriticalSection(&m_csList);
  139. return pMMSInfo;
  140. }
  142. CMMSGraph* CMMSPool::GetMMSByChannel(string strChannel)
  143. {
  144. list<CMMSGraph*>::iterator it = m_listGraph.begin();
  145. for(; it != m_listGraph.end(); it++) 
  146. {
  147. CMMSGraph* temp = *it;
  148. if(temp->GetChannelName() == strChannel) 
  149. return temp;
  150. }
  152. return NULL;
  153. }
  155. void CMMSPool::RemoveAllMMS()
  156. {
  157. EnterCriticalSection(&m_csList);
  159. list<CMMSGraph*>::iterator it;
  160. while(m_listGraph.size() > 0) 
  161. {
  162. it = m_listGraph.begin();
  163. CMMSGraph* temp = *it;
  164. m_listGraph.erase(it);
  165. delete temp;
  166. }
  167. m_listGraph.clear();
  169. LeaveCriticalSection(&m_csList);
  170. }