vtypes.h

Path MPICH-V for MPICH the MPI Implementation

/** @file vtypes.h defines the header types for mpi messages */
#ifndef _INCLUDE_V2TYPES_H_
#define _INCLUDE_V2TYPES_H_

#include <netinet/in.h>
#include "simple_list.h"

#include "prototypes.h"

/** a pkt_header is a header of message exchanged between daemon
 */
typedef struct pkt_header {
  int iTag;                  /**< tag of the message      */
  int iSrc;                  /**< sender rank             */
  int iDst;                  /**< receiver rank           */
  int iSize;                 /**< size of the data        */
  int iType;                 /**< type of message         */
  proto_header ftp;          /**< protocol dependant part */
} pkt_header;


/** compare the tag with the tag of the pkt_header
 * @param pkt : pkt_header of a message
 * @param tag : a tag
 * @return 0 if different, something different of 0 else
 */
int cmp_tag(void *pkt, void *tag);

/** compare the tag with the tag of the pkt_header of the flitvec
 * @param _vec : a message (flitvec *)
 * @param tag : a tag
 * @return 0 if different, something different of 0 else
 */
#define cmp_vec_tag(_vec, tag) cmp_tag( ((flitvec *)(_vec))->flittab[0], tag)

/** format the pkt_header in a human readable way for debug
 * @param p : a header of message
 * @param max : maximum bytes of payload to display
 * @return char * to write in debug message
 */
char *format_packet_long(pkt_header *p, int max);
#define format_packet(p) format_packet_long(p, 0)

#define ANY_MSG_AVAIL		 1 /**< this code the type of packet */
#define RECV_ANY_CONTROL 	 2 /**< for system request to receive a packet size */
#define SEND_CONTROL 		 3 /**< for system request to receive a packet size */
#define RECV_FROM_CHANNEL 	 4 /**< for system request to receive a packet size */
#define SEND_CHANNEL 		 5 /**< for system request to receive a packet size */
#define CP_START                 6 /**< for checkpoint starting from client */
#define REPLAY_START             7 /**< for replaying from client */
#define CLIENT_EXIT 		 8 /**< notifying the server about exiting */
#define CP_SUCCESSFUL            9 /**< checkpoint is successful */
#define CP_START_NO_FORK         10
#define DEVICE_EXIT              11
#define FORCE_CHECKPOINT         12 /**< This constant is used by CL to force checkpoint waves with 0-length messages */

/*constants to distinguish own clients and clients-destinations*/
#define CLI_OWN		0
#define CLI_DST		1
#define CLI_RECONNECT	2

#define PROTOCOL_TYPE(a)   (0xff00 | (a))

#endif /*_INCLUDE_V2TYPES_H_*/