Uplink data status handling in SM

src/ue/nas/sm/establishment.cpp

@@ -89,6 +89,7 @@ void NasSm::sendEstablishmentRequest(const SessionConfig &config)
     ps->sessionAmbr = {};
     ps->authorizedQoSFlowDescriptions = {};
     ps->pduAddress = {};
+    ps->uplinkPending = false;
 
     /* Make PCO */
     nas::ProtocolConfigurationOptions opt{};

src/ue/nas/sm/interface.cpp

@@ -39,4 +39,22 @@ void NasSm::onTimerTick()
     }
 }
 
+bool NasSm::anyUplinkDataPending()
+{
+    auto status = getUplinkDataStatus();
+    for (int i = 1; i < 16; i++)
+        if (status[i])
+            return true;
+    return false;
+}
+
+std::bitset<16> NasSm::getUplinkDataStatus()
+{
+    std::bitset<16> res{};
+    for (int i = 1; i < 16; i++)
+        if (m_pduSessions[i]->psState == EPsState::ACTIVE && m_pduSessions[i]->uplinkPending)
+            res[i] = true;
+    return res;
+}
+
 } // namespace nr::ue

src/ue/nas/sm/resource.cpp

@@ -61,6 +61,9 @@ bool NasSm::anyEmergencySession()
 void NasSm::handleUplinkStatusChange(int psi, bool isPending)
 {
     m_logger->debug("Uplink data status changed PSI[%d] pending[%s]", psi, isPending ? "true" : "false");
+
+    m_pduSessions[psi]->uplinkPending = isPending;
+
     // TODO
 }
 

src/ue/nas/sm/sm.hpp

@@ -9,6 +9,7 @@
 #pragma once
 
 #include <array>
+#include <bitset>
 #include <nas/nas.hpp>
 #include <nas/timer.hpp>
 #include <ue/nts.hpp>
@@ -50,6 +51,8 @@ class NasSm
     void localReleaseAllSessions();
     bool anyEmergencySession();
     void handleUplinkStatusChange(int psi, bool isPending);
+    bool anyUplinkDataPending();
+    std::bitset<16> getUplinkDataStatus();
 
     /* Session Release */
     void sendReleaseRequest(int psi);

src/ue/types.hpp

@@ -250,6 +250,7 @@ struct PduSession
     const int psi;
 
     EPsState psState{};
+    bool uplinkPending{};
 
     nas::EPduSessionType sessionType{};
     std::optional<std::string> apn{};