darshan-stdio.c 42.7 KB
Newer Older
1 2 3 4 5 6
/*
 * Copyright (C) 2015 University of Chicago.
 * See COPYRIGHT notice in top-level directory.
 *
 */

Philip Carns's avatar
Philip Carns committed
7 8 9 10 11
/* catalog of stdio functions instrumented by this module
 *
 * functions for opening streams
 * --------------
 * FILE    *fdopen(int, const char *);                      DONE
Philip Carns's avatar
Philip Carns committed
12
 * FILE    *fopen(const char *, const char *);              DONE
Philip Carns's avatar
Philip Carns committed
13
 * FILE    *fopen64(const char *, const char *);            DONE
Philip Carns's avatar
Philip Carns committed
14
 * FILE    *freopen(const char *, const char *, FILE *);    DONE
Philip Carns's avatar
Philip Carns committed
15
 * FILE    *freopen64(const char *, const char *, FILE *);  DONE
Philip Carns's avatar
Philip Carns committed
16 17 18 19 20 21 22
 *
 * functions for closing streams
 * --------------
 * int      fclose(FILE *);                                 DONE
 *
 * functions for flushing streams
 * --------------
Philip Carns's avatar
Philip Carns committed
23
 * int      fflush(FILE *);                                 DONE
Philip Carns's avatar
Philip Carns committed
24 25 26
 *
 * functions for reading data
 * --------------
Philip Carns's avatar
Philip Carns committed
27
 * int      fgetc(FILE *);                                  DONE
Philip Carns's avatar
Philip Carns committed
28
 * char    *fgets(char *, int, FILE *);                     DONE
Philip Carns's avatar
Philip Carns committed
29
 * size_t   fread(void *, size_t, size_t, FILE *);          DONE
Philip Carns's avatar
Philip Carns committed
30 31
 * int      fscanf(FILE *, const char *, ...);              DONE
 * int      vfscanf(FILE *, const char *, va_list);         DONE
Philip Carns's avatar
Philip Carns committed
32
 * int      getc(FILE *);                                   DONE
Philip Carns's avatar
Philip Carns committed
33
 * int      getw(FILE *);                                   DONE
Philip Carns's avatar
Philip Carns committed
34 35 36
 *
 * functions for writing data
 * --------------
Philip Carns's avatar
Philip Carns committed
37 38
 * int      fprintf(FILE *, const char *, ...);             DONE
 * int      vfprintf(FILE *, const char *, va_list);        DONE
Philip Carns's avatar
Philip Carns committed
39
 * int      fputc(int, FILE *);                             DONE
Philip Carns's avatar
Philip Carns committed
40
 * int      fputs(const char *, FILE *);                    DONE
Philip Carns's avatar
Philip Carns committed
41
 * size_t   fwrite(const void *, size_t, size_t, FILE *);   DONE
Philip Carns's avatar
Philip Carns committed
42
 * int      putc(int, FILE *);                              DONE
Philip Carns's avatar
Philip Carns committed
43
 * int      putw(int, FILE *);                              DONE
Philip Carns's avatar
Philip Carns committed
44 45 46 47
 *
 * functions for changing file position
 * --------------
 * int      fseek(FILE *, long int, int);                   DONE
Philip Carns's avatar
Philip Carns committed
48
 * int      fseeko(FILE *, off_t, int);                     DONE
Philip Carns's avatar
Philip Carns committed
49
 * int      fseeko64(FILE *, off_t, int);                   DONE
Philip Carns's avatar
Philip Carns committed
50 51
 * int      fsetpos(FILE *, const fpos_t *);                DONE
 * int      fsetpos64(FILE *, const fpos_t *);              DONE
Philip Carns's avatar
Philip Carns committed
52
 * void     rewind(FILE *);                                 DONE
Philip Carns's avatar
Philip Carns committed
53
 *
54 55 56 57 58
 * Omissions: 
 *   - _unlocked() variants of the various flush, read, and write
 *     functions.  There are many of these, but they are not available on all
 *     systems and the man page advises not to use them.
 *   - ungetc()
Philip Carns's avatar
Philip Carns committed
59 60
 */

61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80
#define _XOPEN_SOURCE 500
#define _GNU_SOURCE

#include "darshan-runtime-config.h"
#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <stdarg.h>
#include <string.h>
#include <time.h>
#include <stdlib.h>
#include <errno.h>
#include <sys/uio.h>
#include <sys/mman.h>
#include <search.h>
#include <assert.h>
#include <libgen.h>
#include <pthread.h>
Philip Carns's avatar
Philip Carns committed
81 82
#include <stdint.h>
#include <limits.h>
83 84 85 86

#include "darshan.h"
#include "darshan-dynamic.h"

87 88 89 90
#ifndef HAVE_OFF64_T
typedef int64_t off64_t;
#endif

