1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
/*
* Copyright (C) by Argonne National Laboratory
* See COPYRIGHT in top-level directory
*/
#include "adio.h"
#include "adio_extern.h"
#include <pthread.h>
/* Function for running in another thread for doing the file reading while the
* main thread is doing data aggregation - useful only when multiple rounds are
* needed due to file size relative to the read buffer size and number of
* aggregators */
void *ADIOI_IO_Thread_Func(void *vptr_args)
{
ADIOI_IO_ThreadFuncData *args = (ADIOI_IO_ThreadFuncData *) vptr_args;
ADIOI_Assert(args->size == (int) (args->size));
if (args->io_kind == ADIOI_READ) {
ADIO_ReadContig(args->fd, args->buf, args->size, MPI_BYTE,
ADIO_EXPLICIT_OFFSET, args->offset, args->status, &(args->error_code));
} else {
ADIO_WriteContig(args->fd, args->buf, args->size, MPI_BYTE,
ADIO_EXPLICIT_OFFSET, args->offset, args->status, &(args->error_code));
}
pthread_exit(&(args->error_code));
return NULL;
}
|
