avoid crashing when exiting bob

Author: krypdkat

SpecialBufferStructs.h

@@ -194,6 +194,10 @@ class TimedCacheMap {
     }
 
     ~TimedCacheMap() {
+
+    }
+    void stop()
+    {
         {
             std::lock_guard<std::mutex> lock(mtx_);
             should_stop_ = true;
@@ -203,7 +207,6 @@ class TimedCacheMap {
             cleanup_thread_.join();
         }
     }
-
     // Disable copy and assignment
     TimedCacheMap(const TimedCacheMap&) = delete;
     TimedCacheMap& operator=(const TimedCacheMap&) = delete;

bob.cpp

@@ -379,15 +379,27 @@ int runBob(int argc, char *argv[])
     Logger::get()->info("Exited indexer thread");
 
     sc_thread.join();
-    delete gTCM;
-    Logger::get()->info("Exited SC thread");
+    if (gTCM)
+    {
+        gTCM->stop();
+        Logger::get()->info("Stopped gTCM");
+        delete gTCM;
+        gTCM = nullptr;
+        Logger::get()->info("Exited SC thread");
+    }
 
     if (log_event_verifier_thread.joinable())
     {
         log_event_verifier_thread.join();
         Logger::get()->info("Exited verifyLoggingEvent thread");
     }
 
+    if (run_server)
+    {
+        StopQubicServer();
+        Logger::get()->info("Closed Qubic server at port 21842");
+    }
+
     // Now the receivers can drain and exit.
     for (auto& thr : v_recv_thread) thr.join();
     Logger::get()->info("Exited recv threads");
@@ -418,12 +430,6 @@ int runBob(int argc, char *argv[])
         garbage_thread.join();
     }
 
-    if (run_server)
-    {
-        StopQubicServer();
-        Logger::get()->info("Closed Qubic server at port 21842");
-    }
-
     stopRESTServer();
     Logger::get()->info("Closed REST server at port {}", gRpcPort);