OpenVMS マニュアル

#include <stdio.h> 
#include <starlet.h> 
#include <cmbdef.h> 
#include <types.h> 
#include <descrip.h> 
#include <efndef.h> 
#include <iodef.h> 
#include <iosbdef.h> 
#include <ssdef.h> 
#include <string.h> 
 
#include "mbxtest.h" 
 
int main (int argc, char **argv) 
{ 
    unsigned int status, write_ef; 
    char line_buf [LINE_MAX_LEN + 1]; 
    iosb myiosb; 
    short mbxchan; 
 
    /* Get event flag.  Look for or create the mailbox. 
     */ 
    status = lib$get_ef (&write_ef); 
    if (!(status & 1)) 
    { 
 fprintf (stderr, "Server unable to get eventflag, 
                                  status = %x", status); 
 return 0; 
    } 
    status = sys$crembx (0, &mbxchan, 0, 0, 0, 0, &mbxname_dsc, 
                                  CMB$M_WRITEONLY, 0); 
    if (!(status & 1)) 
    { 
 fprintf (stderr, "Server unable to open mailbox, 
                                  status = %x", status); 
 return 0; 
    } 
 
    /* Open for business.  Loop looking for and processing requests. 
     */ 
    while (TRUE) 
    { 
 printf ("Input command: "); 
 gets (&line_buf); 
 
 status = sys$clref (write_ef); 
 if (!(status & 1)) 
 { 
     fprintf (stderr, "Client unable to clear read event flag, 
                                  status = %x", status); 
     return 0; 
 } 
 status = sys$qiow (write_ef, mbxchan, 
                                  IO$_SETMODE | IO$M_READERWAIT, &myiosb, 
                           0, 0, 0, 0, 0, 0, 0, 0); 
 
 if ((status) && (myiosb.iosb$w_status)) 
 { 
     status = sys$clref (write_ef); 
     if (!(status & 1)) 
     { 
  fprintf (stderr, "Client unable to clear read event flag, 
                                  status = %x", status); 
  return 0; 
     } 
     if (strlen (line_buf) == 0) 
  status = sys$qio (write_ef, mbxchan, IO$_WRITEOF | IO$M_READERCHECK, &myiosb, 
              0, 0, 0, 0, 0, 0, 0, 0); 
     else 
  status = sys$qio (write_ef, mbxchan, IO$_WRITEVBLK | IO$M_READERCHECK, &myiosb, 
              0, 0, line_buf, strlen (line_buf), 0, 0, 0, 0); 
     if (status) 
     { 
  status = sys$waitfr (write_ef); 
  if ((myiosb.iosb$w_status & 1) && (status & 1)) 
                { 
      if (strlen (line_buf) == 0) 
   break; 
  } 
  else 
      fprintf (stderr, "Server failure during write, 
                             status = %x, iosb$w_status = %x\n", 
               status, myiosb.iosb$w_status); 
     } 
     else 
  fprintf (stderr, "Server failure for write request, 
                             status = %x\n", status); 
 } 
 else 
     fprintf (stderr, "Server failure during wait for reader, 
                             status = %x, iosb$w_status = %x\n", 
               status, myiosb.iosb$w_status);  
    } 
    printf ("\n\nServer done...exiting\n"); 
    return 1; 
} 

#include <stdio.h> 
#include <starlet.h> 
#include <cmbdef.h> 
#include <types.h> 
#include <descrip.h> 
#include <efndef.h> 
#include <iodef.h> 
#include <iosbdef.h> 
#include <ssdef.h> 
#include <string.h> 
 
#include "mbxtest.h" 
 
int main (int argc, char **argv) 
{ 
    unsigned int status, read_ef; 
    iosb myiosb; 
    short mbxchan; 
    char line_buf [LINE_MAX_LEN]; 
 
    /* Get event flag.  Look for or create the mailbox. 
     */ 
    status = lib$get_ef (&read_ef); 
 
    if (!(status & 1)) 
    { 
 fprintf (stderr, "Client unable to get eventflag, status = %x", status); 
 return 0; 
    } 
    status = sys$crembx (0, &mbxchan, 0, 0, 0, 0, &mbxname_dsc, CMB$M_READONLY, 0); 
    if (!(status & 1)) 
    { 
 fprintf (stderr, "Client unable to open mailbox, status = %x", status); 
 return 0; 
    } 
 
    /* Loop requesting, receiving, and processing new data. 
     */ 
    memset (&myiosb, 0, sizeof(myiosb)); 
 
    while (myiosb.iosb$w_status != SS$_ENDOFFILE) 
    { 
 status = sys$qiow (read_ef, mbxchan, IO$_SETMODE | IO$M_WRITERWAIT, &myiosb, 
      0, 0, 0, 0, 0, 0, 0, 0); 
 if ((status) && (myiosb.iosb$w_status)) 
 { 
     status = sys$clref (read_ef); 
     if (!(status & 1)) 
     { 
  fprintf (stderr, "Client unable to clear read event flag, status = %x", status); 
  return 0; 
     } 
     status = sys$qio (read_ef, mbxchan, IO$_READVBLK | IO$M_WRITERCHECK, &myiosb, 
          0, 0, line_buf, sizeof(line_buf), 0, 0, 0, 0); 
     if (status) 
     { 
  status = sys$waitfr (read_ef); 
  if ((myiosb.iosb$w_status & 1) && (status & 1)) 
      puts (line_buf); 
  else if ((myiosb.iosb$w_status != SS$_NOWRITER) && 
                             (myiosb.iosb$w_status != SS$_ENDOFFILE)) 
      fprintf (stderr, "Client failure during read, 
                             status = %x, iosb$w_status = %x\n", 
               status, myiosb.iosb$w_status); 
     } 
     else 
  fprintf (stderr, "Client failure for read request, status = %x\n", status); 
 } 
 else 
     fprintf (stderr, "Client failure during wait for writer, 
                             status = %x, iosb$w_status = %x\n", 
               status, myiosb.iosb$w_status); 
 status = sys$clref (read_ef); 
 if (!(status & 1)) 
 { 
     fprintf (stderr, "Client unable to clear read event flag, 
                             status = %x", status); 
     return 0; 
 } 
    } 
    printf ("\nClient done...exiting\n"); 
    return 1; 
} 

$DESCRIPTOR(mbxname_dsc, "dbg$mptest_mbx"); 
 
#define LINE_MAX_LEN 255