clog.h

fortran并行计算包

/*
   (C) 2001 by Argonne National Laboratory.
       See COPYRIGHT in top-level directory.
*/
#if !defined( _CLOG )
#define _CLOG

/*
   Version 2.00: Initial rewrite of CLOG.
   Version 2.10: Clean up of CLOG record's data structure to minimize
                 wasted disk space.
   Version 2.20: Added CLOG internal profiling state: CLOG_Buffer_write2disk
   Version 2.30: Added support of MPI_Comm.
   Version 2.40: Added support of user-defined event drawable/category.
                 Updated CLOG_Preamble with MPE eventID and stateID info.
   Version 2.41: Added known MPE event drawables(internal solo events)
                 Updated CLOG_Preamble with MPE known solo events.
   Version 2.42: Added a Communicator Table at the end of CLOG2.
                 Updated CLOG_Preamble with a pointer that points to the
                 communicator table.
   Version 2.43: Added a boolean value in CLOG_Preamble to indicate if
                 the file is a finalized file so 1) clog2TOslog2 can
                 refuse to process a local file, 2) clog2_join can "patch"
                 the timestamps by using the timeshift events, 3) a repair
                 program can fixup the broken/unfinish local clog2 file 
                 (for debugging). 
                 Changed CLOG_Preamble_t's comm_world_size to
                 max_comm_world_size.
   Version 2.44: Added a max_thread_count in CLOG_Preamble for thread-safe
                 support.  The variable shows the maximum local threads
                 (per process) among processes recorded in the logfile
                 and is used to generate unique LineID in the YaxisViewMap
                 in clog2TOslog2
*/
#define CLOG_VERSION          "CLOG-02.44"

#include "clog_buffer.h"
#include "clog_sync.h"
#include "clog_merger.h"
#include "clog_record.h"



/* CLOG_KNOWN_SOLO_EVENTID_START < CLOG_KNOWN_EVENTID_START */
#define CLOG_KNOWN_SOLO_EVENTID_START -10

/*
   This is for MPI implementation, i.e., src/wrapper/log_mpi_core.c
   CLOG_KNOWN_EVENTID_START < CLOG_KNOWN_USER_EVENTID_START
*/
#define CLOG_KNOWN_EVENTID_START 0

/*
   This is for users: CLOG_KNOWN_EVENTID_START < CLOG_USER_EVENTID_START
   CLOG_USER_EVENTID_START = 2 * CLOG_USER_STATEID_START
*/
#define CLOG_USER_EVENTID_START 600

/* This is for users: CLOG_USER_EVENTID_START < CLOG_USER_SOLE_EVENTID_START */
#define CLOG_USER_SOLO_EVENTID_START 5000

/*
   This is for MPI implementation, i.e., src/wrapper/log_mpi_core.c
   CLOG_KNOWN_STATEID_START < CLOG_USER_STATEID_START
*/
#define CLOG_KNOWN_STATEID_START 0

/* This is for users: CLOG_KNOWN_STATEID_START < CLOG_USER_STATEID_START */
#define CLOG_USER_STATEID_START 300

#define CLOG_COMM_NULL          -1

typedef struct {
    CLOG_Buffer_t     *buffer;
    CLOG_Sync_t       *syncer;
    CLOG_Merger_t     *merger;
    int                known_solo_eventID;
    int                known_eventID;
    int                known_stateID;
    int                user_eventID;
    int                user_stateID;
    int                user_solo_eventID;
} CLOG_Stream_t;

CLOG_Stream_t *CLOG_Open( void );

void CLOG_Close( CLOG_Stream_t **stream );

void CLOG_Local_init( CLOG_Stream_t *stream, const char *local_tmpfile_name );

void CLOG_Local_finalize( CLOG_Stream_t *stream );

int  CLOG_Get_known_solo_eventID( CLOG_Stream_t *stream );

int  CLOG_Get_known_eventID( CLOG_Stream_t *stream );

int  CLOG_Get_user_eventID( CLOG_Stream_t *stream );

int  CLOG_Get_user_solo_eventID( CLOG_Stream_t *stream );

int  CLOG_Get_known_stateID( CLOG_Stream_t *stream );

int  CLOG_Get_user_stateID( CLOG_Stream_t *stream );

int  CLOG_Check_known_stateID( CLOG_Stream_t *stream, int stateID );

void CLOG_Converge_init(       CLOG_Stream_t *stream,
                         const char          *merged_file_prefix );

void CLOG_Converge_finalize( CLOG_Stream_t *stream );

void CLOG_Converge_sort( CLOG_Stream_t *stream );

#endif  /* of _CLOG */