From 597334c4bfca233e620941b4f8aa78e8cac30ac1 Mon Sep 17 00:00:00 2001
From: Francisco Paisana <paisanaf@tcd.ie>
Date: Wed, 18 Mar 2020 11:57:22 +0000
Subject: [PATCH] limit the rlc queue size for suspended bearers

---
 lib/include/srslte/upper/rlc_common.h | 7 ++++---
 srsue/src/stack/ue_stack_lte.cc       | 2 +-
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/lib/include/srslte/upper/rlc_common.h b/lib/include/srslte/upper/rlc_common.h
index 92cef4c8a..f4866c61a 100644
--- a/lib/include/srslte/upper/rlc_common.h
+++ b/lib/include/srslte/upper/rlc_common.h
@@ -23,6 +23,7 @@
 #define SRSLTE_RLC_COMMON_H
 
 #include "srslte/common/block_queue.h"
+#include "srslte/common/logmap.h"
 #include "srslte/upper/rlc_metrics.h"
 #include <stdlib.h>
 
@@ -297,7 +298,7 @@ private:
 
     // Do not block ever
     if (!rx_pdu_resume_queue.try_push(p)) {
-      fprintf(stderr, "Error dropping PDUs while bearer suspended. Queue should be unbounded\n");
+      srslte::logmap::get("RLC ")->warning("Dropping SDUs while bearer suspended.\n");
       return;
     }
   }
@@ -307,7 +308,7 @@ private:
   {
     // Do not block ever
     if (!tx_sdu_resume_queue.try_push(std::move(sdu)).first) {
-      fprintf(stderr, "Error dropping SDUs while bearer suspended. Queue should be unbounded\n");
+      srslte::logmap::get("RLC ")->warning("Dropping SDUs while bearer suspended.\n");
       return;
     }
   }
@@ -318,7 +319,7 @@ private:
   } pdu_t;
 
   block_queue<pdu_t>                rx_pdu_resume_queue;
-  block_queue<unique_byte_buffer_t> tx_sdu_resume_queue;
+  block_queue<unique_byte_buffer_t> tx_sdu_resume_queue{256};
 };
 
 } // namespace srslte
diff --git a/srsue/src/stack/ue_stack_lte.cc b/srsue/src/stack/ue_stack_lte.cc
index 634ec87b2..c9a65f615 100644
--- a/srsue/src/stack/ue_stack_lte.cc
+++ b/srsue/src/stack/ue_stack_lte.cc
@@ -43,7 +43,7 @@ ue_stack_lte::ue_stack_lte() :
   pdcp(&timers, &pdcp_log),
   nas(&timers),
   thread("STACK"),
-  pending_tasks(1024),
+  pending_tasks(512),
   background_tasks(2)
 {
   ue_queue_id         = pending_tasks.add_queue();