mastersched.h

Path MPICH-V for MPICH the MPI Implementation

typedef struct  SchedJob{
  
  int sockDisp;
  int sockSC;
  int timeSlot;
  int remaintime;
  int on_exec;
  int justlaunch;
  int launch_next;  
};
struct master_info {
  char type;
  int numJob;
  
};
/* Establish connection with dispatchers and checkpoint schedulers*/
void newConnection();

/** Sending execution order to job identified by iJob.
 * @param iJob : which job to restart
 * @return : 1 if sending order to dispatcher is succeded
 */
int send_launchJ_order (int iJob);

/** Set futur job to be launched.
 */
void setNextJob ();

/** Close all sockets of a finalized job.
 * @param iJob : Identifies finalaze job
 */
int finalize_oneJ_checkAll (int iJob);

/** Launch execution of next job.
 * @return : 1 if sending order to dispatcher is successful
 * or if job to launch is not on checkpoint phase 
 */
int launchNextJob ();

/** Launch checkpoint phase according to checkpoint policies.
 */
void on_begin_checkpoint ();


/** Called when a checkpoint scheduler notifies the end of 
 * checkpoint phase. launchs next job according to checkpoint
 * policies.
 */
void on_end_Checkpoint (int iJob);


/** Set counter of time on the less values of remain time of 
 * executing job
 */
void setTimeout();

/** Parsing commande line.
 */
void parse_args(int argc, char *argv[]);