91 92
DARSHAN_FORWARD_DECL(fopen, FILE*, (const char *path, const char *mode));
DARSHAN_FORWARD_DECL(fopen64, FILE*, (const char *path, const char *mode));
Philip Carns's avatar
Philip Carns committed
93
DARSHAN_FORWARD_DECL(fdopen, FILE*, (int fd, const char *mode));
Philip Carns's avatar
Philip Carns committed
94
DARSHAN_FORWARD_DECL(freopen, FILE*, (const char *path, const char *mode, FILE *stream));
Philip Carns's avatar
Philip Carns committed
95
DARSHAN_FORWARD_DECL(freopen64, FILE*, (const char *path, const char *mode, FILE *stream));
96
DARSHAN_FORWARD_DECL(fclose, int, (FILE *fp));
Philip Carns's avatar
Philip Carns committed
97
DARSHAN_FORWARD_DECL(fflush, int, (FILE *fp));
98
DARSHAN_FORWARD_DECL(fwrite, size_t, (const void *ptr, size_t size, size_t nmemb, FILE *stream));
Philip Carns's avatar
Philip Carns committed
99
DARSHAN_FORWARD_DECL(fputc, int, (int c, FILE *stream));
Philip Carns's avatar
Philip Carns committed
100
DARSHAN_FORWARD_DECL(putw, int, (int w, FILE *stream));
Philip Carns's avatar
Philip Carns committed
101
DARSHAN_FORWARD_DECL(fputs, int, (const char *s, FILE *stream));
Philip Carns's avatar
Philip Carns committed
102
DARSHAN_FORWARD_DECL(fprintf, int, (FILE *stream, const char *format, ...));
103
DARSHAN_FORWARD_DECL(printf, int, (const char *format, ...));
Philip Carns's avatar
Philip Carns committed
104
DARSHAN_FORWARD_DECL(vfprintf, int, (FILE *stream, const char *format, va_list));
105
DARSHAN_FORWARD_DECL(vprintf, int, (const char *format, va_list));
106
DARSHAN_FORWARD_DECL(fread, size_t, (void *ptr, size_t size, size_t nmemb, FILE *stream));
Philip Carns's avatar
Philip Carns committed
107
DARSHAN_FORWARD_DECL(fgetc, int, (FILE *stream));
Philip Carns's avatar
Philip Carns committed
108
DARSHAN_FORWARD_DECL(getw, int, (FILE *stream));
Philip Carns's avatar
Philip Carns committed
109
DARSHAN_FORWARD_DECL(_IO_getc, int, (FILE *stream));
Philip Carns's avatar
Philip Carns committed
110
DARSHAN_FORWARD_DECL(_IO_putc, int, (int, FILE *stream));
Philip Carns's avatar
Philip Carns committed
111
DARSHAN_FORWARD_DECL(fscanf, int, (FILE *stream, const char *format, ...));
Philip Carns's avatar
Philip Carns committed
112
DARSHAN_FORWARD_DECL(__isoc99_fscanf, int, (FILE *stream, const char *format, ...));
Philip Carns's avatar
Philip Carns committed
113
DARSHAN_FORWARD_DECL(vfscanf, int, (FILE *stream, const char *format, va_list ap));
Philip Carns's avatar
Philip Carns committed
114
DARSHAN_FORWARD_DECL(fgets, char*, (char *s, int size, FILE *stream));
115
DARSHAN_FORWARD_DECL(fseek, int, (FILE *stream, long offset, int whence));
Philip Carns's avatar
Philip Carns committed
116
DARSHAN_FORWARD_DECL(fseeko, int, (FILE *stream, off_t offset, int whence));
117
DARSHAN_FORWARD_DECL(fseeko64, int, (FILE *stream, off64_t offset, int whence));
Philip Carns's avatar
Philip Carns committed
118
DARSHAN_FORWARD_DECL(fsetpos, int, (FILE *stream, const fpos_t *pos));
119
DARSHAN_FORWARD_DECL(fsetpos64, int, (FILE *stream, const fpos64_t *pos));
Philip Carns's avatar
Philip Carns committed
120
DARSHAN_FORWARD_DECL(rewind, void, (FILE *stream));
121

122 123
/* structure to track stdio stats at runtime */
struct stdio_file_record_ref
124
{
125
    struct darshan_stdio_file* file_rec;
126 127 128 129
    int64_t offset;
    double last_meta_end;
    double last_read_end;
    double last_write_end;
130
    int fs_type;
131 132 133 134 135 136 137 138
};

/* The stdio_runtime structure maintains necessary state for storing
 * STDIO file records and for coordinating with darshan-core at 
 * shutdown time.
 */
struct stdio_runtime
{
139 140 141
    void *rec_id_hash;
    void *stream_hash;
    int file_rec_count;
142 143 144 145 146 147 148 149
};

static struct stdio_runtime *stdio_runtime = NULL;
static pthread_mutex_t stdio_runtime_mutex = PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP;
static int darshan_mem_alignment = 1;
static int my_rank = -1;

static void stdio_runtime_initialize(void);
150 151 152 153 154 155
static void stdio_shutdown(
    MPI_Comm mod_comm,
    darshan_record_id *shared_recs,
    int shared_rec_count,
    void **stdio_buf,
    int *stdio_buf_sz);
156 157
static void stdio_record_reduction_op(void* infile_v, void* inoutfile_v,
    int *len, MPI_Datatype *datatype);
158 159 160
static void stdio_shared_record_variance(
    MPI_Comm mod_comm, struct darshan_stdio_file *inrec_array,
    struct darshan_stdio_file *outrec_array, int shared_rec_count);
161 162 163
static struct stdio_file_record_ref *stdio_track_new_file_record(
    darshan_record_id rec_id, const char *path);
static void stdio_cleanup_runtime();
164

165 166 167
/* extern function def for querying record name from a POSIX fd */
extern char *darshan_posix_lookup_record_name(int fd);

168 169 170 171 172 173
/* we need access to fileno (defined in POSIX module) for instrumenting fopen calls */
#ifdef DARSHAN_PRELOAD
extern int (*__real_fileno)(FILE *stream);
#else
extern int __real_fileno(FILE *stream);
#endif
174

175 176 177
#define STDIO_LOCK() pthread_mutex_lock(&stdio_runtime_mutex)
#define STDIO_UNLOCK() pthread_mutex_unlock(&stdio_runtime_mutex)

178 179
#define STDIO_PRE_RECORD() do { \
    STDIO_LOCK(); \
180
    if(!darshan_core_disabled_instrumentation()) { \
181 182
        if(!stdio_runtime) stdio_runtime_initialize(); \
        if(stdio_runtime) break; \
183
    } \
184 185
    STDIO_UNLOCK(); \
    return(ret); \
186 187 188 189 190 191
} while(0)

#define STDIO_POST_RECORD() do { \
    STDIO_UNLOCK(); \
} while(0)

Philip Carns's avatar
Philip Carns committed
192
#define STDIO_RECORD_OPEN(__ret, __path, __tm1, __tm2) do { \
193 194 195
    darshan_record_id __rec_id; \
    struct stdio_file_record_ref *__rec_ref; \
    char *__newpath; \
