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

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

VC书籍

开发平台：

Visual C++

AV8Buffer.cpp：源码内容
  1. //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
  2. // AV8Buffer.cpp
  4. #include "stdafx.h"
  5. #include "AV8Buffer.h"
  6. #include "PlayView.h"
  7. #include "winsock2.h"
  9. #ifdef _DEBUG
  10. #define new DEBUG_NEW
  11. #undef THIS_FILE
  12. static char THIS_FILE[] = __FILE__;
  13. #endif
  15. extern WSABUF stWSABuf;
  16. extern HWND hWnd;
  20. //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
  21. // CAV8Buffer()
  23. CAV8Buffer::CAV8Buffer(DWORD dwBlock, DWORD dwByte)
  24. {
  25. m_dwBlock = dwBlock;
  26. m_dwByte  = dwByte;
  28. m_pdwIndex  = (DWORD *)malloc(dwBlock * sizeof(DWORD));
  29. m_pdwLength = (DWORD *)malloc(dwBlock * sizeof(DWORD));
  30. m_pbFull    = (BOOL  *)malloc(dwBlock * sizeof(BOOL ));
  31. m_plpArray  = (LPSTR *)malloc(dwBlock * sizeof(LPSTR));
  33. for (DWORD dwIndex = 0; dwIndex < dwBlock; dwIndex++)
  34. {
  35. m_pdwIndex [dwIndex] = dwIndex;
  36. m_pdwLength[dwIndex] = 0;
  37. m_pbFull   [dwIndex] = FALSE;
  38. m_plpArray [dwIndex] = (LPSTR)malloc(dwByte * sizeof(char));
  39. }
  41. m_lEmptyBlock = -1;
  42. Flag = true;
  43. }
  45. //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
  46. // ~CAV8Buffer()
  48. CAV8Buffer::~CAV8Buffer()
  49. {
  50. for (DWORD dwIndex = 0; dwIndex < m_dwBlock; dwIndex++)
  51. free(m_plpArray[dwIndex]);
  52. free(m_pdwIndex);
  53. free(m_pdwLength);
  54. free(m_pbFull);
  55. free(m_plpArray);
  56. }
  59. //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
  60. // PushIn()
  62. DWORD CAV8Buffer::PushIn(LPSTR lpData, DWORD dwLength)
  63. {
  65. //查询缓冲队列中空块的位置
  66. if (m_lEmptyBlock < 0)
  67. m_lEmptyBlock = QueryEmpty(); 
  68. //空块的长度
  69.     DWORD dwOldLength = m_pdwLength[m_lEmptyBlock];
  71. if (m_lEmptyBlock >= 0 && m_plpArray[m_lEmptyBlock])
  72. {
  73. memcpy((void *)(m_plpArray[m_lEmptyBlock] + dwOldLength), (const void *)lpData, min(dwLength, m_dwByte - dwOldLength));
  74. m_pdwLength[m_lEmptyBlock] += min(dwLength, m_dwByte - dwOldLength);
  76. if (m_pdwLength[m_lEmptyBlock] == m_dwByte)
  77. {
  78. m_pbFull[m_lEmptyBlock] = TRUE;
  79. OrderAll(m_lEmptyBlock);
  80. //缓冲区满，发送WM_READYSEND消息，启动数据发送线程
  81. if(Flag)
  82.   ::PostMessage(hWnd,WM_READYSEND,0,0);
  84. m_lEmptyBlock = -1;
  85. }
  87. if (dwLength > m_dwByte - dwOldLength)
  88. PushIn(lpData + (m_dwByte - dwOldLength), dwLength - (m_dwByte - dwOldLength));
  90. return min(dwLength, m_dwByte - dwOldLength);
  91. }
  93. return 0;
  94. }
  96. //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
  97. // PopOut()
  99. DWORD CAV8Buffer::PopOut(LPSTR lpData, DWORD dwLength)
  100. {
  101. for (DWORD dwIndex = 0; dwIndex < m_dwBlock; dwIndex++)
  102. {
  103. DWORD dwPopBlock = m_pdwIndex[dwIndex];
  104. DWORD dwOldLength = m_pdwLength[dwPopBlock];
  106. if (m_pbFull[dwPopBlock])
  107. {
  108. memcpy((void *)lpData, (const void *)m_plpArray[dwPopBlock], min(dwOldLength, dwLength));
  110. m_pdwLength[dwPopBlock] = 0;
  111. m_pbFull[dwPopBlock] = FALSE;
  113. return min(dwOldLength, dwLength);
  114. }
  115. }
  117. return 0;
  118. }
  120. //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
  121. // ClearAll()
  123. void CAV8Buffer::ClearAll()
  124. {
  125. for (DWORD dwIndex = 0; dwIndex < m_dwBlock; dwIndex++)
  126. {
  127. m_pdwIndex [dwIndex] = dwIndex;
  128. m_pdwLength[dwIndex] = 0;
  129. m_pbFull   [dwIndex] = FALSE;
  130. }
  131. }
  133. //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
  134. // QueryEmpty()
  136. LONG CAV8Buffer::QueryEmpty()
  137. {
  138. for (DWORD dwIndex = 0; dwIndex < m_dwBlock; dwIndex++)
  139. if (! m_pbFull[dwIndex])
  140. return (LONG)dwIndex;
  142. return -1;
  143. }
  145. //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
  146. // OrderAll()
  148. void CAV8Buffer::OrderAll(DWORD dwTheLast)
  149. {
  150. for (DWORD dwIndex = 0; dwIndex < m_dwBlock; dwIndex++)
  151. if (m_pdwIndex[dwIndex] == dwTheLast)
  152. break;
  154. for (; dwIndex < m_dwBlock - 1; dwIndex++)
  155. m_pdwIndex[dwIndex] = m_pdwIndex[dwIndex + 1];
  157. m_pdwIndex[dwIndex] = dwTheLast;
  158. }
  160. // The End ///////////////////////////////////////////////////////////////////////////////////////////////////////////////