[Offload][NFC] Make sure the thread is not running already

Author: jhuber6

offload/plugins-nextgen/common/include/RPC.h

@@ -99,7 +99,7 @@ struct RPCServerTy {
     /// Initialize the worker thread to run in the background.
     ServerThread(void *Buffers[], plugin::GenericDeviceTy *Devices[],
                  size_t Length)
-        : Running(true), NumUsers(0), CV(), Mutex(), Buffers(Buffers, Length),
+        : Running(false), NumUsers(0), CV(), Mutex(), Buffers(Buffers, Length),
           Devices(Devices, Length) {}
 
     ~ServerThread() { assert(!Running && "Thread not shut down explicitly\n"); }

offload/plugins-nextgen/common/src/RPC.cpp

@@ -99,10 +99,15 @@ static rpc::Status runServer(plugin::GenericDeviceTy &Device, void *Buffer) {
 }
 
 void RPCServerTy::ServerThread::startThread() {
+  assert(!Running.load(std::memory_order_relaxed) &&
+         "Attempting to start thread that is already running");
+  Running.store(true, std::memory_order_release);
   Worker = std::thread([this]() { run(); });
 }
 
 void RPCServerTy::ServerThread::shutDown() {
+  assert(Running.load(std::memory_order_relaxed) &&
+         "Attempting to shut down a thread that is not running");
   {
     std::lock_guard<decltype(Mutex)> Lock(Mutex);
     Running.store(false, std::memory_order_release);