196
    int __fd; \
197
    MAP_OR_FAIL(fileno); \
198 199 200 201 202
    if(!__ret || !__path) break; \
    __newpath = darshan_clean_file_path(__path); \
    if(!__newpath) __newpath = (char*)__path; \
    if(darshan_core_excluded_path(__newpath)) { \
        if(__newpath != (char*)__path) free(__newpath); \
203
        break; \
Philip Carns's avatar
Philip Carns committed
204
    } \
205 206 207 208 209
    __rec_id = darshan_core_gen_record_id(__newpath); \
    __rec_ref = darshan_lookup_record_ref(stdio_runtime->rec_id_hash, &__rec_id, sizeof(darshan_record_id)); \
    if(!__rec_ref) __rec_ref = stdio_track_new_file_record(__rec_id, __newpath); \
    if(!__rec_ref) { \
        if(__newpath != (char*)__path) free(__newpath); \
210 211
        break; \
    } \
212
    _STDIO_RECORD_OPEN(__ret, __rec_ref, __tm1, __tm2, 1, -1); \
213
    __fd = __real_fileno(__ret); \
214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232
    darshan_instrument_fs_data(__rec_ref->fs_type, __newpath, __fd); \
    if(__newpath != (char*)__path) free(__newpath); \
} while(0)

#define STDIO_RECORD_REFOPEN(__ret, __rec_ref, __tm1, __tm2, __ref_counter) do { \
    if(!ret || !rec_ref) break; \
    _STDIO_RECORD_OPEN(__ret, __rec_ref, __tm1, __tm2, 0, __ref_counter); \
} while(0)

#define _STDIO_RECORD_OPEN(__ret, __rec_ref, __tm1, __tm2, __reset_flag, __ref_counter) do { \
    if(__reset_flag) __rec_ref->offset = 0; \
    __rec_ref->file_rec->counters[STDIO_OPENS] += 1; \
    if(__ref_counter >= 0) __rec_ref->file_rec->counters[__ref_counter] += 1; \
    if(__rec_ref->file_rec->fcounters[STDIO_F_OPEN_START_TIMESTAMP] == 0 || \
     __rec_ref->file_rec->fcounters[STDIO_F_OPEN_START_TIMESTAMP] > __tm1) \
        __rec_ref->file_rec->fcounters[STDIO_F_OPEN_START_TIMESTAMP] = __tm1; \
    __rec_ref->file_rec->fcounters[STDIO_F_OPEN_END_TIMESTAMP] = __tm2; \
    DARSHAN_TIMER_INC_NO_OVERLAP(__rec_ref->file_rec->fcounters[STDIO_F_META_TIME], __tm1, __tm2, __rec_ref->last_meta_end); \
    darshan_add_record_ref(&(stdio_runtime->stream_hash), &(__ret), sizeof(__ret), __rec_ref); \
Philip Carns's avatar
Philip Carns committed
233 234 235
} while(0)


236
#define STDIO_RECORD_READ(__fp, __bytes,  __tm1, __tm2) do{ \
237
    struct stdio_file_record_ref* rec_ref; \
238
    int64_t this_offset; \
Philip Carns's avatar
Philip Carns committed
239
    rec_ref = darshan_lookup_record_ref(stdio_runtime->stream_hash, &(__fp), sizeof(__fp)); \
240 241 242 243 244 245 246 247 248 249 250
    if(!rec_ref) break; \
    this_offset = rec_ref->offset; \
    rec_ref->offset = this_offset + __bytes; \
    if(rec_ref->file_rec->counters[STDIO_MAX_BYTE_READ] < (this_offset + __bytes - 1)) \
        rec_ref->file_rec->counters[STDIO_MAX_BYTE_READ] = (this_offset + __bytes - 1); \
    rec_ref->file_rec->counters[STDIO_BYTES_READ] += __bytes; \
    rec_ref->file_rec->counters[STDIO_READS] += 1; \
    if(rec_ref->file_rec->fcounters[STDIO_F_READ_START_TIMESTAMP] == 0 || \
     rec_ref->file_rec->fcounters[STDIO_F_READ_START_TIMESTAMP] > __tm1) \
        rec_ref->file_rec->fcounters[STDIO_F_READ_START_TIMESTAMP] = __tm1; \
    rec_ref->file_rec->fcounters[STDIO_F_READ_END_TIMESTAMP] = __tm2; \
251
    DARSHAN_TIMER_INC_NO_OVERLAP(rec_ref->file_rec->fcounters[STDIO_F_READ_TIME], __tm1, __tm2, rec_ref->last_read_end); \
252 253
} while(0)

Philip Carns's avatar
Philip Carns committed
254
#define STDIO_RECORD_WRITE(__fp, __bytes,  __tm1, __tm2, __fflush_flag) do{ \
255
    struct stdio_file_record_ref* rec_ref; \
256
    int64_t this_offset; \
Philip Carns's avatar
Philip Carns committed
257
    rec_ref = darshan_lookup_record_ref(stdio_runtime->stream_hash, &(__fp), sizeof(__fp)); \
258 259 260 261 262 263
    if(!rec_ref) break; \
    this_offset = rec_ref->offset; \
    rec_ref->offset = this_offset + __bytes; \
    if(rec_ref->file_rec->counters[STDIO_MAX_BYTE_WRITTEN] < (this_offset + __bytes - 1)) \
        rec_ref->file_rec->counters[STDIO_MAX_BYTE_WRITTEN] = (this_offset + __bytes - 1); \
    rec_ref->file_rec->counters[STDIO_BYTES_WRITTEN] += __bytes; \
Philip Carns's avatar
Philip Carns committed
264
    if(__fflush_flag) \
265
        rec_ref->file_rec->counters[STDIO_FLUSHES] += 1; \
Philip Carns's avatar
Philip Carns committed
266
    else \
