/* $Id: pvmproto.h,v 1.18 2000/02/10 20:43:54 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.
*/
/*
* pvmproto.h
*
* PVM protocol definitions.
*
* $Log: pvmproto.h,v $
* Revision 1.18 2000/02/10 20:43:54 pvmsrc
* Removed hard-coded /tmp in TDSOCKNAME / TDSOCKNAME_CSPP.
* - use pvmgettmp() routine now to determine PVM temp dir.
* (Spanker=kohl)
*
* Revision 1.17 1999/07/08 18:59:48 kohl
* Fixed "Log" keyword placement.
* - indent with " * " for new CVS.
*
* Revision 1.16 1998/01/12 21:12:01 pvmsrc
* Added task output collection op defines.
* - TO_NEW, TO_SPAWN, TO_EOF.
* (Spanker=kohl)
*
* Revision 1.15 1997/10/22 22:08:16 pvmsrc
* Added SYSCTX_DG constant for dynamic group context.
* (Spanker=kohl)
*
* Revision 1.14 1997/10/01 15:34:49 pvmsrc
* Fixed TM_LAST decl.
* - should be same as last entry, not last + 1...
* (Spanker=kohl)
*
* Revision 1.13 1997/07/09 13:29:37 pvmsrc
* Fixed Author Header.
*
* Revision 1.12 1997/06/10 16:38:55 pvmsrc
* Minor text cleanup.
*
* Revision 1.11 1997/05/29 15:15:05 pvmsrc
* Fixed decl of SM_FIRST:
* - some compilers too stupid to know it's an (int)0x80040001...
* - D-Oh.
*
* Revision 1.10 1997/05/27 14:40:58 pvmsrc
* Added new TM message:
* TM_SHMCONN. This allows socket and shmem task structs to be merged.
* Also when exchanged sets new TF flag TF_SHMCONN.
*
* Revision 1.9 1997/04/09 14:37:17 pvmsrc
* PVM patches from the base 3.3.10 to 3.3.11 versions where applicable.
* Originals by Bob Manchek. Altered by Graham Fagg where required.
*
* Revision 1.8 1997/04/08 19:18:11 pvmsrc
* Damn. Added matching DM_RESETACK constant... :-Q
*
* Revision 1.7 1997/04/08 19:05:51 pvmsrc
* Added DM_RESET constant.
* - for reset of system, cleanup of persistent message mboxes.
*
* Revision 1.6 1997/04/07 18:20:15 pvmsrc
* Added TMDB_RESET constant.
* - for resetting mbox db on pvmreset()...
*
* Revision 1.5 1997/04/04 15:45:03 pvmsrc
* Typos CTXT -> CTX for consistency. Affects task.c, too
*
* Revision 1.4 1997/04/03 19:15:52 pvmsrc
* Added some system defined contexts for use by TM, TC messages
*
* Revision 1.3 1997/04/03 16:12:38 pvmsrc
* Added correct macro for sequence number wrap-around comparison.
* This is on SEQLESSTHAN and is useful for 16 bit sequence numbers
*
* Revision 1.2 1997/01/28 19:14:22 pvmsrc
* New Copyright Notice & Authors.
*
* Revision 1.1 1996/10/25 13:43:38 pvmsrc
* Initial revision
*
*
*/
#ifndef _PVMPROTO_H_
#define _PVMPROTO_H_
/* protocol version */
#ifndef SDPROTOCOL
#define SDPROTOCOL 4302
#endif
/*
* t - task
* d - pvmd
* R - resource manager
* H - hoster
* T - tasker
*/
#define SM_FIRST (int)0x80040001 /* first SM_ message */
#define SM_SPAWN (SM_FIRST+0) /* t<>R like TM_SPAWN */
#define SM_EXEC (SM_FIRST+1) /* R->d like DM_EXEC */
#define SM_EXECACK (SM_FIRST+2) /* d->R like DM_EXECACK */
#define SM_TASK (SM_FIRST+3) /* t<>R like TM_TASK */
#define SM_CONFIG (SM_FIRST+4) /* t<>R like TM_CONFIG */
#define SM_ADDHOST (SM_FIRST+5) /* t<>R like TM_ADDHOST */
#define SM_DELHOST (SM_FIRST+6) /* t<>R like TM_DELHOST */
#define SM_ADD (SM_FIRST+7) /* R->d like DM_ADD */
#define SM_ADDACK (SM_FIRST+8) /* d->R like DM_ADDACK */
#define SM_NOTIFY (SM_FIRST+9) /* t->R like TM_NOTIFY */
#define SM_TASKX (SM_FIRST+10) /* d->R notify of task exit */
#define SM_HOSTX (SM_FIRST+11) /* d->R notify sched of host delete */
#define SM_HANDOFF (SM_FIRST+12) /* R->d pvmd to new sched */
#define SM_SCHED (SM_FIRST+13) /* t<>R like TM_SCHED */
#define SM_STHOST (SM_FIRST+14) /* d->H start slave pvmds */
#define SM_STHOSTACK (SM_FIRST+15) /* H->d like DM_STARTACK */
#define SM_STTASK (SM_FIRST+16) /* d->T start task */
#define SM_LAST (SM_FIRST+16) /* last SM_ message */
/*
* ddpro.h
*
* Pvmd-pvmd protocol
*
* Revision 1.5 1996/05/13 20:24:06 manchek
* [GEF pvm3.3.10to11 patch updates]
* added PVMDISTASK
*
* Revision 1.4 1995/05/17 16:06:18 manchek
* cast DM_FIRST to int.
* added debugging classes
*
* Revision 1.3 1994/07/18 19:19:27 manchek
* added PDMWAITC
*
* Revision 1.2 1994/06/03 20:38:13 manchek
* version 3.3.0
*
* Revision 1.1 1993/08/30 23:26:47 manchek
* Initial revision
*
*/
/* protocol version */
#ifndef DDPROTOCOL
#define DDPROTOCOL 2316
#endif
#define DDMINRETRIES 10
#define DDMAXRTT 9 /* seconds */
#define DDMINTIMEOUT (DDMINRETRIES*DDMAXRTT*2) /* seconds */
#define DDERRRETRY 300000 /* uSec */
#define DDPINGTIME 60 /* (sec) between keepalive pings */
#define DDBAILTIME 300 /* (sec) for new slave to bail if no config */
#define NEXTSEQNUM(x) (((x)+1)&0xffff)
#define SEQNUMCOMPARE(x,y) ((x)<(y)||(((x)>0x8000)&&((y)<0x8000)))
#define SEQLESSTHAN(x,y)( ((x)<(y) && (y)-(x) < 32768) ||\
((x)>(y) && (x)-(y) >= 32768) )
/*DocThis*/
/*
* Pvmd-pvmd packet header
*
* 0 1 2 3
* +---------------------------------------------------------------+
* 0| dst |
* +---------------------------------------------------------------+
* 4| src |
* +-------------------------------+-------------------------------+
* 8| seq | ack |
* +---------------+---------------+-------------------------------+
* 12| flags | |
* +---------------+-----------------------------------------------+
*/
/*EndDocThis*/
#define DDFRAGHDR 16
/* frag flags */
#define FFDAT 4 /* packet contains data, seq num is valid */
#define FFFIN 8 /* sender closing connection */
#define FFACK 16 /* ack num is valid */
/* d-d message flavors */
#define DM_FIRST (int)0x80020001 /* first DM_ message */
#define DM_ADD (DM_FIRST+0) /* add hosts to machine */
#define DM_ADDACK (DM_FIRST+1)
#define DM_EXEC (DM_FIRST+2) /* start tasks */
#define DM_EXECACK (DM_FIRST+3)
#define DM_SENDSIG (DM_FIRST+4) /* signal a task */
#define DM_HTUPD (DM_FIRST+5) /* define new host table */
#define DM_HTUPDACK (DM_FIRST+6)
#define DM_HTCOMMIT (DM_FIRST+7) /* switch to new host table */
#define DM_SLCONF (DM_FIRST+8) /* config slave pvmd */
#define DM_STARTACK (DM_FIRST+9) /* pvmd' completed slave startup */
#define DM_TASK (DM_FIRST+10) /* get list of tasks */
#define DM_TASKACK (DM_FIRST+11)
#define DM_DELHOST (DM_FIRST+12) /* delete hosts from machine */
#define DM_DELHOSTACK (DM_FIRST+13)
#define DM_NULL (DM_FIRST+14) /* null message */
#define DM_TASKOUT (DM_FIRST+15) /* task standard out/err data */
#define DM_PSTAT (DM_FIRST+16) /* query status of task */
#define DM_PSTATACK (DM_FIRST+17)
#define DM_HALT (DM_FIRST+18) /* request master pvmd to halt */
#define DM_MCA (DM_FIRST+19) /* define multicast tid */
#define DM_NOTIFY (DM_FIRST+20) /* request notify */
#define DM_NOTIFYACK (DM_FIRST+21)
#define DM_DB (DM_FIRST+22) /* message-mailbox request */
#define DM_DBACK (DM_FIRST+23)
#define DM_RESET (DM_FIRST+24) /* reset linkage (mbox tidy) */
#define DM_RESETACK (DM_FIRST+25)
#define DM_HTDEL (DM_FIRST+26) /* delete hosts from host table */
#define DM_HOSTSYNC (DM_FIRST+27) /* request clock sample */
#define DM_HOSTSYNCACK (DM_FIRST+28)
#define DM_LAST (DM_FIRST+28) /* last DM_ message */
/* DM_SLCONF fields - don't use 0 */
#define DM_SLCONF_EP 1 /* set epath */
#define DM_SLCONF_BP 2 /* set bpath */
#define DM_SLCONF_WD 3 /* set wdir */
#define DM_SLCONF_SCHED 4 /* set scheduler tid */
#define DM_SLCONF_TRACE 5 /* set tracer info */
/* pvmd run states */
#define PVMDNORMAL 1 /* normal running state */
#define PVMDHTUPD 2 /* getting host table update */
#define PVMDSTARTUP 3 /* slave just started, not fully configured */
#define PVMDPRIME 4 /* am pvmd' */
#define PVMDHALTING 5 /* stopping rsn */
#define PVMDSHUTDOWN 6 /* in timeout to halt, waiting for FIN|ACK */
#define PVMDISTASK 7 /* between fork and exec to spawn task */
/* used to cache multicast addresses */
struct mca {
struct mca *mc_link; /* dll of peers */
struct mca *mc_rlink;
int mc_tid; /* the multicast tid */
int mc_ndst; /* number of dsts */
int *mc_dsts; /* dst tids (local tasks or foreign pvmds) */
};
struct mca *mca_new __ProtoGlarp__(( void ));
void mca_free __ProtoGlarp__((struct mca *mcap));
struct pmsg *mesg_new __ProtoGlarp__(( int master ));
/*
* tdpro.h
*
* Task-pvmd protocol
*
* Revision 1.5 1995/06/28 15:32:29 manchek
* added TC_SHMAT
*
* Revision 1.4 1995/05/17 16:56:06 manchek
* added support for CSPP subcomplexes (/tmp file naming).
* case TM_FIRST, TC_FIRST to int
* add TM_GETOPT message
*
* Revision 1.3 1994/06/03 20:38:31 manchek
* version 3.3.0
*
* Revision 1.2 1993/10/04 20:30:50 manchek
* added alternate TDSOCKNAME if SHAREDTMP is defined
*
* Revision 1.1 1993/08/30 23:26:52 manchek
* Initial revision
*
*/
/* protocol version */
#ifndef TDPROTOCOL
#define TDPROTOCOL 1318
#endif
/*DocThis*/
/*
* Task-task, task-pvmd fragment header
*
* 0 1 2 3
* +---------------------------------------------------------------+
* 0| dst |
* +---------------------------------------------------------------+
* 4| src |
* +---------------------------------------------------------------+
* 8| length |
* +---------------+-----------------------------------------------+
* 12| flags | |
* +---------------+-----------------------------------------------+
*/
/*EndDocThis*/
#define TDFRAGHDR 16
/*
* Maximum size of all headers in system
*/
#define MAXHDR ((DDFRAGHDR > TDFRAGHDR ? DDFRAGHDR : TDFRAGHDR) \
+ MSGHDRLEN)
/* file with task->pvmd sockaddr */
#ifdef SHAREDTMP
#define TDSOCKNAME "%s/pvmd.%d.%s"
#else
#define TDSOCKNAME "%s/pvmd.%d"
#endif
#ifdef IMA_CSPP
#ifdef SHAREDTMP
#define TDSOCKNAME_CSPP "%s/pvmd.%d.%d.%s"
#else
#define TDSOCKNAME_CSPP "%s/pvmd.%d.%d"
#endif
#endif /*IMA_CSPP*/
#define TM_FIRST (int)0x80010001 /* first TM_ message */
#define TM_CONNECT (TM_FIRST+0) /* task connects */
#define TM_CONN2 (TM_FIRST+1) /* 2nd round of connect */
#define TM_EXIT (TM_FIRST+2) /* task disconnects */
#define TM_ADDHOST (TM_FIRST+3) /* add hosts to machine */
#define TM_DELHOST (TM_FIRST+4) /* delete hosts from machine */
#define TM_CONFIG (TM_FIRST+5) /* get machine config */
#define TM_MSTAT (TM_FIRST+6) /* get host status */
#define TM_HALT (TM_FIRST+7) /* halt machine */
#define TM_TICKLE (TM_FIRST+8) /* tickle pvmd */
#define TM_SPAWN (TM_FIRST+9) /* spawn new tasks */
#define TM_PSTAT (TM_FIRST+10) /* get task status */
#define TM_SENDSIG (TM_FIRST+11) /* signal a task */
#define TM_TASK (TM_FIRST+12) /* list tasks */
#define TM_MCA (TM_FIRST+13) /* request multicast tid */
#define TM_NOTIFY (TM_FIRST+14) /* request notification */
#define TM_DB (TM_FIRST+15) /* message-mailbox request */
#define TM_SCHED (TM_FIRST+16) /* register task as scheduler */
#define TM_TASKER (TM_FIRST+17) /* register task as task starter */
#define TM_HOSTER (TM_FIRST+18) /* register task as pvmd starter */
#define TM_TRACER (TM_FIRST+19) /* register task as task tracer */
#define TM_HOSTSYNC (TM_FIRST+20) /* get clock delta to host */
#define TM_SETOPT (TM_FIRST+21) /* set task parameters */
#define TM_GETOPT (TM_FIRST+22) /* get all task parameters */
#define TM_CONTEXT (TM_FIRST+23) /* allocate or free a context id */
#define TM_SHMCONN (TM_FIRST+24) /* shmem task connect */
#define TM_LAST (TM_FIRST+24) /* last TM_ message */
/*
* for TM_DB
*/
#define TMDB_PUT 1 /* insert message */
#define TMDB_REMOVE 2 /* delete entry */
#define TMDB_GET 3 /* retrieve entry */
#define TMDB_NAMES 4 /* get list of all names defined */
#define TMDB_RESET 5 /* wipe out mbox db entries */
/*
* for TM_SETOPT
*/
#define TS_OUTTID 1 /* stdout dst */
#define TS_OUTCTX 2 /* stdout message context */
#define TS_OUTTAG 3 /* stdout message tag */
#define TS_TRCTID 4 /* trace dst */
#define TS_TRCCTX 5 /* trace message context */
#define TS_TRCTAG 6 /* trace message tag */
#define TC_FIRST (int)0x80030001 /* first TC_ message */
#define TC_CONREQ (TC_FIRST+0) /* connection request */
#define TC_CONACK (TC_FIRST+1) /* connection request ack */
#define TC_TASKEXIT (TC_FIRST+2) /* task exited/doesn't exist */
#define TC_NOOP (TC_FIRST+3) /* do nothing */
#define TC_OUTPUT (TC_FIRST+4) /* child stdout data */
#define TC_SETTRACE (TC_FIRST+5) /* set task tracing */
#define TC_SETTMASK (TC_FIRST+6) /* set task trace mask */
#define TC_SETTRCBUF (TC_FIRST+7) /* set task trace buffer */
#define TC_SETTRCOPT (TC_FIRST+8) /* set task trace options */
#define TC_SHMAT (TC_FIRST+9) /* shmem connect handshake */
#define TC_OUTPUTX (TC_FIRST+10) /* (not sent) flush out coll */
#define TC_SIBLINGS (TC_FIRST+11) /* parent announce spawn grp */
#define TC_LAST (TC_FIRST+11) /* last TC_ message */
/*
* for Task Output Ops
*/
#define TO_EOF 0
#define TO_SPAWN -1
#define TO_NEW -2
/* Contexts Used by Some System Calls - these are allocated from the
top of the context space */
#define SYSCTX_FIRST (int) 0x0007ffff /* first system context */
#define SYSCTX_TC (SYSCTX_FIRST-0) /* ctxt for TC messages */
#define SYSCTX_TM (SYSCTX_FIRST-1) /* ctxt for TM messages */
#define SYSCTX_SG (SYSCTX_FIRST-2) /* ctxt for static group formation*/
#define SYSCTX_DG (SYSCTX_FIRST-3) /* ctxt for dynamic groups */
#define SYSCTX_RS4 (SYSCTX_FIRST-4) /* Reserved system context */
#define SYSCTX_RS5 (SYSCTX_FIRST-5) /* Reserved system context */
#define SYSCTX_RS6 (SYSCTX_FIRST-6) /* Reserved system context */
#define SYSCTX_RS7 (SYSCTX_FIRST-7) /* Reserved system context */
#define SYSCTX_RS8 (SYSCTX_FIRST-8) /* Reserved system context */
#define SYSCTX_RS9 (SYSCTX_FIRST-9) /* Reserved system context */
#define SYSCTX_LAST (SYSCTX_FIRST-9)
#define NUM_SYSCTX (SYSCTX_FIRST-SYSCTX_LAST+1)
#define BASECONTEXT (int) 0
#endif /*_PVMPROTO_H_*/
syntax highlighted by Code2HTML, v. 0.9.1