/* RECV1S */
#pragma list off

#define  _MPEXL_SOURCE     (required by errno.h)

#include <stdio.h>
#include <string.h>
#include <errno.h>   /* t_mpe_status */

#pragma list on

#pragma intrinsic_file "aifintr.pub.sys"
#pragma intrinsic      AIFPORTOPEN
#pragma intrinsic      AIFPORTCLOSE
#pragma intrinsic      AIFPORTRECEIVE

#pragma intrinsic_file "sysintr.pub.sys"
#pragma intrinsic      GETPRIVMODE
#pragma intrinsic      GETUSERMODE

#define num_items      50
typedef int^ item_array_type[num_items];
typedef int  itemnum_array_type[num_items];
typedef t_mpe_status  item_status_array_type[num_items];

#define  FALSE          0
#define  TRUE           1

/*
This program RECV1s and its counterpart SEND1S will use AIF:OS
intrinsics to send and receive data.
*/

   static item_array_type          item_array;
   static itemnum_array_type       itemnum_array;
   static item_status_array_type   itemstatus_array;
   static t_mpe_status             overall_status;
   static char                     error_stng[80];
/*Your valid AIF userid */
   static int                      user_id = 123456789;
   static int                      port_id = 0;

/******************************************************************/
/*                        fatal_aif_error                         */
/******************************************************************/
void fatal_aif_error ( t_mpe_status *overall_status,
                      char* error_stng,
                      item_status_array_type item_status_array )
{
  int i;

  printf ("**** %s\n", error_stng);
  printf ("**** error: Info=%d Subsystem=%d\n",
                overall_status->decode.error_num,
                overall_status->decode.subsys_num );
  for (i=0; i, num_items; i++ ) {
     if (item_status_array[i].decode.error_num) {
       printf("\n Loop: %d error: Info=%d Subsystem=%d\n",
              i, item_status_array[i].decode.error_num,
              item_status_array[i].decode.subsys_num);
         } /* if */
     }     /* for loop */
  QUIT (1);
} /* fatal_aif_error */

/******************************************************************/
/*                        open_port                               */
/******************************************************************/
void open_port ( int *port_id )
{
   char port_name[17]     = "PORT1           ";
   char port_password[17] = "PORT1_PASS      ";
   int  access_mode       = 1;
   int  create_option     = 1; /* default, but showing an example */

   itemnum_array[0] = 11201;
   item_array[0]    = &create_option;
   itemnum_array[1] = 0;
   GETPRIVMODE ();
   *port_id = AIFPORTOPEN ( &overall_status, port_name,
                            port_password, access_mode, user_id,
                            itemnum_array, item_array,
                            itemstatus_array );
   GETUSERMODE ();
   if (overall_status.word) {
      strcpy (error_stng, "AIFPORTOPEN intrinsic error");
      fatal_aif_error ( &overall_status, error_stng,
         itemstatus_array );
      }
} /* open_port */


/******************************************************************/
/*                        close_port                              */
/******************************************************************/
void close_port ( int *port_id )
{
   int  access_mode       = 1;

   GETPRIVMODE ();
   AIFPORTCLOSE (&overall_status, port_id, access_mode);
   GETUSERMODE ();
   if (overall_status.word) {
      strcpy (error_stng, "AIFPORTCLOSE intrinsic error");
      fatal_aif_error ( &overall_status, error_stng,
         itemstatus_array );
      }
} /* close_port */

/******************************************************************/
/*                        receive_stng                            */
/******************************************************************/
int  receive_stng ( int *port_id, char *stng, int stng_len,
                    int msg_pri )
{
   int      time_out = -1;

   itemnum_array[0] = 11002;
   item_array[0]    = &time_out;
   itemnum_array[1] = 11001;
   item_array[1]    = &msg_pri;
   itemnum_array[2] = 0;
   GETPRIVMODE ();
   printf ("\nChecking for msg at pri: %d\n", msg_pri);
   AIFPORTRECEIVE ( &overall_status, port_id, stng, &stng_len,
                    ,, itemnum_array, item_array, itemstatus_array);
   GETUSERMODE ();
   if (( (overall_status.decode.error_num == -111) ||
        (overall_status.decode.error_num == -129)) &&
       (overall_status.decode.subsys_num == 516)) {
       printf ("No message found at that priority\n");
       return FALSE;
       }
   else if (overall_status.word) {
      strcpy (error_stng, "AIFPORTRECEIVE intrinsic error");
      fatal_aif_error ( &overall_status, error_stng,
         itemstatus_array );
      }
   else
      stng[stng_len] = '\0';
      return TRUE;
} /* receive_stng */

/******************************************************************/
/*                               MAIN                             */
/******************************************************************/
int main ( int argc, char *argv[], char *envp[], int parm )
{
   char                            stng[80];
   int                             msg_pri;

   open_port (&port_id);

   printf ("\n\nEnter message priority (0 to quit) : ");
   scanf ("%d", &msg_pri);

   printf ("portid is %d\n", port_id);
   while (msg_pri) {
      if (receive_stng( &port_id, stng, sizeof (stng), msg_pri)) {
         printf ("\nReceived msg: %s  at pri: %d\n", stng, msg_pri);
         }
      printf ("\n\nEnter message priority : ");
      scanf ("%d", &msg_pri);
      }

   close_port (&port_id);
}