267 268 269 270 271 272
        rec_ref->file_rec->counters[STDIO_WRITES] += 1; \
    if(rec_ref->file_rec->fcounters[STDIO_F_WRITE_START_TIMESTAMP] == 0 || \
     rec_ref->file_rec->fcounters[STDIO_F_WRITE_START_TIMESTAMP] > __tm1) \
        rec_ref->file_rec->fcounters[STDIO_F_WRITE_START_TIMESTAMP] = __tm1; \
    rec_ref->file_rec->fcounters[STDIO_F_WRITE_END_TIMESTAMP] = __tm2; \
    DARSHAN_TIMER_INC_NO_OVERLAP(rec_ref->file_rec->fcounters[STDIO_F_WRITE_TIME], __tm1, __tm2, rec_ref->last_write_end); \
273
} while(0)
Philip Carns's avatar
Philip Carns committed
274

Philip Carns's avatar
Philip Carns committed
275
FILE* DARSHAN_DECL(fopen)(const char *path, const char *mode)
Philip Carns's avatar
Philip Carns committed
276 277 278 279
{
    FILE* ret;
    double tm1, tm2;

Philip Carns's avatar
Philip Carns committed
280
    MAP_OR_FAIL(fopen);
Philip Carns's avatar
Philip Carns committed
281 282

    tm1 = darshan_core_wtime();
Philip Carns's avatar
Philip Carns committed
283
    ret = __real_fopen(path, mode);
Philip Carns's avatar
Philip Carns committed
284 285
    tm2 = darshan_core_wtime();

286
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
287
    STDIO_RECORD_OPEN(ret, path, tm1, tm2);
288
    STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
289 290 291 292

    return(ret);
}

Philip Carns's avatar
Philip Carns committed
293
FILE* DARSHAN_DECL(fopen64)(const char *path, const char *mode)
294 295
{
    FILE* ret;
Philip Carns's avatar
Philip Carns committed
296
    double tm1, tm2;
297

Shane Snyder's avatar
Shane Snyder committed
298
    MAP_OR_FAIL(fopen64);
299

Philip Carns's avatar
Philip Carns committed
300
    tm1 = darshan_core_wtime();
Philip Carns's avatar
Philip Carns committed
301
    ret = __real_fopen64(path, mode);
Philip Carns's avatar
Philip Carns committed
302 303
    tm2 = darshan_core_wtime();

304
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
305
    STDIO_RECORD_OPEN(ret, path, tm1, tm2);
306
    STDIO_POST_RECORD();
307 308 309 310

    return(ret);
}

Philip Carns's avatar
Philip Carns committed
311
FILE* DARSHAN_DECL(fdopen)(int fd, const char *mode)
312 313
{
    FILE* ret;
Philip Carns's avatar
Philip Carns committed
314
    double tm1, tm2;
315 316
    darshan_record_id rec_id;
    struct stdio_file_record_ref *rec_ref;
317

Philip Carns's avatar
Philip Carns committed
318
    MAP_OR_FAIL(fdopen);
319

Philip Carns's avatar
Philip Carns committed
320
    tm1 = darshan_core_wtime();
Philip Carns's avatar
Philip Carns committed
321 322 323
    ret = __real_fdopen(fd, mode);
    tm2 = darshan_core_wtime();

324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340
    if(ret)
    {
        char *rec_name = darshan_posix_lookup_record_name(fd);
        if(rec_name)
        {
            rec_id = darshan_core_gen_record_id(rec_name);

            STDIO_PRE_RECORD();
            rec_ref = darshan_lookup_record_ref(stdio_runtime->rec_id_hash,
                &rec_id, sizeof(darshan_record_id));
            if(!rec_ref)
                rec_ref = stdio_track_new_file_record(rec_id, rec_name);
            STDIO_RECORD_REFOPEN(ret, rec_ref, tm1, tm2, STDIO_FDOPENS);
            STDIO_POST_RECORD();
        }
    }

Philip Carns's avatar
Philip Carns committed
341 342 343 344 345 346 347 348 349 350 351 352 353

    return(ret);
}

FILE* DARSHAN_DECL(freopen)(const char *path, const char *mode, FILE *stream)
{
    FILE* ret;
    double tm1, tm2;

    MAP_OR_FAIL(freopen);

    tm1 = darshan_core_wtime();
    ret = __real_freopen(path, mode, stream);
Philip Carns's avatar
Philip Carns committed
354 355
    tm2 = darshan_core_wtime();

356
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
357
    STDIO_RECORD_OPEN(ret, path, tm1, tm2);
358
    STDIO_POST_RECORD();
359 360 361 362

    return(ret);
}

Philip Carns's avatar
Philip Carns committed
363 364 365 366 367 368 369 370 371 372 373
FILE* DARSHAN_DECL(freopen64)(const char *path, const char *mode, FILE *stream)
{
    FILE* ret;
    double tm1, tm2;

    MAP_OR_FAIL(freopen64);

    tm1 = darshan_core_wtime();
    ret = __real_freopen64(path, mode, stream);
    tm2 = darshan_core_wtime();

374
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
375
    STDIO_RECORD_OPEN(ret, path, tm1, tm2);
376
    STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
377 378 379 380 381

    return(ret);
}


Philip Carns's avatar
Philip Carns committed
382 383 384 385 386 387 388 389 390 391 392
int DARSHAN_DECL(fflush)(FILE *fp)
{
    double tm1, tm2;
    int ret;

    MAP_OR_FAIL(fflush);

    tm1 = darshan_core_wtime();
    ret = __real_fflush(fp);
    tm2 = darshan_core_wtime();

393
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
394 395
    if(ret >= 0)
        STDIO_RECORD_WRITE(fp, 0, tm1, tm2, 1);
396
    STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
397 398 399 400

    return(ret);
}

