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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 多媒体 > 流媒体/Mpeg4/MP4 > 查看源码
media_source.h
资源名称：NETVIDEO.rar　[点击查看]
上传用户：sun1608
上传日期：2007-02-02
资源大小：6116k
文件大小：8k
源码类别：

流媒体/Mpeg4/MP4

开发平台：

Visual C++

media_source.h：源码内容
  1. /*
  2.  * The contents of this file are subject to the Mozilla Public
  3.  * License Version 1.1 (the "License"); you may not use this file
  4.  * except in compliance with the License. You may obtain a copy of
  5.  * the License at http://www.mozilla.org/MPL/
  6.  * 
  7.  * Software distributed under the License is distributed on an "AS
  8.  * IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or
  9.  * implied. See the License for the specific language governing
  10.  * rights and limitations under the License.
  11.  * 
  12.  * The Original Code is MPEG4IP.
  13.  * 
  14.  * The Initial Developer of the Original Code is Cisco Systems Inc.
  15.  * Portions created by Cisco Systems Inc. are
  16.  * Copyright (C) Cisco Systems Inc. 2000-2002.  All Rights Reserved.
  17.  * 
  18.  * Contributor(s): 
  19.  * Dave Mackie dmackie@cisco.com
  20.  * Bill May  wmay@cisco.com
  21.  */
  23. #ifndef __MEDIA_SOURCE_H__
  24. #define __MEDIA_SOURCE_H__
  26. #include "media_node.h"
  27. #include "media_sink.h"
  29. #include "video_util_resize.h"
  31. // forward declarations
  32. class CAudioEncoder;
  33. class CVideoEncoder;
  35. // virtual parent class for audio and/or video sources
  36. // contains all the common media processing code
  38. class CMediaSource : public CMediaNode {
  39. public:
  40. CMediaSource();
  42. ~CMediaSource();
  44. bool AddSink(CMediaSink* pSink);
  46. void RemoveSink(CMediaSink* pSink);
  48. void RemoveAllSinks(void);
  50. void StartVideo(void) {
  51. m_myMsgQueue.send_message(MSG_SOURCE_START_VIDEO,
  52. NULL, 0, m_myMsgQueueSemaphore);
  53. }
  55. void StartAudio(void) {
  56. m_myMsgQueue.send_message(MSG_SOURCE_START_AUDIO,
  57. NULL, 0, m_myMsgQueueSemaphore);
  58. }
  60. void GenerateKeyFrame(void) {
  61. m_myMsgQueue.send_message(MSG_SOURCE_KEY_FRAME,
  62. NULL, 0, m_myMsgQueueSemaphore);
  63. }
  65. virtual bool IsDone() = NULL;
  67. virtual Duration GetElapsedDuration();
  69. virtual float GetProgress() = NULL;
  71. virtual u_int32_t GetNumEncodedVideoFrames() {
  72. return m_videoDstFrameNumber;
  73. }
  75. virtual u_int32_t GetNumEncodedAudioFrames() {
  76. return m_audioDstFrameNumber;
  77. }
  79. void SetVideoSource(CMediaSource* source) {
  80. m_videoSource = source;
  81. }
  83. void AddEncodingDrift(Duration drift) {
  84. // currently there is no thread contention
  85. // for this function, so we omit a mutex
  86. m_otherTotalDrift += drift;
  87. }
  89. protected:
  90. // Video & Audio support
  91. virtual void ProcessMedia();
  92. virtual void ProcessVideo() {
  93. };
  94. virtual void ProcessAudio() {
  95. };
  96. virtual bool IsEndOfVideo() { 
  97. return true;
  98. }
  99. virtual bool IsEndOfAudio() {
  100. return true;
  101. }
  103. void PaceSource();
  105. void ForwardFrame(CMediaFrame* pFrame);
  107. void DoStopSource();
  110. // Video
  112. bool InitVideo(
  113. MediaType srcType,
  114. bool realTime = true);
  116. void SetVideoSrcSize(
  117. u_int16_t srcWidth,
  118. u_int16_t srcHeight,
  119. u_int16_t srcStride,
  120. bool matchAspectRatios = false);
  122. void SetVideoSrcStride(
  123. u_int16_t srcStride);
  125. void ProcessVideoYUVFrame(
  126. u_int8_t* pY,
  127. u_int8_t* pU,
  128. u_int8_t* pV,
  129. u_int16_t yStride,
  130. u_int16_t uvStride,
  131. Timestamp frameTimestamp);
  133. void DoGenerateKeyFrame() {
  134. m_videoWantKeyFrame = true;
  135. }
  137. void DestroyVideoResizer();
  139. void DoStopVideo();
  141. // Audio
  143. bool InitAudio(
  144. bool realTime);
  146. bool SetAudioSrc(
  147. MediaType srcType,
  148. u_int8_t srcChannels,
  149. u_int32_t srcSampleRate);
  151. void ProcessAudioFrame(
  152. u_int8_t* frameData,
  153. u_int32_t frameDataLength,
  154. Timestamp frameTimestamp,
  155. bool resync);
  157. void ResampleAudio(
  158. u_int8_t* frameData,
  159. u_int32_t frameDataLength);
  161. void ForwardEncodedAudioFrames(
  162. Timestamp baseTimestamp,
  163. u_int32_t* pNumSamples,
  164. u_int32_t* pNumFrames);
  166. void DoStopAudio();
  168. // audio utility routines
  170. Duration SrcSamplesToTicks(u_int32_t numSamples) {
  171. return (numSamples * TimestampTicks) / m_audioSrcSampleRate;
  172. }
  174. Duration DstSamplesToTicks(u_int32_t numSamples) {
  175. return (numSamples * TimestampTicks) / m_audioDstSampleRate;
  176. }
  178. u_int32_t SrcTicksToSamples(Duration duration) {
  179. return (duration * m_audioSrcSampleRate) / TimestampTicks;
  180. }
  182. u_int32_t DstTicksToSamples(Duration duration) {
  183. return (duration * m_audioDstSampleRate) / TimestampTicks;
  184. }
  186. u_int32_t SrcSamplesToBytes(u_int32_t numSamples) {
  187. return (numSamples * m_audioSrcChannels * sizeof(u_int16_t));
  188. }
  190. u_int32_t DstSamplesToBytes(u_int32_t numSamples) {
  191. return (numSamples * m_audioDstChannels * sizeof(u_int16_t));
  192. }
  194. u_int32_t SrcBytesToSamples(u_int32_t numBytes) {
  195. return (numBytes / (m_audioSrcChannels * sizeof(u_int16_t)));
  196. }
  198. u_int32_t DstBytesToSamples(u_int32_t numBytes) {
  199. return (numBytes / (m_audioDstChannels * sizeof(u_int16_t)));
  200. }
  203. protected:
  204. static const int MSG_SOURCE = 2048;
  205. static const int MSG_SOURCE_START_VIDEO = MSG_SOURCE + 1;
  206. static const int MSG_SOURCE_START_AUDIO = MSG_SOURCE + 2;
  207. static const int MSG_SOURCE_KEY_FRAME = MSG_SOURCE + 3;
  209. // sink info
  210. static const u_int16_t MAX_SINKS = 8;
  211. CMediaSink* m_sinks[MAX_SINKS];
  212. SDL_mutex* m_pSinksMutex;
  214. // generic media info
  215. bool m_source;
  216. bool m_sourceVideo;
  217. bool m_sourceAudio;
  218. bool m_sourceRealTime;
  219. bool m_sinkRealTime;
  220. Timestamp m_startTimestamp;
  221. Duration m_maxAheadDuration;
  223. // video source info
  224. CMediaSource* m_videoSource; 
  225. MediaType m_videoSrcType;
  226. u_int32_t m_videoSrcFrameNumber;
  227. u_int16_t m_videoSrcWidth;
  228. u_int16_t m_videoSrcHeight;
  229. u_int16_t m_videoSrcAdjustedHeight;
  230. float m_videoSrcAspectRatio;
  231. u_int32_t m_videoSrcYUVSize;
  232. u_int32_t m_videoSrcYSize;
  233. u_int16_t m_videoSrcYStride;
  234. u_int32_t m_videoSrcUVSize;
  235. u_int16_t m_videoSrcUVStride;
  236. u_int32_t m_videoSrcYCrop;
  237. u_int32_t m_videoSrcUVCrop;
  239. // video destination info
  240. MediaType m_videoDstType;
  241. float m_videoDstFrameRate;
  242. Duration m_videoDstFrameDuration;
  243. u_int32_t m_videoDstFrameNumber;
  244. u_int16_t m_videoDstWidth;
  245. u_int16_t m_videoDstHeight;
  246. float m_videoDstAspectRatio;
  247. u_int32_t m_videoDstYUVSize;
  248. u_int32_t m_videoDstYSize;
  249. u_int32_t m_videoDstUVSize;
  251. // video resizing info
  252. bool m_videoMatchAspectRatios;
  253. image_t* m_videoSrcYImage;
  254. image_t* m_videoDstYImage;
  255. scaler_t* m_videoYResizer;
  256. image_t* m_videoSrcUVImage;
  257. image_t* m_videoDstUVImage;
  258. scaler_t* m_videoUVResizer;
  260. // video encoding info
  261. CVideoEncoder* m_videoEncoder;
  262. bool m_videoWantKeyFrame;
  264. // video timing info
  265. u_int32_t m_videoSkippedFrames;
  266. Duration m_videoEncodingDrift;
  267. Duration m_videoEncodingMaxDrift;
  268. Duration m_videoSrcElapsedDuration;
  269. Duration m_videoDstElapsedDuration;
  270. Duration m_otherTotalDrift;
  271. Duration m_otherLastTotalDrift;
  273. // video previous frame info
  274. u_int8_t* m_videoDstPrevImage;
  275. u_int8_t* m_videoDstPrevReconstructImage;
  276. u_int8_t* m_videoDstPrevFrame;
  277. u_int32_t m_videoDstPrevFrameLength;
  280. // audio source info 
  281. MediaType m_audioSrcType;
  282. u_int8_t m_audioSrcChannels;
  283. u_int32_t m_audioSrcSampleRate;
  284. u_int16_t m_audioSrcSamplesPerFrame;
  285. u_int64_t m_audioSrcSampleNumber;
  286. u_int32_t m_audioSrcFrameNumber;
  288. // audio resampling info
  289. int16_t* m_audioResampleInputBuffer;
  290. u_int32_t m_audioResampleInputNumber;
  291. bool m_audioResampleUseLinear;
  293. // audio destination info
  294. MediaType m_audioDstType;
  295. u_int8_t m_audioDstChannels;
  296. u_int32_t m_audioDstSampleRate;
  297. u_int16_t m_audioDstSamplesPerFrame;
  298. u_int64_t m_audioDstSampleNumber;
  299. u_int32_t m_audioDstFrameNumber;
  300. u_int64_t m_audioDstRawSampleNumber;
  301. u_int32_t m_audioDstRawFrameNumber;
  303. // audio encoding info
  304. u_int8_t* m_audioPreEncodingBuffer;
  305. u_int32_t m_audioPreEncodingBufferLength;
  306. u_int32_t m_audioPreEncodingBufferMaxLength;
  307. CAudioEncoder* m_audioEncoder;
  309. // audio timing info
  310. Duration m_audioSrcElapsedDuration;
  311. Duration m_audioDstElapsedDuration;
  312. };
  314. #endif /* __MEDIA_SOURCE_H__ */