impl clearing of queue

Author: usa-m

src/dds.net-connector-cpp.lib/connector/src/internal/inc/sync_queue.h

@@ -23,6 +23,8 @@ namespace dds {
           bool canEnqueue() override;
           void enqueue(T data) override;
 
+          void clear();
+
 
         private:
           std::mutex lock;

src/dds.net-connector-cpp.lib/connector/src/internal/src/sync_queue.cpp

@@ -117,3 +117,19 @@ void dds::net::connector::_internal::SyncQueue<T>::enqueue(T data)
     sleep(SLEEP_TIME_MS_WHEN_DATA_CANNOT_BE_ENQUEUED);
   }
 }
+
+template<typename T>
+void dds::net::connector::_internal::SyncQueue<T>::clear()
+{
+  lock.lock();
+
+  for (int i = 0; i < queueSize; i++)
+  {
+    queueValidity[i] = false;
+  }
+
+  nextWriteIndex = 0;
+  nextReadIndex = 0;
+
+  lock.unlock();
+}