/* * Copyright (C) 2015 University of Chicago. * See COPYRIGHT notice in top-level directory. * */ #ifndef __DARSHAN_LOG_UTILS_H #define __DARSHAN_LOG_UTILS_H #include #ifdef HAVE_LIBBZ2 #include #endif #include "uthash-1.9.2/src/uthash.h" #include "darshan-log-format.h" /* default to a buffer size of 4 MiB for compression/decompression */ #define DARSHAN_DEF_COMP_BUF_SZ (4*1024*1024) /* TODO: can we refactor this def out of header? modules currently poke at swap_flag * directly, but other than that there's no reason for another module to know this * definition. */ struct darshan_fd_s { int fildes; int64_t pos; enum darshan_comp_type comp_type; char version[8]; int swap_flag; char *exe_mnt_data; struct darshan_log_map job_map; struct darshan_log_map rec_map; struct darshan_log_map mod_map[DARSHAN_MAX_MODS]; }; typedef struct darshan_fd_s* darshan_fd; struct darshan_record_ref { struct darshan_record rec; UT_hash_handle hlink; }; struct darshan_mod_logutil_funcs { int (*log_get_record)( darshan_fd fd, void** mod_buf_p, int* mod_bytes_left, void** file_rec, darshan_record_id* rec_id ); void (*log_print_record)( void *file_rec, char *file_name, char *mnt_pt, char *fs_type ); }; extern struct darshan_mod_logutil_funcs *mod_logutils[DARSHAN_MAX_MODS]; #include "darshan-posix-logutils.h" #include "darshan-mpiio-logutils.h" #include "darshan-hdf5-logutils.h" #include "darshan-pnetcdf-logutils.h" darshan_fd darshan_log_open(const char *name); darshan_fd darshan_log_create(const char *name, enum darshan_comp_type comp_type); int darshan_log_getheader(darshan_fd fd, struct darshan_header *header); int darshan_log_putheader(darshan_fd fd); int darshan_log_getjob(darshan_fd fd, struct darshan_job *job); int darshan_log_putjob(darshan_fd fd, struct darshan_job *job); int darshan_log_getexe(darshan_fd fd, char *buf); int darshan_log_putexe(darshan_fd fd, char *buf); int darshan_log_getmounts(darshan_fd fd, char*** mnt_pts, char*** fs_types, int* count); int darshan_log_putmounts(darshan_fd fd, char** mnt_pts, char** fs_types, int count); int darshan_log_gethash(darshan_fd fd, struct darshan_record_ref **hash); int darshan_log_puthash(darshan_fd fd, struct darshan_record_ref *hash); int darshan_log_getmod(darshan_fd fd, darshan_module_id mod_id, void *mod_buf, int *mod_buf_sz); int darshan_log_putmod(darshan_fd fd, darshan_module_id mod_id, void *mod_buf, int mod_buf_sz); void darshan_log_close(darshan_fd file); /* convenience macros for printing Darshan counters */ #define DARSHAN_PRINT_HEADER() \ printf("\n#\t\t\t\t" \ "\t\t\t\n") #define DARSHAN_COUNTER_PRINT(__mod_name, __rank, __file_id, \ __counter, __counter_val, __file_name, \ __mnt_pt, __fs_type) do { \ printf("%s\t%" PRId64 "\t%" PRIu64 "\t%s\t%" PRId64 "\t%s\t%s\t%s\n", \ __mod_name, __rank, __file_id, __counter, __counter_val, \ __file_name, __mnt_pt, __fs_type); \ } while(0) #define DARSHAN_F_COUNTER_PRINT(__mod_name, __rank, __file_id, \ __counter, __counter_val, __file_name, \ __mnt_pt, __fs_type) do { \ printf("%s\t%" PRId64 "\t%" PRIu64 "\t%s\t%f\t%s\t%s\t%s\n", \ __mod_name, __rank, __file_id, __counter, __counter_val, \ __file_name, __mnt_pt, __fs_type); \ } while(0) /* naive byte swap implementation */ #define DARSHAN_BSWAP64(__ptr) do {\ char __dst_char[8]; \ char* __src_char = (char*)__ptr; \ __dst_char[0] = __src_char[7]; \ __dst_char[1] = __src_char[6]; \ __dst_char[2] = __src_char[5]; \ __dst_char[3] = __src_char[4]; \ __dst_char[4] = __src_char[3]; \ __dst_char[5] = __src_char[2]; \ __dst_char[6] = __src_char[1]; \ __dst_char[7] = __src_char[0]; \ memcpy(__ptr, __dst_char, 8); \ } while(0) #define DARSHAN_BSWAP32(__ptr) do {\ char __dst_char[4]; \ char* __src_char = (char*)__ptr; \ __dst_char[0] = __src_char[3]; \ __dst_char[1] = __src_char[2]; \ __dst_char[2] = __src_char[1]; \ __dst_char[3] = __src_char[0]; \ memcpy(__ptr, __dst_char, 4); \ } while(0) #endif