media_sink.h
上传用户:sun1608
上传日期:2007-02-02
资源大小:6116k
文件大小:2k
源码类别:

流媒体/Mpeg4/MP4

开发平台:

Visual C++

  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.  */
  22. #ifndef __MEDIA_SINK_H__
  23. #define __MEDIA_SINK_H__
  24. #include "media_node.h"
  25. class CMediaSink : public CMediaNode {
  26. public:
  27. CMediaSink() : CMediaNode() {
  28. m_sink = false;
  29. m_pEnqueueMutex = SDL_CreateMutex();
  30. if (m_pEnqueueMutex == NULL) {
  31. debug_message("EnqueueFrame CreateMutex error");
  32. }
  33. }
  34. ~CMediaSink() {
  35. SDL_DestroyMutex(m_pEnqueueMutex);
  36. }
  37. void EnqueueFrame(CMediaFrame* pFrame) {
  38. if (pFrame == NULL) {
  39. debug_message("EnqueueFrame: got NULL frame!?");
  40. return;
  41. }
  42. if (SDL_LockMutex(m_pEnqueueMutex) == -1) {
  43. debug_message("EnqueueFrame LockMutex error");
  44. return;
  45. }
  46. pFrame->AddReference();
  47. m_myMsgQueue.send_message(MSG_SINK_FRAME, 
  48. (unsigned char*)pFrame, 0,
  49. m_myMsgQueueSemaphore);
  50. if (SDL_UnlockMutex(m_pEnqueueMutex) == -1) {
  51. debug_message("EnqueueFrame UnlockMutex error");
  52. }
  53. }
  54. protected:
  55. static const int MSG_SINK = 4096;
  56. static const int MSG_SINK_FRAME = MSG_SINK + 1;
  57. bool  m_sink;
  58. SDL_mutex* m_pEnqueueMutex;
  59. };
  60. #endif /* __MEDIA_SINK_H__ */