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

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

VC书籍

开发平台：

Visual C++

AudioDecoderACM.cpp：源码内容
  1. /**************************************************************************************
  2.  *                                                                                    *
  3.  *                                                                                    *
  4.  **************************************************************************************/
  6. #include "AudioDecoderACM.h"
  8. /*
  9.  * ACM封装器类
  10.  *
  11.  */
  13. MediaAudioDecoderACM::MediaAudioDecoderACM()
  14. {
  15. this->out_buffer  = NULL;
  16. this->in_buffer   = NULL;
  17. this->oFormat     = NULL;
  19. this->ring        = new MediaRingBuffer();
  20. }
  22. MediaAudioDecoderACM::~MediaAudioDecoderACM()
  23. {
  24. delete this->ring;
  25. }
  27. /*
  28.  * 媒体项函数
  29.  */
  31. media_type_t  MediaAudioDecoderACM::GetType()
  32. {
  33. return MEDIA_TYPE_AUDIO_DECODER;
  34. }
  36. char  *MediaAudioDecoderACM::GetName()
  37. {
  38. if(this->hacm != NULL) {
  40. char            *name;
  41. HACMDRIVERID     dId;
  42. ACMDRIVERDETAILS details;
  44. name = (char *) new char[128];
  46. if(acmDriverID((HACMOBJ) this->hacm, &dId, 0) > 0) {
  48. return NULL;
  49. }
  51. memset(&details, 0, sizeof(ACMDRIVERDETAILS));
  52. details.cbStruct = sizeof(ACMDRIVERDETAILS);
  54. if(acmDriverDetails(dId, &details, 0) == MMSYSERR_INVALHANDLE) {
  56. return NULL;
  57. }
  59. strcpy(name, details.szLongName);
  60. return name;
  61. }
  63. return "ACM Wrapper";
  64. }
  66. MP_RESULT     MediaAudioDecoderACM::Connect(MediaItem *item)
  67. {
  68. MMRESULT      mmres;
  69. WAVEFORMATEX *inFormat;
  70. DWORD         dwOutputFormatSize;
  72. if(item && item->GetType() == MEDIA_TYPE_DECAPS) {
  74. this->decaps = (MediaItemDecaps *) item;
  76. inFormat = this->decaps->GetAudioFormat(0);
  80. if(inFormat->wFormatTag == 85 && inFormat->cbSize != 12) {
  84. MPEGLAYER3WAVEFORMAT *format;
  86. format = (MPEGLAYER3WAVEFORMAT *) inFormat;
  88. format->wfx.cbSize      = 12;
  90. format->wID             = 1;
  91. format->fdwFlags        = 2;
  92. format->nBlockSize      = 313;
  93. format->nFramesPerBlock = 1;
  94. format->nCodecDelay     = 1393;
  95. }
  99. if (acmMetrics(NULL, ACM_METRIC_MAX_SIZE_FORMAT, (LPVOID)&dwOutputFormatSize)) {
  101. return MP_RESULT_ERROR;
  102. }
  104. this->oFormat = (WAVEFORMATEX *) new WAVEFORMATEX;
  105. this->oFormat->wFormatTag = WAVE_FORMAT_PCM;
  107. if (acmFormatSuggest(NULL, inFormat, this->oFormat, dwOutputFormatSize, ACM_FORMATSUGGESTF_WFORMATTAG)) {
  109. }
  111. if (oFormat->wBitsPerSample!=8 && oFormat->wBitsPerSample!=16)
  112. oFormat->wBitsPerSample=16;
  114. if (oFormat->nChannels!=1 && oFormat->nChannels!=2)
  115. oFormat->nChannels = 2;
  117. oFormat->nBlockAlign = (oFormat->wBitsPerSample/8) * oFormat->nChannels;
  118. oFormat->nAvgBytesPerSec = oFormat->nBlockAlign * oFormat->nSamplesPerSec;
  119. oFormat->cbSize = 0;
  121. mmres = acmStreamOpen(&hacm, NULL, inFormat, 
  122.   this->oFormat, NULL, NULL, 0, ACM_STREAMOPENF_NONREALTIME);
  124. if(mmres != 0) {
  128. return MP_RESULT_ERROR;
  129. }
  133. this->inputSize  = max(2048 - (2048 % inFormat->nBlockAlign),  8*inFormat->nBlockAlign);
  134. this->outputSize = 0;
  136. if (acmStreamSize(this->hacm, this->inputSize, &this->outputSize, ACM_STREAMSIZEF_SOURCE))
  137. return MP_RESULT_ERROR;
  139. this->ring->Init();
  141. this->in_buffer  = (char *) new char[this->inputSize];
  142. this->out_buffer = (char *) new char[this->outputSize];
  144. this->acmInLeft = 0;
  145. this->acmLeft   = 0;
  147. return MP_RESULT_OK;
  148. }
  150. return MP_RESULT_ERROR;
  151. }
  153. MP_RESULT     MediaAudioDecoderACM::ReleaseConnections()
  154. {
  157. this->decaps = NULL;
  159. free(this->in_buffer);
  160. this->in_buffer = NULL;
  162. free(this->out_buffer);
  163. this->out_buffer = NULL;
  165. free(this->oFormat);
  166. this->oFormat = NULL;
  168. acmStreamClose(this->hacm, 0);
  170. return MP_RESULT_OK;
  171. }
  173. DWORD         MediaAudioDecoderACM::GetCaps()
  174. {
  175. return 0;
  176. }
  178. MP_RESULT     MediaAudioDecoderACM::Configure(HINSTANCE hInstance, HWND hwnd)
  179. {
  180. return MP_RESULT_ERROR;
  181. }
  185. WAVEFORMATEX *MediaAudioDecoderACM::GetAudioFormat()
  186. {
  187. return this->oFormat;
  188. }
  190. MP_RESULT     MediaAudioDecoderACM::EmptyAudioBuffer()
  191. {
  192. if(this->ring)
  193. this->ring->Init();
  195. this->acmLeft   = 0;
  196. this->acmInLeft = 0;
  198. return MP_RESULT_OK;
  199. }
  201. unsigned int MediaAudioDecoderACM::Decompress(void *buffer, unsigned int size)
  202. {
  203. DWORD    i, done;
  204. MMRESULT res;
  206. done = 0;
  208. if(this->hacm) {
  210. if(size < 16384) {
  212. if(this->acmLeft > 0 && !this->ring->IsFullFor(this->acmLeft)) {
  215. this->ring->Write((char *) this->out_buffer, this->acmLeft);
  216. this->acmLeft = 0;
  217. }
  219. if(this->acmLeft > 0)
  220. goto done;
  222. if(!this->acmInLeft) {
  224. if(this->decaps->ReadAudioData(0, this->in_buffer, this->inputSize) != this->inputSize) {
  226. return done;
  227. }
  228. }
  230. memset(&this->acmHeader, 0, sizeof(ACMSTREAMHEADER));
  232. this->acmHeader.cbStruct    = sizeof(ACMSTREAMHEADER);
  234. if(this->acmInLeft > 0) {
  236. memcpy(this->in_buffer, ((char *) this->in_buffer) + this->inputSize - this->acmInLeft, this->acmInLeft);
  238. if(this->decaps->ReadAudioData(0, ((char *) this->in_buffer) + this->acmInLeft, this->inputSize - this->acmInLeft) != (this->inputSize - this->acmInLeft) ) {
  240. return done;
  241. }
  243. this->acmHeader.pbSrc       = (unsigned char *) this->in_buffer;
  244. this->acmHeader.cbSrcLength = this->inputSize;
  246. this->acmInLeft = 0;
  247. }
  248. else {
  249. this->acmHeader.pbSrc       = (unsigned char *) this->in_buffer;
  250. this->acmHeader.cbSrcLength = this->inputSize;
  251. }
  253. this->acmHeader.pbDst       = (unsigned char *) this->out_buffer;
  254. this->acmHeader.cbDstLength = this->outputSize;
  256. res = acmStreamPrepareHeader(this->hacm, &this->acmHeader, 0);
  258. if(res > 0) {
  260. return done;
  261. }
  263. res = acmStreamConvert(this->hacm, &this->acmHeader, 0);
  265. if(res > 0) {
  267. acmStreamUnprepareHeader(this->hacm, &this->acmHeader, 0);
  268. return done;
  269. }
  271. while(!this->ring->IsFullFor(this->acmHeader.cbDstLengthUsed)) {
  275. this->ring->Write((char *) this->acmHeader.pbDst, this->acmHeader.cbDstLengthUsed);
  279. acmStreamUnprepareHeader(this->hacm, &this->acmHeader, 0);
  281. if(!this->acmInLeft) {
  283. if(this->decaps->ReadAudioData(0, this->in_buffer, this->inputSize) != this->inputSize) {
  285. return done;
  286. }
  287. }
  289. memset(&this->acmHeader, 0, sizeof(ACMSTREAMHEADER));
  291. this->acmHeader.cbStruct    = sizeof(ACMSTREAMHEADER);
  293. if(this->acmInLeft > 0) {
  295. memcpy(this->in_buffer, ((char *) this->in_buffer) + this->inputSize - this->acmInLeft, this->acmInLeft);
  297. if(this->decaps->ReadAudioData(0, ((char *) this->in_buffer) + this->acmInLeft, this->inputSize - this->acmInLeft) != (this->inputSize - this->acmInLeft) ) {
  299. return done;
  300. }
  302. this->acmHeader.pbSrc       = (unsigned char *) this->in_buffer;
  303. this->acmHeader.cbSrcLength = this->inputSize;
  305. this->acmInLeft = 0;
  306. }
  307. else {
  308. this->acmHeader.pbSrc       = (unsigned char *) this->in_buffer;
  309. this->acmHeader.cbSrcLength = this->inputSize;
  310. }
  312. this->acmHeader.pbDst       = (unsigned char *) this->out_buffer;
  313. this->acmHeader.cbDstLength = this->outputSize;
  315. res = acmStreamPrepareHeader(this->hacm, &this->acmHeader, 0);
  317. if(res > 0) {
  319. return done;
  320. }
  322. res = acmStreamConvert(this->hacm, &this->acmHeader, 0);
  324. if(res > 0) {
  326. acmStreamUnprepareHeader(this->hacm, &this->acmHeader, 0);
  327. return done;
  328. }
  330. this->acmInLeft = this->inputSize - this->acmHeader.cbSrcLengthUsed;
  331. }
  333. this->acmLeft = this->acmHeader.cbDstLengthUsed;
  335. acmStreamUnprepareHeader(this->hacm, &this->acmHeader, 0);
  336. done:
  338. this->ring->Read((char *) buffer, size);
  339. done += size;
  341. return done;
  342. }
  343. else {
  345. unsigned int blocks = size / 16384;
  347. for(i = 0; i < blocks; i++) {
  349. if(this->acmLeft > 0 && !this->ring->IsFullFor(this->acmLeft)) {
  353. this->ring->Write((char *) this->out_buffer, this->acmLeft);
  354. this->acmLeft = 0;
  355. }
  357. if(this->acmLeft > 0)
  358. goto done2;
  360. if(!this->acmInLeft) {
  362. if(this->decaps->ReadAudioData(0, this->in_buffer, this->inputSize) != this->inputSize) {
  364. return done;
  365. }
  366. }
  368. memset(&this->acmHeader, 0, sizeof(ACMSTREAMHEADER));
  370. this->acmHeader.cbStruct    = sizeof(ACMSTREAMHEADER);
  372. if(this->acmInLeft > 0) {
  374. memcpy(this->in_buffer, ((char *) this->in_buffer) + this->inputSize - this->acmInLeft, this->acmInLeft);
  376. if(this->decaps->ReadAudioData(0, ((char *) this->in_buffer) + this->acmInLeft, this->inputSize - this->acmInLeft) != (this->inputSize - this->acmInLeft) ) {
  378. return done;
  379. }
  381. this->acmHeader.pbSrc       = (unsigned char *) this->in_buffer;
  382. this->acmHeader.cbSrcLength = this->inputSize;
  384. this->acmInLeft = 0;
  385. }
  386. else {
  387. this->acmHeader.pbSrc       = (unsigned char *) this->in_buffer;
  388. this->acmHeader.cbSrcLength = this->inputSize;
  389. }
  391. this->acmHeader.pbDst       = (unsigned char *) this->out_buffer;
  392. this->acmHeader.cbDstLength = this->outputSize;
  394. res = acmStreamPrepareHeader(this->hacm, &this->acmHeader, 0);
  396. if(res > 0) {
  398. return done;
  399. }
  401. res = acmStreamConvert(this->hacm, &this->acmHeader, 0);
  403. if(res > 0) {
  405. acmStreamUnprepareHeader(this->hacm, &this->acmHeader, 0);
  406. return done;
  407. }
  409. while(!this->ring->IsFullFor(this->acmHeader.cbDstLengthUsed)) {
  413. this->ring->Write((char *) this->acmHeader.pbDst, this->acmHeader.cbDstLengthUsed);
  417. acmStreamUnprepareHeader(this->hacm, &this->acmHeader, 0);
  419. if(!this->acmInLeft) {
  421. if(this->decaps->ReadAudioData(0, this->in_buffer, this->inputSize) != this->inputSize) {
  423. return done;
  424. }
  425. }
  427. memset(&this->acmHeader, 0, sizeof(ACMSTREAMHEADER));
  429. this->acmHeader.cbStruct    = sizeof(ACMSTREAMHEADER);
  431. if(this->acmInLeft > 0) {
  433. memcpy(this->in_buffer, ((char *) this->in_buffer) + this->inputSize - this->acmInLeft, this->acmInLeft);
  435. if(this->decaps->ReadAudioData(0, ((char *) this->in_buffer) + this->acmInLeft, this->inputSize - this->acmInLeft) != (this->inputSize - this->acmInLeft) ) {
  437. return done;
  438. }
  440. this->acmHeader.pbSrc       = (unsigned char *) this->in_buffer;
  441. this->acmHeader.cbSrcLength = this->inputSize;
  443. this->acmInLeft = 0;
  444. }
  445. else {
  447. this->acmHeader.pbSrc       = (unsigned char *) this->in_buffer;
  448. this->acmHeader.cbSrcLength = this->inputSize;
  449. }
  451. this->acmHeader.pbDst       = (unsigned char *) this->out_buffer;
  452. this->acmHeader.cbDstLength = this->outputSize;
  454. res = acmStreamPrepareHeader(this->hacm, &this->acmHeader, 0);
  456. if(res > 0) {
  458. return done;
  459. }
  461. res = acmStreamConvert(this->hacm, &this->acmHeader, 0);
  463. if(res > 0) {
  465. acmStreamUnprepareHeader(this->hacm, &this->acmHeader, 0);
  466. return done;
  467. }
  469. this->acmInLeft = this->inputSize - this->acmHeader.cbSrcLengthUsed;
  470. }
  472. this->acmLeft = this->acmHeader.cbDstLengthUsed;
  474. acmStreamUnprepareHeader(this->hacm, &this->acmHeader, 0);
  475. done2:
  477. this->ring->Read(((char *) buffer) + i*16384, 16384);
  478. done += 16384;
  479. }
  481.  
  482. int left = size - (blocks * 16384);
  484. if(left > 0) {
  485. this->Decompress((void *) ((char *) buffer + size - left), left);
  487. done += left;
  488. }
  490. return done;
  491. }
  492. }
  494. return 0;
  495. }