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

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

VxWorks

开发平台：

C/C++

msgQDistGrpLibP.h：源码内容
  1. /* msgQDistGrpLibP.h - distributed msg Q group library private hdr (VxFusion) */
  3. /* Copyright 1999 Wind River Systems, Inc. */
  5. /*
  6. modification history
  7. --------------------
  8. 01b,24may99,drm  added vxfusion prefix to VxFusion related includes
  9. 01a,11jun97,ur   written.
  10. */
  12. #ifndef __INCmsgQDistGrpLibPh
  13. #define __INCmsgQDistGrpLibPh
  15. #ifdef __cplusplus
  16. extern "C" {
  17. #endif
  19. #include "vxWorks.h"
  20. #include "sllLib.h"
  21. #include "dllLib.h"
  22. #include "hashLib.h"
  23. #include "sysLib.h"
  24. #include "vxfusion/distLib.h"
  25. #include "vxfusion/private/msgQDistLibP.h"
  26. #include "vxfusion/private/distPktLibP.h"
  27. #include "vxfusion/private/distNetLibP.h"
  28. #include "vxfusion/private/distNodeLibP.h"
  29. #include "vxfusion/private/distNameLibP.h"
  31. extern SEMAPHORE distGrpDbSemaphore;
  32. extern DIST_MSG_Q_GRP_ID distGrpIdNext;
  34. /*
  35.  * defines
  36.  */
  38. #define DIST_DGDB_SERV_NAME "tServDgdb"
  39. #define DIST_DGDB_SERV_TASK_PRIO 50
  40. #define DIST_DGDB_SERV_TASK_STACK_SZ 5000
  42. #define DIST_MSG_Q_GRP_SERV_NAME "tServGrp"
  43. #define DIST_MSG_Q_GRP_SERV_TASK_PRIO 50
  44. #define DIST_MSG_Q_GRP_SERV_TASK_STACK_SZ 5000
  46. #define DIST_GAP_SERV_NAME "tServGap"
  47. #define DIST_GAP_SERV_TASK_PRIO 50
  48. #define DIST_GAP_SERV_TASK_STACK_SZ 5000
  50. #define DIST_DGDB_SERV_NET_PRIO 0
  51. #define DIST_MSG_Q_GRP_SERV_NET_PRIO 0
  52. #define DIST_GAP_SERV_NET_PRIO 0
  54. #define DIST_GAP_MGR_WAKEUP_DSEC 10 /* wakeup manager once a sec */
  55. #define DIST_GAP_MGR_PRIO 50
  56. #define DIST_GAP_MGR_STACK_SZ 5000
  58. #define DIST_MSG_Q_GRP_WAIT_TASK_PRIO 50
  59. #define DIST_MSG_Q_GRP_WAIT_TASK_STACK_SZ 5000
  61. /*
  62.  * The following timeouts are in units of DIST_GAP_MGR_WAKEUP_DSEC.
  63.  */
  64. #define DIST_GAP_TRY_TIMO 2 /* 2 times DIST_GAP_MGR_WAKEUP_DSEC */
  65. #define DIST_GAP_WAIT_TIMO 2 /* 2 times DIST_GAP_MGR_WAKEUP_DSEC */
  67. #define DIST_GAP_MAX_RETRIES 1 /* a single retry */
  69. #define DIST_MSG_Q_GRP_PRIO 
  70. (servTable[DIST_ID_MSG_Q_GRP_SERV].servNetPrio)
  72. #define DIST_DGDB_PRIO 
  73. (servTable[DIST_ID_DGDB_SERV].servNetPrio)
  75. #define DIST_GAP_PRIO 
  76. (servTable[DIST_ID_GAP_SERV].servNetPrio)
  78. /* subtypes of DIST_PKT_TYPE_DGDB */
  80. #define DIST_PKT_TYPE_DGDB_ADD 0
  82. /* subtypes of DIST_PKT_TYPE_MSG_Q_GRP */
  84. #define DIST_PKT_TYPE_MSG_Q_GRP_SEND 0
  85. #define DIST_PKT_TYPE_MSG_Q_GRP_STATUS 1
  87. /* subtypes of DIST_PKT_TYPE_GAP */
  89. #define DIST_PKT_TYPE_GAP_OK 0
  90. #define DIST_PKT_TYPE_GAP_REJECT 1
  91. #define DIST_PKT_TYPE_GAP_TRY 2
  92. #define DIST_PKT_TYPE_GAP_ASK_WAIT 3
  93. #define DIST_PKT_TYPE_GAP_SET 4
  95. /* status codes for distributed groups */
  96. #define MSG_Q_DIST_GRP_STATUS_OK OK
  97. #define MSG_Q_DIST_GRP_STATUS_ERROR 1
  98. #define MSG_Q_DIST_GRP_STATUS_NOT_ENOUGH_MEMORY 2
  99. #define MSG_Q_DIST_GRP_STATUS_ILLEGAL_OBJ_ID 3
  100. #define MSG_Q_DIST_GRP_STATUS_PROTOCOL_ERROR 4
  101. #define MSG_Q_DIST_GRP_STATUS_INTERNAL_ERROR 5
  102. #define MSG_Q_DIST_GRP_STATUS_UNAVAIL 6
  103. #define MSG_Q_DIST_GRP_STATUS_LOCAL_TIMEOUT 7
  105. /* status codes for DGDB */
  106. #define DIST_GDB_STATUS_OK OK
  107. #define DIST_GDB_STATUS_PROTOCOL_ERROR 1
  109. /* status codes for GAP */
  110. #define DIST_GAP_STATUS_OK OK
  112. #define DIST_GRP_STATE_LOCAL_TRY 0 /* local node tries to create group */
  113. #define DIST_GRP_STATE_REMOTE_TRY 1 /* remote node tries to create group */
  114. #define DIST_GRP_STATE_WAIT 2 /* wait for id from remote node */
  115. #define DIST_GRP_STATE_WAIT_TRY 3 /* retry after wait */
  116. #define DIST_GRP_STATE_GLOBAL 5 /* group is global */
  118. #define DIST_MSG_Q_GRP_INQ_TYPE_SEND ((0 << 8) | DIST_MSG_Q_GRP_INQ)
  120. #define DIST_GAP_MGR_WAKEUP_TICKS 
  121. (DIST_GAP_MGR_WAKEUP_DSEC * (sysClkRateGet () / 10))
  123. #define msgQDistGrpLclGetId(distGrpDbNode) 
  124. ((distGrpDbNode)->grpDbId)
  125. /* msgQDistGrpLclSetId() is a function */
  127. #define msgQDistGrpLclGetState(distGrpDbNode) 
  128. ((distGrpDbNode)->grpDbState)
  129. #define msgQDistGrpLclSetState(distGrpDbNode, distGrpState) 
  130. ((distGrpDbNode)->grpDbState = (distGrpState))
  132. #define msgQDistGrpLclSetCreator(distGrpDbNode, distNodeId) 
  133. ((distGrpDbNode)->grpDbNodeId = (distNodeId))
  135. #define msgQDistGrpDbLockInit()
  136. semBInit (&distGrpDbSemaphore, SEM_Q_PRIORITY, SEM_FULL)
  137. #define msgQDistGrpDbUnlock() 
  138. semGive (&distGrpDbSemaphore)
  139. #define msgQDistGrpDbLock() 
  140. semTake (&distGrpDbSemaphore, WAIT_FOREVER)
  142. #define distGapLockInit() 
  143. semBInit (&distGapSemaphore, SEM_Q_PRIORITY, SEM_FULL)
  144. #define distGapUnlock() 
  145. semGive (&distGapSemaphore)
  146. #define distGapLock() 
  147. semTake (&distGapSemaphore, WAIT_FOREVER)
  149. #define msgQGrpSendInqLockInit(pInqId) 
  150. semBInit (&((pInqId)->sendInqLock), SEM_Q_PRIORITY, SEM_FULL)
  151. #define msgQGrpSendInqUnlock(pInqId) 
  152. semGive (&((pInqId)->sendInqLock))
  153. #define msgQGrpSendInqLock(pInqId) 
  154. semTake (&((pInqId)->sendInqLock), WAIT_FOREVER)
  156. #define DIST_PKT_GAP_MAX_LEN (sizeof (DIST_PKT_GAP_OK))
  158. /*
  159.  * typedefs
  160.  */
  162. /*
  163.  * Forward structure declarations [sic].
  164.  */
  166. #ifdef __STDC__
  167. struct _DIST_GRP_DB_NODE;
  168. #endif
  170. typedef struct /* DIST_GAP_NODE */
  171. {
  172. DL_NODE gapLink;
  173. struct _DIST_GRP_DB_NODE *pGapGrp;
  174. SL_LIST gapOutstand;
  175. short gapTimeout;
  176. short gapRetries;
  177. SEMAPHORE gapWaitFor;
  178. } DIST_GAP_NODE;
  180. typedef struct /* DIST_GAP_RESPONSE */
  181. {
  182. SL_NODE gapResponseNext;
  183. DIST_NODE_DB_NODE *pGapResponseNode;
  184. } DIST_GAP_RESPONSE;
  186. /* MSG_Q_GRP packets */
  188. typedef struct /* DIST_PKT_MSG_Q_GRP_SEND */
  189. {
  190. DIST_PKT pktMsgQGrpSendHdr;
  191. uint32_t pktMsgQGrpSendInqId;
  192. uint32_t pktMsgQGrpSendTimeout;
  193. DIST_MSG_Q_GRP_ID pktMsgQGrpSendId; /* uint16_t */
  194. __DIST_PKT_HDR_END__
  195. /* message follows */
  196. } DIST_PKT_MSG_Q_GRP_SEND;
  198. typedef struct /* DIST_PKT_MSG_Q_GRP_STATUS */
  199. {
  200. DIST_PKT pktMsgQGrpStatusHdr;
  201. uint32_t pktMsgQGrpStatusInqId;
  202. uint32_t pktMsgQGrpStatusErrno;
  203. uint16_t pktMsgQGrpStatusDStatus;
  204. __DIST_PKT_HDR_END__
  205. } DIST_PKT_MSG_Q_GRP_STATUS;
  207. /* DGDB (distributed group database) telegrams */
  209. typedef struct /* DIST_PKT_DGDB_ADD */
  210. {
  211. DIST_PKT pktDgdbAddHdr;
  212. DIST_NODE_ID pktDgdbAddCreator; /* uint32_t */
  213. DIST_MSG_Q_GRP_ID pktDgdbAddId; /* uint16_t */
  214. __DIST_PKT_HDR_END__
  215. /* group name follows */
  216. } DIST_PKT_DGDB_ADD;
  218. /* GAP (group agreement protocol) telegrams */
  220. typedef struct /* DIST_PKT_GAP_OK */
  221. {
  222. DIST_PKT okHdr;
  223. DIST_MSG_Q_GRP_ID okId; /* uint16_t */
  224. char okName[DIST_NAME_MAX_LENGTH + 1];
  225. } DIST_PKT_GAP_OK;
  227. typedef struct /* DIST_PKT_GAP_REJECT */
  228. {
  229. DIST_PKT rejectHdr;
  230. DIST_MSG_Q_GRP_ID rejectId; /* uint16_t */
  231. char rejectName[DIST_NAME_MAX_LENGTH + 1];
  232. } DIST_PKT_GAP_REJECT;
  234. typedef struct /* DIST_PKT_GAP_TRY */
  235. {
  236. DIST_PKT tryHdr;
  237. DIST_MSG_Q_GRP_ID tryId; /* uint16_t */
  238. char tryName[DIST_NAME_MAX_LENGTH + 1];
  239. } DIST_PKT_GAP_TRY;
  241. typedef struct /* DIST_PKT_GAP_ASK_WAIT */
  242. {
  243. DIST_PKT askWaitHdr;
  244. DIST_MSG_Q_GRP_ID askWaitId; /* uint16_t */
  245. char askWaitName[DIST_NAME_MAX_LENGTH + 1];
  246. } DIST_PKT_GAP_ASK_WAIT;
  248. typedef struct /* DIST_PKT_GAP_SET */
  249. {
  250. DIST_PKT setHdr;
  251. DIST_MSG_Q_GRP_ID setId; /* uint16_t */
  252. char setName[DIST_NAME_MAX_LENGTH + 1];
  253. } DIST_PKT_GAP_SET;
  255. /* other typedefs */
  257. typedef int DIST_GRP_STATE; /* DIST_GRP_STATE */
  259. typedef struct _DIST_GRP_DB_NODE /* DIST_GRP_DB_NODE */
  260. {
  261. union
  262. {
  263. SL_NODE freeNode; /* used to link free nodes */
  264. struct
  265. {
  266. char distGrpName[DIST_NAME_MAX_LENGTH + 1];
  267. DIST_MSG_Q_GRP_ID distGrpId; /* distributed group id */
  268. MSG_Q_ID msgQId; /* message queue id */
  269. DIST_NODE_ID distNodeId; /* id of the creating node */
  270. SL_LIST msgQIdLst; /* list of members */
  271. DIST_GRP_STATE grpState; /* current state of group */
  272. DIST_GAP_NODE *pDistGapNode; /* ptr to GAP structure */
  273. } dbNode;
  274. } stateNode;
  275. int ixNode;
  276. } DIST_GRP_DB_NODE;
  278. #define grpDbFreeNode stateNode.freeNode
  279. #define grpDbName stateNode.dbNode.distGrpName
  280. #define grpDbId stateNode.dbNode.distGrpId
  281. #define grpDbNodeId stateNode.dbNode.distNodeId
  282. #define grpDbMsgQIdLst stateNode.dbNode.msgQIdLst
  283. #define grpDbState stateNode.dbNode.grpState
  284. #define pGrpDbGapNode stateNode.dbNode.pDistGapNode
  285. #define grpDbMsgQId stateNode.dbNode.msgQId
  287. typedef struct /* DIST_GRP_HASH_NODE */
  288. {
  289. HASH_NODE hashNode;
  290. DIST_GRP_DB_NODE *pDbNode;
  291. } DIST_GRP_HASH_NODE;
  293. typedef struct /* DIST_GRP_MSG_Q_NODE */
  294. {
  295. SL_NODE slNode;
  296. MSG_Q_ID msgQId;
  297. } DIST_GRP_MSG_Q_NODE;
  299. typedef struct /* DIST_GRP_BURST */
  300. {
  301. DIST_NODE_ID burstNodeId;
  302. STATUS burstStatus;
  303. } DIST_GRP_BURST;
  305. typedef struct /* DIST_MSG_Q_GRP_SEND_INQ */
  306. {
  307. DIST_INQ sendInq;
  308. SEMAPHORE sendInqLock; /* lock this group-send inquiry */
  309.     SEMAPHORE sendInqWait;
  310. int sendInqTask;
  311. int sendInqNumBlocked;
  312. int sendInqNumOutstanding;
  313. DIST_STATUS sendInqStatus;
  314. } DIST_MSG_Q_GRP_SEND_INQ;
  316. /* declarations */
  318. #if defined(__STDC__) || defined(__cplusplus)
  320. DIST_MSG_Q_GRP_ID msgQDistGrpAgree (DIST_GRP_DB_NODE *pDistGrpDbNode);
  321. STATUS msgQDistGrpAddMember (DIST_GRP_DB_NODE *pDistGrpDbNode,
  322. MSG_Q_ID msgQId);
  323. STATUS msgQDistGrpSend (DIST_MSG_Q_GRP_ID distMsgQGrpId,
  324. char *buffer, UINT nBytes, int msgQTimeout,
  325. int overallTimeout, int priority);
  326. STATUS msgQDistGrpBurst (DIST_NODE_ID nodeId);
  328. DIST_GRP_DB_NODE *msgQDistGrpLclCreate (char *distGrpName,
  329. DIST_MSG_Q_GRP_ID grpId, DIST_GRP_STATE grpState);
  330. void msgQDistGrpLclSetId (DIST_GRP_DB_NODE *pDistGrpDbNode,
  331. DIST_MSG_Q_GRP_ID grpId);
  332. STATUS msgQDistGrpLclAddMember (DIST_GRP_DB_NODE *pDbNode,
  333. MSG_Q_ID msgQId);
  334. DIST_GRP_DB_NODE *msgQDistGrpLclFindByName (char *distGrpName);
  335. DIST_GRP_DB_NODE *msgQDistGrpLclFindById (DIST_MSG_Q_GRP_ID uniqGrpId);
  336. void msgQDistGrpLclEach (FUNCPTR routine, int routineArg);
  338. STATUS distGapLibInit (void);
  339. DIST_MSG_Q_GRP_ID distGapStart (DIST_GRP_DB_NODE *pDistGrpDbNode);
  340. void distGapNodeInit (DIST_GAP_NODE *pDistGapNode,
  341. DIST_GRP_DB_NODE *pDistGrpDbNode, BOOL link);
  342. void distGapNodeDelete (DIST_GAP_NODE *pDistGapNode);
  344. #else   /* __STDC__ */
  346. DIST_MSG_Q_GRP_ID msgQDistGrpAgree ();
  347. STATUS msgQDistGrpAddMember ();
  348. STATUS msgQDistGrpSend ();
  349. STATUS msgQDistGrpBurst ();
  351. DIST_GRP_DB_NODE *msgQDistGrpLclCreate ();
  352. void msgQDistGrpLclSetId ();
  353. STATUS msgQDistGrpLclAddMember ();
  354. DIST_GRP_DB_NODE *msgQDistGrpLclFindByName ();
  355. DIST_GRP_DB_NODE *msgQDistGrpLclFindById ();
  356. void msgQDistGrpLclEach ();
  358. STATUS distGapLibInit ();
  359. DIST_MSG_Q_GRP_ID distGapStart ();
  360. void distGapNodeInit ();
  361. void distGapNodeDelete ();
  363. #endif  /* __STDC__ */
  366. #ifdef __cplusplus
  367. }
  368. #endif
  370. #endif /* __INCmsgQDistGrpLibPh */