Thread device registers new address upon receipt of error notification. (ARMmbed#1767)

Author: deepakvenugopal

source/6LoWPAN/Thread/thread_bbr_api.c

@@ -1125,8 +1125,7 @@ int thread_bbr_prefix_set(int8_t interface_id, uint8_t *prefix)
     (void) interface_id;
     (void) prefix;
 #ifdef HAVE_THREAD_BORDER_ROUTER
-    thread_extension_bbr_prefix_set(interface_id, prefix);
-return 0;
+    return thread_extension_bbr_prefix_set(interface_id, prefix);
 #else
     return -1;
 #endif // HAVE_THREAD_BORDER_ROUTER

source/6LoWPAN/Thread/thread_extension.c

@@ -125,6 +125,15 @@ static int thread_extension_dua_registration_cb(int8_t service_id, uint8_t sourc
     }
 
     // registration unsuccessful
+    // processing for ourselves - if we have the address re register
+    if_address_entry_t *addr_entry = addr_get_entry(cur, addr_data_ptr);
+    if (addr_entry) {
+        cur->dad_failures++;
+        thread_extension_address_generate(cur);
+        return 0;
+    }
+
+    // processing for MTD children
     ipv6_neighbour_t *neighbour_entry;
     uint16_t nce_short_addr;
     uint8_t destination_address[16] = {0};
@@ -164,9 +173,25 @@ static int thread_extension_mtd_dua_ntf_cb(int8_t service_id, uint8_t source_add
     (void) source_address;
     (void) source_port;
     (void) response_ptr;
+    uint16_t addr_len;
+    uint8_t *addr_data_ptr;
 
     tr_debug("Thread MTD n/dn callback");
 
+    protocol_interface_info_entry_t *cur = protocol_stack_interface_info_get_by_id(thread_management_client_get_interface_id_by_service_id(service_id));
+    if (!cur) {
+        return -1;
+    }
+    addr_len = thread_meshcop_tlv_find(response_ptr->payload_ptr, response_ptr->payload_len, TMFCOP_TLV_TARGET_EID, &addr_data_ptr);
+
+    if (addr_len < 16) {
+        tr_warn("Invalid target eid in DUA.rsp cb message");
+        return -2;
+    }
+    // generate new dua address
+    cur->dad_failures++;
+    thread_extension_address_generate(cur);
+
     return 0;
 }
 

source/6LoWPAN/Thread/thread_extension_bbr.h

@@ -67,7 +67,7 @@ int thread_extension_bbr_prefix_set(int8_t interface_id, uint8_t *prefix);
 #define thread_extension_bbr_timeout_set(interface_id, timeout_a, timeout_b, delay)
 #define thread_extension_bbr_address_set(interface_id, addr_ptr, port) (-1)
 #define thread_extension_bbr_route_update(cur)
-#define thread_extension_bbr_prefix_set(interface_id, prefix)
+#define thread_extension_bbr_prefix_set(interface_id, prefix) 0
 #endif
 
 #ifdef __cplusplus