IOR
|
#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <fcntl.h>
#include <sys/stat.h>
#include <assert.h>
#include "ior.h"
#include "aiori.h"
#include "iordef.h"
#include "hdfs.h"
Go to the source code of this file.
Macros | |
#define | open64 open /* unlikely, but may pose */ |
#define | lseek64 lseek /* unlikely, but may pose */ |
#define | O_BINARY 0 |
#define | O_DIRECT 000000 |
Functions | |
static void * | HDFS_Create (char *, IOR_param_t *) |
static void * | HDFS_Open (char *, IOR_param_t *) |
static IOR_offset_t | HDFS_Xfer (int, void *, IOR_size_t *, IOR_offset_t, IOR_param_t *) |
static void | HDFS_Close (void *, IOR_param_t *) |
static void | HDFS_Delete (char *, IOR_param_t *) |
static void | HDFS_SetVersion (IOR_param_t *) |
static void | HDFS_Fsync (void *, IOR_param_t *) |
static IOR_offset_t | HDFS_GetFileSize (IOR_param_t *, MPI_Comm, char *) |
void | hdfs_set_o_direct_flag (int *fd) |
static void | hdfs_connect (IOR_param_t *param) |
static void | hdfs_disconnect (IOR_param_t *param) |
static void * | HDFS_Create_Or_Open (char *testFileName, IOR_param_t *param, unsigned char createFile) |
Variables | |
ior_aiori_t | hdfs_aiori |
#define lseek64 lseek /* unlikely, but may pose */ |
Definition at line 94 of file aiori-HDFS.c.
#define O_BINARY 0 |
Definition at line 98 of file aiori-HDFS.c.
#define O_DIRECT 000000 |
Referenced by hdfs_set_o_direct_flag().
#define open64 open /* unlikely, but may pose */ |
Definition at line 90 of file aiori-HDFS.c.
|
static |
Definition at line 518 of file aiori-HDFS.c.
References ERR, IOR_param_t::hdfs_fs, IOR_WRONLY, IOR_param_t::openFlags, IOR_param_t::verbose, and VERBOSE_4.
|
static |
Definition at line 161 of file aiori-HDFS.c.
References ERR_SIMPLE, IOR_param_t::hdfs_fs, IOR_param_t::hdfs_name_node, IOR_param_t::hdfs_name_node_port, IOR_param_t::hdfs_user, IOR_param_t::verbose, and VERBOSE_4.
Referenced by HDFS_Create_Or_Open(), HDFS_Delete(), and HDFS_GetFileSize().
|
static |
Definition at line 343 of file aiori-HDFS.c.
References HDFS_Create_Or_Open(), TRUE, IOR_param_t::verbose, and VERBOSE_4.
|
static |
Definition at line 216 of file aiori-HDFS.c.
References ERR, IOR_param_t::filePerProc, IOR_param_t::hdfs_block_size, hdfs_connect(), IOR_param_t::hdfs_fs, IOR_param_t::hdfs_replicas, hdfs_set_o_direct_flag(), IOR_APPEND, IOR_EXCL, IOR_RDWR, IOR_WRONLY, MPI_CHECK, NULL, IOR_param_t::openFlags, rank, testComm, IOR_param_t::transferSize, TRUE, IOR_param_t::useO_DIRECT, IOR_param_t::verbose, and VERBOSE_4.
Referenced by HDFS_Create(), and HDFS_Open().
|
static |
Definition at line 549 of file aiori-HDFS.c.
References ERR_SIMPLE, EWARN, hdfs_connect(), IOR_param_t::hdfs_fs, rank, IOR_param_t::verbose, and VERBOSE_4.
|
static |
Definition at line 197 of file aiori-HDFS.c.
References IOR_param_t::hdfs_fs, NULL, IOR_param_t::verbose, and VERBOSE_4.
|
static |
Definition at line 479 of file aiori-HDFS.c.
References EWARN, IOR_param_t::hdfs_fs, IOR_param_t::verbose, and VERBOSE_4.
Referenced by HDFS_Xfer().
|
static |
Definition at line 596 of file aiori-HDFS.c.
References ERR_SIMPLE, IOR_param_t::filePerProc, hdfs_connect(), IOR_param_t::hdfs_fs, MPI_CHECK, rank, TRUE, IOR_param_t::verbose, VERBOSE_4, and WARN.
|
static |
Definition at line 357 of file aiori-HDFS.c.
References FALSE, HDFS_Create_Or_Open(), IOR_CREAT, IOR_param_t::openFlags, TRUE, IOR_param_t::verbose, and VERBOSE_4.
void hdfs_set_o_direct_flag | ( | int * | fd | ) |
Definition at line 134 of file aiori-HDFS.c.
References O_DIRECT, and WARN.
Referenced by HDFS_Create_Or_Open().
|
static |
Definition at line 578 of file aiori-HDFS.c.
References IOR_param_t::api, IOR_param_t::apiVersion, IOR_param_t::verbose, and VERBOSE_4.
|
static |
Definition at line 380 of file aiori-HDFS.c.
References ERR, IOR_param_t::fsyncPerWrite, IOR_param_t::hdfs_fs, HDFS_Fsync(), MAX_RETRY, MPI_CHECK, offset, IOR_param_t::offset, rank, rc, IOR_param_t::singleXferAttempt, TRUE, verbose, IOR_param_t::verbose, VERBOSE_4, and WRITE.
ior_aiori_t hdfs_aiori |
Definition at line 116 of file aiori-HDFS.c.