44#include "net/link-stats.h"
45#include "net/routing/rpl-classic/rpl.h"
46#include "net/routing/rpl-classic/rpl-private.h"
47#include "net/routing/rpl-classic/rpl-dag-root.h"
51#include "net/nbr-table.h"
61#define LOG_MODULE "RPL"
62#define LOG_LEVEL LOG_LEVEL_RPL
65#ifdef RPL_CALLBACK_PARENT_SWITCH
66void RPL_CALLBACK_PARENT_SWITCH(rpl_parent_t *old, rpl_parent_t *
new);
71static rpl_of_t *
const objective_functions[] = RPL_SUPPORTED_OFS;
76#ifndef RPL_CONF_GROUNDED
79#define RPL_GROUNDED RPL_CONF_GROUNDED
84NBR_TABLE_GLOBAL(rpl_parent_t, rpl_parents);
92rpl_print_neighbor_list(
void)
94 if(default_instance != NULL && default_instance->current_dag != NULL &&
95 default_instance->of != NULL) {
96 int curr_dio_interval = default_instance->dio_intcurrent;
97 int curr_rank = default_instance->current_dag->rank;
98 rpl_parent_t *p = nbr_table_head(rpl_parents);
101 LOG_DBG(
"RPL: MOP %u OCP %u rank %u dioint %u, nbr count %u\n",
102 default_instance->mop, default_instance->of->ocp, curr_rank, curr_dio_interval,
uip_ds6_nbr_num());
104 const struct link_stats *stats = rpl_get_parent_link_stats(p);
105 uip_ipaddr_t *parent_addr = rpl_parent_get_ipaddr(p);
106 LOG_DBG(
"RPL: nbr %02x %5u, %5u => %5u -- %2u %c%c (last tx %u min ago)\n",
107 parent_addr != NULL ? parent_addr->u8[15] : 0x0,
109 rpl_get_parent_link_metric(p),
110 rpl_rank_via_parent(p),
111 stats != NULL ? stats->freshness : 0,
112 link_stats_is_fresh(stats) ?
'f' :
' ',
113 p == default_instance->current_dag->preferred_parent ?
'p' :
' ',
114 stats != NULL ? (unsigned)((clock_now - stats->last_tx_time) / (60 *
CLOCK_SECOND)) : -1u
116 p = nbr_table_next(rpl_parents, p);
118 LOG_DBG(
"RPL: end of list\n");
123rpl_get_nbr(rpl_parent_t *parent)
125 const linkaddr_t *lladdr = rpl_get_parent_lladdr(parent);
134nbr_callback(
void *ptr)
136 rpl_remove_parent(ptr);
142 nbr_table_register(rpl_parents, (nbr_table_callback *)nbr_callback);
146rpl_get_parent(
const uip_lladdr_t *
addr)
148 return nbr_table_get_from_lladdr(rpl_parents, (
const linkaddr_t *)
addr);
152rpl_get_parent_rank(uip_lladdr_t *
addr)
154 rpl_parent_t *p = nbr_table_get_from_lladdr(rpl_parents, (linkaddr_t *)
addr);
159 return RPL_INFINITE_RANK;
163rpl_get_parent_link_metric(rpl_parent_t *p)
165 if(p != NULL && p->dag != NULL) {
167 if(instance != NULL && instance->of != NULL &&
168 instance->of->parent_link_metric != NULL) {
169 return instance->of->parent_link_metric(p);
176rpl_rank_via_parent(rpl_parent_t *p)
178 if(p != NULL && p->dag != NULL) {
180 if(instance != NULL && instance->of != NULL &&
181 instance->of->rank_via_parent != NULL) {
182 return instance->of->rank_via_parent(p);
185 return RPL_INFINITE_RANK;
189rpl_get_parent_lladdr(rpl_parent_t *p)
191 return nbr_table_get_lladdr(rpl_parents, p);
195rpl_parent_get_ipaddr(rpl_parent_t *p)
197 const linkaddr_t *lladdr = rpl_get_parent_lladdr(p);
204const struct link_stats *
205rpl_get_parent_link_stats(rpl_parent_t *p)
207 const linkaddr_t *lladdr = rpl_get_parent_lladdr(p);
208 return link_stats_from_lladdr(lladdr);
212rpl_parent_is_fresh(rpl_parent_t *p)
214 const struct link_stats *stats = rpl_get_parent_link_stats(p);
215 return link_stats_is_fresh(stats);
219rpl_parent_is_reachable(rpl_parent_t *p)
221 if(p == NULL || p->dag == NULL || p->dag->instance == NULL ||
222 p->dag->instance->of == NULL) {
228 if(rpl_get_nbr(p) == NULL) {
234 return !rpl_parent_is_fresh(p) ||
235 p->dag->instance->of->parent_has_usable_link(p);
239rpl_set_preferred_parent(
rpl_dag_t *dag, rpl_parent_t *p)
241 if(dag == NULL || dag->preferred_parent == p) {
245 LOG_INFO(
"rpl_set_preferred_parent ");
247 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(p));
251 LOG_INFO_(
" used to be ");
252 if(dag->preferred_parent != NULL) {
253 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(dag->preferred_parent));
259#ifdef RPL_CALLBACK_PARENT_SWITCH
260 RPL_CALLBACK_PARENT_SWITCH(dag->preferred_parent, p);
265 nbr_table_unlock(rpl_parents, dag->preferred_parent);
266 nbr_table_lock(rpl_parents, p);
267 dag->preferred_parent = p;
273lollipop_greater_than(
int a,
int b)
276 if(a > RPL_LOLLIPOP_CIRCULAR_REGION && b <= RPL_LOLLIPOP_CIRCULAR_REGION) {
277 return (RPL_LOLLIPOP_MAX_VALUE + 1 + b - a) > RPL_LOLLIPOP_SEQUENCE_WINDOWS;
281 return (a > b && (a - b) < RPL_LOLLIPOP_SEQUENCE_WINDOWS) ||
282 (a < b && (b - a) > (RPL_LOLLIPOP_CIRCULAR_REGION + 1 - RPL_LOLLIPOP_SEQUENCE_WINDOWS));
287remove_parents(
rpl_dag_t *dag, rpl_rank_t minimum_rank)
291 LOG_INFO(
"Removing parents (minimum rank %u)\n", minimum_rank);
293 p = nbr_table_head(rpl_parents);
295 if(dag == p->dag && p->rank >= minimum_rank) {
296 rpl_remove_parent(p);
298 p = nbr_table_next(rpl_parents, p);
303nullify_parents(
rpl_dag_t *dag, rpl_rank_t minimum_rank)
307 LOG_INFO(
"Nullifying parents (minimum rank %u)\n", minimum_rank);
309 p = nbr_table_head(rpl_parents);
311 if(dag == p->dag && p->rank >= minimum_rank) {
312 rpl_nullify_parent(p);
314 p = nbr_table_next(rpl_parents, p);
319should_refresh_routes(
rpl_instance_t *instance, rpl_dio_t *dio, rpl_parent_t *p)
322 if(instance->mop == RPL_MOP_NO_DOWNWARD_ROUTES) {
327 return p == instance->current_dag->preferred_parent &&
328 (lollipop_greater_than(dio->dtsn, p->dtsn));
332acceptable_rank(
rpl_dag_t *dag, rpl_rank_t rank)
334 return rank != RPL_INFINITE_RANK &&
335 ((dag->instance->max_rankinc == 0) ||
336 DAG_RANK(rank, dag->instance) <= DAG_RANK(dag->min_rank + dag->instance->max_rankinc, dag->instance));
340get_dag(uint8_t instance_id, uip_ipaddr_t *dag_id)
346 instance = rpl_get_instance(instance_id);
347 if(instance == NULL) {
351 for(i = 0; i < RPL_MAX_DAG_PER_INSTANCE; ++i) {
352 dag = &instance->dag_table[i];
353 if(dag->used && uip_ipaddr_cmp(&dag->dag_id, dag_id)) {
362rpl_set_root(uint8_t instance_id, uip_ipaddr_t *dag_id)
369 version = RPL_LOLLIPOP_INIT;
370 instance = rpl_get_instance(instance_id);
371 if(instance != NULL) {
372 for(i = 0; i < RPL_MAX_DAG_PER_INSTANCE; ++i) {
373 dag = &instance->dag_table[i];
375 if(uip_ipaddr_cmp(&dag->dag_id, dag_id)) {
376 version = dag->version;
377 RPL_LOLLIPOP_INCREMENT(version);
379 if(dag == dag->instance->current_dag) {
380 LOG_INFO(
"Dropping a joined DAG when setting this node as root\n");
381 rpl_set_default_route(instance, NULL);
382 dag->instance->current_dag = NULL;
384 LOG_INFO(
"Dropping a DAG when setting this node as root\n");
392 dag = rpl_alloc_dag(instance_id, dag_id);
394 LOG_ERR(
"Failed to allocate a DAG\n");
398 instance = dag->instance;
400 dag->version = version;
402 dag->grounded = RPL_GROUNDED;
403 dag->preference = RPL_PREFERENCE;
404 instance->mop = RPL_MOP_DEFAULT;
405 instance->of = rpl_find_of(RPL_OF_OCP);
406 if(instance->of == NULL) {
407 LOG_WARN(
"OF with OCP %u not supported\n", RPL_OF_OCP);
411 rpl_set_preferred_parent(dag, NULL);
413 memcpy(&dag->dag_id, dag_id,
sizeof(dag->dag_id));
415 instance->dio_intdoubl = RPL_DIO_INTERVAL_DOUBLINGS;
416 instance->dio_intmin = RPL_DIO_INTERVAL_MIN;
419 instance->dio_intcurrent = RPL_DIO_INTERVAL_MIN +
420 RPL_DIO_INTERVAL_DOUBLINGS;
421 instance->dio_redundancy = RPL_DIO_REDUNDANCY;
422 instance->max_rankinc = RPL_MAX_RANKINC;
423 instance->min_hoprankinc = RPL_MIN_HOPRANKINC;
424 instance->default_lifetime = RPL_DEFAULT_LIFETIME;
425 instance->lifetime_unit = RPL_DEFAULT_LIFETIME_UNIT;
427 dag->rank = ROOT_RANK(instance);
429 if(instance->current_dag != dag && instance->current_dag != NULL) {
431 if(RPL_IS_STORING(instance)) {
432 rpl_remove_routes(instance->current_dag);
435 instance->current_dag->joined = 0;
438 instance->current_dag = dag;
439 instance->dtsn_out = RPL_LOLLIPOP_INIT;
440 instance->of->update_metric_container(instance);
441 default_instance = instance;
443 LOG_INFO(
"Node set to be a DAG root with DAG ID ");
444 LOG_INFO_6ADDR(&dag->dag_id);
447 LOG_ANNOTATE(
"#A root=%u\n", dag->dag_id.u8[
sizeof(dag->dag_id) - 1]);
449 rpl_reset_dio_timer(instance);
455rpl_repair_root(uint8_t instance_id)
459 instance = rpl_get_instance(instance_id);
460 if(instance == NULL ||
461 instance->current_dag->rank != ROOT_RANK(instance)) {
462 LOG_WARN(
"rpl_repair_root triggered but not root\n");
465 RPL_STAT(rpl_stats.root_repairs++);
467 RPL_LOLLIPOP_INCREMENT(instance->current_dag->version);
468 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
469 LOG_INFO(
"rpl_repair_root initiating global repair with version %d\n",
470 instance->current_dag->version);
471 rpl_reset_dio_timer(instance);
478 memset(
ipaddr, 0,
sizeof(uip_ipaddr_t));
479 memcpy(
ipaddr, &prefix->prefix, (prefix->length + 7) / 8);
489 if(last_prefix != NULL && new_prefix != NULL &&
490 last_prefix->length == new_prefix->length &&
491 uip_ipaddr_prefixcmp(&last_prefix->prefix,
492 &new_prefix->prefix, new_prefix->length) &&
493 last_prefix->flags == new_prefix->flags) {
498 if(last_prefix != NULL) {
499 set_ip_from_prefix(&
ipaddr, last_prefix);
500 rep = uip_ds6_addr_lookup(&
ipaddr);
502 LOG_DBG(
"removing global IP address ");
505 uip_ds6_addr_rm(rep);
509 if(new_prefix != NULL) {
510 set_ip_from_prefix(&
ipaddr, new_prefix);
511 if(uip_ds6_addr_lookup(&
ipaddr) == NULL) {
512 LOG_DBG(
"adding global IP address ");
521rpl_set_prefix(
rpl_dag_t *dag, uip_ipaddr_t *prefix,
unsigned len)
524 uint8_t last_len = dag->prefix_info.length;
529 if(dag->prefix_info.length != 0) {
530 memcpy(&last_prefix, &dag->prefix_info,
sizeof(
rpl_prefix_t));
532 memset(&dag->prefix_info.prefix, 0,
sizeof(dag->prefix_info.prefix));
533 memcpy(&dag->prefix_info.prefix, prefix, (len + 7) / 8);
534 dag->prefix_info.length = len;
535 dag->prefix_info.flags = UIP_ND6_RA_FLAG_AUTONOMOUS;
536 dag->prefix_info.lifetime = RPL_ROUTE_INFINITE_LIFETIME;
537 LOG_INFO(
"Prefix set - will announce this in DIOs\n");
538 if(dag->rank != ROOT_RANK(dag->instance)) {
542 LOG_INFO(
"rpl_set_prefix - prefix NULL\n");
543 check_prefix(NULL, &dag->prefix_info);
545 LOG_INFO(
"rpl_set_prefix - prefix NON-NULL\n");
546 check_prefix(&last_prefix, &dag->prefix_info);
553rpl_set_default_route(
rpl_instance_t *instance, uip_ipaddr_t *from)
555 if(instance->def_route != NULL) {
556 LOG_DBG(
"Removing default route through ");
557 LOG_DBG_6ADDR(&instance->def_route->ipaddr);
559 uip_ds6_defrt_rm(instance->def_route);
560 instance->def_route = NULL;
564 LOG_DBG(
"Adding default route through ");
567 instance->def_route = uip_ds6_defrt_add(from,
568 RPL_DEFAULT_ROUTE_INFINITE_LIFETIME ? 0 : RPL_LIFETIME(instance, instance->default_lifetime));
569 if(instance->def_route == NULL) {
577rpl_alloc_instance(uint8_t instance_id)
581 for(instance = &instance_table[0], end = instance + RPL_MAX_INSTANCES;
582 instance < end; ++instance) {
583 if(instance->used == 0) {
584 memset(instance, 0,
sizeof(*instance));
585 instance->instance_id = instance_id;
586 instance->def_route = NULL;
598rpl_alloc_dag(uint8_t instance_id, uip_ipaddr_t *dag_id)
603 instance = rpl_get_instance(instance_id);
604 if(instance == NULL) {
605 instance = rpl_alloc_instance(instance_id);
606 if(instance == NULL) {
607 RPL_STAT(rpl_stats.mem_overflows++);
612 for(dag = &instance->dag_table[0], end = dag + RPL_MAX_DAG_PER_INSTANCE; dag < end; ++dag) {
614 memset(dag, 0,
sizeof(*dag));
616 dag->rank = RPL_INFINITE_RANK;
617 dag->min_rank = RPL_INFINITE_RANK;
618 dag->instance = instance;
623 RPL_STAT(rpl_stats.mem_overflows++);
630 default_instance = instance;
634rpl_get_default_instance(
void)
636 return default_instance;
645 LOG_INFO(
"Leaving the instance %u\n", instance->instance_id);
648 for(dag = &instance->dag_table[0], end = dag + RPL_MAX_DAG_PER_INSTANCE;
656 rpl_set_default_route(instance, NULL);
665 if(default_instance == instance) {
666 default_instance = NULL;
676 LOG_INFO(
"Leaving the DAG ");
677 LOG_INFO_6ADDR(&dag->dag_id);
682 if(RPL_IS_STORING(dag->instance)) {
683 rpl_remove_routes(dag);
691 if((dag->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS)) {
692 check_prefix(&dag->prefix_info, NULL);
695 remove_parents(dag, 0);
701rpl_add_parent(
rpl_dag_t *dag, rpl_dio_t *dio, uip_ipaddr_t *
addr)
703 rpl_parent_t *p = NULL;
708 LOG_DBG(
"rpl_add_parent lladdr %p ", lladdr);
713 p = nbr_table_add_lladdr(rpl_parents, (linkaddr_t *)lladdr,
714 NBR_TABLE_REASON_RPL_DIO, dio);
716 LOG_DBG(
"rpl_add_parent p NULL\n");
722 memcpy(&p->mc, &dio->mc,
sizeof(p->mc));
731find_parent_any_dag_any_instance(uip_ipaddr_t *
addr)
735 return nbr_table_get_from_lladdr(rpl_parents, (linkaddr_t *)lladdr);
741 rpl_parent_t *p = find_parent_any_dag_any_instance(
addr);
742 if(p != NULL && p->dag == dag) {
752 rpl_parent_t *p = find_parent_any_dag_any_instance(
addr);
763 rpl_parent_t *p = find_parent_any_dag_any_instance(
addr);
764 if(p && p->dag && p->dag->instance == instance) {
774 rpl_parent_t *last_parent;
778 old_rank = instance->current_dag->rank;
779 last_parent = instance->current_dag->preferred_parent;
781 if(instance->current_dag->rank != ROOT_RANK(instance)) {
782 rpl_select_parent(p->dag);
786 for(dag = &instance->dag_table[0], end = dag + RPL_MAX_DAG_PER_INSTANCE;
789 if(dag->used && dag->preferred_parent != NULL &&
790 dag->preferred_parent->rank != RPL_INFINITE_RANK) {
791 if(best_dag == NULL) {
794 best_dag = instance->of->best_dag(best_dag, dag);
799 if(best_dag == NULL) {
804 if(instance->current_dag != best_dag) {
806 if(RPL_IS_STORING(instance)) {
807 rpl_remove_routes(instance->current_dag);
810 LOG_INFO(
"New preferred DAG: ");
811 LOG_INFO_6ADDR(&best_dag->dag_id);
814 if(best_dag->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
815 check_prefix(&instance->current_dag->prefix_info, &best_dag->prefix_info);
816 }
else if(instance->current_dag->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
817 check_prefix(&instance->current_dag->prefix_info, NULL);
820 best_dag->joined = 1;
821 instance->current_dag->joined = 0;
822 instance->current_dag = best_dag;
825 instance->of->update_metric_container(instance);
827 best_dag->rank = rpl_rank_via_parent(best_dag->preferred_parent);
828 if(last_parent == NULL || best_dag->rank < best_dag->min_rank) {
834 best_dag->min_rank = best_dag->rank;
837 if(!acceptable_rank(best_dag, best_dag->rank)) {
838 LOG_WARN(
"New rank unacceptable!\n");
839 rpl_set_preferred_parent(instance->current_dag, NULL);
840 if(RPL_IS_STORING(instance) && last_parent != NULL) {
842 dao_output(last_parent, RPL_ZERO_LIFETIME);
847 if(best_dag->preferred_parent != last_parent) {
848 rpl_set_default_route(instance, rpl_parent_get_ipaddr(best_dag->preferred_parent));
849 LOG_INFO(
"Changed preferred parent, rank changed from %u to %u\n",
850 (
unsigned)old_rank, best_dag->rank);
851 RPL_STAT(rpl_stats.parent_switch++);
852 if(RPL_IS_STORING(instance)) {
853 if(last_parent != NULL) {
855 dao_output(last_parent, RPL_ZERO_LIFETIME);
859 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
863 if(instance->mop != RPL_MOP_NO_DOWNWARD_ROUTES) {
864 rpl_schedule_dao(instance);
867 rpl_reset_dio_timer(instance);
868 if(LOG_DBG_ENABLED) {
869 rpl_print_neighbor_list();
871 }
else if(best_dag->rank != old_rank) {
872 LOG_DBG(
"Preferred parent update, rank changed from %u to %u\n",
873 (
unsigned)old_rank, best_dag->rank);
879best_parent(
rpl_dag_t *dag,
int fresh_only)
883 rpl_parent_t *best = NULL;
885 if(dag == NULL || dag->instance == NULL || dag->instance->of == NULL) {
889 of = dag->instance->of;
891 for(p = nbr_table_head(rpl_parents); p != NULL; p = nbr_table_next(rpl_parents, p)) {
895 if(p->dag != dag || p->rank == RPL_INFINITE_RANK ||
896 p->rank < ROOT_RANK(dag->instance)) {
897 if(p->rank < ROOT_RANK(dag->instance)) {
898 LOG_WARN(
"Parent has invalid rank\n");
903 if(fresh_only && !rpl_parent_is_fresh(p)) {
910 if(rpl_get_nbr(p) == NULL) {
916 best = of->best_parent(best, p);
926 rpl_parent_t *best = best_parent(dag, 0);
930 if(rpl_parent_is_fresh(best)) {
931 rpl_set_preferred_parent(dag, best);
933 dag->instance->urgent_probing_target = NULL;
936 rpl_parent_t *best_fresh = best_parent(dag, 1);
937 if(best_fresh == NULL) {
939 rpl_set_preferred_parent(dag, best);
942 rpl_set_preferred_parent(dag, best_fresh);
945 dag->instance->urgent_probing_target = best;
949 rpl_set_preferred_parent(dag, best);
950 dag->rank = rpl_rank_via_parent(dag->preferred_parent);
953 rpl_set_preferred_parent(dag, NULL);
956 dag->rank = rpl_rank_via_parent(dag->preferred_parent);
957 return dag->preferred_parent;
961rpl_remove_parent(rpl_parent_t *parent)
963 LOG_INFO(
"Removing parent ");
964 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(parent));
967 rpl_nullify_parent(parent);
969 nbr_table_remove(rpl_parents, parent);
973rpl_nullify_parent(rpl_parent_t *parent)
980 if(parent == dag->preferred_parent || dag->preferred_parent == NULL) {
981 dag->rank = RPL_INFINITE_RANK;
983 if(dag->instance->def_route != NULL) {
984 LOG_DBG(
"Removing default route ");
985 LOG_DBG_6ADDR(rpl_parent_get_ipaddr(parent));
987 uip_ds6_defrt_rm(dag->instance->def_route);
988 dag->instance->def_route = NULL;
991 if(parent == dag->preferred_parent) {
992 if(RPL_IS_STORING(dag->instance)) {
993 dao_output(parent, RPL_ZERO_LIFETIME);
995 rpl_set_preferred_parent(dag, NULL);
1000 LOG_INFO(
"Nullifying parent ");
1001 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(parent));
1008 if(parent == dag_src->preferred_parent) {
1009 rpl_set_preferred_parent(dag_src, NULL);
1010 dag_src->rank = RPL_INFINITE_RANK;
1011 if(dag_src->joined && dag_src->instance->def_route != NULL) {
1012 LOG_DBG(
"Removing default route ");
1013 LOG_DBG_6ADDR(rpl_parent_get_ipaddr(parent));
1015 LOG_DBG(
"rpl_move_parent\n");
1016 uip_ds6_defrt_rm(dag_src->instance->def_route);
1017 dag_src->instance->def_route = NULL;
1019 }
else if(dag_src->joined) {
1020 if(RPL_IS_STORING(dag_src->instance)) {
1022 rpl_remove_routes_by_nexthop(rpl_parent_get_ipaddr(parent), dag_src);
1026 LOG_INFO(
"Moving parent ");
1027 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(parent));
1030 parent->dag = dag_dst;
1034rpl_get_any_dag_with_parent(
bool requires_parent)
1038 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1039 if(instance_table[i].used
1040 && instance_table[i].current_dag->joined
1041 && (!requires_parent || instance_table[i].current_dag->preferred_parent != NULL)) {
1042 return instance_table[i].current_dag;
1051 if(rpl_dag_root_is_root()) {
1054 return rpl_get_any_dag_with_parent(
true) != NULL;
1061 if(rpl_dag_root_is_root()) {
1064 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1065 if(instance_table[i].used && instance_table[i].has_downward_route) {
1073rpl_get_dag(
const uip_ipaddr_t *
addr)
1075 for(
int i = 0; i < RPL_MAX_INSTANCES; ++i) {
1076 if(instance_table[i].used) {
1077 for(
int j = 0; j < RPL_MAX_DAG_PER_INSTANCE; ++j) {
1078 if(instance_table[i].dag_table[j].joined
1079 && uip_ipaddr_prefixcmp(&instance_table[i].dag_table[j].dag_id,
addr,
1080 instance_table[i].dag_table[j].prefix_info.length)) {
1081 return &instance_table[i].dag_table[j];
1090rpl_get_any_dag(
void)
1092 return rpl_get_any_dag_with_parent(
false);
1096rpl_get_instance(uint8_t instance_id)
1100 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1101 if(instance_table[i].used && instance_table[i].instance_id == instance_id) {
1102 return &instance_table[i];
1109rpl_find_of(rpl_ocp_t ocp)
1112 i <
sizeof(objective_functions) /
sizeof(objective_functions[0]);
1114 if(objective_functions[i]->ocp == ocp) {
1115 return objective_functions[i];
1123rpl_join_instance(uip_ipaddr_t *from, rpl_dio_t *dio)
1130 if((!RPL_WITH_NON_STORING && dio->mop == RPL_MOP_NON_STORING)
1131 || (!RPL_WITH_STORING && (dio->mop == RPL_MOP_STORING_NO_MULTICAST
1132 || dio->mop == RPL_MOP_STORING_MULTICAST))) {
1133 LOG_WARN(
"DIO advertising a non-supported MOP %u\n", dio->mop);
1139 of = rpl_find_of(dio->ocp);
1141 LOG_WARN(
"DIO for DAG instance %u does not specify a supported OF: %u\n",
1142 dio->instance_id, dio->ocp);
1146 dag = rpl_alloc_dag(dio->instance_id, &dio->dag_id);
1148 LOG_ERR(
"Failed to allocate a DAG object!\n");
1152 instance = dag->instance;
1154 p = rpl_add_parent(dag, dio, from);
1156 LOG_DBG_6ADDR(from);
1157 LOG_DBG_(
" as a parent: ");
1159 LOG_DBG_(
"failed\n");
1163 p->dtsn = dio->dtsn;
1164 LOG_DBG_(
"succeeded\n");
1168 if(dio->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
1169 check_prefix(NULL, &dio->prefix_info);
1173 dag->preference = dio->preference;
1174 dag->grounded = dio->grounded;
1175 dag->version = dio->version;
1178 instance->mop = dio->mop;
1179 instance->mc.type = dio->mc.type;
1180 instance->mc.flags = dio->mc.flags;
1181 instance->mc.aggr = dio->mc.aggr;
1182 instance->mc.prec = dio->mc.prec;
1183 instance->current_dag = dag;
1184 instance->dtsn_out = RPL_LOLLIPOP_INIT;
1186 instance->max_rankinc = dio->dag_max_rankinc;
1187 instance->min_hoprankinc = dio->dag_min_hoprankinc;
1188 instance->dio_intdoubl = dio->dag_intdoubl;
1189 instance->dio_intmin = dio->dag_intmin;
1190 instance->dio_intcurrent = instance->dio_intmin + instance->dio_intdoubl;
1191 instance->dio_redundancy = dio->dag_redund;
1192 instance->default_lifetime = dio->default_lifetime;
1193 instance->lifetime_unit = dio->lifetime_unit;
1195 memcpy(&dag->dag_id, &dio->dag_id,
sizeof(dio->dag_id));
1198 memcpy(&dag->prefix_info, &dio->prefix_info,
sizeof(
rpl_prefix_t));
1200 rpl_set_preferred_parent(dag, p);
1201 instance->of->update_metric_container(instance);
1202 dag->rank = rpl_rank_via_parent(p);
1204 dag->min_rank = dag->rank;
1206 if(default_instance == NULL) {
1207 default_instance = instance;
1210 LOG_INFO(
"Joined DAG with instance ID %u, rank %hu, DAG ID ",
1211 dio->instance_id, dag->rank);
1212 LOG_INFO_6ADDR(&dag->dag_id);
1215 LOG_ANNOTATE(
"#A join=%u\n", dag->dag_id.u8[
sizeof(dag->dag_id) - 1]);
1217 rpl_reset_dio_timer(instance);
1218 rpl_set_default_route(instance, from);
1220 if(instance->mop != RPL_MOP_NO_DOWNWARD_ROUTES) {
1221 rpl_schedule_dao(instance);
1223 LOG_WARN(
"The DIO does not meet the prerequisites for sending a DAO\n");
1226 instance->of->reset(dag);
1228#if RPL_MAX_DAG_PER_INSTANCE > 1
1231rpl_add_dag(uip_ipaddr_t *from, rpl_dio_t *dio)
1238 dag = rpl_alloc_dag(dio->instance_id, &dio->dag_id);
1240 LOG_ERR(
"Failed to allocate a DAG object!\n");
1244 instance = dag->instance;
1246 previous_dag = find_parent_dag(instance, from);
1247 if(previous_dag == NULL) {
1249 LOG_DBG_6ADDR(from);
1250 LOG_DBG_(
" as a parent: ");
1251 p = rpl_add_parent(dag, dio, from);
1253 LOG_DBG_(
"failed\n");
1257 LOG_DBG_(
"succeeded\n");
1259 p = rpl_find_parent(previous_dag, from);
1261 rpl_move_parent(previous_dag, dag, p);
1264 p->rank = dio->rank;
1268 of = rpl_find_of(dio->ocp);
1269 if(of != instance->of ||
1270 instance->mop != dio->mop ||
1271 instance->max_rankinc != dio->dag_max_rankinc ||
1272 instance->min_hoprankinc != dio->dag_min_hoprankinc ||
1273 instance->dio_intdoubl != dio->dag_intdoubl ||
1274 instance->dio_intmin != dio->dag_intmin ||
1275 instance->dio_redundancy != dio->dag_redund ||
1276 instance->default_lifetime != dio->default_lifetime ||
1277 instance->lifetime_unit != dio->lifetime_unit) {
1278 LOG_WARN(
"DIO for DAG instance %u incompatible with previous DIO\n",
1280 rpl_remove_parent(p);
1286 dag->grounded = dio->grounded;
1287 dag->preference = dio->preference;
1288 dag->version = dio->version;
1290 memcpy(&dag->dag_id, &dio->dag_id,
sizeof(dio->dag_id));
1293 memcpy(&dag->prefix_info, &dio->prefix_info,
sizeof(
rpl_prefix_t));
1295 rpl_set_preferred_parent(dag, p);
1296 dag->rank = rpl_rank_via_parent(p);
1297 dag->min_rank = dag->rank;
1299 LOG_INFO(
"Joined DAG with instance ID %u, rank %hu, DAG ID ",
1300 dio->instance_id, dag->rank);
1301 LOG_INFO_6ADDR(&dag->dag_id);
1304 LOG_ANNOTATE(
"#A join=%u\n", dag->dag_id.u8[
sizeof(dag->dag_id) - 1]);
1306 rpl_process_parent_event(instance, p);
1307 p->dtsn = dio->dtsn;
1315global_repair(uip_ipaddr_t *from,
rpl_dag_t *dag, rpl_dio_t *dio)
1319 remove_parents(dag, 0);
1320 dag->version = dio->version;
1323 dag->instance->dio_intdoubl = dio->dag_intdoubl;
1324 dag->instance->dio_intmin = dio->dag_intmin;
1325 dag->instance->dio_redundancy = dio->dag_redund;
1326 dag->instance->default_lifetime = dio->default_lifetime;
1327 dag->instance->lifetime_unit = dio->lifetime_unit;
1329 dag->instance->of->reset(dag);
1330 dag->min_rank = RPL_INFINITE_RANK;
1331 RPL_LOLLIPOP_INCREMENT(dag->instance->dtsn_out);
1333 p = rpl_add_parent(dag, dio, from);
1335 LOG_ERR(
"Failed to add a parent during the global repair\n");
1336 dag->rank = RPL_INFINITE_RANK;
1338 dag->rank = rpl_rank_via_parent(p);
1339 dag->min_rank = dag->rank;
1340 LOG_DBG(
"rpl_process_parent_event global repair\n");
1341 rpl_process_parent_event(dag->instance, p);
1344 LOG_DBG(
"Participating in a global repair (version=%u, rank=%hu)\n",
1345 dag->version, dag->rank);
1347 RPL_STAT(rpl_stats.global_repairs++);
1355 if(instance == NULL) {
1356 LOG_WARN(
"local repair requested for instance NULL\n");
1359 LOG_INFO(
"Starting a local instance repair\n");
1360 for(i = 0; i < RPL_MAX_DAG_PER_INSTANCE; i++) {
1361 if(instance->dag_table[i].used) {
1362 instance->dag_table[i].rank = RPL_INFINITE_RANK;
1363 nullify_parents(&instance->dag_table[i], 0);
1368 instance->has_downward_route = 0;
1373 rpl_reset_dio_timer(instance);
1374 if(RPL_IS_STORING(instance)) {
1381 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
1384 RPL_STAT(rpl_stats.local_repairs++);
1388rpl_recalculate_ranks(
void)
1397 p = nbr_table_head(rpl_parents);
1399 if(p->dag != NULL && p->dag->instance && (p->flags & RPL_PARENT_FLAG_UPDATED)) {
1400 p->flags &= ~RPL_PARENT_FLAG_UPDATED;
1401 LOG_DBG(
"rpl_process_parent_event recalculate_ranks\n");
1402 if(!rpl_process_parent_event(p->dag->instance, p)) {
1403 LOG_DBG(
"A parent was dropped\n");
1406 p = nbr_table_next(rpl_parents, p);
1411rpl_process_parent_event(
rpl_instance_t *instance, rpl_parent_t *p)
1414 rpl_parent_t *last_parent = instance->current_dag->preferred_parent;
1417 rpl_rank_t old_rank;
1418 old_rank = instance->current_dag->rank;
1423 if(RPL_IS_STORING(instance)
1424 && uip_ds6_route_is_nexthop(rpl_parent_get_ipaddr(p))
1425 && !rpl_parent_is_reachable(p) && instance->mop > RPL_MOP_NON_STORING) {
1426 LOG_WARN(
"Unacceptable link %u, removing routes via: ",
1427 rpl_get_parent_link_metric(p));
1428 LOG_WARN_6ADDR(rpl_parent_get_ipaddr(p));
1430 rpl_remove_routes_by_nexthop(rpl_parent_get_ipaddr(p), p->dag);
1433 if(!acceptable_rank(p->dag, rpl_rank_via_parent(p))) {
1436 LOG_WARN(
"Unacceptable rank %u (Current min %u, MaxRankInc %u)\n",
1438 p->dag->min_rank, p->dag->instance->max_rankinc);
1439 rpl_nullify_parent(p);
1440 if(p != instance->current_dag->preferred_parent) {
1447 if(rpl_select_dag(instance, p) == NULL) {
1448 if(last_parent != NULL) {
1450 LOG_ERR(
"No parents found in any DAG\n");
1451 rpl_local_repair(instance);
1457 if(DAG_RANK(old_rank, instance) !=
1458 DAG_RANK(instance->current_dag->rank, instance)) {
1459 LOG_INFO(
"Moving in the instance from rank %hu to %hu\n",
1460 DAG_RANK(old_rank, instance),
1461 DAG_RANK(instance->current_dag->rank, instance));
1462 if(instance->current_dag->rank != RPL_INFINITE_RANK) {
1463 LOG_DBG(
"The preferred parent is ");
1464 LOG_DBG_6ADDR(rpl_parent_get_ipaddr(instance->current_dag->preferred_parent));
1465 LOG_DBG_(
" (rank %u)\n",
1466 (
unsigned)DAG_RANK(instance->current_dag->preferred_parent->rank,
1469 LOG_WARN(
"We don't have any parent");
1474 return return_value;
1478add_nbr_from_dio(uip_ipaddr_t *from, rpl_dio_t *dio)
1481 if(rpl_icmp6_update_nbr_table(from, NBR_TABLE_REASON_RPL_DIO, dio) == NULL) {
1482 LOG_ERR(
"Out of memory, dropping DIO from ");
1483 LOG_ERR_6ADDR(from);
1491rpl_process_dio(uip_ipaddr_t *from, rpl_dio_t *dio)
1497#if RPL_WITH_MULTICAST
1503 if(dio->mop < RPL_MOP_STORING_NO_MULTICAST) {
1505 if(dio->mop != RPL_MOP_DEFAULT) {
1507 LOG_ERR(
"Ignoring a DIO with an unsupported MOP: %d\n", dio->mop);
1511 dag = get_dag(dio->instance_id, &dio->dag_id);
1512 instance = rpl_get_instance(dio->instance_id);
1514 if(dag != NULL && instance != NULL) {
1515 if(lollipop_greater_than(dio->version, dag->version)) {
1516 if(dag->rank == ROOT_RANK(instance)) {
1517 LOG_WARN(
"Root received inconsistent DIO version number (current: %u, received: %u)\n",
1518 dag->version, dio->version);
1519 dag->version = dio->version;
1520 RPL_LOLLIPOP_INCREMENT(dag->version);
1521 rpl_reset_dio_timer(instance);
1523 LOG_DBG(
"Global repair\n");
1524 if(dio->prefix_info.length != 0) {
1525 if(dio->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
1526 LOG_DBG(
"Prefix announced in DIO\n");
1527 rpl_set_prefix(dag, &dio->prefix_info.prefix,
1528 dio->prefix_info.length);
1531 global_repair(from, dag, dio);
1536 if(lollipop_greater_than(dag->version, dio->version)) {
1538 LOG_WARN(
"old version received => inconsistency detected\n");
1540 rpl_reset_dio_timer(instance);
1546 if(instance == NULL) {
1547 LOG_INFO(
"New instance detected (ID=%u): Joining...\n", dio->instance_id);
1548 if(add_nbr_from_dio(from, dio)) {
1549 rpl_join_instance(from, dio);
1551 LOG_WARN(
"Not joining since we could not add a parent\n");
1556 if(instance->current_dag->rank == ROOT_RANK(instance) &&
1557 instance->current_dag != dag) {
1558 LOG_WARN(
"Root ignored DIO for different DAG\n");
1563#if RPL_MAX_DAG_PER_INSTANCE > 1
1564 LOG_INFO(
"Adding new DAG to known instance.\n");
1565 if(!add_nbr_from_dio(from, dio)) {
1566 LOG_WARN(
"Could not add new DAG, could not add parent\n");
1569 dag = rpl_add_dag(from, dio);
1571 LOG_WARN(
"Failed to add DAG.\n");
1575 LOG_WARN(
"Only one instance supported.\n");
1580 if(dio->rank < ROOT_RANK(instance)) {
1581 LOG_INFO(
"Ignoring DIO with too low rank: %u\n",
1582 (
unsigned)dio->rank);
1587 if(dio->prefix_info.length != 0) {
1588 if(dio->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
1589 LOG_DBG(
"Prefix announced in DIO\n");
1590 rpl_set_prefix(dag, &dio->prefix_info.prefix, dio->prefix_info.length);
1594 if(!add_nbr_from_dio(from, dio)) {
1595 LOG_WARN(
"Could not add parent based on DIO\n");
1599 if(dag->rank == ROOT_RANK(instance)) {
1600 if(dio->rank != RPL_INFINITE_RANK) {
1601 instance->dio_counter++;
1607 dag->lifetime = (1UL << (instance->dio_intmin + instance->dio_intdoubl)) *
1608 RPL_DAG_LIFETIME / 1000;
1609 LOG_DBG(
"Set DAG ");
1610 LOG_DBG_6ADDR(&dag->dag_id);
1611 LOG_DBG_(
" lifetime to %ld\n", (
long int)dag->lifetime);
1620 p = rpl_find_parent(dag, from);
1622 previous_dag = find_parent_dag(instance, from);
1623 if(previous_dag == NULL) {
1625 p = rpl_add_parent(dag, dio, from);
1627 LOG_WARN(
"Failed to add a new parent (");
1628 LOG_WARN_6ADDR(from);
1632 LOG_INFO(
"New candidate parent with rank %u: ", (
unsigned)p->rank);
1633 LOG_INFO_6ADDR(from);
1636 p = rpl_find_parent(previous_dag, from);
1638 rpl_move_parent(previous_dag, dag, p);
1642 if(p->rank == dio->rank) {
1643 LOG_INFO(
"Received consistent DIO\n");
1645 instance->dio_counter++;
1649 p->rank = dio->rank;
1651 if(dio->rank == RPL_INFINITE_RANK && p == dag->preferred_parent) {
1653 rpl_reset_dio_timer(instance);
1657 p->flags |= RPL_PARENT_FLAG_UPDATED;
1659 LOG_INFO(
"Preferred DAG ");
1660 LOG_INFO_6ADDR(&instance->current_dag->dag_id);
1661 LOG_INFO_(
", rank %u, min_rank %u, ",
1662 instance->current_dag->rank, instance->current_dag->min_rank);
1663 LOG_INFO_(
"parent rank %u, link metric %u\n",
1664 p->rank, rpl_get_parent_link_metric(p));
1669 memcpy(&p->mc, &dio->mc,
sizeof(p->mc));
1671 if(rpl_process_parent_event(instance, p) == 0) {
1672 LOG_WARN(
"The candidate parent is rejected\n");
1677 if(dag->joined && p == dag->preferred_parent) {
1678 if(should_refresh_routes(instance, dio, p)) {
1681 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
1682 rpl_schedule_dao(instance);
1689 uip_ds6_defrt_add(from, RPL_DEFAULT_ROUTE_INFINITE_LIFETIME ? 0 : RPL_LIFETIME(instance, instance->default_lifetime));
1691 p->dtsn = dio->dtsn;
Header file for the callback timer.
clock_time_t clock_time(void)
Get the current clock time.
#define CLOCK_SECOND
A second, measured in system clock time.
void ctimer_stop(struct ctimer *c)
Stop a pending callback timer.
void rpl_schedule_probing(void)
Schedule probing with delay RPL_PROBING_DELAY_FUNC()
void rpl_schedule_probing_now(void)
Schedule probing within a few seconds.
int rpl_has_downward_route(void)
Get the RPL's best guess on if we have downward route or not.
const uip_lladdr_t * uip_ds6_nbr_get_ll(const uip_ds6_nbr_t *nbr)
Get the link-layer address associated with a specified nbr cache.
int rpl_has_joined(void)
Tells whether the node has joined a network or not.
uip_ds6_nbr_t * uip_ds6_nbr_ll_lookup(const uip_lladdr_t *lladdr)
Get the neighbor cache associated with a specified link-layer address.
uip_lladdr_t uip_lladdr
Host L2 address.
uip_ds6_nbr_t * uip_ds6_nbr_lookup(const uip_ipaddr_t *ipaddr)
Get the neighbor cache associated with a specified IPv6 address.
uip_ds6_addr_t * uip_ds6_addr_add(uip_ipaddr_t *ipaddr, unsigned long vlifetime, uint8_t type)
Add a unicast address to the interface.
int uip_ds6_nbr_num(void)
Return the number of neighbor caches.
void uip_ds6_set_addr_iid(uip_ipaddr_t *ipaddr, const uip_lladdr_t *lladdr)
set the last 64 bits of an IP address based on the MAC address
const uip_lladdr_t * uip_ds6_nbr_lladdr_from_ipaddr(const uip_ipaddr_t *ipaddr)
Get the link-layer address associated with a specified IPv6 address.
uip_ipaddr_t * uip_ds6_nbr_ipaddr_from_lladdr(const uip_lladdr_t *lladdr)
Get an IPv6 address associated with a specified link-layer address.
Linked list manipulation routines.
Header file for the logging system.
Memory block allocation routines.
API for RPL objective functions (OF)
Unicast address structure.
The default nbr_table entry (when UIP_DS6_NBR_MULTI_IPV6_ADDRS is disabled), that implements nbr cach...
IPv6 Neighbor cache (link-layer/IPv6 address mapping)
This header file contains configuration directives for uIPv6 multicast support.
static uip_ipaddr_t ipaddr
Pointer to prefix information option in uip_buf.
static uip_ds6_addr_t * addr
Pointer to a nbr cache entry.
Header file for IPv6 Neighbor discovery (RFC 4861)
Header file for the uIP TCP/IP stack.