stage.h

Go to the documentation of this file.

#ifndef _STAGE_H_
#define _STAGE_H_

// 1 bit field
#define FTI_SI_NAVL 0x1
#define FTI_SI_IAVL 0x0

#define FTI_SI_IALL 0x1
#define FTI_SI_NALL 0x0

#define FTI_SI_APTR( ptr ) ((FTIT_StageAppInfo*)ptr)
#define FTI_SI_HPTR( ptr ) ((FTIT_StageHeadInfo*)ptr)

#define FTI_SI_MAX_ID (0x7ffff)

#define FTI_DISABLE_STAGING do{*enableStagingPtr = false;} while(0)
#define FTI_SI_ENABLED (*(bool*)enableStagingPtr)

typedef enum {
    FTI_SIF_AVL = 0,
    FTI_SIF_VAL,
} FTIT_StatusField;

typedef enum {
    FTI_SIF_ALL = 0,
    FTI_SIF_IDX
} FTIT_RequestField;

typedef struct FTIT_StageHeadInfo {
    char lpath[FTI_BUFS];           
    char rpath[FTI_BUFS];           
    size_t offset;                  
    size_t size;                    
    int ID;                         
} FTIT_StageHeadInfo;

typedef struct FTIT_StageAppInfo {
    void *sendBuf;                  
    MPI_Request mpiReq;             
    int ID;                         
} FTIT_StageAppInfo;


int FTI_GetRequestID( FTIT_execution *FTI_Exec, FTIT_topology *FTI_Topo ); 
int FTI_InitStage( FTIT_execution *FTI_Exec, FTIT_configuration *FTI_Conf, FTIT_topology *FTI_Topo );
int FTI_InitStageRequestApp( FTIT_execution *FTI_Exec, FTIT_topology *FTI_Topo, uint32_t ID );
int FTI_AsyncStage( char *lpath, char *rpath, FTIT_configuration *FTI_Conf, 
        FTIT_execution *FTI_Exec, FTIT_topology *FTI_Topo, int ID );
int FTI_InitStageRequestHead( char* lpath, char *rpath, FTIT_execution *FTI_Exec, 
        FTIT_topology *FTI_Topo, int source, uint32_t ID );
int FTI_SyncStage( char* lpath, char *rpath, FTIT_execution *FTI_Exec, 
        FTIT_topology *FTI_Topo, FTIT_configuration *FTI_Conf, uint32_t ID ); 
int FTI_HandleStageRequest(FTIT_configuration* FTI_Conf, FTIT_execution* FTI_Exec,
        FTIT_topology* FTI_Topo, FTIT_checkpoint* FTI_Ckpt, int source);
int FTI_GetStatusField( FTIT_execution *FTI_Exec, FTIT_topology *FTI_Topo, int ID, FTIT_StatusField val, int source ); 
int FTI_SetStatusField( FTIT_execution *FTI_Exec, FTIT_topology *FTI_Topo, int ID, uint8_t entry, FTIT_StatusField val, int source );
int FTI_GetRequestField( int ID, FTIT_RequestField val ); 
int FTI_SetRequestField( int ID, uint32_t entry, FTIT_RequestField val );
int FTI_FreeStageRequest( FTIT_execution *FTI_Exec, FTIT_topology *FTI_Topo, int ID, int source ); 
void FTI_PrintStageStatus( FTIT_execution *FTI_Exec, FTIT_topology *FTI_Topo, int ID, int source ); 
int FTI_GetRequestIdx( int ID );
void FTI_FinalizeStage( FTIT_execution *FTI_Exec, FTIT_topology *FTI_Topo, FTIT_configuration *FTI_Conf ); 

#endif