static char rcsid[] =
"$Id: mhf_server.c,v 1.4 1999/01/19 17:45:47 pvmsrc Exp $";
/*
* PVM version 3.4: Parallel Virtual Machine System
* University of Tennessee, Knoxville TN.
* Oak Ridge National Laboratory, Oak Ridge TN.
* Emory University, Atlanta GA.
* Authors: J. J. Dongarra, G. E. Fagg, M. Fischer
* G. A. Geist, J. A. Kohl, R. J. Manchek, P. Mucci,
* P. M. Papadopoulos, S. L. Scott, and V. S. Sunderam
* (C) 1997 All Rights Reserved
*
* NOTICE
*
* Permission to use, copy, modify, and distribute this software and
* its documentation for any purpose and without fee is hereby granted
* provided that the above copyright notice appear in all copies and
* that both the copyright notice and this permission notice appear in
* supporting documentation.
*
* Neither the Institutions (Emory University, Oak Ridge National
* Laboratory, and University of Tennessee) nor the Authors make any
* representations about the suitability of this software for any
* purpose. This software is provided ``as is'' without express or
* implied warranty.
*
* PVM version 3 was funded in part by the U.S. Department of Energy,
* the National Science Foundation and the State of Tennessee.
*/
/***************************************************************
* Filename: mhf_server.c
*
* This is a "server" program for testing message handler functions.
* Use the mhf_tickle program to speak to this server.
*
* Operation:
* 1. startup pvm console
* 2. startup the mhf_server
* 3. startup as many mhf_tickle instances as you wish
* - follow menu options and in-code comments on
* how to run and what it tests / shows...
*
***************************************************************/
#include "stdio.h"
#include "pvm3.h"
#define NOISE1 1 /* sets level of program noise - minimum noise */
/* #define NOISE2 2 each level "up" adds noise */
#define PMH 0 /* display present message handlers */
#define LMH 1 /* load message handler */
#define DMH 2 /* delete message handler */
#define ERJ 3 /* tell mhf_server() to pvm_exit() and rejoin */
#define HIT 4 /* message to hit a specified handler... */
#define GSMB 7 /* NOT USED IN mhf_server() - use to grab the */
/* mhf_server contact info from mailbox again... */
#define CEAT 8 /* client (this program ) exit pvm and terminate */
/* self - server not contacted... */
#define SEAT 9 /* server exits pvm and terminate self */
#define SC1 1 /* string_catcher1 */
#define SC2 2 /* string_catcher2 */
#define SC3 3 /* string_catcher3 */
#define SC4 4 /* string_catcher4 */
#define SC5 5 /* string_catcher5 */
#define IC1 6 /* int_catcher6 */
#define IC2 7 /* int_catcher7 */
#define IC3 8 /* int_catcher8 */
#define IC4 9 /* int_catcher9 */
#define IC5 0 /* int_catcher10 */
#define STR_LEN 100
#define YES 1
#define NO 0
/*
* globals to bring back message handler information
*/
int mhf_catch; /* should be same as number of "catcher" hit */
int mhf_magic_number;
char mhf_msg[STR_LEN];
/**********************************************************************/
/**********************************************************************/
/**********************************************************************
* register this server via "well known" mailbox so others may contact us
* mailbox name is set to... server = "mhf_server"
*
* Returns mailbox index where placed
*/
int
register_server( mytid, ctx, machine, server )
int mytid;
int ctx;
char *machine;
char *server;
{ char *me = "register_server";
int index;
pvm_initsend( PvmDataDefault );
pvm_pkint( &mytid, 1, 1 );
pvm_pkint( &ctx, 1, 1 );
pvm_pkstr( machine );
if ( ( index = pvm_putinfo( server, pvm_getsbuf( ), PvmMboxDefault ) ) < 0 ) {
/*
* problem inserting mailbox entry - tell user why, exit pvm, and terminate task...
*/
switch ( index ) {
case PvmExists:
printf( "\n%s: Named service already running\n", me );
break;
case PvmBadParam:
printf( "\n%s: Invalid argument to pvm_recvinfo( ).\n", me );
break;
case PvmNoSuchBuf:
printf( "\n%s: Message buffer id does not exist.\n", me );
break;
case PvmDenied:
printf( "\n%s: Key locked by another task, can't delete.\n", me );
break;
case PvmNoMem:
printf( "\n%s: Libpvm is unable to allocate memory to pack data.\n", me );
break;
case PvmNotFound:
printf( "\n%s: Requested key does not exist.\n", me );
break;
default:
lpvmerr( "\n%s: task0.c: error %d", me, index );
break;
} /* end_switch */
return( index ); /* returns error code */
}
printf( "%s: mailbox... just inserted server <%s> at mailbox %d with context %d.\n",
me, server, index, ctx );
return( index );
} /* register_server */
/**********************************************************************
* Function: string_catcher1 - unpack 1 string
* string_catcher2 - unpack 2 strings
* string_catcher3 - unpack 3 strings
* string_catcher4 - unpack 4 strings
* string_catcher5 - unpack 5 strings
*
* int_catcher6 - unpack 1 integer
* int_catcher7 - unpack 2 integers
* int_catcher8 - unpack 3 integers
* int_catcher9 - unpack 4 integers
* int_catcher10 - unpack 5 integers
*
* These are all simple message handlers to use in testing loading,
* deleting, and using message handlers.
*
* Each one simply echos out the information that is being sent.
* Thus showing that a given handler may "handle" messages of a given type.
**********************************************************************/
int
string_catcher1( mid )
int mid;
{ char *me = "string_catcher1";
int rbf;
rbf = pvm_setrbuf( mid );
pvm_upkint( &mhf_catch, 1, 1 );
pvm_upkstr( mhf_msg );
printf( "\n%s: string_catcher%d received message -->> <%s>\n\n", me, mhf_catch, mhf_msg );
pvm_freebuf( pvm_setrbuf( rbf ) );
return 0;
} /* string_catcher1 */
int
string_catcher2( mid )
int mid;
{ char *me = "string_catcher2";
int rbf;
rbf = pvm_setrbuf( mid );
pvm_upkint( &mhf_catch, 1, 1 );
pvm_upkstr( mhf_msg );
printf( "\n%s: string_catcher%d received message -->> <%s>\n\n", me, mhf_catch, mhf_msg );
pvm_freebuf( pvm_setrbuf( rbf ) );
return 0;
} /* string_catcher2 */
int
string_catcher3( mid )
int mid;
{ char *me = "string_catcher3";
int rbf;
rbf = pvm_setrbuf( mid );
pvm_upkint( &mhf_catch, 1, 1 );
pvm_upkstr( mhf_msg );
printf( "\n%s: string_catcher%d received message -->> <%s>\n\n", me, mhf_catch, mhf_msg );
pvm_freebuf( pvm_setrbuf( rbf ) );
return 0;
} /* string_catcher3 */
int
string_catcher4( mid )
int mid;
{ char *me = "string_catcher4";
int rbf;
rbf = pvm_setrbuf( mid );
pvm_upkint( &mhf_catch, 1, 1 );
pvm_upkstr( mhf_msg );
printf( "\n%s: string_catcher%d received message -->> <%s>\n\n", me, mhf_catch, mhf_msg );
pvm_freebuf( pvm_setrbuf( rbf ) );
return 0;
} /* string_catcher4 */
int
string_catcher5( mid )
int mid;
{ char *me = "string_catcher5";
int rbf;
rbf = pvm_setrbuf( mid );
pvm_upkint( &mhf_catch, 1, 1 );
pvm_upkstr( mhf_msg );
printf( "\n%s: string_catcher%d received message -->> <%s>\n\n", me, mhf_catch, mhf_msg );
pvm_freebuf( pvm_setrbuf( rbf ) );
return 0;
} /* string_catcher5 */
int
int_catcher6( mid )
int mid;
{ char *me = "int_catcher6";
int rbf;
rbf = pvm_setrbuf( mid );
pvm_upkint( &mhf_catch, 1, 1 );
pvm_upkint( &mhf_magic_number, 1, 1 );
printf( "\n%s: int_catcher%d received magic number -->> %d.\n\n", me, mhf_catch, mhf_magic_number );
pvm_freebuf( pvm_setrbuf( rbf ) );
return 0;
} /* int_catcher6 */
int
int_catcher7( mid )
int mid;
{ char *me = "int_catcher7";
int rbf;
rbf = pvm_setrbuf( mid );
pvm_upkint( &mhf_catch, 1, 1 );
pvm_upkint( &mhf_magic_number, 1, 1 );
printf( "\n%s: int_catcher%d received magic number -->> %d.\n\n", me, mhf_catch, mhf_magic_number );
pvm_freebuf( pvm_setrbuf( rbf ) );
return 0;
} /* int_catcher7 */
int
int_catcher8( mid )
int mid;
{ char *me = "int_catcher8";
int rbf;
rbf = pvm_setrbuf( mid );
pvm_upkint( &mhf_catch, 1, 1 );
pvm_upkint( &mhf_magic_number, 1, 1 );
printf( "\n%s: int_catcher%d received magic number -->> %d.\n\n", me, mhf_catch, mhf_magic_number );
pvm_freebuf( pvm_setrbuf( rbf ) );
return 0;
} /* int_catcher8 */
int
int_catcher9( mid )
int mid;
{ char *me = "int_catcher9";
int rbf;
rbf = pvm_setrbuf( mid );
pvm_upkint( &mhf_catch, 1, 1 );
pvm_upkint( &mhf_magic_number, 1, 1 );
printf( "\n%s: int_catcher%d received magic number -->> %d.\n\n", me, mhf_catch, mhf_magic_number );
pvm_freebuf( pvm_setrbuf( rbf ) );
return 0;
} /* int_catcher9 */
int
int_catcher10( mid )
int mid;
{ char *me = "int_catcher10";
int rbf;
rbf = pvm_setrbuf( mid );
pvm_upkint( &mhf_catch, 1, 1 );
pvm_upkint( &mhf_magic_number, 1, 1 );
printf( "\n%s: int_catcher%d received magic number -->> %d.\n\n", me, mhf_catch, mhf_magic_number );
pvm_freebuf( pvm_setrbuf( rbf ) );
return 0;
} /* int_catcher10 */
/**********************************************************************/
/**********************************************************************/
/**********************************************************************/
main ( argc, argv )
int argc;
char *argv[];
{ char *me = "mhf_server";
int cc; /* local stuff */
int mytid; /* tid of this server */
int ctid; /* tid of request sender - to this server */
int msgtag; /* sender specified message tag */
int length; /* length of message */
int sctx; /* server's context */
int info; /* status return and temporary input values */
int mhid; /* message handler id */
int lmh; /* int represent local message handler to ping */
int index; /* mailbox entry index */
char msg[STR_LEN]; /* used for local info messages */
char msg_txt[STR_LEN]; /* used for received messages */
char machine[25];
int FOREVER = YES;
/*
* for display - note IC5 position
*/
static char *mh_arr[] = { "IC5", "SC1", "SC2", "SC3", "SC4", "SC5", "IC1",
"IC2", "IC3", "IC4" };
/* expected message information coming from "tickle" program */
char action_tag; /* action for server to take -> p, l, d, x j */
int src; /* message source = sender's tid */
int tag; /* message tag */
int ctx; /* message context */
if ( ( mytid = pvm_mytid( ) ) < 0 ){
printf( "\n%s: try starting pvm first...\n", me );
exit( -1 );
}
gethostname( machine, 25 );
sctx = pvm_newcontext( ); /* get new context */
pvm_setcontext( sctx ); /* activate new context */
printf( "%s: t%x on machine <%s> with context %d.\n",
me, mytid, machine, pvm_getcontext( ) );
if ( register_server( mytid, sctx, machine, me ) < 0 ){
pvm_exit( );
exit( -1 );
}
pvmdisplaymhfinfo( me, "startup...", mytid );
/*
* startup message "server" to wait for messages
* leave when receive the "END" message
*
* Remember: message handlers are keying on specific
* source - tag - context --> tuples...
*/
while( FOREVER )
{
if ( ( cc = pvm_recv( -1, -1 ) ) < 0 ){ /* receive all */
lpvmerr( "\nmhf_server: pvm_recv( ): error %d", cc );
pvm_exit( ); exit( 0 );
}
/* who sent message */
if ( (info = pvm_bufinfo( cc, &length, &msgtag, &ctid )) < 0 ){
lpvmerr( "\nmhf_server: pvm_bufinfo( ): error %d", info );
pvm_exit( ); exit( 0 );
}
switch ( msgtag ){
case PMH: /* display present message handlers */
pvm_upkstr( msg_txt );
sprintf( msg, "%s: PMH: %s", me, msg_txt );
pvmdisplaymhfinfo( me, msg, mytid );
break;
/* load message handler */
/* ( src=tid_of_sender ...usually..., tag, ctx ) */
case LMH:
/* tid of msg handler ONLY user - unless wildcard -1 */
pvm_upkint( &src, 1, 1 );
pvm_upkint( &tag, 1, 1 );
pvm_upkint( &ctx, 1, 1 );
/* number indicates which handler to load */
pvm_upkint( &info, 1, 1 );
#ifdef NOISE2
sprintf( msg,
"%s: LMH: BEFORE load with pvm_addmhf( src = t%x, tag = %d, ctx = %d ) -> load %s",
me, src, tag, ctx, mh_arr[info] );
pvmdisplaymhfinfo( me, msg, mytid );
#endif
switch ( info ){
case SC1:
mhid = pvm_addmhf( src, tag, ctx, string_catcher1 );
break;
case SC2:
mhid = pvm_addmhf( src, tag, ctx, string_catcher2 );
break;
case SC3:
mhid = pvm_addmhf( src, tag, ctx, string_catcher3 );
break;
case SC4:
mhid = pvm_addmhf( src, tag, ctx, string_catcher4 );
break;
case SC5:
mhid = pvm_addmhf( src, tag, ctx, string_catcher5 );
break;
case IC1:
mhid = pvm_addmhf( src, tag, ctx, int_catcher6 );
break;
case IC2:
mhid = pvm_addmhf( src, tag, ctx, int_catcher7 );
break;
case IC3:
mhid = pvm_addmhf( src, tag, ctx, int_catcher8 );
break;
case IC4:
mhid = pvm_addmhf( src, tag, ctx, int_catcher9 );
break;
case IC5:
mhid = pvm_addmhf( src, tag, ctx, int_catcher10 );
break;
default:
printf( "\n%s: no such message handler <%d> to load... Only 0 - 9 available!", me, info );
mhid = PvmBadParam;
break;
} /* end_switch ( info ) */
if ( mhid == PvmExists ){
printf( "\n%s: message handler already exists...\n", me );
break;
}
if ( mhid < 0 ){
printf( "\n%s: pvm_addmhf failed with error code %d.\n", me, mhid );
break;
}
#ifdef NOISE1
sprintf( msg,
"%s: LMH: AFTER load with pvm_addmhf( src = t%x, tag = %d, ctx = %d ) -> loaded %s",
me, src, tag, ctx, mh_arr[info] );
pvmdisplaymhfinfo( me, msg, mytid );
#endif
break;
case DMH: /* delete message handler */
pvm_upkint( &mhid, 1, 1 );
#ifdef NOISE2
sprintf( msg, "%s: DMH: BEFORE delete with pvm_delmhf( mhid = %d )", me, mhid );
pvmdisplaymhfinfo( me, msg, mytid );
#endif
if ( ( info = pvm_delmhf( mhid ) ) < 0 ){
sprintf( msg,"%s: pvm_delmhf failed - no such handler existed.", me );
lpvmerr( msg, PvmNotFound );
break;
}
sprintf( msg, "%s: DMH: AFTER delete with pvm_delmhf( mhid = %d )", me, mhid );
pvmdisplaymhfinfo( me, msg, mytid );
break;
case ERJ: /* tell mhf_server() to pvm_exit( ) and then rejoin ->> check message handlers existance */
#ifdef NOISE2
sprintf( msg, "%s: ERJ: BEFORE pvm_exit( )", me );
pvmdisplaymhfinfo( me, msg, mytid );
#endif
/*
* exit pvm part...
*/
if ( ( info = pvm_exit( ) ) < 0 ){
printf( "\n%s: pvm_exit failed with error code %d.\n", me, info );
break;
}
#ifdef NOISE1
printf( "\n%s: Just did pvm_exit...\n", me );
sprintf( msg, "%s: ERJ: AFTER pvm_exit( )", me );
pvmdisplaymhfinfo( me, msg, mytid );
#endif
/*
* rejoin pvm part...
*/
if ( ( mytid = pvm_mytid( ) ) < 0 ){
printf( "\n%s: could not restart - pvm not up...\n", me );
exit( -1 );
}
#ifdef NOISE1
printf( "%s: just rejoined pvm...\n", me );
printf( "%s: restarted as t%x on machine <%s> with context %d.\n", me, mytid, machine, pvm_getcontext( ) );
sprintf( msg, "%s: ERJ: rejoin pvm AFTER pvm_exit( )", me );
pvmdisplaymhfinfo( me, msg, mytid );
#endif
/*
* re-register server via mailbox...
*/
if ( ( info = register_server( mytid, sctx, machine, me ) ) < 0 ){
printf( "\n%s: register_server( ) failed with error code %d.\n", me, info );
pvm_exit( );
exit( -1 );
}
#ifdef NOISE1
printf( "%s: just registered server...\n", me );
#endif
break;
case HIT: /* message to hit a specified handler... */
pvm_upkint( &lmh, 1, 1 ); /* integer indicates which target trying to ping */
if ( lmh == mhf_catch )
printf( "\n%s: HIT: ping target %d - %s ", me, lmh, mh_arr[lmh] );
else
printf( "\n%s: NO HIT: lmh = %d - %s mhf_catch = %d - ?C? ",
me, lmh, mh_arr[lmh], mhf_catch );
switch ( lmh ) {
case 1: case 2: case 3: case 4: case 5:
pvm_upkstr( msg_txt );
if ( strcmp( msg_txt, mhf_msg ) == 0 )
printf( "strings match <%s>.\n", msg_txt );
else
printf( "strings NO match - local <%s> mhf <%s>.\n", msg_txt, mhf_msg );
break;
case 0: case 6: case 7: case 8: case 9:
pvm_upkint( &cc, 1, 1 );
if ( cc == mhf_magic_number )
printf( "magic_numbers match %d.\n", cc );
else
printf( "magic_numbers NO match - local %d mhf %d.\n", cc, mhf_magic_number );
break;
}
sprintf( msg, "%s: HIT:", me );
pvmdisplaymhfinfo( me, msg, mytid );
/*
* reset globals to some known values for testing
*/
mhf_catch = -99;
mhf_magic_number = -99;
strcpy ( mhf_msg, "NO MATCH" );
break;
case SEAT: /* server exits pvm and terminate self */
sprintf( msg, "%s: CEAT: Termiate Self...", me );
pvmdisplaymhfinfo( me, msg, mytid );
FOREVER = NO; /* will cause program termination */
break;
default:/* invalid msgtag - just ignore the message
*/
printf( "%s: default: INVALID msgtag: length = %d msgtag = <%d> ctid = t%x",
me, length, msgtag, ctid );
break;
} /* switch_end */
fflush( stdout );
} /* end_while_FOREVER */
pvm_exit( );
exit( 0 );
} /* end_main */
