Skip to content

Commit 9d6e1bb

Browse files
openmpiopenmpi
committed
adapt OceanStor Pacipic 100D filesystem
1 parent 8b4a8cd commit 9d6e1bb

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

43 files changed

+5938
-121
lines changed

‎.mailmap

-113
This file was deleted.

‎ompi/mca/io/romio321/romio/adio/Makefile.mk

+3-1
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,8 @@ noinst_HEADERS += \
2222
adio/include/nopackage.h \
2323
adio/include/romioconf-undefs.h \
2424
adio/include/mpiu_external32.h \
25-
adio/include/hint_fns.h
25+
adio/include/hint_fns.h \
26+
adio/include/ad_env.h
2627

2728
include $(top_srcdir)/adio/ad_gpfs/Makefile.mk
2829
include $(top_srcdir)/adio/ad_gpfs/bg/Makefile.mk
@@ -43,5 +44,6 @@ include $(top_srcdir)/adio/ad_testfs/Makefile.mk
4344
include $(top_srcdir)/adio/ad_ufs/Makefile.mk
4445
include $(top_srcdir)/adio/ad_xfs/Makefile.mk
4546
include $(top_srcdir)/adio/ad_zoidfs/Makefile.mk
47+
include $(top_srcdir)/adio/ad_oceanfs/Makefile.mk
4648
include $(top_srcdir)/adio/common/Makefile.mk
4749

‎ompi/mca/io/romio321/romio/adio/ad_oceanfs/Makefile.mk

+39
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
## -*- Mode: Makefile; -*-
2+
## vim: set ft=automake :
3+
##
4+
## (C) 2017 by DataDirect Networks
5+
## See COPYRIGHT in top-level directory.
6+
##
7+
8+
if BUILD_AD_OCEANFS
9+
10+
noinst_HEADERS += adio/ad_oceanfs/ad_oceanfs.h \
11+
adio/ad_oceanfs/ad_oceanfs_common.h \
12+
adio/ad_oceanfs/ad_oceanfs_file.h \
13+
adio/ad_oceanfs/ad_oceanfs_pub.h \
14+
adio/ad_oceanfs/ad_oceanfs_tuning.h \
15+
adio/ad_oceanfs/ad_oceanfs_group_tuning.h \
16+
adio/ad_oceanfs/ad_oceanfs_aggrs.h \
17+
adio/ad_oceanfs/mpi_fs_intf.h
18+
romio_other_sources += \
19+
adio/ad_oceanfs/ad_oceanfs.c \
20+
adio/ad_oceanfs/ad_oceanfs_close.c \
21+
adio/ad_oceanfs/ad_oceanfs_common.c \
22+
adio/ad_oceanfs/ad_oceanfs_fcntl.c \
23+
adio/ad_oceanfs/ad_oceanfs_io.c \
24+
adio/ad_oceanfs/ad_oceanfs_open.c \
25+
adio/ad_oceanfs/ad_oceanfs_file.c \
26+
adio/ad_oceanfs/ad_oceanfs_pub.c \
27+
adio/ad_oceanfs/ad_oceanfs_tuning.c \
28+
adio/ad_oceanfs/ad_oceanfs_group_tuning.c \
29+
adio/ad_oceanfs/ad_oceanfs_aggrs.c \
30+
adio/ad_oceanfs/ad_oceanfs_rdstr.c \
31+
adio/ad_oceanfs/ad_oceanfs_rdcoll.c \
32+
adio/ad_oceanfs/ad_oceanfs_wrcoll.c \
33+
adio/ad_oceanfs/ad_oceanfs_resize.c \
34+
adio/ad_oceanfs/ad_oceanfs_hints.c \
35+
adio/ad_oceanfs/ad_oceanfs_view.c \
36+
adio/ad_oceanfs/ad_oceanfs_viewio.c \
37+
adio/ad_oceanfs/mpi_fs_intf.c
38+
39+
endif BUILD_AD_OCEANFS

‎ompi/mca/io/romio321/romio/adio/ad_oceanfs/ad_oceanfs.c

