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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 嵌入式/单片机编程 > VxWorks > 查看源码
msgQDistLibP.h
资源名称：vxwork_src.rar　[点击查看]
上传用户：nvosite88
上传日期：2007-01-17
资源大小：4983k
文件大小：8k
源码类别：

VxWorks

开发平台：

C/C++

msgQDistLibP.h：源码内容
  1. /* msgQDistLibP.h - distributed message queue library private hdr (VxFusion) */
  3. /* Copyright 1999 Wind River Systems, Inc. */
  5. /*
  6. modification history
  7. --------------------
  8. 01e,24may99,drm  added vxfusion prefix to VxFusion related includes
  9. 01d,19feb99,drm  added remoteError member to send/receive _INQ packets
  10. 01c,21may98,drm  removed redundant #include statement
  11. 01b,08may98,ur   removed 8 bit node id restriction
  12. 01a,06jun97,ur   written
  13. */
  15. #ifndef __INCmsgQDistLibPh
  16. #define __INCmsgQDistLibPh
  18. #ifdef __cplusplus
  19. extern "C" {
  20. #endif
  22. #include "vxWorks.h"
  23. #include "sllLib.h"
  24. #include "msgQLib.h"
  25. #include "private/semLibP.h"
  26. #include "vxfusion/private/distNodeLibP.h"
  27. #include "vxfusion/private/distPktLibP.h"
  28. #include "vxfusion/private/distObjLibP.h"
  30. /* defines */
  32. #define msgQDistTblLock() semTake(&msgQDistTblLock, WAIT_FOREVER)
  33. #define msgQDistTblUnlock() semGive(&msgQDistTblLock)
  35. #define IS_DIST_MSG_Q_OBJ(pObjNode) 
  36. ((pObjNode)->objNodeType == DIST_OBJ_TYPE_MSG_Q)
  38. /* DIST_MSG_Q_ID looks like this: |----tblIx-or-grpId----|-type-| */
  40. #define DIST_MSG_Q_TYPE_SHIFT 1
  41. #define DIST_MSG_Q_TYPE_MSG_Q 0x0 /* message queue */
  42. #define DIST_MSG_Q_TYPE_MSG_Q_GRP 0x1 /* message queue group */
  44. #define IS_DIST_MSG_Q_TYPE_GRP(distMsgQId) 
  45. (((distMsgQId) & ((1 << DIST_MSG_Q_TYPE_SHIFT) - 1)) == 
  46.  DIST_MSG_Q_TYPE_MSG_Q_GRP)
  48. /* message queue service */
  50. #define DIST_MSG_Q_SERV_NAME "tServMsgQ"
  51. #define DIST_MSG_Q_SERV_TASK_PRIO 50
  52. #define DIST_MSG_Q_SERV_TASK_STACK_SZ 5000
  54. #define DIST_MSG_Q_SERV_NET_PRIO 0
  56. #define DIST_MSG_Q_WAIT_TASK_PRIO 50
  57. #define DIST_MSG_Q_WAIT_TASK_STACK_SZ 5000
  59. /* priority stuff */
  61. #define DIST_MSG_PRI_MASK (0x07)
  63. #define DIST_MSG_Q_PRIO_VERIFY(msgQPrio) 
  64. (((msgQPrio) == MSG_PRI_URGENT) || 
  65.  ((msgQPrio) == MSG_PRI_NORMAL) || 
  66.  (((msgQPrio) >= DIST_MSG_PRI_0) && ((msgQPrio) <= DIST_MSG_PRI_7)))
  68. #define DIST_MSG_Q_PRIO_TO_NET_PRIO(msgQPrio) 
  69. (((msgQPrio) == MSG_PRI_URGENT) ? 
  70. ((int) (DIST_MSG_PRI_0 & DIST_MSG_PRI_MASK)) : 
  71.  ((msgQPrio) == MSG_PRI_NORMAL) ? 
  72. ((int) (DIST_MSG_PRI_4 & DIST_MSG_PRI_MASK)) : 
  73.  ((int) ((msgQPrio) & DIST_MSG_PRI_MASK)))
  75. #define DIST_MSG_Q_PRIO_TO_MSG_Q_PRIO(msgQPrio) 
  76. (((msgQPrio) == MSG_PRI_URGENT) ? MSG_PRI_URGENT : 
  77.  ((msgQPrio) == MSG_PRI_NORMAL) ? MSG_PRI_NORMAL : 
  78.  (((msgQPrio) <= DIST_MSG_PRI_3) ?  MSG_PRI_URGENT : MSG_PRI_NORMAL))
  80. #define NET_PRIO_TO_DIST_MSG_Q_PRIO(netPrio) 
  81. (((netPrio) <= 3) ?  MSG_PRI_URGENT : MSG_PRI_NORMAL)
  83. /* packet subtypes of DIST_PKT_TYPE_MSG_Q */
  84. #define DIST_PKT_TYPE_MSG_Q_SEND 0 /* send a message */
  85. #define DIST_PKT_TYPE_MSG_Q_RECV_REQ 1 /* ask for a message */
  86. #define DIST_PKT_TYPE_MSG_Q_RECV_RPL 2 /* return message */
  87. #define DIST_PKT_TYPE_MSG_Q_NUM_MSGS_REQ 3 /* ask for num messages */
  88. #define DIST_PKT_TYPE_MSG_Q_NUM_MSGS_RPL 4 /* reply with num messages */
  89. #define DIST_PKT_TYPE_MSG_Q_STATUS 64 /* status */
  91. #define DIST_MSG_Q_INQ_TYPE_NUM_MSGS ((0 << 8) | DIST_MSG_Q_INQ)
  92. #define DIST_MSG_Q_INQ_TYPE_RECV ((1 << 8) | DIST_MSG_Q_INQ)
  93. #define DIST_MSG_Q_INQ_TYPE_SEND ((2 << 8) | DIST_MSG_Q_INQ)
  95. #define MSG_Q_DIST_STATUS_OK OK /* OK--no error */
  96. #define MSG_Q_DIST_STATUS_ERROR 1 /* general error */
  97. #define MSG_Q_DIST_STATUS_TIMEOUT 2 /* timeout */
  98. #define MSG_Q_DIST_STATUS_UNAVAIL 3 /* message unavailable */
  99. #define MSG_Q_DIST_STATUS_UNREACH 4 /* remote node is unreachable */
  100. #define MSG_Q_DIST_STATUS_ILLEGAL_OBJ_ID 5 /* illegal object id */
  101. #define MSG_Q_DIST_STATUS_NOT_ENOUGH_MEMORY 6 /* out of memory */
  102. #define MSG_Q_DIST_STATUS_INTERNAL_ERROR 7 /* internal error */
  103. #define MSG_Q_DIST_STATUS_PROTOCOL_ERROR 8 /* protocol error */
  104. #define MSG_Q_DIST_STATUS_LOCAL_TIMEOUT 9 /* local timeout */
  106. #define DIST_MSG_Q_NUM_MSGS_PRIO (servTable[DIST_ID_MSG_Q_SERV].servNetPrio)
  107. #define DIST_MSG_Q_RECV_PRIO (servTable[DIST_ID_MSG_Q_SERV].servNetPrio)
  108. #define DIST_MSG_Q_ERROR_PRIO (servTable[DIST_ID_MSG_Q_SERV].servNetPrio)
  110. #define DIST_MSG_Q_TYPE_NBITS 1
  111. #define DIST_MSG_Q_TYPE_MASK 0x1L
  112. #define TYPE_DIST_MSG_Q 0L
  113. #define TYPE_DIST_MSG_Q_GRP 1L
  115. /* maximum number of nodes on the net */
  116. #define DIST_MSG_Q_MAX_NODES_LOG2 8
  117. #define DIST_MSG_Q_MAX_NODES 256
  119. /* maximum number of local message queues */
  120. #define DIST_MSG_Q_MAX_QS_LOG2 8
  121. #define DIST_MSG_Q_MAX_QS 256
  123. /* size of table for local message queues */
  124. #define TBL_SIZE 64
  125. #if TBL_SIZE > DIST_MSG_Q_MAX_QS
  126. #error "Too many local message queues for underlying layer!"
  127. #endif
  129. /*
  130.  * MSG_Q_ID -> foo
  131.  */
  133. /* MSG_Q_ID -> DIST_OBJ_NODE */
  134. #define MSG_Q_ID_TO_DIST_OBJ_NODE(msgQId) 
  135. ((DIST_OBJ_NODE *) (((uint32_t) msgQId) & ~VX_TYPE_OBJ_MASK))
  137. /*
  138.  * DIST_OBJ_NODE -> foo
  139.  */
  141. /* DIST_OBJ_NODE -> MSG_Q_ID */
  142. #define DIST_OBJ_NODE_TO_MSG_Q_ID(pObjNode) 
  143. ((MSG_Q_ID) (((uint32_t) pObjNode) | VX_TYPE_DIST_OBJ))
  145. /*
  146.  * DIST_MSG_Q_ID -> foo
  147.  */
  149. /* DIST_MSG_Q_ID -> DIST_MSG_Q_GRP_ID */
  150. #define DIST_MSG_Q_ID_TO_DIST_MSG_Q_GRP_ID(distMsgQId) 
  151. ((DIST_MSG_Q_GRP_ID) ((distMsgQId) >> DIST_MSG_Q_TYPE_SHIFT))
  153. /* DIST_MSG_Q_ID -> TBL_IX */
  154. #define DIST_MSG_Q_ID_TO_TBL_IX(distMsgQId) 
  155. ((TBL_IX) ((distMsgQId) >> DIST_MSG_Q_TYPE_SHIFT))
  157. /*
  158.  * DIST_MSG_Q_GRP_ID -> foo
  159.  */
  161. /* DIST_MSG_Q_GRP_ID -> DIST_MSG_Q_ID */
  162. #define DIST_MSG_Q_GRP_ID_TO_DIST_MSG_Q_ID(distMsgQGrpId) 
  163. ((DIST_MSG_Q_ID) 
  164.  (((uint32_t) (distMsgQGrpId) << DIST_MSG_Q_TYPE_SHIFT) | 
  165.   DIST_MSG_Q_TYPE_MSG_Q_GRP))
  167. /*
  168.  * TBL_IX -> foo
  169.  */
  171. /* TBL_IX -> DIST_MSG_Q_ID */
  172. #define TBL_IX_TO_DIST_MSG_Q_ID(tblIx) 
  173. ((DIST_MSG_Q_ID) 
  174.  (((uint32_t) (tblIx) << DIST_MSG_Q_TYPE_SHIFT) | 
  175.   DIST_MSG_Q_TYPE_MSG_Q))
  177. /*
  178.  * IS_xxx
  179.  */
  181. /* typedefs and structures */
  183. typedef uint32_t DIST_MSG_Q_ID; /* DIST_MSG_Q_ID */
  184. typedef uint16_t DIST_MSG_Q_SNGL_ID; /* DIST_MSG_Q_SNGL_ID */
  185. typedef uint16_t DIST_MSG_Q_GRP_ID; /* DIST_MSG_Q_GRP_ID */
  186. typedef uint8_t TBL_IX; /* TBL_IX */
  188. typedef short DIST_MSG_Q_STATUS; /* DIST_MSG_Q_STATUS */
  190. typedef struct  /* TBL_NODE */
  191. {
  192. union
  193. {
  194. SL_NODE nxtFree;
  195. MSG_Q_ID msgQId;
  196. } tblNodeType;
  197. TBL_IX   tblIx;
  198. } TBL_NODE;
  200. #define tblNxtFree tblNodeType.nxtFree
  201. #define tblMsgQId tblNodeType.msgQId
  203. /*
  204.  * Header for a packet addressed to a remote message queue.
  205.  */
  207. typedef struct /* DIST_PKT_MSG_Q_SEND */
  208. {
  209. DIST_PKT sendHdr;
  210. uint32_t sendInqId;
  211. uint32_t sendTimeout;
  212. TBL_IX sendTblIx; /* uint8_t */
  213. __DIST_PKT_HDR_END__
  214. /* message follows */
  215. } DIST_PKT_MSG_Q_SEND;
  217. typedef struct /* DIST_PKT_MSG_Q_RECV_REQ */
  218. {
  219. DIST_PKT recvReqHdr;
  220. uint32_t recvReqInqId;
  221. uint32_t recvReqMaxNBytes;
  222. uint32_t recvReqTimeout;
  223. TBL_IX recvReqTblIx; /* uint8_t */
  224. __DIST_PKT_HDR_END__
  225. } DIST_PKT_MSG_Q_RECV_REQ;
  227. typedef struct /* DIST_PKT_MSG_Q_RECV_RPL */
  228. {
  229. DIST_PKT recvRplHdr;
  230. uint32_t recvRplInqId;
  231. __DIST_PKT_HDR_END__
  232. /* message follows */
  233. } DIST_PKT_MSG_Q_RECV_RPL;
  235. typedef struct /* DIST_PKT_MSG_Q_NUM_MSGS_REQ */
  236. {
  237. DIST_PKT numMsgsReqHdr;
  238. uint32_t numMsgsReqInqId;
  239. TBL_IX numMsgsReqTblIx; /* uint8_t */
  240. __DIST_PKT_HDR_END__
  241. } DIST_PKT_MSG_Q_NUM_MSGS_REQ;
  243. typedef struct /* DIST_PKT_MSG_Q_NUM_MSGS_RPL */
  244. {
  245. DIST_PKT numMsgsRplHdr;
  246. uint32_t numMsgsRplInqId;
  247. uint32_t numMsgsRplNum;
  248. __DIST_PKT_HDR_END__
  249. } DIST_PKT_MSG_Q_NUM_MSGS_RPL;
  251. typedef struct /* DIST_PKT_MSG_Q_STATUS */
  252. {
  253. DIST_PKT statusHdr;
  254. uint32_t statusInqId;
  255. uint32_t statusErrno;
  256. uint16_t statusDStatus;
  257. __DIST_PKT_HDR_END__
  258. } DIST_PKT_MSG_Q_STATUS;
  260. /*
  261.  * Inquiry nodes.
  262.  */
  264. typedef struct /* DIST_MSG_Q_SEND_INQ */
  265. {
  266. DIST_INQ sendInq;
  267. SEMAPHORE sendInqWait;
  268. int sendInqTask;
  269. BOOL sendInqMsgQueued;
  270. BOOL        remoteError;
  271. } DIST_MSG_Q_SEND_INQ;
  273. typedef struct /* DIST_MSG_Q_RECV_INQ */
  274. {
  275. DIST_INQ recvInq;
  276. SEMAPHORE recvInqWait;
  277. int recvInqTask;
  278. char *pRecvInqBuffer;
  279. UINT recvInqMaxNBytes;
  280. BOOL recvInqMsgArrived;
  281. BOOL        remoteError;
  282. } DIST_MSG_Q_RECV_INQ;
  284. typedef struct /* DIST_MSG_Q_NUM_MSGS_INQ */
  285. {
  286. DIST_INQ numMsgsInq;
  287. SEMAPHORE numMsgsInqWait;
  288. int numMsgsInqTask;
  289. int numMsgsInqNum;
  290. } DIST_MSG_Q_NUM_MSGS_INQ;
  292. extern FUNCPTR msgQDistShowRtn;
  293. extern FUNCPTR msgQDistInfoGetRtn;
  295. /* function declarations */
  297. #if defined(__STDC__) || defined(__cplusplus)
  299. MSG_Q_ID msgQDistGetMapped (MSG_Q_ID msgQId);
  301. #else   /* __STDC__ */
  303. MSG_Q_ID msgQDistGetMapped ();
  305. #endif  /* __STDC__ */
  307. #ifdef __cplusplus
  308. }
  309. #endif
  311. #endif /* __INCmsgQDistLibPh */