msg_queue.h

网络MPEG4IP流媒体开发源代码

/*
 * The contents of this file are subject to the Mozilla Public
 * License Version 1.1 (the "License"); you may not use this file
 * except in compliance with the License. You may obtain a copy of
 * the License at http://www.mozilla.org/MPL/
 * 
 * Software distributed under the License is distributed on an "AS
 * IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or
 * implied. See the License for the specific language governing
 * rights and limitations under the License.
 * 
 * The Original Code is MPEG4IP.
 * 
 * The Initial Developer of the Original Code is Cisco Systems Inc.
 * Portions created by Cisco Systems Inc. are
 * Copyright (C) Cisco Systems Inc. 2000, 2001.  All Rights Reserved.
 * 
 * Contributor(s): 
 *              Bill May        [e-mail]
 */
/*
 * msg_queue.h - provides a basic, SDL based message passing routine
 */
#ifndef __MSG_QUEUE_H__
#define __MSG_QUEUE_H__ 1

#include "systems.h"
#include <SDL.h>
#include <SDL_thread.h>

class CMsg {
 public:
  CMsg(uint32_t value, void *msg = NULL, uint32_t msg_len = 0);
  CMsg(uint32_t value, uint32_t param);
  ~CMsg(void);
  const void *get_message(uint32_t &len);
  CMsg *get_next(void) { return m_next; };
  void set_next (CMsg *next) { m_next = next; };
  uint32_t get_value(void) { return m_value;};
  int has_param(void) { return m_has_param; };
  uint32_t get_param (void) { return m_param; };
 private:
  CMsg *m_next;
  uint32_t m_value;
  int m_has_param;
  uint32_t m_param;
  uint32_t m_msg_len;
  void *m_msg;
};

class CMsgQueue {
 public:
  CMsgQueue(void);
  ~CMsgQueue(void);
  int send_message(uint32_t msgval,
		   void *msg = NULL,
		   uint32_t msg_len = 0,
		   SDL_sem *sem = NULL);
  int send_message(uint32_t msgval,
	  uint32_t param, 
	  SDL_sem *sem = NULL);
  CMsg *get_message(void);
  void *show_message(void) { return m_msg_queue; };
 private:
  int send_message(CMsg *msg, SDL_sem *sem);
  CMsg *m_msg_queue;
  SDL_mutex *m_msg_queue_mutex;
};

#endif