iox-#27 Add releaseQueuedRequests to server port

eclipse-iceoryx · Feb 11, 2022 · 902468f · 902468f
1 parent 14981a3
commit 902468f
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/iceoryx_posh/include/iceoryx_posh/internal/popo/ports/server_port_user.hpp b/iceoryx_posh/include/iceoryx_posh/internal/popo/ports/server_port_user.hpp
@@ -95,6 +95,9 @@ class ServerPortUser : public BasePort
     /// @param[in] chunkHeader, pointer to the ChunkHeader to release
     void releaseRequest(const RequestHeader* const requestHeader) noexcept;
 
+    /// @brief Release all the requests that are currently queued up.
+    void releaseQueuedRequests() noexcept;
+
     /// @brief check if there are requests in the queue
     /// @return if there are requests in the queue return true, otherwise false
     bool hasNewRequests() const noexcept;

diff --git a/iceoryx_posh/source/popo/ports/server_port_user.cpp b/iceoryx_posh/source/popo/ports/server_port_user.cpp
@@ -68,6 +68,11 @@ void ServerPortUser::releaseRequest(const RequestHeader* const requestHeader) no
     }
 }
 
+void ServerPortUser::releaseQueuedRequests() noexcept
+{
+    m_chunkReceiver.clear();
+}
+
 bool ServerPortUser::hasNewRequests() const noexcept
 {
     return !m_chunkReceiver.empty();