401 402 403 404
int DARSHAN_DECL(fclose)(FILE *fp)
{
    double tm1, tm2;
    int ret;
405
    struct stdio_file_record_ref *rec_ref;
406 407 408 409 410 411 412

    MAP_OR_FAIL(fclose);

    tm1 = darshan_core_wtime();
    ret = __real_fclose(fp);
    tm2 = darshan_core_wtime();

413 414 415
    STDIO_PRE_RECORD();
    rec_ref = darshan_lookup_record_ref(stdio_runtime->stream_hash, &fp, sizeof(fp));
    if(rec_ref)
416
    {
417 418 419 420
        if(rec_ref->file_rec->fcounters[STDIO_F_CLOSE_START_TIMESTAMP] == 0 ||
         rec_ref->file_rec->fcounters[STDIO_F_CLOSE_START_TIMESTAMP] > tm1)
           rec_ref->file_rec->fcounters[STDIO_F_CLOSE_START_TIMESTAMP] = tm1;
        rec_ref->file_rec->fcounters[STDIO_F_CLOSE_END_TIMESTAMP] = tm2;
421
        DARSHAN_TIMER_INC_NO_OVERLAP(
422 423 424
            rec_ref->file_rec->fcounters[STDIO_F_META_TIME],
            tm1, tm2, rec_ref->last_meta_end);
        darshan_delete_record_ref(&(stdio_runtime->stream_hash), &fp, sizeof(fp));
425
    }
426
    STDIO_POST_RECORD();
427 428 429 430

    return(ret);
}

431 432 433 434 435 436 437 438 439 440 441
size_t DARSHAN_DECL(fwrite)(const void *ptr, size_t size, size_t nmemb, FILE *stream)
{
    size_t ret;
    double tm1, tm2;

    MAP_OR_FAIL(fwrite);

    tm1 = darshan_core_wtime();
    ret = __real_fwrite(ptr, size, nmemb, stream);
    tm2 = darshan_core_wtime();

442
    STDIO_PRE_RECORD();
443
    if(ret > 0)
Philip Carns's avatar
Philip Carns committed
444
        STDIO_RECORD_WRITE(stream, size*ret, tm1, tm2, 0);
445
    STDIO_POST_RECORD();
446 447 448 449

    return(ret);
}

Philip Carns's avatar
Philip Carns committed
450 451 452 453 454 455 456 457 458 459 460 461

int DARSHAN_DECL(fputc)(int c, FILE *stream)
{
    int ret;
    double tm1, tm2;

    MAP_OR_FAIL(fputc);

    tm1 = darshan_core_wtime();
    ret = __real_fputc(c, stream);
    tm2 = darshan_core_wtime();

462
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
463 464
    if(ret != EOF)
        STDIO_RECORD_WRITE(stream, 1, tm1, tm2, 0);
465
    STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
466 467 468 469

    return(ret);
}

Philip Carns's avatar
Philip Carns committed
470 471 472 473 474 475 476 477 478 479 480
int DARSHAN_DECL(putw)(int w, FILE *stream)
{
    int ret;
    double tm1, tm2;

    MAP_OR_FAIL(putw);

    tm1 = darshan_core_wtime();
    ret = __real_putw(w, stream);
    tm2 = darshan_core_wtime();

481
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
482 483
    if(ret != EOF)
        STDIO_RECORD_WRITE(stream, sizeof(int), tm1, tm2, 0);
484
    STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
485 486 487 488 489

    return(ret);
}


Philip Carns's avatar
Philip Carns committed
490 491 492 493 494 495 496 497 498 499 500 501

int DARSHAN_DECL(fputs)(const char *s, FILE *stream)
{
    int ret;
    double tm1, tm2;

    MAP_OR_FAIL(fputs);

    tm1 = darshan_core_wtime();
    ret = __real_fputs(s, stream);
    tm2 = darshan_core_wtime();

502
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
503 504
    if(ret != EOF && ret > 0)
        STDIO_RECORD_WRITE(stream, strlen(s), tm1, tm2, 0);
505
    STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
506 507 508 509

    return(ret);
}

510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528
int DARSHAN_DECL(vprintf)(const char *format, va_list ap)
{
    int ret;
    double tm1, tm2;

    MAP_OR_FAIL(vprintf);

    tm1 = darshan_core_wtime();
    ret = __real_vprintf(format, ap);
    tm2 = darshan_core_wtime();

    STDIO_PRE_RECORD();
    if(ret > 0)
        STDIO_RECORD_WRITE(stdout, ret, tm1, tm2, 0);
    STDIO_POST_RECORD();

    return(ret);
}

Philip Carns's avatar
Philip Carns committed
529 530 531 532 533 534 535 536 537 538 539
int DARSHAN_DECL(vfprintf)(FILE *stream, const char *format, va_list ap)
{
    int ret;
    double tm1, tm2;

    MAP_OR_FAIL(vfprintf);

    tm1 = darshan_core_wtime();
    ret = __real_vfprintf(stream, format, ap);
    tm2 = darshan_core_wtime();

540
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
541
    if(ret > 0)
542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568
        STDIO_RECORD_WRITE(stream, ret, tm1, tm2, 0);
    STDIO_POST_RECORD();

    return(ret);
}


int DARSHAN_DECL(printf)(const char *format, ...)
{
    int ret;
    double tm1, tm2;
    va_list ap;

    MAP_OR_FAIL(vprintf);

    tm1 = darshan_core_wtime();
    /* NOTE: we intentionally switch to vprintf here to handle the variable
     * length arguments.
     */
    va_start(ap, format);
    ret = __real_vprintf(format, ap);
    va_end(ap);
    tm2 = darshan_core_wtime();

    STDIO_PRE_RECORD();
    if(ret > 0)
        STDIO_RECORD_WRITE(stdout, ret, tm1, tm2, 0);
569
    STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590

    return(ret);
}

