Test mode updates for BBR (ARMmbed#2011)

Added possibility to send test backbone messages.

Author: deepakvenugopal

nanostack/net_thread_test.h

@@ -241,6 +241,19 @@ int thread_test_version_set(int8_t interface_id, uint8_t version);
  */
 int thread_test_router_selection_jitter_set(int8_t interface_id, uint32_t jitter);
 
+/**
+ * \brief Set Thread PBBR status response override.
+ *
+ * \param interface_id Network Interface
+ * \param dua_status expected dua response value from PBBR
+ * \param dua_count number of times dua_response is repeated
+ * \param ba_failure_count number of times bba failure is repeated
+ *
+ * \return 0, OK
+ * \return <0 Error
+ */
+int thread_test_pbbr_response_override_set(int8_t interface_id, uint8_t dua_status, uint8_t dua_count, uint8_t ba_failure_count);
+
 /**
  * \brief Sets the thread MIN_DELAY_TIMER default value.
  *

source/6LoWPAN/Thread/thread_bbr_api.c

@@ -1125,6 +1125,7 @@ int thread_bbr_timeout_set(int8_t interface_id, uint32_t timeout_a, uint32_t tim
 #endif // HAVE_THREAD_BORDER_ROUTER
 }
 
+
 int thread_bbr_prefix_set(int8_t interface_id, uint8_t *prefix)
 {
     (void) interface_id;
@@ -1159,8 +1160,6 @@ int thread_bbr_validation_interface_address_set(int8_t interface_id, const uint8
 #endif // HAVE_THREAD_BORDER_ROUTER
 }
 
-
-
 void thread_bbr_stop(int8_t interface_id)
 {
     (void) interface_id;

source/6LoWPAN/Thread/thread_extension_bbr.c

@@ -63,6 +63,10 @@
 #if defined(HAVE_THREAD_V2) && defined(HAVE_THREAD_BORDER_ROUTER)
 #define TRACE_GROUP "pBBR"
 
+static uint8_t dua_response_status = 0xff;
+static uint8_t dua_status_count = 1;
+static uint8_t ba_response_status_count = 0;
+
 /*
  * Border router instance data.
  */
@@ -104,7 +108,7 @@ static NS_LIST_DEFINE(duplicate_dua_tr_list, duplicate_dua_tr_t, link);
 #define THREAD_BBR_MLR_REGISTRATION_TIMEOUT       600   //<* Default MLR timeout in seconds
 #define THREAD_BBR_DUA_REGISTRATION_TIMEOUT       3600
 #define THREAD_BBR_DUA_REGISTRATION_DELAY         5000  // 5 seconds in ms
-#define THREAD_BBR_BACKBONE_PORT                  61631  //<* Backbone border router
+#define THREAD_BBR_BACKBONE_PORT                  5683  //<* Backbone border router
 #define THREAD_BBR_DUA_DAD_QUERY_TIMEOUT          1     // wait period for Duplicate Address Detection
 #define THREAD_BBR_DUA_DAD_REPEATS                2     // multicast repeated as part of DUA
 
@@ -510,8 +514,10 @@ static int thread_pbbr_bb_qry_cb(int8_t service_id, uint8_t source_address[16],
     (void)source_port;
     uint16_t addr_len;
     uint8_t *addr_data_ptr;
+    uint8_t *ml_eid_ptr;
     uint16_t rloc;
     uint16_t *rloc_ptr = NULL;
+    uint32_t last_transaction_time;
     tr_info("Thread BBR BB_QRY.ntf Received");
 
     thread_pbbr_t *this = thread_border_router_find_by_service(service_id);
@@ -537,6 +543,16 @@ static int thread_pbbr_bb_qry_cb(int8_t service_id, uint8_t source_address[16],
         tr_warn("Invalid BB_QRY.ntf message");
         return -1;
     }
+
+    // Test code for b/ba response override
+    if (ba_response_status_count) {
+        device_configuration_s *device_config = thread_joiner_application_get_device_config(this->interface_id);
+        ml_eid_ptr = device_config->eui64;
+        last_transaction_time = protocol_core_monotonic_time;
+        ba_response_status_count--;
+        goto send_response;
+    }
+
     ipv6_route_t *route = ipv6_route_choose_next_hop(addr_data_ptr, this->interface_id, NULL);
     if (!route || route->prefix_len < 128 || !route->on_link || route->info.source != ROUTE_THREAD_PROXIED_DUA_HOST || !route->info.info) {
         //address not in mesh
@@ -546,9 +562,10 @@ static int thread_pbbr_bb_qry_cb(int8_t service_id, uint8_t source_address[16],
         rloc_ptr = &rloc;
     }
 
-    uint32_t last_transaction_time = protocol_core_monotonic_time - ((thread_pbbr_dua_info_t *)route->info.info)->last_contact_time;
-    uint8_t *ml_eid_ptr = ((thread_pbbr_dua_info_t *)route->info.info)->mleid_ptr;
+    last_transaction_time = protocol_core_monotonic_time - ((thread_pbbr_dua_info_t *)route->info.info)->last_contact_time;
+    ml_eid_ptr = ((thread_pbbr_dua_info_t *)route->info.info)->mleid_ptr;
 
+send_response:
     // This address is valid in our MESH
     return thread_border_router_bb_ans_send(this, source_address, addr_data_ptr, ml_eid_ptr, last_transaction_time, link_configuration_ptr->name, rloc_ptr);
 }
@@ -893,6 +910,7 @@ static int thread_extension_bbr_dua_cb(int8_t service_id, uint8_t source_address
     if (!cur) {
         return -1;
     }
+
     if (0 == thread_extension_primary_bbr_get(cur, bbr_rloc_addr, NULL, NULL, NULL) &&
             !addr_get_entry(cur, bbr_rloc_addr)) {
         // Primary pBBR present and I am not the pBBR
@@ -918,6 +936,13 @@ static int thread_extension_bbr_dua_cb(int8_t service_id, uint8_t source_address
 
     tr_debug("DUA.req addr:%s ml_eid:%s", trace_array(addr_data_ptr, addr_len), trace_array(ml_eid_ptr, ml_eid_len));
 
+    // Test code for dua response override
+    if (dua_response_status != 0xff && dua_status_count) {
+        bbr_status = dua_response_status;
+        dua_status_count--;
+        goto send_response;
+    }
+
     entry_keep_alive = false;
     ipv6_route_t *route = ipv6_route_lookup_with_info(addr_data_ptr, 128, this->interface_id, NULL, ROUTE_THREAD_PROXIED_DUA_HOST, NULL, 0);
 
@@ -1481,4 +1506,24 @@ void thread_extension_bbr_old_partition_data_clean(int8_t interface_id)
     }
 }
 
+void thread_extension_bbr_status_override_get(uint8_t *dua_status, uint8_t *dua_count, uint8_t *ba_failure_count)
+{
+    if (*dua_status) {
+        *dua_status = dua_response_status;
+    }
+    if (*dua_count) {
+        *dua_count = dua_status_count;
+    }
+    if (*ba_failure_count) {
+        *ba_failure_count = ba_response_status_count;
+    }
+}
+
+void thread_extension_bbr_status_override_set(uint8_t dua_status, uint8_t dua_count, uint8_t ba_failure_count)
+{
+    dua_response_status = dua_status;
+    dua_status_count = dua_count;
+    ba_response_status_count = ba_failure_count;
+}
+
 #endif //HAVE_THREAD_BORDER_ROUTER && HAVE_THREAD_V2

source/6LoWPAN/Thread/thread_extension_bbr.h

@@ -47,7 +47,6 @@ typedef struct thread_pbbr_dua_info {
 } thread_pbbr_dua_info_t;
 
 #if defined(HAVE_THREAD_V2) && defined(HAVE_THREAD_BORDER_ROUTER)
-
 int8_t thread_extension_bbr_init(int8_t interface_id, int8_t backbone_interface_id);
 void thread_extension_bbr_delete(int8_t interface_id);
 bool thread_extension_bbr_nd_query_process(protocol_interface_info_entry_t *cur, const uint8_t *target_addr, uint16_t rloc);
@@ -58,6 +57,9 @@ int thread_extension_bbr_address_set(int8_t interface_id, const uint8_t *addr_pt
 void thread_extension_bbr_route_update(protocol_interface_info_entry_t *cur);
 int thread_extension_bbr_prefix_set(int8_t interface_id, uint8_t *prefix);
 void thread_extension_bbr_old_partition_data_clean(int8_t interface_id);
+void thread_extension_bbr_status_override_get(uint8_t *dua_status, uint8_t *dua_count, uint8_t *ba_failure_count);
+void thread_extension_bbr_status_override_set(uint8_t dua_status, uint8_t dua_count, uint8_t ba_failure_count);
+void thread_extension_status_override_count_set(uint8_t value);
 
 
 #else
@@ -72,6 +74,9 @@ void thread_extension_bbr_old_partition_data_clean(int8_t interface_id);
 #define thread_extension_bbr_sequence_number_set(interface_id, seq_number) (-1)
 #define thread_extension_bbr_prefix_set(interface_id, prefix) 0
 #define thread_extension_bbr_old_partition_data_clean(interface_id)
+#define thread_extension_bbr_status_override_get(dua_status, dua_count, ba_failure_count);
+#define thread_extension_bbr_status_override_set(dua_status, dua_count, ba_failure_count);
+#define thread_extension_status_override_count_set(value)
 #endif
 
 #ifdef __cplusplus

source/6LoWPAN/Thread/thread_test_api.c

@@ -49,6 +49,7 @@
 #include "6LoWPAN/Thread/thread_discovery.h"
 #include "6LoWPAN/Thread/thread_nvm_store.h"
 #include "6LoWPAN/Thread/thread_extension_bootstrap.h"
+#include "6LoWPAN/Thread/thread_extension_bbr.h"
 #include "6LoWPAN/Thread/thread_neighbor_class.h"
 #include "MLE/mle.h"
 #include "thread_meshcop_lib.h"
@@ -639,6 +640,23 @@ int thread_test_version_set(int8_t interface_id, uint8_t version)
     return -1;
 #endif
 }
+
+int thread_test_pbbr_response_override_set(int8_t interface_id, uint8_t dua_status, uint8_t dua_count, uint8_t ba_failure_count)
+{
+#ifdef HAVE_THREAD
+    (void)interface_id;
+    thread_extension_bbr_status_override_set(dua_status, dua_count, ba_failure_count);
+    return 0;
+
+#else
+    (void)interface_id;
+    (void)dua_status;
+    (void)dua_count;
+    (void)ba_failure_count;
+    return -1;
+#endif
+}
+
 int thread_test_router_selection_jitter_set(int8_t interface_id, uint32_t jitter)
 {
 #ifdef HAVE_THREAD