added a _cancelled flag for the client call to track if the call was …

…cancelled. If cancelled then we need to signal occurrence no matter if the call is still under ActiveListCalls or not (#360)
ni · May 10, 2024 · 22643bb · 22643bb
1 parent 5efe8ee
commit 22643bb
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/src/grpc_client.cc b/src/grpc_client.cc
@@ -60,6 +60,7 @@ namespace grpc_labview
     void ClientCall::Cancel()
     {
         _context.get()->Cancel();
+        _cancelled = true;
     }
 
     //---------------------------------------------------------------------
@@ -202,6 +203,10 @@ void CheckActiveAndSignalOccurenceForClientCall(grpc_labview::ClientCall *client
     {
         return;
     }
+    if (clientCall->_cancelled == true)
+    {
+        grpc_labview::SignalOccurrence(clientCall->_occurrence);
+    }
     std::unique_lock<std::mutex> lock(clientCall->_client->clientLock);
     if (clientCall->_client->ActiveClientCalls.find(clientCall) != clientCall->_client->ActiveClientCalls.end())
     {

diff --git a/src/grpc_client.h b/src/grpc_client.h
@@ -62,6 +62,7 @@ namespace grpc_labview
         grpc::Status _status;
         std::future<int> _runFuture;
         bool _useLVEfficientMessage;
+        bool _cancelled = false;
     };
 
     //---------------------------------------------------------------------