int DARSHAN_DECL(fprintf)(FILE *stream, const char *format, ...)
{
    int ret;
    double tm1, tm2;
    va_list ap;

    MAP_OR_FAIL(vfprintf);

    tm1 = darshan_core_wtime();
    /* NOTE: we intentionally switch to vfprintf here to handle the variable
     * length arguments.
     */
    va_start(ap, format);
    ret = __real_vfprintf(stream, format, ap);
    va_end(ap);
    tm2 = darshan_core_wtime();

591
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
592
    if(ret > 0)
593
        STDIO_RECORD_WRITE(stream, ret, tm1, tm2, 0);
594
    STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
595 596 597 598

    return(ret);
}

599 600 601 602 603 604 605 606 607 608 609
size_t DARSHAN_DECL(fread)(void *ptr, size_t size, size_t nmemb, FILE *stream)
{
    size_t ret;
    double tm1, tm2;

    MAP_OR_FAIL(fread);

    tm1 = darshan_core_wtime();
    ret = __real_fread(ptr, size, nmemb, stream);
    tm2 = darshan_core_wtime();

610
    STDIO_PRE_RECORD();
611 612
    if(ret > 0)
        STDIO_RECORD_READ(stream, size*ret, tm1, tm2);
613
    STDIO_POST_RECORD();
614 615 616 617

    return(ret);
}

618
int DARSHAN_DECL(fgetc)(FILE *stream)
Philip Carns's avatar
Philip Carns committed
619 620 621 622 623 624 625 626 627 628
{
    int ret;
    double tm1, tm2;

    MAP_OR_FAIL(fgetc);

    tm1 = darshan_core_wtime();
    ret = __real_fgetc(stream);
    tm2 = darshan_core_wtime();

629
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
630 631
    if(ret != EOF)
        STDIO_RECORD_READ(stream, 1, tm1, tm2);
632
    STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
633 634 635 636 637

    return(ret);
}

/* NOTE: stdio.h typically implements getc() as a macro pointing to _IO_getc */
638
int DARSHAN_DECL(_IO_getc)(FILE *stream)
Philip Carns's avatar
Philip Carns committed
639 640 641 642 643 644 645 646 647 648
{
    int ret;
    double tm1, tm2;

    MAP_OR_FAIL(_IO_getc);

    tm1 = darshan_core_wtime();
    ret = __real__IO_getc(stream);
    tm2 = darshan_core_wtime();

649
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
650 651
    if(ret != EOF)
        STDIO_RECORD_READ(stream, 1, tm1, tm2);
652
    STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
653 654 655 656

    return(ret);
}

Philip Carns's avatar
Philip Carns committed
657
/* NOTE: stdio.h typically implements putc() as a macro pointing to _IO_putc */
658
int DARSHAN_DECL(_IO_putc)(int c, FILE *stream)
Philip Carns's avatar
Philip Carns committed
659 660 661 662 663 664 665 666 667 668
{
    int ret;
    double tm1, tm2;

    MAP_OR_FAIL(_IO_putc);

    tm1 = darshan_core_wtime();
    ret = __real__IO_putc(c, stream);
    tm2 = darshan_core_wtime();

669
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
670 671
    if(ret != EOF)
        STDIO_RECORD_WRITE(stream, 1, tm1, tm2, 0);
672
    STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
673 674 675

    return(ret);
}
676 677

int DARSHAN_DECL(getw)(FILE *stream)
Philip Carns's avatar
Philip Carns committed
678 679 680 681 682 683 684 685 686 687
{
    int ret;
    double tm1, tm2;

    MAP_OR_FAIL(getw);

    tm1 = darshan_core_wtime();
    ret = __real_getw(stream);
    tm2 = darshan_core_wtime();

688
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
689 690
    if(ret != EOF || ferror(stream) == 0)
        STDIO_RECORD_READ(stream, sizeof(int), tm1, tm2);
691
    STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
692 693 694 695

    return(ret);
}

Philip Carns's avatar
Philip Carns committed
696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718
/* NOTE: some glibc versions use __isoc99_fscanf as the underlying symbol
 * rather than fscanf
 */
int DARSHAN_DECL(__isoc99_fscanf)(FILE *stream, const char *format, ...)
{
    int ret;
    double tm1, tm2;
    va_list ap;
    long start_off, end_off;

    MAP_OR_FAIL(vfscanf);

    tm1 = darshan_core_wtime();
    /* NOTE: we intentionally switch to vfscanf here to handle the variable
     * length arguments.
     */
    start_off = ftell(stream);
    va_start(ap, format);
    ret = __real_vfscanf(stream, format, ap);
    va_end(ap);
    end_off = ftell(stream);
    tm2 = darshan_core_wtime();

719
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
720 721
    if(ret != 0)
        STDIO_RECORD_READ(stream, (end_off-start_off), tm1, tm2);
722
    STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
723 724 725 726

    return(ret);
}

Philip Carns's avatar
Philip Carns committed
727

Philip Carns's avatar
Philip Carns committed
728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747
int DARSHAN_DECL(fscanf)(FILE *stream, const char *format, ...)
{
    int ret;
    double tm1, tm2;
    va_list ap;
    long start_off, end_off;

    MAP_OR_FAIL(vfscanf);

    tm1 = darshan_core_wtime();
    /* NOTE: we intentionally switch to vfscanf here to handle the variable
     * length arguments.
     */
    start_off = ftell(stream);
    va_start(ap, format);
    ret = __real_vfscanf(stream, format, ap);
    va_end(ap);
    end_off = ftell(stream);
    tm2 = darshan_core_wtime();

748
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
749
    if(ret != 0)
Philip Carns's avatar
Philip Carns committed
750
        STDIO_RECORD_READ(stream, (end_off-start_off), tm1, tm2);
751
    STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769

    return(ret);
}

int DARSHAN_DECL(vfscanf)(FILE *stream, const char *format, va_list ap)
{
    int ret;
    double tm1, tm2;
    long start_off, end_off;

    MAP_OR_FAIL(vfscanf);

    tm1 = darshan_core_wtime();
    start_off = ftell(stream);
    ret = __real_vfscanf(stream, format, ap);
    end_off = ftell(stream);
    tm2 = darshan_core_wtime();

770
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
771 772
    if(ret != 0)
        STDIO_RECORD_READ(stream, end_off-start_off, tm1, tm2);
773
    STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
774 775 776 777 778

    return(ret);
}


