|
|
|
Examples one and two illustrate using the AIF:OS system calls to send and
receive data. These two examples are written in HP C/iX.
To compile the source code for SEND1S:
ccxl send1s,,$null;info="-Aa +e"
link from=$oldpass,xdbend.lib.sys;to=send1p;&
cap=ia,pm;rl=libcinit.lib.sys
This is the source code for program SEND1S:
 or
View in browser
#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 AIFPORTSEND
#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];
/*
This program SEND1S and its counterpart RECV1S 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] = "PORT2 ";
char port_password[17] = "PORT2_PASS ";
int access_mode = 2;
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 = 2;
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 */
/******************************************************************/
/* send_stng */
/******************************************************************/
void send_stng ( int *port_id, char *stng, int msg_pri )
{
int stng_len;
stng_len = strlen (stng);
itemnum_array[0] = 11102;
item_array[0] = &msg_pri; /* set the pri*/
itemnum_array[1] = 0;
printf ("\nSending msg: %s: to port: %d at priority %d\n",
stng, *port_id, msg_pri);
GETPRIVMODE ();
AIFPORTSEND ( &overall_status, port_id, stng, stng_len,
,, itemnum_array, item_array, itemstatus_array );
GETUSERMODE ();
if (overall_status.word) {
strcpy (error_stng, "AIFPORTSEND intrinsic error");
fatal_aif_error ( &overall_status, error_stng,
itemstatus_array );
}
} /* send_stng */
/******************************************************************/
/* MAIN */
/******************************************************************/
int main ( int argc, char *argv[], char *envp[], int parm )
{
char stng[80];
char pri_stng[20];
int msg_pri;
open_port ( &port_id );
printf ("\n\nEnter message to be sent (Q to quit) : ");
gets (stng);
while (strncmp (stng, "Q", 1) != 0) {
printf ("\n\nEnter message priority : ");
gets (pri_stng);
msg_pri = atoi (pri_stng);
send_stng ( &port_id, stng, msg_pri );
printf ("\n\nEnter message to be sent (Q to quit) : ");
gets (stng);
}
close_port ( &port_id );
}
|
