From 27459bf706b3b8e2d11d906021ddbc16e47472f2 Mon Sep 17 00:00:00 2001
From: Andre Puschmann <andre@softwareradiosystems.com>
Date: Mon, 17 Sep 2018 13:10:44 +0200
Subject: [PATCH] add API to change LCID of PDCP bearers

---
 lib/include/srslte/upper/pdcp.h |  1 +
 lib/src/upper/pdcp.cc           | 22 ++++++++++++++++++++++
 2 files changed, 23 insertions(+)

diff --git a/lib/include/srslte/upper/pdcp.h b/lib/include/srslte/upper/pdcp.h
index e4be9d548..7272f5079 100644
--- a/lib/include/srslte/upper/pdcp.h
+++ b/lib/include/srslte/upper/pdcp.h
@@ -61,6 +61,7 @@ public:
   void add_bearer(uint32_t lcid, srslte_pdcp_config_t cnfg = srslte_pdcp_config_t());
   void add_bearer_mrb(uint32_t lcid, srslte_pdcp_config_t cnfg = srslte_pdcp_config_t());
   void del_bearer(uint32_t lcid);
+  void change_lcid(uint32_t old_lcid, uint32_t new_lcid);
   void config_security(uint32_t lcid,
                        uint8_t *k_enc,
                        uint8_t *k_int,
diff --git a/lib/src/upper/pdcp.cc b/lib/src/upper/pdcp.cc
index c8391518b..93ac0cf15 100644
--- a/lib/src/upper/pdcp.cc
+++ b/lib/src/upper/pdcp.cc
@@ -187,6 +187,28 @@ void pdcp::del_bearer(uint32_t lcid)
   pthread_rwlock_unlock(&rwlock);
 }
 
+void pdcp::change_lcid(uint32_t old_lcid, uint32_t new_lcid)
+{
+  pthread_rwlock_wrlock(&rwlock);
+
+  // make sure old LCID exists and new LCID is still free
+  if (valid_lcid(old_lcid) && not valid_lcid(new_lcid)) {
+    // insert old PDCP entity into new LCID
+    pdcp_map_t::iterator it = pdcp_array.find(old_lcid);
+    pdcp_entity_interface *pdcp_entity = it->second;
+    if (not pdcp_array.insert(pdcp_map_pair_t(new_lcid, pdcp_entity)).second) {
+      pdcp_log->error("Error inserting PDCP entity into array\n.");
+      goto exit;
+    }
+    // erase from old position
+    pdcp_array.erase(it);
+    pdcp_log->warning("Changed LCID of PDCP bearer from %d to %d\n", old_lcid, new_lcid);
+  } else {
+    pdcp_log->error("Can't change PDCP of bearer %s from %d to %d. Bearer doesn't exist or new LCID already occupied.\n", rrc->get_rb_name(old_lcid).c_str(), old_lcid, new_lcid);
+  }
+exit:
+  pthread_rwlock_unlock(&rwlock);
+}
 
 void pdcp::config_security(uint32_t lcid,
                            uint8_t *k_enc,