Arcane  4.1.12.0
Developer documentation
Loading...
Searching...
No Matches
ParallelNonBlockingCollectiveDispatcher.h
1// -*- tab-width: 2; indent-tabs-mode: nil; coding: utf-8-with-signature -*-
2//-----------------------------------------------------------------------------
3// Copyright 2000-2026 CEA (www.cea.fr) IFPEN (www.ifpenergiesnouvelles.com)
4// See the top-level COPYRIGHT file for details.
5// SPDX-License-Identifier: Apache-2.0
6//-----------------------------------------------------------------------------
7/*---------------------------------------------------------------------------*/
8/* ParallelNonBlockingCollectiveDispatcher.h (C) 2000-2025 */
9/* */
10/* Interface of the parallelism manager on a domain. */
11/*---------------------------------------------------------------------------*/
12#ifndef ARCANE_CORE_PARALLELNONBLOCKINGCOLLECTIVEDISPATCHER_H
13#define ARCANE_CORE_PARALLELNONBLOCKINGCOLLECTIVEDISPATCHER_H
14/*---------------------------------------------------------------------------*/
15/*---------------------------------------------------------------------------*/
16
17#include "arcane/core/IParallelNonBlockingCollective.h"
18#include "arcane/core/IParallelNonBlockingCollectiveDispatch.h"
19
20/*---------------------------------------------------------------------------*/
21/*---------------------------------------------------------------------------*/
22
23namespace Arcane
24{
25
26/*---------------------------------------------------------------------------*/
27/*---------------------------------------------------------------------------*/
28
29template <typename T>
30class IParallelNonBlockingCollectiveDispatchT;
31
32/*---------------------------------------------------------------------------*/
33/*---------------------------------------------------------------------------*/
34
40class ARCANE_CORE_EXPORT ParallelNonBlockingCollectiveDispatcher
41: public IParallelNonBlockingCollective
42{
43 public:
44
45 explicit ParallelNonBlockingCollectiveDispatcher(IParallelMng* pm);
46 ~ParallelNonBlockingCollectiveDispatcher() override;
47
48 public:
49
50 IParallelMng* parallelMng() const override { return m_parallel_mng; }
51
52 protected:
53
54 void _setDispatchers(IParallelNonBlockingCollectiveDispatchT<char>* c,
55 IParallelNonBlockingCollectiveDispatchT<signed char>* sc,
56 IParallelNonBlockingCollectiveDispatchT<unsigned char>* uc,
57 IParallelNonBlockingCollectiveDispatchT<short>* s,
58 IParallelNonBlockingCollectiveDispatchT<unsigned short>* us,
59 IParallelNonBlockingCollectiveDispatchT<int>* i,
60 IParallelNonBlockingCollectiveDispatchT<unsigned int>* ui,
61 IParallelNonBlockingCollectiveDispatchT<long>* l,
62 IParallelNonBlockingCollectiveDispatchT<unsigned long>* ul,
63 IParallelNonBlockingCollectiveDispatchT<long long>* ll,
64 IParallelNonBlockingCollectiveDispatchT<unsigned long long>* ull,
65#ifdef ARCANE_REAL_NOT_BUILTIN
66 IParallelNonBlockingCollectiveDispatchT<Real>* r,
67#endif
68 IParallelNonBlockingCollectiveDispatchT<float>* f,
69 IParallelNonBlockingCollectiveDispatchT<double>* d,
70 IParallelNonBlockingCollectiveDispatchT<long double>* ld,
71 IParallelNonBlockingCollectiveDispatchT<Real2>* r2,
72 IParallelNonBlockingCollectiveDispatchT<Real3>* r3,
73 IParallelNonBlockingCollectiveDispatchT<Real2x2>* r22,
74 IParallelNonBlockingCollectiveDispatchT<Real3x3>* r33,
75 IParallelNonBlockingCollectiveDispatchT<HPReal>* hpr);
76
77 ITimeStats* timeStats();
78
79 private:
80
81 IParallelMng* m_parallel_mng = nullptr;
82
83 public:
84
85#define ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(field, type) \
86 public: \
87\
88 virtual Request allGather(ConstArrayView<type> send_buf, ArrayView<type> recv_buf); \
89 virtual Request gather(ConstArrayView<type> send_buf, ArrayView<type> recv_buf, Integer rank); \
90 virtual Request allGatherVariable(ConstArrayView<type> send_buf, Array<type>& recv_buf); \
91 virtual Request gatherVariable(ConstArrayView<type> send_buf, Array<type>& recv_buf, Integer rank); \
92 virtual Request scatterVariable(ConstArrayView<type> send_buf, ArrayView<type> recv_buf, Integer root); \
93 virtual Request allReduce(eReduceType rt, ConstArrayView<type> send_buf, ArrayView<type> v); \
94 virtual Request broadcast(ArrayView<type> send_buf, Int32 rank); \
95 virtual Request allToAll(ConstArrayView<type> send_buf, ArrayView<type> recv_buf, Integer count); \
96 virtual Request allToAllVariable(ConstArrayView<type> send_buf, Int32ConstArrayView send_count, \
97 Int32ConstArrayView send_index, ArrayView<type> recv_buf, \
98 Int32ConstArrayView recv_count, Int32ConstArrayView recv_index); \
99\
100 protected: \
101\
102 IParallelNonBlockingCollectiveDispatchT<type>* field;
103
104 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_char, char)
105 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_unsigned_char, unsigned char)
106 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_signed_char, signed char)
107 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_short, short)
108 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_unsigned_short, unsigned short)
109 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_int, int)
110 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_unsigned_int, unsigned int)
111 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_long, long)
112 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_unsigned_long, unsigned long)
113 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_long_long, long long)
114 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_unsigned_long_long, unsigned long long)
115 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_float, float)
116 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_double, double)
117 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_long_double, long double)
118#ifdef ARCANE_REAL_NOT_BUILTIN
119 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_real, Real)
120#endif
121 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_real2, Real2)
122 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_real3, Real3)
123 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_real2x2, Real2x2)
124 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_real3x3, Real3x3)
125 ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE(m_hpreal, HPReal)
126
127#undef ARCANE_PARALLEL_NONBLOCKINGCOLLECTIVE_DISPATCH_PROTOTYPE
128
129 public:
130
131 virtual IParallelNonBlockingCollectiveDispatchT<char>* dispatcher(char*);
132 virtual IParallelNonBlockingCollectiveDispatchT<signed char>* dispatcher(signed char*);
133 virtual IParallelNonBlockingCollectiveDispatchT<unsigned char>* dispatcher(unsigned char*);
134 virtual IParallelNonBlockingCollectiveDispatchT<short>* dispatcher(short*);
135 virtual IParallelNonBlockingCollectiveDispatchT<unsigned short>* dispatcher(unsigned short*);
136 virtual IParallelNonBlockingCollectiveDispatchT<int>* dispatcher(int*);
137 virtual IParallelNonBlockingCollectiveDispatchT<unsigned int>* dispatcher(unsigned int*);
138 virtual IParallelNonBlockingCollectiveDispatchT<long>* dispatcher(long*);
139 virtual IParallelNonBlockingCollectiveDispatchT<unsigned long>* dispatcher(unsigned long*);
140 virtual IParallelNonBlockingCollectiveDispatchT<long long>* dispatcher(long long*);
141 virtual IParallelNonBlockingCollectiveDispatchT<unsigned long long>* dispatcher(unsigned long long*);
142#ifdef ARCANE_REAL_NOT_BUILTIN
143 virtual IParallelNonBlockingCollectiveDispatchT<Real>* dispatcher(Real*);
144#endif
145 virtual IParallelNonBlockingCollectiveDispatchT<float>* dispatcher(float*);
146 virtual IParallelNonBlockingCollectiveDispatchT<double>* dispatcher(double*);
147 virtual IParallelNonBlockingCollectiveDispatchT<long double>* dispatcher(long double*);
148 virtual IParallelNonBlockingCollectiveDispatchT<Real2>* dispatcher(Real2*);
149 virtual IParallelNonBlockingCollectiveDispatchT<Real3>* dispatcher(Real3*);
150 virtual IParallelNonBlockingCollectiveDispatchT<Real2x2>* dispatcher(Real2x2*);
151 virtual IParallelNonBlockingCollectiveDispatchT<Real3x3>* dispatcher(Real3x3*);
152 virtual IParallelNonBlockingCollectiveDispatchT<HPReal>* dispatcher(HPReal*);
153};
154
155/*---------------------------------------------------------------------------*/
156/*---------------------------------------------------------------------------*/
157
158} // namespace Arcane
159
160/*---------------------------------------------------------------------------*/
161/*---------------------------------------------------------------------------*/
162
163#endif
Arcane::HPReal
Class implementing a High-Precision real number.
Definition HPReal.h:159
Arcane::IParallelMng
Interface of the parallelism manager for a subdomain.
Definition IParallelMng.h:53
Arcane::IParallelNonBlockingCollectiveDispatchT
Interface for non-blocking collectives for the type Type.
Definition IParallelNonBlockingCollectiveDispatch.h:35
Arcane::IParallelNonBlockingCollective
Interface for non-blocking collective parallel operations.
Definition IParallelNonBlockingCollective.h:53
Arcane::ITimeStats
Interface managing execution time statistics.
Definition ITimeStats.h:44
Arcane::ParallelNonBlockingCollectiveDispatcher::parallelMng
IParallelMng * parallelMng() const override
Associated parallelism manager.
Definition ParallelNonBlockingCollectiveDispatcher.h:50
Arcane::Real2
Class managing a 2-dimensional real vector.
Definition Real2.h:122
Arcane::Real2x2
Class managing a 2x2 matrix of reals.
Definition Real2x2.h:55
Arcane::Real3
Class managing a 3-dimensional real vector.
Definition Real3.h:132
Arcane::Real3x3
Class managing a 3x3 real matrix.
Definition Real3x3.h:67
Arcane
-- tab-width: 2; indent-tabs-mode: nil; coding: utf-8-with-signature --
Definition arcane/src/arcane/accelerator/AcceleratorGlobal.h:37
Arcane::Real
double Real
Type representing a real number.
Definition ArccoreGlobal.h:275