Philip Carns's avatar
Philip Carns committed
779 780 781 782 783 784 785 786 787 788 789
char* DARSHAN_DECL(fgets)(char *s, int size, FILE *stream)
{
    char *ret;
    double tm1, tm2;

    MAP_OR_FAIL(fgets);

    tm1 = darshan_core_wtime();
    ret = __real_fgets(s, size, stream);
    tm2 = darshan_core_wtime();

790
    STDIO_PRE_RECORD();
Philip Carns's avatar
Philip Carns committed
791 792
    if(ret != NULL)
        STDIO_RECORD_READ(stream, strlen(ret), tm1, tm2);
793
    STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
794 795 796 797 798

    return(ret);
}


Philip Carns's avatar
Philip Carns committed
799 800 801
void DARSHAN_DECL(rewind)(FILE *stream)
{
    double tm1, tm2;
802
    struct stdio_file_record_ref *rec_ref;
Philip Carns's avatar
Philip Carns committed
803 804 805 806 807 808 809

    MAP_OR_FAIL(rewind);

    tm1 = darshan_core_wtime();
    __real_rewind(stream);
    tm2 = darshan_core_wtime();

810 811 812
    /* NOTE: we don't use STDIO_PRE_RECORD here because there is no return
     * value in this wrapper.
     */
Philip Carns's avatar
Philip Carns committed
813
    STDIO_LOCK();
814
    if(darshan_core_disabled_instrumentation()) {
815 816 817 818
        STDIO_UNLOCK();
        return;
    }
    if(!stdio_runtime) stdio_runtime_initialize();
819 820 821 822 823 824 825 826
    if(!stdio_runtime) {
        STDIO_UNLOCK();
        return;
    }

    rec_ref = darshan_lookup_record_ref(stdio_runtime->stream_hash, &stream, sizeof(stream));

    if(rec_ref)
Philip Carns's avatar
Philip Carns committed
827
    {
828
        rec_ref->offset = 0;
Philip Carns's avatar
Philip Carns committed
829
        DARSHAN_TIMER_INC_NO_OVERLAP(
830 831 832
            rec_ref->file_rec->fcounters[STDIO_F_META_TIME],
            tm1, tm2, rec_ref->last_meta_end);
        rec_ref->file_rec->counters[STDIO_SEEKS] += 1;
Philip Carns's avatar
Philip Carns committed
833
    }
834
    STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
835 836 837 838

    return;
}

839 840 841
int DARSHAN_DECL(fseek)(FILE *stream, long offset, int whence)
{
    int ret;
842
    struct stdio_file_record_ref *rec_ref;
843 844 845 846 847 848 849 850 851 852
    double tm1, tm2;

    MAP_OR_FAIL(fseek);

    tm1 = darshan_core_wtime();
    ret = __real_fseek(stream, offset, whence);
    tm2 = darshan_core_wtime();

    if(ret >= 0)
    {
853 854 855
        STDIO_PRE_RECORD();
        rec_ref = darshan_lookup_record_ref(stdio_runtime->stream_hash, &stream, sizeof(stream));
        if(rec_ref)
Philip Carns's avatar
Philip Carns committed
856
        {
857
            rec_ref->offset = ftell(stream);
Philip Carns's avatar
Philip Carns committed
858
            DARSHAN_TIMER_INC_NO_OVERLAP(
859 860 861
                rec_ref->file_rec->fcounters[STDIO_F_META_TIME],
                tm1, tm2, rec_ref->last_meta_end);
            rec_ref->file_rec->counters[STDIO_SEEKS] += 1;
Philip Carns's avatar
Philip Carns committed
862
        }
863
        STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
864 865 866 867 868 869 870 871
    }

    return(ret);
}

int DARSHAN_DECL(fseeko)(FILE *stream, off_t offset, int whence)
{
    int ret;
872
    struct stdio_file_record_ref *rec_ref;
Philip Carns's avatar
Philip Carns committed
873 874 875 876 877 878 879 880 881 882
    double tm1, tm2;

    MAP_OR_FAIL(fseeko);

    tm1 = darshan_core_wtime();
    ret = __real_fseeko(stream, offset, whence);
    tm2 = darshan_core_wtime();

    if(ret >= 0)
    {
883 884 885
        STDIO_PRE_RECORD();
        rec_ref = darshan_lookup_record_ref(stdio_runtime->stream_hash, &stream, sizeof(stream));
        if(rec_ref)
Philip Carns's avatar
Philip Carns committed
886
        {
887
            rec_ref->offset = ftell(stream);
Philip Carns's avatar
Philip Carns committed
888
            DARSHAN_TIMER_INC_NO_OVERLAP(
889 890 891
                rec_ref->file_rec->fcounters[STDIO_F_META_TIME],
                tm1, tm2, rec_ref->last_meta_end);
            rec_ref->file_rec->counters[STDIO_SEEKS] += 1;
Philip Carns's avatar
Philip Carns committed
892
        }
893
        STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
894 895 896 897 898
    }

    return(ret);
}

899
int DARSHAN_DECL(fseeko64)(FILE *stream, off64_t offset, int whence)
Philip Carns's avatar
Philip Carns committed
900 901
{
    int ret;
902
    struct stdio_file_record_ref *rec_ref;
Philip Carns's avatar
Philip Carns committed
903 904 905 906 907 908 909 910 911 912
    double tm1, tm2;

    MAP_OR_FAIL(fseeko64);

    tm1 = darshan_core_wtime();
    ret = __real_fseeko64(stream, offset, whence);
    tm2 = darshan_core_wtime();

    if(ret >= 0)
    {
913 914 915
        STDIO_PRE_RECORD();
        rec_ref = darshan_lookup_record_ref(stdio_runtime->stream_hash, &stream, sizeof(stream));
        if(rec_ref)
916
        {
917
            rec_ref->offset = ftell(stream);
918
            DARSHAN_TIMER_INC_NO_OVERLAP(
919 920 921
                rec_ref->file_rec->fcounters[STDIO_F_META_TIME],
                tm1, tm2, rec_ref->last_meta_end);
            rec_ref->file_rec->counters[STDIO_SEEKS] += 1;
922
        }
923
        STDIO_POST_RECORD();
924 925 926 927 928
    }

    return(ret);
}

