wait for thread to terminate before closing pin fd

nRF24 · Mar 19, 2024 · 3b3187a · 3b3187a
1 parent 0df788c
commit 3b3187a
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/utility/RPi/interrupt.cpp b/utility/RPi/interrupt.cpp
@@ -47,7 +47,8 @@ IrqChipCache::IrqChipCache()
 IrqChipCache::~IrqChipCache()
 {
     for (std::map<rf24_gpio_pin_t, IrqPinCache>::iterator i = irqCache.begin(); i != irqCache.end(); ++i) {
-        pthread_cancel(i->second.id);
+        pthread_cancel(i->second.id);     // send cancel request
+        pthread_join(i->second.id, NULL); // wait till thread terminates
         close(i->second.fd);
     }
     irqCache.clear();
@@ -180,7 +181,8 @@ int detachInterrupt(rf24_gpio_pin_t pin)
     if (cachedPin == irqCache.end()) {
         return 0; // pin not in cache; just exit
     }
-    pthread_cancel(cachedPin->second.id);
+    pthread_cancel(cachedPin->second.id);     // send cancel request
+    pthread_join(cachedPin->second.id, NULL); // wait till thread terminates
     close(cachedPin->second.fd);
     irqCache.erase(cachedPin);
     return 1;

diff --git a/utility/SPIDEV/interrupt.cpp b/utility/SPIDEV/interrupt.cpp
@@ -25,7 +25,8 @@ struct IrqChipCache : public GPIOChipCache
     ~IrqChipCache()
     {
         for (std::map<rf24_gpio_pin_t, IrqPinCache>::iterator i = irqCache.begin(); i != irqCache.end(); ++i) {
-            pthread_cancel(i->second.id);
+            pthread_cancel(i->second.id);     // send cancel request
+            pthread_join(i->second.id, NULL); // wait till thread terminates
             close(i->second.fd);
         }
         irqCache.clear();
@@ -160,7 +161,8 @@ int detachInterrupt(rf24_gpio_pin_t pin)
     if (cachedPin == irqCache.end()) {
         return 0; // pin not in cache; just exit
     }
-    pthread_cancel(cachedPin->second.id);
+    pthread_cancel(cachedPin->second.id);     // send cancel request
+    pthread_join(cachedPin->second.id, NULL); // wait till thread terminates
     close(cachedPin->second.fd);
     irqCache.erase(cachedPin);
     return 1;