Fixes #19. Add destructor to ConditionBank.

Added a destructor to the ConditionBank class to deallocate the m_pair array.
Valgrind was used to test the shutdown of samples/MallocTest was clean.

Additional changes were needed in MallocTest to register with and update QSBR
so the table migration would be cleaned up.

diff --git a/junction/striped/ConditionBank.cpp b/junction/striped/ConditionBank.cpp
index 30aec87..5fda216 100644 (file)
--- a/junction/striped/ConditionBank.cpp
+++ b/junction/striped/ConditionBank.cpp
@@ -1,6 +1,6 @@
 /*------------------------------------------------------------------------
   Junction: Concurrent data structures in C++
 /*------------------------------------------------------------------------
   Junction: Concurrent data structures in C++

-  Copyright (c) 2016 Jeff Preshing
+  Copyright (c) 2016-2017 Jeff Preshing

 
   Distributed under the Simplified BSD License.
   Original location: https://github.com/preshing/junction
 
   Distributed under the Simplified BSD License.
   Original location: https://github.com/preshing/junction


@@ -20,6 +20,13 @@ namespace striped {
 
 ConditionBank DefaultConditionBank;
 
 
 ConditionBank DefaultConditionBank;
 

+ConditionBank::~ConditionBank() {
+    m_initSpinLock.lock();
+    ConditionPair* pairs = m_pairs.exchange(nullptr, turf::ConsumeRelease);
+    delete [] pairs;
+    m_initSpinLock.unlock();
+}
+

 ConditionPair* ConditionBank::initialize() {
     m_initSpinLock.lock();
     ConditionPair* pairs = m_pairs.loadNonatomic();
 ConditionPair* ConditionBank::initialize() {
     m_initSpinLock.lock();
     ConditionPair* pairs = m_pairs.loadNonatomic();

diff --git a/junction/striped/ConditionBank.h b/junction/striped/ConditionBank.h
index 2556637..163bc31 100644 (file)
--- a/junction/striped/ConditionBank.h
+++ b/junction/striped/ConditionBank.h
@@ -1,6 +1,6 @@
 /*------------------------------------------------------------------------
   Junction: Concurrent data structures in C++
 /*------------------------------------------------------------------------
   Junction: Concurrent data structures in C++

-  Copyright (c) 2016 Jeff Preshing
+  Copyright (c) 2016-2017 Jeff Preshing

 
   Distributed under the Simplified BSD License.
   Original location: https://github.com/preshing/junction
 
   Distributed under the Simplified BSD License.
   Original location: https://github.com/preshing/junction


@@ -36,6 +36,8 @@ private:
     ConditionPair* initialize();
 
 public:
     ConditionPair* initialize();
 
 public:

+    ~ConditionBank();
+

     ConditionPair& get(void* ptr) {
         ConditionPair* pairs = m_pairs.load(turf::Consume);
         if (!pairs) {
     ConditionPair& get(void* ptr) {
         ConditionPair* pairs = m_pairs.load(turf::Consume);
         if (!pairs) {

diff --git a/samples/MallocTest/MallocTest.cpp b/samples/MallocTest/MallocTest.cpp
index c0e18cf..3aba8f0 100644 (file)
--- a/samples/MallocTest/MallocTest.cpp
+++ b/samples/MallocTest/MallocTest.cpp
@@ -1,6 +1,6 @@
 /*------------------------------------------------------------------------
   Junction: Concurrent data structures in C++
 /*------------------------------------------------------------------------
   Junction: Concurrent data structures in C++

-  Copyright (c) 2016 Jeff Preshing
+  Copyright (c) 2016-2017 Jeff Preshing

 
   Distributed under the Simplified BSD License.
   Original location: https://github.com/preshing/junction
 
   Distributed under the Simplified BSD License.
   Original location: https://github.com/preshing/junction


@@ -22,6 +22,8 @@ int main() {
     junction::extra::MapAdapter::ThreadContext context(adapter, 0);
     junction::extra::MapAdapter::Map map(65536);
 
     junction::extra::MapAdapter::ThreadContext context(adapter, 0);
     junction::extra::MapAdapter::Map map(65536);
 

+    context.registerThread();
+

     ureg population = 0;
     for (ureg i = 0; i < 100; i++) {
 #if TURF_USE_DLMALLOC && TURF_DLMALLOC_FAST_STATS
     ureg population = 0;
     for (ureg i = 0; i < 100; i++) {
 #if TURF_USE_DLMALLOC && TURF_DLMALLOC_FAST_STATS


@@ -31,5 +33,8 @@ int main() {
             map.assign(population + 1, (void*) ((population << 2) | 3));
     }
 
             map.assign(population + 1, (void*) ((population << 2) | 3));
     }
 

+    context.update();
+    context.unregisterThread();
+

     return 0;
 }
     return 0;
 }