28 |
|
|
29 |
\begin{enumerate} |
\begin{enumerate} |
30 |
\item A core set of numerical and support code. This is discussed in detail in |
\item A core set of numerical and support code. This is discussed in detail in |
31 |
section \ref{sec:partII}. |
section \ref{sect:partII}. |
32 |
\item A scheme for supporting optional "pluggable" {\bf packages} (containing |
\item A scheme for supporting optional "pluggable" {\bf packages} (containing |
33 |
for example mixed-layer schemes, biogeochemical schemes, atmospheric physics). |
for example mixed-layer schemes, biogeochemical schemes, atmospheric physics). |
34 |
These packages are used both to overlay alternate dynamics and to introduce |
These packages are used both to overlay alternate dynamics and to introduce |
74 |
to ``fit'' within the WRAPPER infrastructure. Writing code to ``fit'' within |
to ``fit'' within the WRAPPER infrastructure. Writing code to ``fit'' within |
75 |
the WRAPPER means that coding has to follow certain, relatively |
the WRAPPER means that coding has to follow certain, relatively |
76 |
straightforward, rules and conventions ( these are discussed further in |
straightforward, rules and conventions ( these are discussed further in |
77 |
section \ref{sec:specifying_a_decomposition} ). |
section \ref{sect:specifying_a_decomposition} ). |
78 |
|
|
79 |
The approach taken by the WRAPPER is illustrated in figure |
The approach taken by the WRAPPER is illustrated in figure |
80 |
\ref{fig:fit_in_wrapper} which shows how the WRAPPER serves to insulate code |
\ref{fig:fit_in_wrapper} which shows how the WRAPPER serves to insulate code |
98 |
\end{figure} |
\end{figure} |
99 |
|
|
100 |
\subsection{Target hardware} |
\subsection{Target hardware} |
101 |
\label{sec:target_hardware} |
\label{sect:target_hardware} |
102 |
|
|
103 |
The WRAPPER is designed to target as broad as possible a range of computer |
The WRAPPER is designed to target as broad as possible a range of computer |
104 |
systems. The original development of the WRAPPER took place on a |
systems. The original development of the WRAPPER took place on a |
118 |
|
|
119 |
\subsection{Supporting hardware neutrality} |
\subsection{Supporting hardware neutrality} |
120 |
|
|
121 |
The different systems listed in section \ref{sec:target_hardware} can be |
The different systems listed in section \ref{sect:target_hardware} can be |
122 |
categorized in many different ways. For example, one common distinction is |
categorized in many different ways. For example, one common distinction is |
123 |
between shared-memory parallel systems (SMP's, PVP's) and distributed memory |
between shared-memory parallel systems (SMP's, PVP's) and distributed memory |
124 |
parallel systems (for example x86 clusters and large MPP systems). This is one |
parallel systems (for example x86 clusters and large MPP systems). This is one |
211 |
whenever it requires values that outside the domain it owns. Periodically |
whenever it requires values that outside the domain it owns. Periodically |
212 |
processors will make calls to WRAPPER functions to communicate data between |
processors will make calls to WRAPPER functions to communicate data between |
213 |
tiles, in order to keep the overlap regions up to date (see section |
tiles, in order to keep the overlap regions up to date (see section |
214 |
\ref{sec:communication_primitives}). The WRAPPER functions can use a |
\ref{sect:communication_primitives}). The WRAPPER functions can use a |
215 |
variety of different mechanisms to communicate data between tiles. |
variety of different mechanisms to communicate data between tiles. |
216 |
|
|
217 |
\begin{figure} |
\begin{figure} |
298 |
\end{figure} |
\end{figure} |
299 |
|
|
300 |
\subsection{Shared memory communication} |
\subsection{Shared memory communication} |
301 |
\label{sec:shared_memory_communication} |
\label{sect:shared_memory_communication} |
302 |
|
|
303 |
Under shared communication independent CPU's are operating |
Under shared communication independent CPU's are operating |
304 |
on the exact same global address space at the application level. |
on the exact same global address space at the application level. |
324 |
communication very efficient provided it is used appropriately. |
communication very efficient provided it is used appropriately. |
325 |
|
|
326 |
\subsubsection{Memory consistency} |
\subsubsection{Memory consistency} |
327 |
\label{sec:memory_consistency} |
\label{sect:memory_consistency} |
328 |
|
|
329 |
When using shared memory communication between |
When using shared memory communication between |
330 |
multiple processors the WRAPPER level shields user applications from |
multiple processors the WRAPPER level shields user applications from |
348 |
ensure memory consistency for a particular platform. |
ensure memory consistency for a particular platform. |
349 |
|
|
350 |
\subsubsection{Cache effects and false sharing} |
\subsubsection{Cache effects and false sharing} |
351 |
\label{sec:cache_effects_and_false_sharing} |
\label{sect:cache_effects_and_false_sharing} |
352 |
|
|
353 |
Shared-memory machines often have local to processor memory caches |
Shared-memory machines often have local to processor memory caches |
354 |
which contain mirrored copies of main memory. Automatic cache-coherence |
which contain mirrored copies of main memory. Automatic cache-coherence |
367 |
threads operating within a single process is the standard mechanism for |
threads operating within a single process is the standard mechanism for |
368 |
supporting shared memory that the WRAPPER utilizes. Configuring and launching |
supporting shared memory that the WRAPPER utilizes. Configuring and launching |
369 |
code to run in multi-threaded mode on specific platforms is discussed in |
code to run in multi-threaded mode on specific platforms is discussed in |
370 |
section \ref{sec:running_with_threads}. However, on many systems, potentially |
section \ref{sect:running_with_threads}. However, on many systems, potentially |
371 |
very efficient mechanisms for using shared memory communication between |
very efficient mechanisms for using shared memory communication between |
372 |
multiple processes (in contrast to multiple threads within a single |
multiple processes (in contrast to multiple threads within a single |
373 |
process) also exist. In most cases this works by making a limited region of |
process) also exist. In most cases this works by making a limited region of |
380 |
nature. |
nature. |
381 |
|
|
382 |
\subsection{Distributed memory communication} |
\subsection{Distributed memory communication} |
383 |
\label{sec:distributed_memory_communication} |
\label{sect:distributed_memory_communication} |
384 |
Many parallel systems are not constructed in a way where it is |
Many parallel systems are not constructed in a way where it is |
385 |
possible or practical for an application to use shared memory |
possible or practical for an application to use shared memory |
386 |
for communication. For example cluster systems consist of individual computers |
for communication. For example cluster systems consist of individual computers |
394 |
highly optimized library. |
highly optimized library. |
395 |
|
|
396 |
\subsection{Communication primitives} |
\subsection{Communication primitives} |
397 |
\label{sec:communication_primitives} |
\label{sect:communication_primitives} |
398 |
|
|
399 |
\begin{figure} |
\begin{figure} |
400 |
\begin{center} |
\begin{center} |
538 |
computing CPU's. |
computing CPU's. |
539 |
\end{enumerate} |
\end{enumerate} |
540 |
This section describes the details of each of these operations. |
This section describes the details of each of these operations. |
541 |
Section \ref{sec:specifying_a_decomposition} explains how the way in which |
Section \ref{sect:specifying_a_decomposition} explains how the way in which |
542 |
a domain is decomposed (or composed) is expressed. Section |
a domain is decomposed (or composed) is expressed. Section |
543 |
\ref{sec:starting_a_code} describes practical details of running codes |
\ref{sect:starting_a_code} describes practical details of running codes |
544 |
in various different parallel modes on contemporary computer systems. |
in various different parallel modes on contemporary computer systems. |
545 |
Section \ref{sec:controlling_communication} explains the internal information |
Section \ref{sect:controlling_communication} explains the internal information |
546 |
that the WRAPPER uses to control how information is communicated between |
that the WRAPPER uses to control how information is communicated between |
547 |
tiles. |
tiles. |
548 |
|
|
549 |
\subsection{Specifying a domain decomposition} |
\subsection{Specifying a domain decomposition} |
550 |
\label{sec:specifying_a_decomposition} |
\label{sect:specifying_a_decomposition} |
551 |
|
|
552 |
At its heart much of the WRAPPER works only in terms of a collection of tiles |
At its heart much of the WRAPPER works only in terms of a collection of tiles |
553 |
which are interconnected to each other. This is also true of application |
which are interconnected to each other. This is also true of application |
599 |
dimensions of {\em sNx} and {\em sNy}. If, when the code is executed, these tiles are |
dimensions of {\em sNx} and {\em sNy}. If, when the code is executed, these tiles are |
600 |
allocated to different threads of a process that are then bound to |
allocated to different threads of a process that are then bound to |
601 |
different physical processors ( see the multi-threaded |
different physical processors ( see the multi-threaded |
602 |
execution discussion in section \ref{sec:starting_the_code} ) then |
execution discussion in section \ref{sect:starting_the_code} ) then |
603 |
computation will be performed concurrently on each tile. However, it is also |
computation will be performed concurrently on each tile. However, it is also |
604 |
possible to run the same decomposition within a process running a single thread on |
possible to run the same decomposition within a process running a single thread on |
605 |
a single processor. In this case the tiles will be computed over sequentially. |
a single processor. In this case the tiles will be computed over sequentially. |
790 |
This set of values can be used for a cube sphere calculation. |
This set of values can be used for a cube sphere calculation. |
791 |
Each tile of size $32 \times 32$ represents a face of the |
Each tile of size $32 \times 32$ represents a face of the |
792 |
cube. Initializing the tile connectivity correctly ( see section |
cube. Initializing the tile connectivity correctly ( see section |
793 |
\ref{sec:cube_sphere_communication}. allows the rotations associated with |
\ref{sect:cube_sphere_communication}. allows the rotations associated with |
794 |
moving between the six cube faces to be embedded within the |
moving between the six cube faces to be embedded within the |
795 |
tile-tile communication code. |
tile-tile communication code. |
796 |
\end{enumerate} |
\end{enumerate} |
797 |
|
|
798 |
|
|
799 |
\subsection{Starting the code} |
\subsection{Starting the code} |
800 |
\label{sec:starting_the_code} |
\label{sect:starting_the_code} |
801 |
When code is started under the WRAPPER, execution begins in a main routine {\em |
When code is started under the WRAPPER, execution begins in a main routine {\em |
802 |
eesupp/src/main.F} that is owned by the WRAPPER. Control is transferred |
eesupp/src/main.F} that is owned by the WRAPPER. Control is transferred |
803 |
to the application through a routine called {\em THE\_MODEL\_MAIN()} |
to the application through a routine called {\em THE\_MODEL\_MAIN()} |
842 |
\end{figure} |
\end{figure} |
843 |
|
|
844 |
\subsubsection{Multi-threaded execution} |
\subsubsection{Multi-threaded execution} |
845 |
\label{sec:multi-threaded-execution} |
\label{sect:multi-threaded-execution} |
846 |
Prior to transferring control to the procedure {\em THE\_MODEL\_MAIN()} the |
Prior to transferring control to the procedure {\em THE\_MODEL\_MAIN()} the |
847 |
WRAPPER may cause several coarse grain threads to be initialized. The routine |
WRAPPER may cause several coarse grain threads to be initialized. The routine |
848 |
{\em THE\_MODEL\_MAIN()} is called once for each thread and is passed a single |
{\em THE\_MODEL\_MAIN()} is called once for each thread and is passed a single |
849 |
stack argument which is the thread number, stored in the |
stack argument which is the thread number, stored in the |
850 |
variable {\em myThid}. In addition to specifying a decomposition with |
variable {\em myThid}. In addition to specifying a decomposition with |
851 |
multiple tiles per process ( see section \ref{sec:specifying_a_decomposition}) |
multiple tiles per process ( see section \ref{sect:specifying_a_decomposition}) |
852 |
configuring and starting a code to run using multiple threads requires the following |
configuring and starting a code to run using multiple threads requires the following |
853 |
steps.\\ |
steps.\\ |
854 |
|
|
930 |
} \\ |
} \\ |
931 |
|
|
932 |
\subsubsection{Multi-process execution} |
\subsubsection{Multi-process execution} |
933 |
\label{sec:multi-process-execution} |
\label{sect:multi-process-execution} |
934 |
|
|
935 |
Despite its appealing programming model, multi-threaded execution remains |
Despite its appealing programming model, multi-threaded execution remains |
936 |
less common then multi-process execution. One major reason for this |
less common then multi-process execution. One major reason for this |
942 |
|
|
943 |
Multi-process execution is more ubiquitous. |
Multi-process execution is more ubiquitous. |
944 |
In order to run code in a multi-process configuration a decomposition |
In order to run code in a multi-process configuration a decomposition |
945 |
specification ( see section \ref{sec:specifying_a_decomposition}) |
specification ( see section \ref{sect:specifying_a_decomposition}) |
946 |
is given ( in which the at least one of the |
is given ( in which the at least one of the |
947 |
parameters {\em nPx} or {\em nPy} will be greater than one) |
parameters {\em nPx} or {\em nPy} will be greater than one) |
948 |
and then, as for multi-threaded operation, |
and then, as for multi-threaded operation, |
1112 |
neighbor to communicate with on a particular face. A value |
neighbor to communicate with on a particular face. A value |
1113 |
of {\em COMM\_MSG} is used to indicated that some form of distributed |
of {\em COMM\_MSG} is used to indicated that some form of distributed |
1114 |
memory communication is required to communicate between |
memory communication is required to communicate between |
1115 |
these tile faces ( see section \ref{sec:distributed_memory_communication}). |
these tile faces ( see section \ref{sect:distributed_memory_communication}). |
1116 |
A value of {\em COMM\_PUT} or {\em COMM\_GET} is used to indicate |
A value of {\em COMM\_PUT} or {\em COMM\_GET} is used to indicate |
1117 |
forms of shared memory communication ( see section |
forms of shared memory communication ( see section |
1118 |
\ref{sec:shared_memory_communication}). The {\em COMM\_PUT} value indicates |
\ref{sect:shared_memory_communication}). The {\em COMM\_PUT} value indicates |
1119 |
that a CPU should communicate by writing to data structures owned by another |
that a CPU should communicate by writing to data structures owned by another |
1120 |
CPU. A {\em COMM\_GET} value indicates that a CPU should communicate by reading |
CPU. A {\em COMM\_GET} value indicates that a CPU should communicate by reading |
1121 |
from data structures owned by another CPU. These flags affect the behavior |
from data structures owned by another CPU. These flags affect the behavior |
1166 |
are read from the file {\em eedata}. If the value of {\em nThreads} |
are read from the file {\em eedata}. If the value of {\em nThreads} |
1167 |
is inconsistent with the number of threads requested from the |
is inconsistent with the number of threads requested from the |
1168 |
operating system (for example by using an environment |
operating system (for example by using an environment |
1169 |
variable as described in section \ref{sec:multi_threaded_execution}) |
variable as described in section \ref{sect:multi_threaded_execution}) |
1170 |
then usually an error will be reported by the routine |
then usually an error will be reported by the routine |
1171 |
{\em CHECK\_THREADS}.\\ |
{\em CHECK\_THREADS}.\\ |
1172 |
|
|
1184 |
} |
} |
1185 |
|
|
1186 |
\item {\bf memsync flags} |
\item {\bf memsync flags} |
1187 |
As discussed in section \ref{sec:memory_consistency}, when using shared memory, |
As discussed in section \ref{sect:memory_consistency}, when using shared memory, |
1188 |
a low-level system function may be need to force memory consistency. |
a low-level system function may be need to force memory consistency. |
1189 |
The routine {\em MEMSYNC()} is used for this purpose. This routine should |
The routine {\em MEMSYNC()} is used for this purpose. This routine should |
1190 |
not need modifying and the information below is only provided for |
not need modifying and the information below is only provided for |
1210 |
\end{verbatim} |
\end{verbatim} |
1211 |
|
|
1212 |
\item {\bf Cache line size} |
\item {\bf Cache line size} |
1213 |
As discussed in section \ref{sec:cache_effects_and_false_sharing}, |
As discussed in section \ref{sect:cache_effects_and_false_sharing}, |
1214 |
milti-threaded codes explicitly avoid penalties associated with excessive |
milti-threaded codes explicitly avoid penalties associated with excessive |
1215 |
coherence traffic on an SMP system. To do this the shared memory data structures |
coherence traffic on an SMP system. To do this the shared memory data structures |
1216 |
used by the {\em GLOBAL\_SUM}, {\em GLOBAL\_MAX} and {\em BARRIER} routines |
used by the {\em GLOBAL\_SUM}, {\em GLOBAL\_MAX} and {\em BARRIER} routines |
1238 |
setting for the \_GSUM macro is given in the file {\em CPP\_EEMACROS.h}. |
setting for the \_GSUM macro is given in the file {\em CPP\_EEMACROS.h}. |
1239 |
The \_GSUM macro is a performance critical operation, especially for |
The \_GSUM macro is a performance critical operation, especially for |
1240 |
large processor count, small tile size configurations. |
large processor count, small tile size configurations. |
1241 |
The custom communication example discussed in section \ref{sec:jam_example} |
The custom communication example discussed in section \ref{sect:jam_example} |
1242 |
shows how the macro is used to invoke a custom global sum routine |
shows how the macro is used to invoke a custom global sum routine |
1243 |
for a specific set of hardware. |
for a specific set of hardware. |
1244 |
|
|
1252 |
in the header file {\em CPP\_EEMACROS.h}. As with \_GSUM, the |
in the header file {\em CPP\_EEMACROS.h}. As with \_GSUM, the |
1253 |
\_EXCH operation plays a crucial role in scaling to small tile, |
\_EXCH operation plays a crucial role in scaling to small tile, |
1254 |
large logical and physical processor count configurations. |
large logical and physical processor count configurations. |
1255 |
The example in section \ref{sec:jam_example} discusses defining an |
The example in section \ref{sect:jam_example} discusses defining an |
1256 |
optimized and specialized form on the \_EXCH operation. |
optimized and specialized form on the \_EXCH operation. |
1257 |
|
|
1258 |
The \_EXCH operation is also central to supporting grids such as |
The \_EXCH operation is also central to supporting grids such as |
1292 |
if this might be unavailable then the work arrays can be extended |
if this might be unavailable then the work arrays can be extended |
1293 |
with dimensions use the tile dimensioning scheme of {\em nSx} |
with dimensions use the tile dimensioning scheme of {\em nSx} |
1294 |
and {\em nSy} ( as described in section |
and {\em nSy} ( as described in section |
1295 |
\ref{sec:specifying_a_decomposition}). However, if the configuration |
\ref{sect:specifying_a_decomposition}). However, if the configuration |
1296 |
being specified involves many more tiles than OS threads then |
being specified involves many more tiles than OS threads then |
1297 |
it can save memory resources to reduce the variable |
it can save memory resources to reduce the variable |
1298 |
{\em MAX\_NO\_THREADS} to be equal to the actual number of threads that |
{\em MAX\_NO\_THREADS} to be equal to the actual number of threads that |
1351 |
how it can be used to adapt to new griding approaches. |
how it can be used to adapt to new griding approaches. |
1352 |
|
|
1353 |
\subsubsection{JAM example} |
\subsubsection{JAM example} |
1354 |
\label{sec:jam_example} |
\label{sect:jam_example} |
1355 |
On some platforms a big performance boost can be obtained by |
On some platforms a big performance boost can be obtained by |
1356 |
binding the communication routines {\em \_EXCH} and |
binding the communication routines {\em \_EXCH} and |
1357 |
{\em \_GSUM} to specialized native libraries ) fro example the |
{\em \_GSUM} to specialized native libraries ) fro example the |
1374 |
pattern. |
pattern. |
1375 |
|
|
1376 |
\subsubsection{Cube sphere communication} |
\subsubsection{Cube sphere communication} |
1377 |
\label{sec:cube_sphere_communication} |
\label{sect:cube_sphere_communication} |
1378 |
Actual {\em \_EXCH} routine code is generated automatically from |
Actual {\em \_EXCH} routine code is generated automatically from |
1379 |
a series of template files, for example {\em exch\_rx.template}. |
a series of template files, for example {\em exch\_rx.template}. |
1380 |
This is done to allow a large number of variations on the exchange |
This is done to allow a large number of variations on the exchange |
1407 |
|
|
1408 |
Fitting together the WRAPPER elements, package elements and |
Fitting together the WRAPPER elements, package elements and |
1409 |
MITgcm core equation elements of the source code produces calling |
MITgcm core equation elements of the source code produces calling |
1410 |
sequence shown in section \ref{sec:calling_sequence} |
sequence shown in section \ref{sect:calling_sequence} |
1411 |
|
|
1412 |
\subsection{Annotated call tree for MITgcm and WRAPPER} |
\subsection{Annotated call tree for MITgcm and WRAPPER} |
1413 |
\label{sec:calling_sequence} |
\label{sect:calling_sequence} |
1414 |
|
|
1415 |
WRAPPER layer. |
WRAPPER layer. |
1416 |
|
|