select.h

Path MPICH-V for MPICH the MPI Implementation

/** @file select.h define the main select loop subfunctions
 */
#ifndef SELECT_H
#define SELECT_H
#include "simple_list.h"
#include "vtypes.h"
#include "genericCheckpoint.h"

/** used to send message in async mode */
typedef struct sbOffset
{
  char * sbo;
  long int messagesize;

} sbOffset;

/* to be  called in this mandatory order */
/** initialize all structure of the daemon
 * @param rank : rank of the local mpi process
 * @param group : group of the local mpi process
 * @param np : size of the COMMWORLD
 * @param el : address of the event logger
 * @param cs : address of the checkpoint server
 * @param sc : address of the checkpoint scheduler
 * @param use_local : if 1 then restart from local checkpoint image  
 * @return void
 */
void initstruct(int rank, int group, int np, struct sockaddr_in el, struct sockaddr_in cs, struct sockaddr_in sc, int use_local);

/** initialize the establishment of all connection
 * @param RFmpi : pipe fd to read from the mpi process
 * @param WTmpi : pipe fd to write to the mpi process
 * @param listenPort : socket to listen to
 * @param dispatcher : socket to dispatcher
 * @return void
*/
void initcomm(int RFmpi, int WTmpi, int listen_socket, int socket_to_dispatcher);

/** main (select) loop of the daemon
 * @return void
 */
void daemonselect();

/** close all socket openned by the daemon
 * @return void
 */
void close_all_sockets();

/** signal handler
 * @param numSignal: the number of signal raised
 */
void gestSignal(int numSignal);

/**
 * called when the MPI process performs the Finalize
 */
void dispatcher_mpi_exit();

/**
 * called for initial communications with the dispatcher
 * @param s socket to the dispatcher
 * @param name name of the parameter to receive
 * @return the value (malloced)
 */
char *recv_strparam(int s, char *name);

/**
 * called for initial communications with the dispatcher
 * @param ss socket to the dispatcher
 * @param name name of the parameter to receive
 * @return the value
 */
int recv_intparam(int s, char *name);

/**
 * say whether every process has finished.
 * call ftp_finalize if so
 */
int all_is_done(void);


#endif /* SELECT_H */