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

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

VC书籍

开发平台：

Visual C++

AudioRenderer.cpp：源码内容
  1. /**************************************************************************************
  2.  *                                                                                    *
  3.  *                                                                                    *
  4.  **************************************************************************************/
  6. #include "AudioRenderer.h"
  10. #define PERIOD 30
  13. MediaAudioRenderer::MediaAudioRenderer()
  14. {
  15. this->lpDirectSound = NULL;
  16. this->lpBuffer      = NULL;
  17. }
  19. MediaAudioRenderer::~MediaAudioRenderer()
  20. {
  21. }
  24. media_type_t  MediaAudioRenderer::GetType()
  25. {
  26. return MEDIA_TYPE_AUDIO_RENDERER;
  27. }
  29. char         *MediaAudioRenderer::GetName()
  30. {
  31. return "DirectSound Audio Renderer";
  32. }
  36. MP_RESULT     MediaAudioRenderer::Connect(MediaItem *item)
  37. {
  38. return MP_RESULT_ERROR;
  39. }
  41. MP_RESULT     MediaAudioRenderer::ReleaseConnections()
  42. {
  43. return MP_RESULT_ERROR;
  44. }
  46. DWORD         MediaAudioRenderer::GetCaps()
  47. {
  48. return 0;
  49. }
  51. MP_RESULT     MediaAudioRenderer::Configure(HINSTANCE hInstance, HWND hwnd)
  52. {
  53. return MP_RESULT_ERROR;
  54. }
  57. MP_RESULT     MediaAudioRenderer::Open(HWND hwnd, WAVEFORMATEX *inFormat)
  58. {
  59. if(hwnd && inFormat) {
  61. this->ourFormat = inFormat;
  63. HRESULT hr;
  65. if(DirectSoundCreate(NULL, &this->lpDirectSound, NULL) == DS_OK) {
  69. hr = lpDirectSound->SetCooperativeLevel(hwnd, DSSCL_NORMAL);
  71. if(hr != DS_OK) {
  73. this->lpDirectSound->Release();
  74. this->lpDirectSound = NULL;
  76. return MP_RESULT_ERROR;
  77. }
  81. DSBUFFERDESC  dsbdesc;
  82. WAVEFORMATEX  wf;
  84. memset(&dsbdesc, 0, sizeof(DSBUFFERDESC));
  85. dsbdesc.dwSize = sizeof(DSBUFFERDESC);
  86.     
  87. ZeroMemory(&wf, sizeof(WAVEFORMATEX));
  88. memcpy(&wf, this->ourFormat, sizeof(WAVEFORMATEX));
  90. dsbdesc.lpwfxFormat = (LPWAVEFORMATEX) &wf;
  91.     
  92. dsbdesc.dwFlags = DSBCAPS_CTRLVOLUME | DSBCAPS_GLOBALFOCUS;
  93. dsbdesc.dwBufferBytes = 2 * this->ourFormat->nAvgBytesPerSec;
  95. hr = lpDirectSound->CreateSoundBuffer(&dsbdesc, &lpBuffer, NULL);
  97. if(hr != DS_OK) {
  99. this->lpDirectSound->Release();
  100. this->lpDirectSound = NULL;
  102. return MP_RESULT_ERROR;
  103. }
  106. this->dwBufferSize = 2 * this->ourFormat->nAvgBytesPerSec;
  107. this->lInTimer = FALSE;
  109. return MP_RESULT_OK;
  110. }
  111. }
  113. return MP_RESULT_ERROR;
  114. }
  119. MP_RESULT     MediaAudioRenderer::SetCallback(void *lpData, MediaAudioCallback callback)
  120. {
  121. this->lpData   = lpData;
  122. this->callback = callback;
  124. return MP_RESULT_OK;
  125. }
  127. MP_RESULT     MediaAudioRenderer::SetVolume(unsigned int volume)
  128. {
  129. if(this->lpBuffer) {
  131. double vol;
  133. vol = - ( 70*pow(10, (100.0 - (double) volume)*2.0/100.0) );
  135. if(this->lpBuffer != NULL)
  136. this->lpBuffer->SetVolume((int) vol);
  137. }
  139. return MP_RESULT_ERROR;
  140. }
  142. unsigned long MediaAudioRenderer::GetAudioTime()
  143. {
  144. return (unsigned long) (( ((double) this->dwPlayed * (1000/(this->ourFormat->wBitsPerSample*this->ourFormat->nChannels/8)))) / (this->ourFormat->nSamplesPerSec));
  145. }
  148. void CALLBACK AudioTimeFunc(UINT uTimerID, UINT uMsg, DWORD dwUser, DWORD dw1, DWORD dw2)
  149. {
  150. MediaAudioRenderer *audioRenderer = (MediaAudioRenderer *) dwUser;
  152. if (InterlockedExchange(&audioRenderer->lInTimer, TRUE)) return;
  154. if(audioRenderer->callback) {
  156. void *buffer1, *buffer2;
  157. DWORD bytes1 = 0, bytes2 = 0;
  158. DWORD dwPlay, dwWrite, dwSize;
  160. audioRenderer->lpBuffer->GetCurrentPosition(&dwPlay, &dwWrite);
  162. if(audioRenderer->dwLastPlayPos == dwPlay) {
  164. InterlockedExchange(&audioRenderer->lInTimer, FALSE);
  165. return;
  166. }
  168. if(audioRenderer->dwLastPlayPos <= dwPlay) {
  170. dwSize = dwPlay - audioRenderer->dwLastPlayPos;
  172. audioRenderer->lpBuffer->Lock(audioRenderer->dwLastPlayPos,
  173.   dwSize,
  174.   &buffer1, &bytes1, 
  175.   &buffer2, &bytes2, 0);
  177. if(buffer1) {
  179. bytes1 = audioRenderer->callback(audioRenderer->lpData, buffer1, bytes1);
  180. }
  182. audioRenderer->lpBuffer->Unlock(buffer1, bytes1, buffer2, bytes2);
  184. audioRenderer->dwLastPlayPos += bytes1;
  185. audioRenderer->dwPlayed += bytes1;
  186. }
  187. else {
  189. DWORD bytes1_ori;
  191. dwSize = (audioRenderer->dwBufferSize - audioRenderer->dwLastPlayPos) + dwPlay;
  193. audioRenderer->lpBuffer->Lock(audioRenderer->dwLastPlayPos,
  194.   dwSize,
  195.   &buffer1, &bytes1, 
  196.   &buffer2, &bytes2, 0);
  198. bytes1_ori = bytes1;
  200. if(bytes1) {
  202. bytes1 = audioRenderer->callback(audioRenderer->lpData, buffer1, bytes1);
  203. }
  205. if(bytes2) {
  207. bytes2 = audioRenderer->callback(audioRenderer->lpData, buffer2, bytes2);
  208. }
  210. audioRenderer->lpBuffer->Unlock(buffer1, bytes1, buffer2, bytes2);
  212. audioRenderer->dwPlayed += bytes1 + bytes2;
  214. if(bytes1_ori == bytes1)
  215. audioRenderer->dwLastPlayPos = bytes2;
  216. else 
  217. audioRenderer->dwLastPlayPos += bytes1;
  218. }
  220. InterlockedExchange(&audioRenderer->lInTimer, FALSE);
  221. return;
  222. }
  223. }
  227. MP_RESULT     MediaAudioRenderer::Bufferize()
  228. {
  229. if(this->lpBuffer) {
  231. void *buffer1, *buffer2;
  232. DWORD bytes1, bytes2, length;
  235. this->lpBuffer->SetCurrentPosition(0);
  237. this->lpBuffer->Lock(0, this->dwBufferSize,
  238.     &buffer1, &bytes1, &buffer2, &bytes2, 0);
  241. length = this->callback(this->lpData, buffer1, this->dwBufferSize);
  243. this->lpBuffer->Unlock(buffer1, bytes1, buffer2, bytes2);
  245. this->dwNextWriteOffset = this->dwProgress = this->dwPlayed = this->dwLastPlayPos = 0;
  246. }
  248. return MP_RESULT_OK;
  249. }
  251. MP_RESULT     MediaAudioRenderer::Start()
  252. {
  253. if(this->lpBuffer) {
  255. void *buffer1, *buffer2;
  256. DWORD bytes1, bytes2, length;
  260. this->lpBuffer->SetCurrentPosition(0);
  262. this->lpBuffer->Lock(0, this->dwBufferSize,
  263.     &buffer1, &bytes1, &buffer2, &bytes2, 0);
  267. length = this->callback(this->lpData, buffer1, this->dwBufferSize);
  269. this->lpBuffer->Unlock(buffer1, length, buffer2, bytes2);
  271. this->dwProgress = this->dwPlayed = this->dwLastPlayPos = 0;
  275. this->paused = 0;
  277. if(this->lpBuffer->Play(0, 0, DSBPLAY_LOOPING) != DS_OK) {
  279. return MP_RESULT_ERROR;
  280. }
  282. if( timeBeginPeriod( PERIOD ) != 0 ) {
  284. return MP_RESULT_ERROR;
  285. }
  286.         else {
  288. this->uTimerID = timeSetEvent( PERIOD, 5, AudioTimeFunc, (DWORD)(LPVOID)this, TIME_PERIODIC );
  289. }
  291. return MP_RESULT_OK;
  292. }
  294. return MP_RESULT_ERROR;
  295. }
  297. MP_RESULT     MediaAudioRenderer::Pause()
  298. {
  299. if(this->paused) {
  301. this->paused = 0;
  302. this->lpBuffer->Play(0, 0, DSBPLAY_LOOPING);
  304. this->uTimerID = timeSetEvent( PERIOD, 5, AudioTimeFunc, (DWORD)(LPVOID)this, TIME_PERIODIC );
  306. }
  307. else {
  309. if(this->uTimerID) {
  311. timeKillEvent(this->uTimerID); 
  312.   }
  314. this->paused = 1;
  315. this->lpBuffer->Stop();
  316. }
  318. return MP_RESULT_OK;
  319. }
  321. MP_RESULT     MediaAudioRenderer::Stop()
  322. {
  323. if(this->uTimerID) {
  325. timeKillEvent(this->uTimerID); 
  326.   }
  328. if(this->lpBuffer) {
  329. this->lpBuffer->Stop();
  330. timeEndPeriod(PERIOD); 
  331. }
  333. return MP_RESULT_OK;
  334. }
  336. MP_RESULT     MediaAudioRenderer::Close()
  337. {
  338. this->Stop();
  340. if(this->lpDirectSound) {
  342. if(this->lpBuffer)
  343. this->lpBuffer->Release();
  345. this->lpBuffer = NULL;
  347. this->lpDirectSound->Release();
  349. this->lpDirectSound = NULL;
  350. }
  352. return MP_RESULT_OK;
  353. }