From 27da6f318bf6f39dd198293790edab9f170da83b Mon Sep 17 00:00:00 2001 From: nicolotonci Date: Tue, 13 Feb 2024 13:18:56 +0000 Subject: [PATCH] =?UTF-8?q?Deploying=20to=20gh-pages=20from=20@=20ParaGrou?= =?UTF-8?q?p/MTCL@fbd8aa924b916c6578963af315fdb5f10c3969ad=20=F0=9F=9A=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- mtcl_8hpp_source.html | 73 ++++++++++++++++++------------------ shm__buffer_8hpp_source.html | 12 +++--- utils_8hpp_source.html | 19 +++++----- 3 files changed, 52 insertions(+), 52 deletions(-) diff --git a/mtcl_8hpp_source.html b/mtcl_8hpp_source.html index d3a3403..8b2f988 100644 --- a/mtcl_8hpp_source.html +++ b/mtcl_8hpp_source.html @@ -74,44 +74,43 @@
3 
4 namespace MTCL {
5 
-
6 
-
7 #if defined(ENABLE_MPI)
-
8 const bool MPI_ENABLED = true;
-
9 #define MTCL_ENABLE_MPI
-
10 #else
-
11 const bool MPI_ENABLED = false;
-
12 #endif
-
13 #if defined(ENABLE_MPIP2P) && !defined(NO_MTCL_MULTITHREADED)
-
14 const bool MPIP2P_ENABLED = true;
-
15 #define MTCL_ENABLE_MPIP2P
-
16 #else
-
17 const bool MPIP2P_ENABLED = false;
-
18 #endif
-
19 #if defined(ENABLE_UCX)
-
20 const bool UCX_ENABLED = true;
-
21 const bool UCC_ENABLED = true;
-
22 #define MTCL_ENABLE_UCX
-
23 #else
-
24 const bool UCX_ENABLED = false;
-
25 const bool UCC_ENABLED = false;
-
26 #endif
-
27 
-
28 #ifdef ENABLE_SHM
-
29 #define MTCL_ENABLE_SHM
-
30 #endif
-
31 
-
32 #ifdef ENABLE_MQTT
-
33 #define MTCL_ENABLE_MQTT
-
34 #endif
-
35 
-
36 } // namespace
+
6 #if defined(ENABLE_MPI)
+
7 const bool MPI_ENABLED = true;
+
8 #define MTCL_ENABLE_MPI
+
9 #else
+
10 const bool MPI_ENABLED = false;
+
11 #endif
+
12 #if defined(ENABLE_MPIP2P) && !defined(NO_MTCL_MULTITHREADED)
+
13 const bool MPIP2P_ENABLED = true;
+
14 #define MTCL_ENABLE_MPIP2P
+
15 #else
+
16 const bool MPIP2P_ENABLED = false;
+
17 #endif
+
18 #if defined(ENABLE_UCX)
+
19 const bool UCX_ENABLED = true;
+
20 const bool UCC_ENABLED = true;
+
21 #define MTCL_ENABLE_UCX
+
22 #else
+
23 const bool UCX_ENABLED = false;
+
24 const bool UCC_ENABLED = false;
+
25 #endif
+
26 
+
27 #ifdef ENABLE_SHM
+
28 #define MTCL_ENABLE_SHM
+
29 #endif
+
30 
+
31 #ifdef ENABLE_MQTT
+
32 #define MTCL_ENABLE_MQTT
+
33 #endif
+
34 
+
35 } // namespace
+
36 
37 
-
38 
-
39 #include "config.hpp"
-
40 #include "utils.hpp"
-
41 #include "manager.hpp"
-
42 
-
43 #endif
+
38 #include "config.hpp"
+
39 #include "utils.hpp"
+
40 #include "manager.hpp"
+
41 
+
42 #endif
diff --git a/shm__buffer_8hpp_source.html b/shm__buffer_8hpp_source.html index abb9dc9..fea4dc5 100644 --- a/shm__buffer_8hpp_source.html +++ b/shm__buffer_8hpp_source.html @@ -202,7 +202,7 @@
131  pthread_spin_lock(&shmp->spinlock);
132  if (shmp->guard==0) break;
133  pthread_spin_unlock(&shmp->spinlock);
-
134  cpu_relax();
+
134  mtcl_cpu_relax();
135  } while(1);
136  shmp->data.size=sz;
137  shmp->guard=(void*)data;
@@ -215,7 +215,7 @@
144  pthread_spin_lock(&shmp->spinlock);
145  if (shmp->guard==0) break;
146  pthread_spin_unlock(&shmp->spinlock);
-
147  cpu_relax();
+
147  mtcl_cpu_relax();
148  } while(1);
149  shmp->data.size=sz;
150  s = std::min(size, (size_t)SHM_SMALL_MSG_SIZE);
@@ -241,7 +241,7 @@
170  break;
171  }
172  pthread_spin_unlock(&shmp->spinlock);
-
173  cpu_relax();
+
173  mtcl_cpu_relax();
174  } while(true);
175 
176  size_t size = shmp->data.size;
@@ -262,7 +262,7 @@
191  pthread_spin_lock(&shmp->spinlock);
192  if (shmp->guard!=0) break;
193  pthread_spin_unlock(&shmp->spinlock);
-
194  cpu_relax();
+
194  mtcl_cpu_relax();
195  } while(true);
196  }
197  posix_madvise(data, sz, POSIX_MADV_NORMAL);
@@ -282,7 +282,7 @@
211  break;
212  }
213  pthread_spin_unlock(&shmp->spinlock);
-
214  cpu_relax();
+
214  mtcl_cpu_relax();
215  } while(true);
216  size_t size = shmp->data.size;
217  pthread_spin_unlock(&shmp->spinlock);
@@ -321,7 +321,7 @@
250  pthread_spin_lock(&shmp->spinlock);
251  if (shmp->guard!=0) break;
252  pthread_spin_unlock(&shmp->spinlock);
-
253  cpu_relax();
+
253  mtcl_cpu_relax();
254  } while(true);
255  }
256  posix_madvise(data, sz, POSIX_MADV_NORMAL);
diff --git a/utils_8hpp_source.html b/utils_8hpp_source.html index 10e969d..ad63c89 100644 --- a/utils_8hpp_source.html +++ b/utils_8hpp_source.html @@ -289,27 +289,28 @@
218 
219 
220 #if defined(__i386__) || defined(__x86_64__)
-
221 #define PAUSE() __asm__ __volatile__ ("rep; nop" ::: "memory")
+
221 #define MTCL_PAUSE() __asm__ __volatile__ ("rep; nop" ::: "memory")
222 #endif // __i386
223 
224 #if defined (__riscv)
-
225 #define PAUSE() /* ?? */
+
225 #define MTCL_PAUSE() /* ?? */
226 #endif // __riscv
227 
228 #if defined(__powerpc__) || defined(__ppc__)
229 // yield == or 27, 27, 27
-
230 #define PAUSE() asm volatile ("or 27,27,27" ::: "memory");
+
230 #define MTCL_PAUSE() asm volatile ("or 27,27,27" ::: "memory");
231 #endif // __powerpc
232 
233 #if defined(__arm__) || defined(__aarch64__)
-
234 #define PAUSE() asm volatile("yield" ::: "memory")
+
234 #define MTCL_PAUSE() asm volatile("yield" ::: "memory")
235 #endif //__arm
236 
-
237 static inline void cpu_relax(void) {
-
238  PAUSE();
-
239 }
-
240 
-
241 #endif
+
237 
+
238 static inline void mtcl_cpu_relax(void) {
+
239  MTCL_PAUSE();
+
240 }
+
241 
+
242 #endif