Nektar++
CommSerial.h
Go to the documentation of this file.
1 ///////////////////////////////////////////////////////////////////////////////
2 //
3 // File CommSerial.h
4 //
5 // For more information, please see: http://www.nektar.info
6 //
7 // The MIT License
8 //
9 // Copyright (c) 2006 Division of Applied Mathematics, Brown University (USA),
10 // Department of Aeronautics, Imperial College London (UK), and Scientific
11 // Computing and Imaging Institute, University of Utah (USA).
12 //
13 // Permission is hereby granted, free of charge, to any person obtaining a
14 // copy of this software and associated documentation files (the "Software"),
15 // to deal in the Software without restriction, including without limitation
16 // the rights to use, copy, modify, merge, publish, distribute, sublicense,
17 // and/or sell copies of the Software, and to permit persons to whom the
18 // Software is furnished to do so, subject to the following conditions:
19 //
20 // The above copyright notice and this permission notice shall be included
21 // in all copies or substantial portions of the Software.
22 //
23 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
24 // OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
25 // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
26 // THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
27 // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
28 // FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
29 // DEALINGS IN THE SOFTWARE.
30 //
31 // Description: CommSerial header
32 //
33 ///////////////////////////////////////////////////////////////////////////////
34 #ifndef NEKTAR_LIB_UTILITIES_COMMSERIAL_H
35 #define NEKTAR_LIB_UTILITIES_COMMSERIAL_H
36 
37 #include <string>
38 
42 
43 namespace Nektar
44 {
45 namespace LibUtilities
46 {
47 // Forward declarations
48 class CommSerial;
49 
50 /// Pointer to a Communicator object.
51 typedef std::shared_ptr<CommSerial> CommSerialSharedPtr;
52 
53 /// A global linear system.
54 class CommSerial : public Comm
55 {
56 public:
57  /// Creates an instance of this class
58  LIB_UTILITIES_EXPORT static CommSharedPtr create(int narg, char *arg[])
59  {
61  }
62 
63  /// Name of class
64  LIB_UTILITIES_EXPORT static std::string className;
65 
66  LIB_UTILITIES_EXPORT CommSerial(int argc, char *argv[]);
67  LIB_UTILITIES_EXPORT virtual ~CommSerial() override;
68 
69 protected:
70  LIB_UTILITIES_EXPORT virtual void v_Finalise() final;
71  LIB_UTILITIES_EXPORT virtual int v_GetRank() override;
72  LIB_UTILITIES_EXPORT virtual bool v_TreatAsRankZero() override;
73  LIB_UTILITIES_EXPORT virtual bool v_IsSerial() override;
74  LIB_UTILITIES_EXPORT virtual std::tuple<int, int, int> v_GetVersion() final;
75 
76  LIB_UTILITIES_EXPORT virtual void v_Block() final;
77  LIB_UTILITIES_EXPORT virtual NekDouble v_Wtime() final;
78  LIB_UTILITIES_EXPORT virtual void v_Send(void *buf, int count,
79  CommDataType dt, int dest) final;
80  LIB_UTILITIES_EXPORT virtual void v_Recv(void *buf, int count,
81  CommDataType dt, int source) final;
82  LIB_UTILITIES_EXPORT virtual void v_SendRecv(
83  void *sendbuf, int sendcount, CommDataType sendtype, int dest,
84  void *recvbuf, int recvcount, CommDataType recvtype, int source) final;
85  LIB_UTILITIES_EXPORT virtual void v_SendRecvReplace(void *buf, int count,
86  CommDataType dt,
87  int pSendProc,
88  int pRecvProc) final;
89  LIB_UTILITIES_EXPORT virtual void v_AllReduce(
90  void *buf, int count, CommDataType dt, enum ReduceOperator pOp) final;
91  LIB_UTILITIES_EXPORT virtual void v_AlltoAll(void *sendbuf, int sendcount,
92  CommDataType sendtype,
93  void *recvbuf, int recvcount,
94  CommDataType recvtype) final;
95  LIB_UTILITIES_EXPORT virtual void v_AlltoAllv(
96  void *sendbuf, int sendcounts[], int sensdispls[],
97  CommDataType sendtype, void *recvbuf, int recvcounts[], int rdispls[],
98  CommDataType recvtype) final;
99  LIB_UTILITIES_EXPORT virtual void v_AllGather(void *sendbuf, int sendcount,
100  CommDataType sendtype,
101  void *recvbuf, int recvcount,
102  CommDataType recvtype) final;
103  LIB_UTILITIES_EXPORT virtual void v_AllGatherv(
104  void *sendbuf, int sendcount, CommDataType sendtype, void *recvbuf,
105  int recvcounts[], int rdispls[], CommDataType recvtype) final;
106  LIB_UTILITIES_EXPORT virtual void v_AllGatherv(void *recvbuf,
107  int recvcounts[],
108  int rdispls[],
109  CommDataType recvtype) final;
110  LIB_UTILITIES_EXPORT virtual void v_Bcast(void *buffer, int count,
111  CommDataType dt, int root) final;
112  LIB_UTILITIES_EXPORT virtual void v_Exscan(
113  Array<OneD, unsigned long long> &pData, const enum ReduceOperator pOp,
114  Array<OneD, unsigned long long> &ans) final;
115  LIB_UTILITIES_EXPORT virtual void v_Gather(void *sendbuf, int sendcount,
116  CommDataType sendtype,
117  void *recvbuf, int recvcount,
118  CommDataType recvtype,
119  int root) final;
120  LIB_UTILITIES_EXPORT virtual void v_Scatter(void *sendbuf, int sendcount,
121  CommDataType sendtype,
122  void *recvbuf, int recvcount,
123  CommDataType recvtype,
124  int root) final;
125 
127  int indegree, const int sources[], const int sourceweights[],
128  int reorder) final;
129 
131  void *sendbuf, int sendcounts[], int sdispls[], CommDataType sendtype,
132  void *recvbuf, int recvcounts[], int rdispls[],
133  CommDataType recvtype) final;
134 
135  LIB_UTILITIES_EXPORT virtual void v_Irsend(void *buf, int count,
136  CommDataType dt, int dest,
137  CommRequestSharedPtr request,
138  int loc) final;
139 
140  LIB_UTILITIES_EXPORT virtual void v_SendInit(void *buf, int count,
141  CommDataType dt, int dest,
142  CommRequestSharedPtr request,
143  int loc) final;
144 
145  LIB_UTILITIES_EXPORT virtual void v_Irecv(void *buf, int count,
146  CommDataType dt, int source,
147  CommRequestSharedPtr request,
148  int loc) final;
149 
150  LIB_UTILITIES_EXPORT virtual void v_RecvInit(void *buf, int count,
151  CommDataType dt, int source,
152  CommRequestSharedPtr request,
153  int loc) final;
154 
155  LIB_UTILITIES_EXPORT virtual void v_StartAll(
156  CommRequestSharedPtr request) final;
157  LIB_UTILITIES_EXPORT virtual void v_WaitAll(
158  CommRequestSharedPtr request) final;
160  int num) final;
161 
162  LIB_UTILITIES_EXPORT virtual void v_SplitComm(int pRows,
163  int pColumns) override;
164  LIB_UTILITIES_EXPORT virtual CommSharedPtr v_CommCreateIf(int flag) final;
165 };
166 } // namespace LibUtilities
167 } // namespace Nektar
168 
169 #endif
#define LIB_UTILITIES_EXPORT
Base communications class.
Definition: Comm.h:90
A global linear system.
Definition: CommSerial.h:55
virtual std::tuple< int, int, int > v_GetVersion() final
Definition: CommSerial.cpp:95
virtual void v_SendRecvReplace(void *buf, int count, CommDataType dt, int pSendProc, int pRecvProc) final
Definition: CommSerial.cpp:145
virtual void v_Gather(void *sendbuf, int sendcount, CommDataType sendtype, void *recvbuf, int recvcount, CommDataType recvtype, int root) final
Definition: CommSerial.cpp:220
virtual CommSharedPtr v_CommCreateIf(int flag) final
Definition: CommSerial.cpp:304
virtual void v_SendRecv(void *sendbuf, int sendcount, CommDataType sendtype, int dest, void *recvbuf, int recvcount, CommDataType recvtype, int source) final
Definition: CommSerial.cpp:134
virtual void v_Bcast(void *buffer, int count, CommDataType dt, int root) final
Definition: CommSerial.cpp:208
virtual CommRequestSharedPtr v_CreateRequest(int num) final
Definition: CommSerial.cpp:286
virtual void v_Irecv(void *buf, int count, CommDataType dt, int source, CommRequestSharedPtr request, int loc) final
Definition: CommSerial.cpp:264
virtual void v_AllReduce(void *buf, int count, CommDataType dt, enum ReduceOperator pOp) final
Definition: CommSerial.cpp:154
static CommSharedPtr create(int narg, char *arg[])
Creates an instance of this class.
Definition: CommSerial.h:58
virtual void v_Exscan(Array< OneD, unsigned long long > &pData, const enum ReduceOperator pOp, Array< OneD, unsigned long long > &ans) final
Definition: CommSerial.cpp:213
virtual void v_SplitComm(int pRows, int pColumns) override
Definition: CommSerial.cpp:295
virtual void v_RecvInit(void *buf, int count, CommDataType dt, int source, CommRequestSharedPtr request, int loc) final
Definition: CommSerial.cpp:270
virtual void v_AlltoAllv(void *sendbuf, int sendcounts[], int sensdispls[], CommDataType sendtype, void *recvbuf, int recvcounts[], int rdispls[], CommDataType recvtype) final
Definition: CommSerial.cpp:173
virtual void v_Finalise() final
Definition: CommSerial.cpp:64
virtual void v_StartAll(CommRequestSharedPtr request) final
Definition: CommSerial.cpp:281
virtual bool v_TreatAsRankZero() override
Definition: CommSerial.cpp:82
CommSerial(int argc, char *argv[])
Definition: CommSerial.cpp:50
virtual NekDouble v_Wtime() final
Definition: CommSerial.cpp:110
static std::string className
Name of class.
Definition: CommSerial.h:64
virtual void v_NeighborAlltoAllv(void *sendbuf, int sendcounts[], int sdispls[], CommDataType sendtype, void *recvbuf, int recvcounts[], int rdispls[], CommDataType recvtype) final
Definition: CommSerial.cpp:243
virtual void v_Irsend(void *buf, int count, CommDataType dt, int dest, CommRequestSharedPtr request, int loc) final
Definition: CommSerial.cpp:252
virtual void v_Block() final
Definition: CommSerial.cpp:103
virtual void v_Send(void *buf, int count, CommDataType dt, int dest) final
Definition: CommSerial.cpp:118
virtual ~CommSerial() override
virtual bool v_IsSerial() override
Definition: CommSerial.cpp:90
virtual void v_WaitAll(CommRequestSharedPtr request) final
Definition: CommSerial.cpp:276
virtual void v_AllGatherv(void *sendbuf, int sendcount, CommDataType sendtype, void *recvbuf, int recvcounts[], int rdispls[], CommDataType recvtype) final
Definition: CommSerial.cpp:193
virtual void v_AlltoAll(void *sendbuf, int sendcount, CommDataType sendtype, void *recvbuf, int recvcount, CommDataType recvtype) final
Definition: CommSerial.cpp:163
virtual void v_Scatter(void *sendbuf, int sendcount, CommDataType sendtype, void *recvbuf, int recvcount, CommDataType recvtype, int root) final
Definition: CommSerial.cpp:228
virtual void v_AllGather(void *sendbuf, int sendcount, CommDataType sendtype, void *recvbuf, int recvcount, CommDataType recvtype) final
Definition: CommSerial.cpp:185
virtual void v_DistGraphCreateAdjacent(int indegree, const int sources[], const int sourceweights[], int reorder) final
Definition: CommSerial.cpp:236
virtual void v_Recv(void *buf, int count, CommDataType dt, int source) final
Definition: CommSerial.cpp:126
virtual int v_GetRank() override
Definition: CommSerial.cpp:74
virtual void v_SendInit(void *buf, int count, CommDataType dt, int dest, CommRequestSharedPtr request, int loc) final
Definition: CommSerial.cpp:258
static std::shared_ptr< DataType > AllocateSharedPtr(const Args &...args)
Allocate a shared pointer from the memory pool.
array buffer
Definition: GsLib.hpp:61
unsigned int CommDataType
Definition: CommDataType.h:70
std::shared_ptr< CommRequest > CommRequestSharedPtr
Definition: Comm.h:86
ReduceOperator
Type of operation to perform in AllReduce.
Definition: Comm.h:67
std::shared_ptr< Comm > CommSharedPtr
Pointer to a Communicator object.
Definition: Comm.h:54
std::shared_ptr< CommSerial > CommSerialSharedPtr
Pointer to a Communicator object.
Definition: CommSerial.h:48
The above copyright notice and this permission notice shall be included.
Definition: CoupledSolver.h:1
double NekDouble