Philip Carns's avatar
Philip Carns committed
929 930 931
int DARSHAN_DECL(fsetpos)(FILE *stream, const fpos_t *pos)
{
    int ret;
932
    struct stdio_file_record_ref *rec_ref;
Philip Carns's avatar
Philip Carns committed
933 934 935 936 937 938 939 940 941 942
    double tm1, tm2;

    MAP_OR_FAIL(fsetpos);

    tm1 = darshan_core_wtime();
    ret = __real_fsetpos(stream, pos);
    tm2 = darshan_core_wtime();

    if(ret >= 0)
    {
943 944 945
        STDIO_PRE_RECORD();
        rec_ref = darshan_lookup_record_ref(stdio_runtime->stream_hash, &stream, sizeof(stream));
        if(rec_ref)
Philip Carns's avatar
Philip Carns committed
946
        {
947
            rec_ref->offset = ftell(stream);
Philip Carns's avatar
Philip Carns committed
948
            DARSHAN_TIMER_INC_NO_OVERLAP(
949 950 951
                rec_ref->file_rec->fcounters[STDIO_F_META_TIME],
                tm1, tm2, rec_ref->last_meta_end);
            rec_ref->file_rec->counters[STDIO_SEEKS] += 1;
Philip Carns's avatar
Philip Carns committed
952
        }
953
        STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
954 955 956 957 958
    }

    return(ret);
}

959
int DARSHAN_DECL(fsetpos64)(FILE *stream, const fpos64_t *pos)
Philip Carns's avatar
Philip Carns committed
960 961
{
    int ret;
962
    struct stdio_file_record_ref *rec_ref;
Philip Carns's avatar
Philip Carns committed
963 964 965 966 967 968 969 970 971 972
    double tm1, tm2;

    MAP_OR_FAIL(fsetpos64);

    tm1 = darshan_core_wtime();
    ret = __real_fsetpos64(stream, pos);
    tm2 = darshan_core_wtime();

    if(ret >= 0)
    {
973 974 975
        STDIO_PRE_RECORD();
        rec_ref = darshan_lookup_record_ref(stdio_runtime->stream_hash, &stream, sizeof(stream));
        if(rec_ref)
Philip Carns's avatar
Philip Carns committed
976
        {
977
            rec_ref->offset = ftell(stream);
Philip Carns's avatar
Philip Carns committed
978
            DARSHAN_TIMER_INC_NO_OVERLAP(
979 980 981
                rec_ref->file_rec->fcounters[STDIO_F_META_TIME],
                tm1, tm2, rec_ref->last_meta_end);
            rec_ref->file_rec->counters[STDIO_SEEKS] += 1;
Philip Carns's avatar
Philip Carns committed
982
        }
983
        STDIO_POST_RECORD();
Philip Carns's avatar
Philip Carns committed
984 985 986 987 988
    }

    return(ret);
}

989 990 991 992 993 994 995
/**********************************************************
 * Internal functions for manipulating STDIO module state *
 **********************************************************/

/* initialize internal STDIO module data structures and register with darshan-core */
static void stdio_runtime_initialize()
{
996 997 998 999
    int stdio_buf_size;

    /* try to store default number of records for this module */
    stdio_buf_size = DARSHAN_DEF_MOD_REC_COUNT * sizeof(struct darshan_stdio_file);
1000 1001 1002 1003

    /* register the stdio module with darshan core */
    darshan_core_register_module(
        DARSHAN_STDIO_MOD,
1004 1005
        &stdio_shutdown,
        &stdio_buf_size,
1006
        &my_rank,
1007 1008
        &darshan_mem_alignment);

1009 1010 1011
    /* return if darshan-core does not provide enough module memory */
    if(stdio_buf_size < sizeof(struct darshan_stdio_file))
    {
Shane Snyder's avatar
Shane Snyder committed
1012
        darshan_core_unregister_module(DARSHAN_STDIO_MOD);
1013
        return;
1014
    }
1015 1016 1017 1018

    stdio_runtime = malloc(sizeof(*stdio_runtime));
    if(!stdio_runtime)
    {
1019
        darshan_core_unregister_module(DARSHAN_STDIO_MOD);
1020 1021
        return;
    }
1022
    memset(stdio_runtime, 0, sizeof(*stdio_runtime));
1023 1024 1025 1026 1027

    /* instantiate records for stdin, stdout, and stderr */
    STDIO_RECORD_OPEN(stdin, "<STDIN>", 0, 0);
    STDIO_RECORD_OPEN(stdout, "<STDOUT>", 0, 0);
    STDIO_RECORD_OPEN(stderr, "<STDERR>", 0, 0);
1028 1029
}

1030 1031 1032
/************************************************************************
 * Functions exported by this module for coordinating with darshan-core *
 ************************************************************************/
1033

1034 1035
static void stdio_record_reduction_op(void* infile_v, void* inoutfile_v,
    int *len, MPI_Datatype *datatype)
1036
{
1037 1038 1039 1040
    struct darshan_stdio_file tmp_file;
    struct darshan_stdio_file *infile = infile_v;
    struct darshan_stdio_file *inoutfile = inoutfile_v;
    int i, j;
1041

1042
    assert(stdio_runtime);
1043

1044
    for(i=0; i<*len; i++)
1045
    {
1046 1047 1048
        memset(&tmp_file, 0, sizeof(struct darshan_stdio_file));
        tmp_file.base_rec.id = infile->base_rec.id;
        tmp_file.base_rec.rank = -1;
1049

Philip Carns's avatar