rrc-nr,test: add log spy and clean NAS_msg

Signed-off-by: Carlo Galiotto <carlo@srs.io>

srsgnb/src/stack/rrc/test/rrc_nr_test.cc

@@ -162,23 +162,38 @@ void test_rrc_sa_connection()
   test_rrc_nr_info_transfer(task_sched, rrc_obj, pdcp_obj, ngap_obj, 0x4601);
   test_rrc_nr_security_mode_cmd(task_sched, rrc_obj, pdcp_obj, 0x4601);
   test_rrc_nr_reconfiguration( task_sched, rrc_obj, pdcp_obj, 0x4601);
-  test_rrc_nr_reconfiguration_II( task_sched, rrc_obj, pdcp_obj, 0x4601);
+  test_rrc_nr_2nd_reconfiguration( task_sched, rrc_obj, pdcp_obj, 0x4601);
 }
 
 } // namespace srsenb
 
 int main(int argc, char** argv)
 {
-  auto& logger = srslog::fetch_basic_logger("ASN1");
+  // Setup the log spy to intercept error and warning log entries.
+  if (!srslog::install_custom_sink(
+          srsran::log_sink_spy::name(),
+          std::unique_ptr<srsran::log_sink_spy>(new srsran::log_sink_spy(srslog::get_default_log_formatter())))) {
+    return SRSRAN_ERROR;
+  }
+
+  auto* spy = static_cast<srsran::log_sink_spy*>(srslog::find_sink(srsran::log_sink_spy::name()));
+  if (!spy) {
+    return SRSRAN_ERROR;
+  }
+
+  auto& logger = srslog::fetch_basic_logger("ASN1", *spy, true);
   logger.set_level(srslog::basic_levels::info);
-  auto& rrc_logger = srslog::fetch_basic_logger("RRC-NR");
+  auto& test_log = srslog::fetch_basic_logger("RRC-NR", *spy, true);
-  rrc_logger.set_level(srslog::basic_levels::debug);
+  test_log.set_level(srslog::basic_levels::debug);
 
   srslog::init();
 
   srsenb::test_sib_generation();
   TESTASSERT(srsenb::test_rrc_setup() == SRSRAN_SUCCESS);
   srsenb::test_rrc_sa_connection();
+  TESTASSERT_EQ( 0, spy->get_warning_counter());
+  TESTASSERT_EQ( 0, spy->get_error_counter());
+
 
   return SRSRAN_SUCCESS;
 }

srsgnb/src/stack/rrc/test/rrc_nr_test_helpers.cc

@@ -14,6 +14,8 @@
 #include "srsran/common/test_common.h"
 #include <string>
 
