Skip to content
GitLab
Projects
Groups
Snippets
/
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Menu
Open sidebar
mpim-sw
libcdi
Commits
9651866e
Commit
9651866e
authored
Oct 26, 2011
by
Deike Kleberg
Browse files
Rename IOModes.
parent
4b94a3e9
Changes
8
Hide whitespace changes
Inline
Side-by-side
pioExamples/collectData.c
View file @
9651866e
...
...
@@ -105,10 +105,10 @@ int main (int argc, char *argv[])
enum
{
nProcsIO
=
3
,
//IOMode = PIO_NONE,
//IOMode = PIO_MPI
_NONB
,
//IOMode = PIO_
POSIX_
FPGUARD
_SENDRECV
,
IOMode
=
PIO_
POSIX_
ASYNCH
,
//IOMode = PIO_POSIX
_NONB
,
//IOMode = PIO_MPI,
//IOMode = PIO_FPGUARD,
IOMode
=
PIO_ASYNCH
,
//IOMode = PIO_POSIX,
nNamespaces
=
1
};
static
int
hasLocalFile
[
nNamespaces
]
=
{
0
};
...
...
pioExamples/collectData2003.F90
View file @
9651866e
...
...
@@ -17,10 +17,10 @@ PROGRAM COLLECTDATA2003
INTEGER
nProcsIO
,
IOMode
,
nNamespaces
PARAMETER
(
nProcsIO
=
3
)
!PARAMETER ( IOMode = PIO_NONE )
!PARAMETER ( IOMode = PIO_MPI
_NONB
)
!PARAMETER ( IOMode = PIO_POSIX
_NONB
)
!PARAMETER ( IOMode = PIO_
POSIX_
ASYNCH )
PARAMETER
(
IOMode
=
PIO_
POSIX_
FPGUARD
_SENDRECV
)
!PARAMETER ( IOMode = PIO_MPI )
!PARAMETER ( IOMode = PIO_POSIX )
!PARAMETER ( IOMode = PIO_ASYNCH )
PARAMETER
(
IOMode
=
PIO_FPGUARD
)
PARAMETER
(
nNamespaces
=
1
)
INTEGER
hasLocalFile
(
nNamespaces
)
PARAMETER
(
hasLocalFile
=
(/
0
/)
)
...
...
pioExamples/pio_write.F90
View file @
9651866e
...
...
@@ -165,10 +165,10 @@ PROGRAM CDIWRITE
CHARACTER
*
(
*
),
PARAMETER
::
PTYPENAMES
(
7
)
=
(/
&
'PIO_NONE '
,
&
'PIO_MPI
_NONB
'
,
&
'PIO_POSIX
_NONB
'
,
&
'PIO_
POSIX_
ASYNCH '
,
&
'PIO_
POSIX_
FPGUARD
_SENDRECV
'
,
&
'PIO_MPI '
,
&
'PIO_POSIX '
,
&
'PIO_ASYNCH '
,
&
'PIO_FPGUARD '
,
&
'PIO_POSIX_FPGUARD_THREAD_REFUSE'
,
&
'PIO_POSIX_FPGUARD_THREAD '
/)
...
...
@@ -517,7 +517,7 @@ CONTAINS
CALL
MPI_COMM_SIZE
(
pioCollectorComm_NODE
,
ncollectors_NODE
,
error
)
CALL
MPI_COMM_SIZE
(
pioComm
,
size
,
error
)
IF
(
ptype
==
PIO_NONE
.OR.
ptype
==
PIO_MPI
_NONB
)
THEN
IF
(
ptype
==
PIO_NONE
.OR.
ptype
==
PIO_MPI
)
THEN
npes_NODE
=
ncollectors_NODE
ELSE
npes_NODE
=
ncollectors_NODE
+
1
...
...
src/cdi.h
View file @
9651866e
...
...
@@ -192,19 +192,19 @@ extern "C" {
#define CALENDAR_366DAYS 4
#define CALENDAR_NONE 5
/* deike */
/* parallel io types, A: asynchronous, B: blocking */
/* IOMode types */
#define PIO_NONE
0
#define PIO_MPI
_NONB
1
#define PIO_POSIX
_NONB
2
#define PIO_
POSIX_
ASYNCH
3
#define PIO_
POSIX_
FPGUARD
_SENDRECV
4
#define PIO_MINIOMOD
US
PIO_NONE
#define PIO_MAXIOMOD
US
PIO_
POSIX_
FPGUARD
_SENDRECV
#define PIO_MINIOMOD
US
WITHSPECIALPROCS PIO_POSIX
_NONB
#define PIO_NONE 0
#define PIO_MPI 1
#define PIO_POSIX 2
#define PIO_ASYNCH 3
#define PIO_FPGUARD
4
#define PIO_MINIOMOD
E
PIO_NONE
#define PIO_MAXIOMOD
E
PIO_FPGUARD
#define PIO_MINIOMOD
E
WITHSPECIALPROCS PIO_POSIX
/* parallel IO routines */
int
pioInit
(
int
,
int
,
int
,
int
,
int
*
);
void
pioFinalize
(
void
);
...
...
src/cdi.inc
View file @
9651866e
...
...
@@ -317,19 +317,16 @@
PARAMETER
(
CALENDAR_366DAYS
=
4
)
INTEGER
CALENDAR_NONE
PARAMETER
(
CALENDAR_NONE
=
5
)
!
!
deike
!
INTEGER
PIO_NONE
PARAMETER
(
PIO_NONE
=
0
)
INTEGER
PIO_MPI
_NONB
PARAMETER
(
PIO_MPI
_NONB
=
1
)
INTEGER
PIO_POSIX
_NONB
PARAMETER
(
PIO_POSIX
_NONB
=
2
)
INTEGER
PIO_
POSIX_
ASYNCH
PARAMETER
(
PIO_
POSIX_
ASYNCH
=
3
)
INTEGER
PIO_
POSIX_
FPGUARD
_SENDRECV
PARAMETER
(
PIO_
POSIX_
FPGUARD
_SENDRECV
=
4
)
INTEGER
PIO_MPI
PARAMETER
(
PIO_MPI
=
1
)
INTEGER
PIO_POSIX
PARAMETER
(
PIO_POSIX
=
2
)
INTEGER
PIO_ASYNCH
PARAMETER
(
PIO_ASYNCH
=
3
)
INTEGER
PIO_FPGUARD
PARAMETER
(
PIO_FPGUARD
=
4
)
INTEGER
pioInit
!
(
INTEGER
,
!
INTEGER
,
...
...
src/cdiFortran.c
View file @
9651866e
...
...
@@ -53,9 +53,6 @@
/* CALENDAR types */
/* deike */
FCALLSCFUN5
(
INT
,
pioInit
,
PIOINIT
,
pioinit
,
INT
,
INT
,
INT
,
INT
,
PINT
)
FCALLSCSUB0
(
pioFinalize
,
PIOFINALIZE
,
piofinalize
)
FCALLSCSUB0
(
pioEndDef
,
PIOENDDEF
,
pioenddef
)
...
...
src/pio.c
View file @
9651866e
...
...
@@ -70,18 +70,18 @@ size_t pioFileWrite ( int fileID, int tsID, const void *buffer, size_t len )
switch
(
commInqIOMode
())
{
case
PIO_MPI
_NONB
:
case
PIO_MPI
:
iret
=
fwMPINONB
(
fileID
,
tsID
,
buffer
,
len
);
break
;
#ifndef _SX
case
PIO_
POSIX_
ASYNCH
:
case
PIO_ASYNCH
:
iret
=
fwPOSIXASYNCH
(
fileID
,
tsID
,
buffer
,
len
);
break
;
#endif
case
PIO_
POSIX_
FPGUARD
_SENDRECV
:
case
PIO_FPGUARD
:
iret
=
fwPOSIXFPGUARDSENDRECV
(
fileID
,
tsID
,
buffer
,
len
);
break
;
case
PIO_POSIX
_NONB
:
case
PIO_POSIX
:
iret
=
fwPOSIXNONB
(
fileID
,
tsID
,
buffer
,
len
);
break
;
}
...
...
@@ -96,18 +96,18 @@ int pioFileClose ( int id )
int
iret
=
CDI_UNDEFID
;
switch
(
commInqIOMode
())
{
case
PIO_MPI
_NONB
:
case
PIO_MPI
:
iret
=
fcMPINONB
(
id
);
break
;
#ifndef _SX
case
PIO_
POSIX_
ASYNCH
:
case
PIO_ASYNCH
:
iret
=
fcPOSIXASYNCH
(
id
);
break
;
#endif
case
PIO_
POSIX_
FPGUARD
_SENDRECV
:
case
PIO_FPGUARD
:
iret
=
fcPOSIXFPGUARDSENDRECV
(
id
);
break
;
case
PIO_POSIX
_NONB
:
case
PIO_POSIX
:
iret
=
fcPOSIXNONB
(
id
);
break
;
}
...
...
@@ -123,18 +123,18 @@ int pioFileOpenW ( const char *filename )
switch
(
commInqIOMode
())
{
case
PIO_MPI
_NONB
:
case
PIO_MPI
:
iret
=
fowMPINONB
(
filename
);
break
;
#ifndef _SX
case
PIO_
POSIX_
ASYNCH
:
case
PIO_ASYNCH
:
iret
=
fowPOSIXASYNCH
(
filename
);
break
;
#endif
case
PIO_
POSIX_
FPGUARD
_SENDRECV
:
case
PIO_FPGUARD
:
iret
=
fowPOSIXFPGUARDSENDRECV
(
filename
);
break
;
case
PIO_POSIX
_NONB
:
case
PIO_POSIX
:
iret
=
fowPOSIXNONB
(
filename
);
break
;
}
...
...
@@ -160,18 +160,18 @@ void backendInit ( void )
commRecvNodeMap
();
commDefCommsIO
();
break
;
case
PIO_MPI
_NONB
:
case
PIO_MPI
:
initMPINONB
();
break
;
#ifndef _SX
case
PIO_
POSIX_
ASYNCH
:
case
PIO_ASYNCH
:
initPOSIXASYNCH
();
break
;
#endif
case
PIO_
POSIX_
FPGUARD
_SENDRECV
:
case
PIO_FPGUARD
:
initPOSIXFPGUARDSENDRECV
();
break
;
case
PIO_POSIX
_NONB
:
case
PIO_POSIX
:
initPOSIXNONB
();
break
;
}
...
...
@@ -186,16 +186,16 @@ void backendCleanup ( void )
{
case
PIO_NONE
:
break
;
case
PIO_MPI
_NONB
:
case
PIO_MPI
:
finalizeMPINONB
();
break
;
case
PIO_
POSIX_
ASYNCH
:
case
PIO_ASYNCH
:
finalizePOSIXASYNCH
();
break
;
case
PIO_
POSIX_
FPGUARD
_SENDRECV
:
case
PIO_FPGUARD
:
finalizePOSIXFPGUARDSENDRECV
();
break
;
case
PIO_POSIX
_NONB
:
case
PIO_POSIX
:
finalizePOSIXNONB
();
break
;
default:
...
...
src/pio_interface.c
View file @
9651866e
...
...
@@ -745,12 +745,12 @@ MPI_Comm pioInit_c ( MPI_Comm commGlob, int nProcsIO, int IOMode,
{
int
sizeGlob
,
nProcsModel
;
if
(
IOMode
<
PIO_MINIOMOD
US
||
IOMode
>
PIO_MAXIOMOD
US
)
if
(
IOMode
<
PIO_MINIOMOD
E
||
IOMode
>
PIO_MAXIOMOD
E
)
xabort
(
"IOMODE IS NOT VALID."
);
#ifdef _SX
if
(
IOMode
==
PIO_
POSIX_
ASYNCH
)
xabort
(
"PIO_
POSIX_
ASYNCH DOES NOT WORK ON SX."
);
if
(
IOMode
==
PIO_ASYNCH
)
xabort
(
"PIO_ASYNCH DOES NOT WORK ON SX."
);
#endif
commInit
();
...
...
@@ -761,7 +761,7 @@ MPI_Comm pioInit_c ( MPI_Comm commGlob, int nProcsIO, int IOMode,
xabort
(
"DISTRIBUTION OF TASKS ON PROCS IS NOT VALID."
);
commDefNProcsIO
(
nProcsIO
);
commDefIOMode
(
IOMode
,
PIO_MAXIOMOD
US
,
PIO_MINIOMOD
US
WITHSPECIALPROCS
);
commDefIOMode
(
IOMode
,
PIO_MAXIOMOD
E
,
PIO_MINIOMOD
E
WITHSPECIALPROCS
);
commDefCommPio
();
// JUST FOR TEST CASES WITH ONLY ONE MPI TASK
...
...
@@ -862,7 +862,7 @@ void pioEndTimestepping ( void )
@return
*/
void
pioFinalize
()
void
pioFinalize
(
void
)
{
#ifdef USE_MPI
int
collID
,
ibuffer
=
1111
;
...
...
Write
Preview
Supports
Markdown
0%
Try again
or
attach a new file
.
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment