allow call end to cleanup a stream ID associated to a given call stream;

src/fne/network/FNENetwork.cpp

@@ -1392,6 +1392,19 @@ bool FNENetwork::checkU2UDroppedPeer(uint32_t peerId)
     return false;
 }
 
+/* Erases a stream ID from the given peer ID connection. */
+
+void FNENetwork::eraseStreamPktSeq(uint32_t peerId, uint32_t streamId)
+{
+    if (peerId > 0 && (m_peers.find(peerId) != m_peers.end())) {
+        FNEPeerConnection* connection = m_peers[peerId];
+        if (connection != nullptr) {
+            std::lock_guard<std::mutex> lock(m_peerMutex);
+            connection->eraseStreamPktSeq(streamId);
+        }
+    }
+}
+
 /* Helper to create a peer on the peers affiliations list. */
 
 void FNENetwork::createPeerAffiliations(uint32_t peerId, std::string peerName)

src/fne/network/FNENetwork.h

@@ -597,6 +597,13 @@ namespace network
          */
         bool checkU2UDroppedPeer(uint32_t peerId);
 
+        /**
+         * @brief Erases a stream ID from the given peer ID connection.
+         * @param peerId Peer ID.
+         * @param streamId Stream ID.
+         */
+        void eraseStreamPktSeq(uint32_t peerId, uint32_t streamId);
+
         /**
          * @brief Helper to create a peer on the peers affiliations list.
          * @param peerId Peer ID.

src/fne/network/callhandler/TagDMRData.cpp

@@ -197,6 +197,7 @@ bool TagDMRData::processFrame(const uint8_t* data, uint32_t len, uint32_t peerId
                         .request(m_network->m_influxServer);
                 }
 
+                m_network->eraseStreamPktSeq(peerId, streamId);
                 m_network->m_callInProgress = false;
             }
         }

src/fne/network/callhandler/TagNXDNData.cpp

@@ -150,6 +150,7 @@ bool TagNXDNData::processFrame(const uint8_t* data, uint32_t len, uint32_t peerI
                             .request(m_network->m_influxServer);
                     }
 
+                    m_network->eraseStreamPktSeq(peerId, streamId);
                     m_network->m_callInProgress = false;
                 }
             }

src/fne/network/callhandler/TagP25Data.cpp

@@ -223,6 +223,7 @@ bool TagP25Data::processFrame(const uint8_t* data, uint32_t len, uint32_t peerId
                                 .request(m_network->m_influxServer);
                         }
 
+                        m_network->eraseStreamPktSeq(peerId, streamId);
                         m_network->m_callInProgress = false;
                     }
                 }