+#define NAS_SEC_CMD_STR "d9119b97d7bb59fc842d5b9cc12f00c27e9d5e4c80ee4cceb99a0dbbc6e0b54daa21a5d9e36d2e3b"
+
 using namespace asn1::rrc_nr;
 
 namespace srsenb {
@@ -137,16 +139,16 @@ void test_rrc_nr_info_transfer(srsran::task_scheduler& task_sched,
 {
   // STEP 1 : Send DLInformationTransfer (gNB -> UE)
   // generate sdu to pass as NAS message in DLInformationTransfer
-  srsran::unique_byte_buffer_t sdu;
+  srsran::unique_byte_buffer_t nsa_sdu;
-  sdu = srsran::make_byte_buffer();
+  nsa_sdu = srsran::make_byte_buffer();
 
   // create an unbounded_octstring object that contains a random NAS message (we simulate a NAS message)
   asn1::unbounded_octstring<false> NAS_DL_msg;
-  NAS_DL_msg.from_string("c574defc80ba722bffb8eacb6f8a163e3222cf1542ac529f6980bb15e0bf12d9f2b29f11fb458ec9");
+  NAS_DL_msg.from_string("21d9dfe07800371095c79a751be8352fb44aba7d69b836f5aad594ede9e72b8e34105ca8d7669d5c");
-  sdu->append_bytes(NAS_DL_msg.data(), NAS_DL_msg.size());
+  nsa_sdu->append_bytes(NAS_DL_msg.data(), NAS_DL_msg.size());
 
   // trigger the RRC to send the DLInformationTransfer
-  rrc_obj.write_dl_info(rnti, std::move(sdu));
+  rrc_obj.write_dl_info(rnti, std::move(nsa_sdu));
 
   // Test whether there exists the SRB1 initiated in the Connection Establishment
   // We test this as the SRB1 was setup in a different function
@@ -202,10 +204,15 @@ void test_rrc_nr_security_mode_cmd(srsran::task_scheduler& task_sched,
                                    pdcp_nr_rrc_tester&     pdcp,
                                    uint16_t                rnti)
 {
-  srsran::unique_byte_buffer_t pdu;
+  // create an unbounded_octstring object that contains a random NAS message (we simulate a NAS message)
+  asn1::unbounded_octstring<false> NAS_msg;
+  NAS_msg.from_string(NAS_SEC_CMD_STR);
+  srsran::unique_byte_buffer_t nas_pdu;
+  nas_pdu = srsran::make_byte_buffer();
+  nas_pdu->append_bytes(NAS_msg.data(), NAS_msg.size());
 
   // Trigger Send SecurityCommand (simulate request from NGAP)
-  rrc_obj.start_security_mode_procedure(rnti, nullptr);
+  rrc_obj.start_security_mode_procedure(rnti, std::move(nas_pdu));
 
   // Test whether there exists the SRB1 initiated in the Connection Establishment
   // We test this as the SRB1 was setup in a different function
@@ -235,6 +242,7 @@ void test_rrc_nr_security_mode_cmd(srsran::task_scheduler& task_sched,
   sec_cmd_complete_msg.rrc_transaction_id = dl_dcch_msg.msg.c1().security_mode_cmd().rrc_transaction_id;
   auto& ies_complete                      = sec_cmd_complete_msg.crit_exts.set_security_mode_complete();
 
+  srsran::unique_byte_buffer_t pdu;
   {
     pdu = srsran::make_byte_buffer();
     asn1::bit_ref bref{pdu->data(), pdu->get_tailroom()};
@@ -253,13 +261,6 @@ void test_rrc_nr_reconfiguration(srsran::task_scheduler& task_sched,
 {
   TESTASSERT_EQ(srsran::srb_to_lcid(srsran::nr_srb::srb1), pdcp.last_sdu_lcid);
 
-  // create an unbounded_octstring object that contains a random NAS message (we simulate a NAS message)
-  asn1::unbounded_octstring<false> NAS_msg;
-  NAS_msg.from_string("c574defc80ba722bffb8eacb6f8a163e3222cf1542ac529f6980bb15e0bf12d9f2b29f11fb458ec9");
-
-  // STEP 2 -  Trigger and send RRCReconfiguration command (gNB -> UE)
-  //rrc_obj.start_rrc_reconfiguration(rnti);
-
   // Test whether there exists the SRB1 initiated in the Connection Establishment
   // We test this as the SRB1 was set up in a different function
   TESTASSERT_EQ(rnti, pdcp.last_sdu_rnti);
@@ -278,6 +279,15 @@ void test_rrc_nr_reconfiguration(srsran::task_scheduler& task_sched,
                 dl_dcch_msg.msg.c1().rrc_recfg().crit_exts.type().value);
   const rrc_recfg_ies_s& reconf_ies = dl_dcch_msg.msg.c1().rrc_recfg().crit_exts.rrc_recfg();
 
+
+  // create an unbounded_octstring object that contains the same NAS message as in SecurityModeCommand
+  // The RRCreconfiguration reads the SecurityModeCommand NAS msg previously saved in the queue
+  asn1::unbounded_octstring<false> NAS_msg;
+  NAS_msg.from_string(NAS_SEC_CMD_STR);
+  TESTASSERT_EQ(true, reconf_ies.non_crit_ext.ded_nas_msg_list_present);
+  // Test if NAS_msg is the same as the one sent in SecurityModeCommand
+  TESTASSERT(NAS_msg == reconf_ies.non_crit_ext.ded_nas_msg_list[0]);
+
   // STEP 2 - Send RRCReconfiguration (UE -> gNB)
   ul_dcch_msg_s ul_dcch_msg;
   auto&         RRC_recfg_complete      = ul_dcch_msg.msg.set_c1().set_rrc_recfg_complete();
@@ -296,15 +306,14 @@ void test_rrc_nr_reconfiguration(srsran::task_scheduler& task_sched,
   rrc_obj.write_pdu(rnti, 1, std::move(pdu));
 }
 
-
+void test_rrc_nr_2nd_reconfiguration(srsran::task_scheduler& task_sched,
-void test_rrc_nr_reconfiguration_II(srsran::task_scheduler& task_sched,
                                      rrc_nr&                 rrc_obj,
                                      pdcp_nr_rrc_tester&     pdcp,
                                      uint16_t                rnti)
 {
   TESTASSERT_EQ(srsran::srb_to_lcid(srsran::nr_srb::srb1), pdcp.last_sdu_lcid);
 
-  // create an unbounded_octstring object that contains a random NAS message (we simulate a NAS message)
+  // create an unbounded_octstring object that contains a NAS message (we simulate a random NAS nas)
   asn1::unbounded_octstring<false> NAS_msg;
   NAS_msg.from_string("c574defc80ba722bffb8eacb6f8a163e3222cf1542ac529f6980bb15e0bf12d9f2b29f11fb458ec9");
 
@@ -354,10 +363,9 @@ void test_rrc_nr_reconfiguration_II(srsran::task_scheduler& task_sched,
   auto& rlc_drb = master_cell_group.rlc_bearer_to_add_mod_list[1];
   TESTASSERT_EQ(reconf_ies.radio_bearer_cfg.drb_to_add_mod_list[1].drb_id, rlc_drb.served_radio_bearer.drb_id());
 
-  asn1::unbounded_octstring<false> expected_nas;
+  // Test if NAS_msg is the same as the one sent in DLInformationTransfer
-  expected_nas.from_string("c574defc80ba722bffb8eacb6f8a163e3222cf1542ac529f6980bb15e0bf12d9f2b29f11fb458ec9");
   TESTASSERT_EQ(true, reconf_ies.non_crit_ext.ded_nas_msg_list_present);
-  TESTASSERT( expected_nas == reconf_ies.non_crit_ext.ded_nas_msg_list[0]);
+  TESTASSERT(NAS_msg == reconf_ies.non_crit_ext.ded_nas_msg_list[0]);
 
   // STEP 2 - Send RRCReconfiguration (UE -> gNB)
   ul_dcch_msg_s ul_dcch_msg;

srsgnb/src/stack/rrc/test/rrc_nr_test_helpers.h

@@ -108,7 +108,7 @@ void test_rrc_nr_reconfiguration(srsran::task_scheduler& task_sched,
                                  pdcp_nr_rrc_tester&     pdcp,
                                  uint16_t                rnti);
 
-void test_rrc_nr_reconfiguration_II(srsran::task_scheduler& task_sched,
+void test_rrc_nr_2nd_reconfiguration(srsran::task_scheduler& task_sched,
                                      rrc_nr&                 rrc_obj,
                                      pdcp_nr_rrc_tester&     pdcp,
                                      uint16_t                rnti);