RLS developments

d7c05809 · aligungr · 5e2120d5 · d7c05809 · d7c05809
Commit d7c05809 authored May 12, 2021 by aligungr
Hide whitespace changes
Inline Side-by-side

Showing with 12 additions and 2 deletions

src/gnb/rls/ctl_task.cpp src/gnb/rls/ctl_task.cpp +6 -1

src/ue/rls/ctl_task.cpp src/ue/rls/ctl_task.cpp +6 -1

No files found.
--- a/src/gnb/rls/ctl_task.cpp
+++ b/src/gnb/rls/ctl_task.cpp
@@ -208,16 +208,21 @@ void RlsControlTask::onAckControlTimerExpired()
 {
    int64_t current = utils::CurrentTimeMillis();

+    std::vector<uint32_t> transmissionFailureIds;
    std::vector<rls::PduInfo> transmissionFailures;

    for (auto &pdu : m_pduMap)
    {
        auto delta = current - pdu.second.sentTime;
        if (delta > MAX_PDU_TTL)
+        {
+            transmissionFailureIds.push_back(pdu.first);
            transmissionFailures.push_back(std::move(pdu.second));
+        }
    }

-    m_pduMap.clear();
+    for (auto id : transmissionFailureIds)
+        m_pduMap.erase(id);

    if (!transmissionFailures.empty())
    {

--- a/src/ue/rls/ctl_task.cpp
+++ b/src/ue/rls/ctl_task.cpp
@@ -208,16 +208,21 @@ void RlsControlTask::onAckControlTimerExpired()
 {
    int64_t current = utils::CurrentTimeMillis();

+    std::vector<uint32_t> transmissionFailureIds;
    std::vector<rls::PduInfo> transmissionFailures;

    for (auto &pdu : m_pduMap)
    {
        auto delta = current - pdu.second.sentTime;
        if (delta > MAX_PDU_TTL)
+        {
+            transmissionFailureIds.push_back(pdu.first);
            transmissionFailures.push_back(std::move(pdu.second));
+        }
    }

-    m_pduMap.clear();
+    for (auto id : transmissionFailureIds)
+        m_pduMap.erase(id);

    if (!transmissionFailures.empty())
    {