+32
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
#include "ad_oceanfs.h"
2+
#include "adioi.h"
3+
4+
struct ADIOI_Fns_struct ADIO_OCEANFS_operations = {
5+
ADIOI_OCEANFS_Open, /* Open */
6+
ADIOI_GEN_OpenColl, /* OpenColl */
7+
ADIOI_OCEANFS_ReadContig, /* ReadContig */
8+
ADIOI_OCEANFS_WriteContig, /* WriteContig */
9+
ADIOI_OCEANFS_ReadStridedColl, /* ReadStridedColl */
10+
ADIOI_OCEANFS_WriteStridedColl, /* WriteStridedColl */
11+
ADIOI_GEN_SeekIndividual, /* SeekIndividual */
12+
ADIOI_OCEANFS_Fcntl, /* Fcntl */
13+
ADIOI_OCEANFS_SetInfo, /* SetInfo */
14+
ADIOI_OCEANFS_ReadStrided, /* ReadStrided */
15+
ADIOI_GEN_WriteStrided, /* WriteStrided */
16+
ADIOI_OCEANFS_Close, /* Close */
17+
ADIOI_FAKE_IreadContig, /* IreadContig */
18+
ADIOI_FAKE_IwriteContig, /* IwriteContig */
19+
ADIOI_FAKE_IODone, /* ReadDone */
20+
ADIOI_FAKE_IODone, /* WriteDone */
21+
ADIOI_FAKE_IOComplete, /* ReadComplete */
22+
ADIOI_FAKE_IOComplete, /* WriteComplete */
23+
ADIOI_FAKE_IreadStrided, /* IreadStrided */
24+
ADIOI_FAKE_IwriteStrided, /* IwriteStrided */
25+
ADIOI_GEN_Flush, /* Flush */
26+
ADIOI_OCEANFS_Resize, /* Resize */
27+
ADIOI_GEN_Delete, /* Delete */
28+
ADIOI_GEN_Feature, /* Feature */
29+
ADIOI_OCEANFS_PREFIX,
30+
ADIOI_GEN_IreadStridedColl, /* IreadStridedColl */
31+
ADIOI_GEN_IwriteStridedColl /* IwriteStridedColl */
32+
};

‎ompi/mca/io/romio321/romio/adio/ad_oceanfs/ad_oceanfs.h

+48
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,48 @@
1+
#ifndef AD_OCEANFS_H_INCLUDED
2+
#define AD_OCEANFS_H_INCLUDED
3+
4+
#include "adio.h"
5+
#include "ad_oceanfs_tuning.h"
6+
7+
#define OCEANFS_READ 0
8+
#define OCEANFS_WRITE 1
9+
#define OCEANFS_READ_STRIDED 2
10+
#define OCEANFS_READ_COLL 3
11+
#define OCEANFS_WRITE_STRIDED 4
12+
#define OCEANFS_WRITE_COLL 5
13+
14+
#define ADIOI_OCEANFS_PREFIX "oceanfs:"
15+
#define ADIOI_OCEANFS_PREFIX_LEN (sizeof(ADIOI_OCEANFS_PREFIX) - 1)
16+
17+
void ADIOI_OCEANFS_Open(ADIO_File fd, int *error_code);
18+
19+
void ADIOI_OCEANFS_Close(ADIO_File fd, int *error_code);
20+
21+
void ADIOI_OCEANFS_ReadContig(ADIO_File fd, void *buf, int count, MPI_Datatype datatype, int file_ptr_type,
22+
ADIO_Offset offset, ADIO_Status *status, int *error_code);
23+
24+
void ADIOI_OCEANFS_WriteContig(ADIO_File fd, const void *buf, int count, MPI_Datatype datatype, int file_ptr_type,
25+
ADIO_Offset offset, ADIO_Status *status, int *error_code);
26+
27+
void ADIOI_OCEANFS_ReadStrided(ADIO_File fd, void *buf, int count, MPI_Datatype datatype, int file_ptr_type,
28+
ADIO_Offset offset, ADIO_Status *status, int *error_code);
29+
30+
void ADIOI_OCEANFS_ReadStridedColl(ADIO_File fd, void *buf, int count, MPI_Datatype datatype, int file_ptr_type,
31+
ADIO_Offset offset, ADIO_Status *status, int *error_code);
32+
33+
void ADIOI_OCEANFS_WriteStridedColl(ADIO_File fd, const void *buf, int count, MPI_Datatype datatype, int file_ptr_type,
34+
ADIO_Offset offset, ADIO_Status *status, int *error_code);
35+
36+
void ADIOI_OCEANFS_Fcntl(ADIO_File fd, int flag, ADIO_Fcntl_t *fcntl_struct, int *error_code);
37+
38+
void ADIOI_OCEANFS_Resize(ADIO_File fd, ADIO_Offset size, int *error_code);
39+
40+
void ADIOI_OCEANFS_SetInfo(ADIO_File fd, MPI_Info users_info, int *error_code);
41+
42+
int ADIOI_OCEANFS_set_view(ADIO_File fd, int *error_code);
43+
44+
int ADIOI_OCEANFS_StridedViewIO(ADIO_File fd, void *buf, int count, MPI_Datatype datatype, int file_ptr_type,
45+
ADIO_Offset offset, ADIO_Status *status, int io_flag, int *error_code);
46+
int ADIOI_OCEANFS_Set_lock(FDTYPE fd, int cmd, int type, ADIO_Offset offset, int whence, ADIO_Offset len);
47+
48+
#endif /* AD_OCEANFS_H_INCLUDED */

0 commit comments

Comments
 (0)