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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 多媒体 > IP电话/视频会议 > 查看源码
mq.h
资源名称：h323.zip　[点击查看]
上传用户：hnnddl
上传日期：2007-01-06
资源大小：3580k
文件大小：3k
源码类别：

IP电话/视频会议

开发平台：

WINDOWS

mq.h：源码内容
  1. /*
  2.  * $Revision: 1.4 $
  3.  * $Date: 1998/05/19 18:16:23 $
  4.  */
  6. ////////////////////////////////////////////////////////////////
  7. //               Copyright (c) 1996,97 Lucent Technologies    //
  8. //                       All Rights Reserved                  //
  9. //                                                            //
  10. //                       THIS IS UNPUBLISHED                  //
  11. //                       PROPRIETARY SOURCE                   //
  12. //                   CODE OF Lucent Technologies              //
  13. // AND elemedia   //
  14. //                                                            //
  15. ////////////////////////////////////////////////////////////////
  16. //
  17. ////////////////////////////////////////////////////////////////
  18. // Example programs are provided soley to demonstrate one     //
  19. // possible use of the stack libraries and are included for   //
  20. // instructional purposes only.  You are free to use, modify  //
  21. // and/or redistribute any portion of code in the example     //
  22. // programs.  However, such examples are not intended to      //
  23. // represent production quality code.                         //
  24. //                                                            //
  25. // THE COPYRIGHT HOLDERS PROVIDE THESE EXAMPLE PROGRAMS       //
  26. // "AS IS" WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED     //
  27. // OR IMPLIED, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED     //
  28. // WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A            //
  29. // PARTICULAR PURPOSE.                                        //
  30. ////////////////////////////////////////////////////////////////
  32. #if !defined(__MQ_H__)
  33. #define __MQ_H__
  35. #if (defined(WIN32))
  36. #include <windows.h>
  37. #elif defined(VXWORKS)
  38. #include "vxWorks.h"
  39. #include "taskLib.h"
  40. #include "semLib.h"
  41. #include "selectLib.h"
  42. #include "fcntl.h"
  43. #include "sockLib.h"
  44. #include "inetLib.h"
  45. #include "msgQLib.h"
  46. #else
  47. #if (defined(__hpux))
  48. #include <pthread.h>
  49. #else
  50. #include <thread.h>
  51. #include <synch.h>
  52. #endif
  53. #endif
  54. #if (defined(WIN32))
  55. #include <windows.h>
  56. #endif
  58. struct USER_MESSAGE
  59. {
  60. int message;
  61. int wParam;
  62. int lParam;
  63. };
  65. class MessageQueue
  66. {
  67. public:
  69. MessageQueue(char *name, int mqlen, unsigned long param);
  70. virtual ~MessageQueue();
  71. void QueueMessage(USER_MESSAGE *msg);
  72. int DequeueMessage(USER_MESSAGE *msg);
  74. // Start listener thread.
  75. int Start();
  77. // Stop listener thread.
  78. void Stop();
  80. virtual void NotifyMessage(USER_MESSAGE&) = 0;
  82. protected:
  84. void wait_for_message();
  86. struct mqueue_node
  87. {
  88. USER_MESSAGE msg;
  89. mqueue_node *next;
  90. } *mqueue_head, *mqueue_tail;
  92. int q_len;
  93. char q_name[80];
  95. #if defined(WIN32)
  96. unsigned long  thread_id;
  97. HANDLE  thread_handle;
  98. static unsigned __stdcall _boot(void *context);
  99. #elif defined(VXWORKS)
  100. MSG_Q_ID mqueue_id;
  101. int thread_id;
  102. SEM_ID thread_exited_flag;
  103. static int _boot(void *context);
  104. #elif (defined(__hpux))
  105. pthread_mutex_t mutex;
  106. pthread_cond_t mqueue_not_empty;
  107. pthread_t thread_id;
  108. static void *_boot(void *context);
  109. #else
  110. mutex_t mutex;
  111. cond_t mqueue_not_empty;
  112. thread_t  thread_id;
  113. static void *_boot(void *context);
  114. #endif
  116. };
  118. #if (defined(WIN32))
  119. #define USER_MESSAGE_ID (WM_USER + 1001)
  120. #else
  121. #define WM_USER 100
  122. #endif
  124. #define MQ_INTERNAL_ID WM_USER + 100
  126. #endif