home *** CD-ROM | disk | FTP | other *** search
/ The C Users' Group Library 1994 August / wc-cdrom-cusersgrouplibrary-1994-08.iso / listings / v_08_11 / 8n11074a < prev    next >
Text File  |  1990-07-31  |  2KB  |  69 lines
  1. /****************** LISTING 3 - comm.c ******************/
  2.  
  3. #include "ipc.h"
  4.  
  5. ULONG open_comm_link(USHORT *mbxid, ULONG mbxsiz, 
  6.             char *mbxname)
  7. {
  8. char    permanence_flag     = TEMPORARY_MBX;
  9. ULONG   protection          = WORLD_ACCESS;
  10. ULONG   access_mode         = PSL$C_USER;
  11. $DESCRIPTOR (mbx_logical_name, mbxname);
  12. mbx_logical_name.dsc$w_length = strlen(mbxname);
  13.  
  14. return (SYS$CREMBX(permanence_flag, mbxid, mbxsiz, mbxsiz, 
  15.             protection, access_mode, &mbx_logical_name));
  16. }
  17.  
  18. ULONG close_comm_link(USHORT mbxid)
  19. {
  20. return (SYS$DASSGN(mbxid));
  21. } 
  22.  
  23.  
  24. ULONG send(USHORT mbxid, MSGBUF *msg, int msgsiz)
  25. {
  26. int               status;
  27. USHORT            func = IO$_WRITEVBLK | IO$M_NOW; 
  28. IO_STATUS_BLOCK   iosb = {0, 0, 0}; 
  29.  
  30. status = SYS$QIOW(0, mbxid, func, &iosb, 0, 0, msg, 
  31.             msgsiz, 0, 0, 0, 0);
  32.  
  33. return status;
  34. }
  35.  
  36.  
  37. ULONG broadcast(MSGBUF *msg, ULONG msgsiz, CLIENT *p)
  38. {
  39. while (p) { 
  40.     send(p->mbxid, msg, msgsiz);
  41.     p = p->link;
  42. }
  43. return SUCCEED;
  44. }
  45.  
  46. void receive(USHORT mbxid)
  47. {
  48. int    status;
  49. USHORT func = IO$_READVBLK;
  50.  
  51. extern RCVBUF msgque[QSIZE];
  52. extern BOOL qfull, qempty, qovrflo;
  53. extern int qtail, qhead;
  54.  
  55. if (!qfull) {
  56.     qempty = FALSE;
  57.     qtail = (++qtail) % QSIZE;
  58.     status = SYS$QIO (RCVEF, mbxid, func, 
  59.                  &msgque[qtail].iosb, &receive, 
  60.                  mbxid, &msgque[qtail].msg, sizeof(MSGBUF),
  61.                  0, 0, 0, 0);
  62.     if (((qtail+1) % QSIZE) == qhead)
  63.         qfull = TRUE;
  64. }
  65. else {
  66.     qovrflo = TRUE;
  67. }
  68. }
  69.