Add log to pool deallocate

lib/include/srslte/common/buffer_pool.h

@@ -38,6 +38,7 @@
                               INCLUDES
 *******************************************************************************/
 
+#include "srslte/common/log.h"
 #include "srslte/common/common.h"
 
 namespace srslte {
@@ -169,6 +170,7 @@ public:
   static byte_buffer_pool*   get_instance(int capacity = -1);
   static void                cleanup(void); 
   byte_buffer_pool(int capacity = -1) {
+    log = NULL;
     pool = new buffer_pool<byte_buffer_t>(capacity);
   }
   ~byte_buffer_pool() {
@@ -177,13 +179,20 @@ public:
   byte_buffer_t* allocate(const char *debug_name = NULL) {
     return pool->allocate(debug_name);
   }
+  void set_log(srslte::log *log) {
+    this->log = log;
+  }
   void deallocate(byte_buffer_t *b) {
     if(!b) {
       return;
     }
     b->reset();
     if (!pool->deallocate(b)) {
-      printf("Error deallocating PDU: Addr=0x%lx not found in pool\n", (uint64_t) b);
+      if (log) {
+        log->error("Deallocating PDU: Addr=0x%lx, name=%s not found in pool\n", (uint64_t) b, b->debug_name);
+      } else {
+        printf("Error deallocating PDU: Addr=0x%lx, name=%s not found in pool\n", (uint64_t) b, b->debug_name);
+      }
     }
     b = NULL;
   }
@@ -191,6 +200,7 @@ public:
     pool->print_all_buffers();
   }
 private:
+  srslte::log *log;
   buffer_pool<byte_buffer_t> *pool; 
 };
 

srsenb/hdr/enb.h

@@ -201,6 +201,7 @@ private:
   srslte::log_filter  rrc_log;
   srslte::log_filter  gtpu_log;
   srslte::log_filter  s1ap_log;
+  srslte::log_filter  pool_log;
 
   srslte::byte_buffer_pool *pool;
 

srsenb/src/enb.cc

@@ -99,6 +99,10 @@ bool enb::init(all_args_t *args_)
   gtpu_log.init("GTPU", logger);
   s1ap_log.init("S1AP", logger);
 
+  pool_log.init("POOL", logger);
+  pool_log.set_level(srslte::LOG_LEVEL_ERROR);
+  pool->set_log(&pool_log);
+
   // Init logs
   rf_log.set_level(srslte::LOG_LEVEL_INFO);
   for (int i=0;i<args->expert.phy.nof_phy_threads;i++) {

srsue/hdr/ue.h

@@ -115,6 +115,7 @@ private:
   srslte::log_filter  nas_log;
   srslte::log_filter  gw_log;
   srslte::log_filter  usim_log;
+  srslte::log_filter  pool_log;
 
   all_args_t       *args;
   bool              started;

srsue/src/ue.cc

@@ -89,6 +89,10 @@ bool ue::init(all_args_t *args_) {
   gw_log.init("GW  ", logger);
   usim_log.init("USIM", logger);
 
+  pool_log.init("POOL", logger);
+  pool_log.set_level(srslte::LOG_LEVEL_ERROR);
+  byte_buffer_pool::get_instance()->set_log(&pool_log);
+
   // Init logs
   rf_log.set_level(srslte::LOG_LEVEL_INFO);
   rf_log.info("Starting UE\n");