Disable mutex when not available

bertmelis · May 15, 2024 · 63056f9 · 63056f9
1 parent 0839f81
commit 63056f9
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 1 deletion.
diff --git a/src/Fixed.h b/src/Fixed.h
@@ -10,7 +10,11 @@ the LICENSE file.
 
 #include <cstddef>  // std::size_t
 #include <cassert>  // assert
+#if _GLIBCXX_HAS_GTHREADS
 #include <mutex>  // NOLINT [build/c++11] std::mutex, std::lock_guard
+#else
+#warning "The memory pool is not thread safe"
+#endif
 
 #ifdef MEMPOL_DEBUG
 #include <iostream>
@@ -38,7 +42,9 @@ class Fixed {
   Fixed& operator= (const Fixed&) = delete;
 
   void* malloc() {
+    #if _GLIBCXX_HAS_GTHREADS
     const std::lock_guard<std::mutex> lockGuard(_mutex);
+    #endif
     if (_head) {
       void* retVal = _head;
       _head = *reinterpret_cast<unsigned char**>(_head);
@@ -49,13 +55,17 @@ class Fixed {
 
   void free(void* ptr) {
     if (!ptr) return;
+    #if _GLIBCXX_HAS_GTHREADS
     const std::lock_guard<std::mutex> lockGuard(_mutex);
+    #endif
     *reinterpret_cast<unsigned char**>(ptr) = _head;
     _head = reinterpret_cast<unsigned char*>(ptr);
   }
 
   std::size_t freeMemory() {
+    #if _GLIBCXX_HAS_GTHREADS
     const std::lock_guard<std::mutex> lockGuard(_mutex);
+    #endif
     unsigned char* i = _head;
     std::size_t retVal = 0;
     while (i) {
@@ -101,7 +111,9 @@ class Fixed {
  private:
   unsigned char _buffer[nrBlocks * (sizeof(std::size_t) > blocksize ? sizeof(std::size_t) : blocksize)];
   unsigned char* _head;
+  #if _GLIBCXX_HAS_GTHREADS
   std::mutex _mutex;
+  #endif
 };
 
-}  // end namespace MemoryPool
+}  // end namespace MemoryPool
diff --git a/src/Variable.h b/src/Variable.h
@@ -10,7 +10,11 @@ the LICENSE file.
 
 #include <cstddef>  // std::size_t
 #include <cassert>  // assert
+#if _GLIBCXX_HAS_GTHREADS
 #include <mutex>  // NOLINT [build/c++11] std::mutex, std::lock_guard
+#else
+#warning "The memory pool is not thread safe"
+#endif
 
 #ifdef MEMPOL_DEBUG
 #include <iostream>
@@ -45,7 +49,9 @@ class Variable {
   Variable& operator= (const Variable&) = delete;
 
   void* malloc(size_t size) {
+    #if _GLIBCXX_HAS_GTHREADS
     const std::lock_guard<std::mutex> lockGuard(_mutex);
+    #endif
     if (size == 0) return nullptr;
 
     size = (size / sizeof(BlockHeader) + (size % sizeof(BlockHeader) != 0)) + 1;  // count by BlockHeader size, add 1 for header
@@ -107,7 +113,9 @@ class Variable {
     std::cout << "free " << static_cast<void*>(reinterpret_cast<BlockHeader*>(ptr) - 1) << std::endl;
     #endif
 
+    #if _GLIBCXX_HAS_GTHREADS
     const std::lock_guard<std::mutex> lockGuard(_mutex);
+    #endif
 
     BlockHeader* toFree = reinterpret_cast<BlockHeader*>(ptr) - 1;
     BlockHeader* previous = reinterpret_cast<BlockHeader*>(_buffer);
@@ -152,7 +160,9 @@ class Variable {
   }
 
   std::size_t freeMemory() {
+    #if _GLIBCXX_HAS_GTHREADS
     const std::lock_guard<std::mutex> lockGuard(_mutex);
+    #endif
     size_t retVal = 0;
     BlockHeader* currentBlock = reinterpret_cast<BlockHeader*>(_head);
 
@@ -165,7 +175,9 @@ class Variable {
   }
 
   std::size_t maxBlockSize() {
+    #if _GLIBCXX_HAS_GTHREADS
     const std::lock_guard<std::mutex> lockGuard(_mutex);
+    #endif
     size_t retVal = 0;
     BlockHeader* currentBlock = reinterpret_cast<BlockHeader*>(_head);
 
@@ -218,7 +230,9 @@ class Variable {
   */
   unsigned char _buffer[(nrBlocks * ((blocksize / sizeof(BlockHeader) + ((blocksize % sizeof(BlockHeader)) ? 1 : 0)) + 1)) * sizeof(BlockHeader)];
   BlockHeader* _head;
+  #if _GLIBCXX_HAS_GTHREADS
   std::mutex _mutex;
+  #endif
 
   #ifdef MEMPOL_DEBUG
   std::size_t _bufferSize;