47 #include "net/link-stats.h" 48 #include "net/routing/rpl-classic/rpl.h" 49 #include "net/routing/rpl-classic/rpl-private.h" 50 #include "net/routing/rpl-classic/rpl-dag-root.h" 54 #include "net/nbr-table.h" 64 #define LOG_MODULE "RPL" 65 #define LOG_LEVEL LOG_LEVEL_RPL 68 #ifdef RPL_CALLBACK_PARENT_SWITCH 69 void RPL_CALLBACK_PARENT_SWITCH(rpl_parent_t *old, rpl_parent_t *
new);
74 static rpl_of_t *
const objective_functions[] = RPL_SUPPORTED_OFS;
79 #ifndef RPL_CONF_GROUNDED 80 #define RPL_GROUNDED 0 82 #define RPL_GROUNDED RPL_CONF_GROUNDED 87 NBR_TABLE_GLOBAL(rpl_parent_t, rpl_parents);
95 rpl_print_neighbor_list(
void)
97 if(default_instance != NULL && default_instance->current_dag != NULL &&
98 default_instance->of != NULL) {
99 int curr_dio_interval = default_instance->dio_intcurrent;
100 int curr_rank = default_instance->current_dag->rank;
101 rpl_parent_t *p = nbr_table_head(rpl_parents);
104 LOG_DBG(
"RPL: MOP %u OCP %u rank %u dioint %u, nbr count %u\n",
105 default_instance->mop, default_instance->of->ocp, curr_rank, curr_dio_interval,
uip_ds6_nbr_num());
107 const struct link_stats *stats = rpl_get_parent_link_stats(p);
108 uip_ipaddr_t *parent_addr = rpl_parent_get_ipaddr(p);
109 LOG_DBG(
"RPL: nbr %02x %5u, %5u => %5u -- %2u %c%c (last tx %u min ago)\n",
110 parent_addr != NULL ? parent_addr->u8[15] : 0x0,
112 rpl_get_parent_link_metric(p),
113 rpl_rank_via_parent(p),
114 stats != NULL ? stats->freshness : 0,
115 link_stats_is_fresh(stats) ?
'f' :
' ',
116 p == default_instance->current_dag->preferred_parent ?
'p' :
' ',
117 stats != NULL ? (
unsigned)((clock_now - stats->last_tx_time) / (60 *
CLOCK_SECOND)) : -1u
119 p = nbr_table_next(rpl_parents, p);
121 LOG_DBG(
"RPL: end of list\n");
126 rpl_get_nbr(rpl_parent_t *parent)
128 const linkaddr_t *lladdr = rpl_get_parent_lladdr(parent);
137 nbr_callback(
void *ptr)
139 rpl_remove_parent(ptr);
145 nbr_table_register(rpl_parents, (nbr_table_callback *)nbr_callback);
149 rpl_get_parent(
const uip_lladdr_t *
addr)
151 rpl_parent_t *p = nbr_table_get_from_lladdr(rpl_parents, (
const linkaddr_t *)addr);
156 rpl_get_parent_rank(uip_lladdr_t *addr)
158 rpl_parent_t *p = nbr_table_get_from_lladdr(rpl_parents, (linkaddr_t *)addr);
162 return RPL_INFINITE_RANK;
167 rpl_get_parent_link_metric(rpl_parent_t *p)
169 if(p != NULL && p->dag != NULL) {
171 if(instance != NULL && instance->of != NULL && instance->of->parent_link_metric != NULL) {
172 return instance->of->parent_link_metric(p);
179 rpl_rank_via_parent(rpl_parent_t *p)
181 if(p != NULL && p->dag != NULL) {
183 if(instance != NULL && instance->of != NULL && instance->of->rank_via_parent != NULL) {
184 return instance->of->rank_via_parent(p);
187 return RPL_INFINITE_RANK;
191 rpl_get_parent_lladdr(rpl_parent_t *p)
193 return nbr_table_get_lladdr(rpl_parents, p);
197 rpl_parent_get_ipaddr(rpl_parent_t *p)
199 const linkaddr_t *lladdr = rpl_get_parent_lladdr(p);
206 const struct link_stats *
207 rpl_get_parent_link_stats(rpl_parent_t *p)
209 const linkaddr_t *lladdr = rpl_get_parent_lladdr(p);
210 return link_stats_from_lladdr(lladdr);
214 rpl_parent_is_fresh(rpl_parent_t *p)
216 const struct link_stats *stats = rpl_get_parent_link_stats(p);
217 return link_stats_is_fresh(stats);
221 rpl_parent_is_reachable(rpl_parent_t *p) {
222 if(p == NULL || p->dag == NULL || p->dag->instance == NULL || p->dag->instance->of == NULL) {
227 if(rpl_get_nbr(p) == NULL) {
232 return !rpl_parent_is_fresh(p) || p->dag->instance->of->parent_has_usable_link(p);
237 rpl_set_preferred_parent(
rpl_dag_t *dag, rpl_parent_t *p)
239 if(dag != NULL && dag->preferred_parent != p) {
240 LOG_INFO(
"rpl_set_preferred_parent ");
242 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(p));
246 LOG_INFO_(
" used to be ");
247 if(dag->preferred_parent != NULL) {
248 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(dag->preferred_parent));
254 #ifdef RPL_CALLBACK_PARENT_SWITCH 255 RPL_CALLBACK_PARENT_SWITCH(dag->preferred_parent, p);
260 nbr_table_unlock(rpl_parents, dag->preferred_parent);
261 nbr_table_lock(rpl_parents, p);
262 dag->preferred_parent = p;
269 lollipop_greater_than(
int a,
int b)
272 if(a > RPL_LOLLIPOP_CIRCULAR_REGION && b <= RPL_LOLLIPOP_CIRCULAR_REGION) {
273 return (RPL_LOLLIPOP_MAX_VALUE + 1 + b - a) > RPL_LOLLIPOP_SEQUENCE_WINDOWS;
277 return (a > b && (a - b) < RPL_LOLLIPOP_SEQUENCE_WINDOWS) ||
278 (a < b && (b - a) > (RPL_LOLLIPOP_CIRCULAR_REGION + 1-
279 RPL_LOLLIPOP_SEQUENCE_WINDOWS));
284 remove_parents(
rpl_dag_t *dag, rpl_rank_t minimum_rank)
288 LOG_INFO(
"Removing parents (minimum rank %u)\n", minimum_rank);
290 p = nbr_table_head(rpl_parents);
292 if(dag == p->dag && p->rank >= minimum_rank) {
293 rpl_remove_parent(p);
295 p = nbr_table_next(rpl_parents, p);
300 nullify_parents(
rpl_dag_t *dag, rpl_rank_t minimum_rank)
304 LOG_INFO(
"Nullifying parents (minimum rank %u)\n", minimum_rank);
306 p = nbr_table_head(rpl_parents);
308 if(dag == p->dag && p->rank >= minimum_rank) {
309 rpl_nullify_parent(p);
311 p = nbr_table_next(rpl_parents, p);
316 should_refresh_routes(
rpl_instance_t *instance, rpl_dio_t *dio, rpl_parent_t *p)
319 if(instance->mop == RPL_MOP_NO_DOWNWARD_ROUTES) {
323 return p == instance->current_dag->preferred_parent &&
324 (lollipop_greater_than(dio->dtsn, p->dtsn));
328 acceptable_rank(
rpl_dag_t *dag, rpl_rank_t rank)
330 return rank != RPL_INFINITE_RANK &&
331 ((dag->instance->max_rankinc == 0) ||
332 DAG_RANK(rank, dag->instance) <=
DAG_RANK(dag->min_rank + dag->instance->max_rankinc, dag->instance));
336 get_dag(uint8_t instance_id, uip_ipaddr_t *dag_id)
342 instance = rpl_get_instance(instance_id);
343 if(instance == NULL) {
347 for(i = 0; i < RPL_MAX_DAG_PER_INSTANCE; ++i) {
348 dag = &instance->dag_table[i];
349 if(dag->used && uip_ipaddr_cmp(&dag->dag_id, dag_id)) {
358 rpl_set_root(uint8_t instance_id, uip_ipaddr_t *dag_id)
365 version = RPL_LOLLIPOP_INIT;
366 instance = rpl_get_instance(instance_id);
367 if(instance != NULL) {
368 for(i = 0; i < RPL_MAX_DAG_PER_INSTANCE; ++i) {
369 dag = &instance->dag_table[i];
371 if(uip_ipaddr_cmp(&dag->dag_id, dag_id)) {
372 version = dag->version;
373 RPL_LOLLIPOP_INCREMENT(version);
375 if(dag == dag->instance->current_dag) {
376 LOG_INFO(
"Dropping a joined DAG when setting this node as root\n");
377 rpl_set_default_route(instance, NULL);
378 dag->instance->current_dag = NULL;
380 LOG_INFO(
"Dropping a DAG when setting this node as root\n");
388 dag = rpl_alloc_dag(instance_id, dag_id);
390 LOG_ERR(
"Failed to allocate a DAG\n");
394 instance = dag->instance;
396 dag->version = version;
398 dag->grounded = RPL_GROUNDED;
399 dag->preference = RPL_PREFERENCE;
400 instance->mop = RPL_MOP_DEFAULT;
401 instance->of = rpl_find_of(RPL_OF_OCP);
402 if(instance->of == NULL) {
403 LOG_WARN(
"OF with OCP %u not supported\n", RPL_OF_OCP);
407 rpl_set_preferred_parent(dag, NULL);
409 memcpy(&dag->dag_id, dag_id,
sizeof(dag->dag_id));
411 instance->dio_intdoubl = RPL_DIO_INTERVAL_DOUBLINGS;
412 instance->dio_intmin = RPL_DIO_INTERVAL_MIN;
415 instance->dio_intcurrent = RPL_DIO_INTERVAL_MIN +
416 RPL_DIO_INTERVAL_DOUBLINGS;
417 instance->dio_redundancy = RPL_DIO_REDUNDANCY;
418 instance->max_rankinc = RPL_MAX_RANKINC;
419 instance->min_hoprankinc = RPL_MIN_HOPRANKINC;
420 instance->default_lifetime = RPL_DEFAULT_LIFETIME;
421 instance->lifetime_unit = RPL_DEFAULT_LIFETIME_UNIT;
425 if(instance->current_dag != dag && instance->current_dag != NULL) {
427 if(RPL_IS_STORING(instance)) {
428 rpl_remove_routes(instance->current_dag);
431 instance->current_dag->joined = 0;
434 instance->current_dag = dag;
435 instance->dtsn_out = RPL_LOLLIPOP_INIT;
436 instance->of->update_metric_container(instance);
437 default_instance = instance;
439 LOG_INFO(
"Node set to be a DAG root with DAG ID ");
440 LOG_INFO_6ADDR(&dag->dag_id);
443 LOG_ANNOTATE(
"#A root=%u\n", dag->dag_id.u8[
sizeof(dag->dag_id) - 1]);
445 rpl_reset_dio_timer(instance);
451 rpl_repair_root(uint8_t instance_id)
455 instance = rpl_get_instance(instance_id);
456 if(instance == NULL ||
457 instance->current_dag->rank !=
ROOT_RANK(instance)) {
458 LOG_WARN(
"rpl_repair_root triggered but not root\n");
461 RPL_STAT(rpl_stats.root_repairs++);
463 RPL_LOLLIPOP_INCREMENT(instance->current_dag->version);
464 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
465 LOG_INFO(
"rpl_repair_root initiating global repair with version %d\n", instance->current_dag->version);
466 rpl_reset_dio_timer(instance);
473 memset(ipaddr, 0,
sizeof(uip_ipaddr_t));
474 memcpy(ipaddr, &prefix->prefix, (prefix->length + 7) / 8);
484 if(last_prefix != NULL && new_prefix != NULL &&
485 last_prefix->length == new_prefix->length &&
486 uip_ipaddr_prefixcmp(&last_prefix->prefix, &new_prefix->prefix, new_prefix->length) &&
487 last_prefix->flags == new_prefix->flags) {
492 if(last_prefix != NULL) {
493 set_ip_from_prefix(&ipaddr, last_prefix);
494 rep = uip_ds6_addr_lookup(&ipaddr);
496 LOG_DBG(
"removing global IP address ");
497 LOG_DBG_6ADDR(&ipaddr);
499 uip_ds6_addr_rm(rep);
503 if(new_prefix != NULL) {
504 set_ip_from_prefix(&ipaddr, new_prefix);
505 if(uip_ds6_addr_lookup(&ipaddr) == NULL) {
506 LOG_DBG(
"adding global IP address ");
507 LOG_DBG_6ADDR(&ipaddr);
515 rpl_set_prefix(
rpl_dag_t *dag, uip_ipaddr_t *prefix,
unsigned len)
518 uint8_t last_len = dag->prefix_info.length;
523 if(dag->prefix_info.length != 0) {
524 memcpy(&last_prefix, &dag->prefix_info,
sizeof(
rpl_prefix_t));
526 memset(&dag->prefix_info.prefix, 0,
sizeof(dag->prefix_info.prefix));
527 memcpy(&dag->prefix_info.prefix, prefix, (len + 7) / 8);
528 dag->prefix_info.length = len;
529 dag->prefix_info.flags = UIP_ND6_RA_FLAG_AUTONOMOUS;
530 LOG_INFO(
"Prefix set - will announce this in DIOs\n");
531 if(dag->rank !=
ROOT_RANK(dag->instance)) {
535 LOG_INFO(
"rpl_set_prefix - prefix NULL\n");
536 check_prefix(NULL, &dag->prefix_info);
538 LOG_INFO(
"rpl_set_prefix - prefix NON-NULL\n");
539 check_prefix(&last_prefix, &dag->prefix_info);
546 rpl_set_default_route(
rpl_instance_t *instance, uip_ipaddr_t *from)
548 if(instance->def_route != NULL) {
549 LOG_DBG(
"Removing default route through ");
550 LOG_DBG_6ADDR(&instance->def_route->ipaddr);
552 uip_ds6_defrt_rm(instance->def_route);
553 instance->def_route = NULL;
557 LOG_DBG(
"Adding default route through ");
560 instance->def_route = uip_ds6_defrt_add(from,
561 RPL_DEFAULT_ROUTE_INFINITE_LIFETIME ? 0 :
RPL_LIFETIME(instance, instance->default_lifetime));
562 if(instance->def_route == NULL) {
570 rpl_alloc_instance(uint8_t instance_id)
574 for(instance = &instance_table[0], end = instance + RPL_MAX_INSTANCES;
575 instance < end; ++instance) {
576 if(instance->used == 0) {
577 memset(instance, 0,
sizeof(*instance));
578 instance->instance_id = instance_id;
579 instance->def_route = NULL;
591 rpl_alloc_dag(uint8_t instance_id, uip_ipaddr_t *dag_id)
596 instance = rpl_get_instance(instance_id);
597 if(instance == NULL) {
598 instance = rpl_alloc_instance(instance_id);
599 if(instance == NULL) {
600 RPL_STAT(rpl_stats.mem_overflows++);
605 for(dag = &instance->dag_table[0], end = dag + RPL_MAX_DAG_PER_INSTANCE; dag < end; ++dag) {
607 memset(dag, 0,
sizeof(*dag));
609 dag->rank = RPL_INFINITE_RANK;
610 dag->min_rank = RPL_INFINITE_RANK;
611 dag->instance = instance;
616 RPL_STAT(rpl_stats.mem_overflows++);
623 default_instance = instance;
629 return default_instance;
638 LOG_INFO(
"Leaving the instance %u\n", instance->instance_id);
641 for(dag = &instance->dag_table[0], end = dag + RPL_MAX_DAG_PER_INSTANCE; dag < end; ++dag) {
647 rpl_set_default_route(instance, NULL);
656 if(default_instance == instance) {
657 default_instance = NULL;
667 LOG_INFO(
"Leaving the DAG ");
668 LOG_INFO_6ADDR(&dag->dag_id);
673 if(RPL_IS_STORING(dag->instance)) {
674 rpl_remove_routes(dag);
682 if((dag->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS)) {
683 check_prefix(&dag->prefix_info, NULL);
686 remove_parents(dag, 0);
692 rpl_add_parent(
rpl_dag_t *dag, rpl_dio_t *dio, uip_ipaddr_t *addr)
694 rpl_parent_t *p = NULL;
699 LOG_DBG(
"rpl_add_parent lladdr %p ", lladdr);
704 p = nbr_table_add_lladdr(rpl_parents, (linkaddr_t *)lladdr,
705 NBR_TABLE_REASON_RPL_DIO, dio);
707 LOG_DBG(
"rpl_add_parent p NULL\n");
713 memcpy(&p->mc, &dio->mc,
sizeof(p->mc));
721 static rpl_parent_t *
722 find_parent_any_dag_any_instance(uip_ipaddr_t *addr)
726 return nbr_table_get_from_lladdr(rpl_parents, (linkaddr_t *)lladdr);
730 rpl_find_parent(
rpl_dag_t *dag, uip_ipaddr_t *addr)
732 rpl_parent_t *p = find_parent_any_dag_any_instance(addr);
733 if(p != NULL && p->dag == dag) {
743 rpl_parent_t *p = find_parent_any_dag_any_instance(addr);
752 rpl_find_parent_any_dag(
rpl_instance_t *instance, uip_ipaddr_t *addr)
754 rpl_parent_t *p = find_parent_any_dag_any_instance(addr);
755 if(p && p->dag && p->dag->instance == instance) {
765 rpl_parent_t *last_parent;
769 old_rank = instance->current_dag->rank;
770 last_parent = instance->current_dag->preferred_parent;
772 if(instance->current_dag->rank !=
ROOT_RANK(instance)) {
773 rpl_select_parent(p->dag);
777 for(dag = &instance->dag_table[0], end = dag + RPL_MAX_DAG_PER_INSTANCE; dag < end; ++dag) {
778 if(dag->used && dag->preferred_parent != NULL && dag->preferred_parent->rank != RPL_INFINITE_RANK) {
779 if(best_dag == NULL) {
782 best_dag = instance->of->best_dag(best_dag, dag);
787 if(best_dag == NULL) {
792 if(instance->current_dag != best_dag) {
794 if(RPL_IS_STORING(instance)) {
795 rpl_remove_routes(instance->current_dag);
798 LOG_INFO(
"New preferred DAG: ");
799 LOG_INFO_6ADDR(&best_dag->dag_id);
802 if(best_dag->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
803 check_prefix(&instance->current_dag->prefix_info, &best_dag->prefix_info);
804 }
else if(instance->current_dag->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
805 check_prefix(&instance->current_dag->prefix_info, NULL);
808 best_dag->joined = 1;
809 instance->current_dag->joined = 0;
810 instance->current_dag = best_dag;
813 instance->of->update_metric_container(instance);
815 best_dag->rank = rpl_rank_via_parent(best_dag->preferred_parent);
816 if(last_parent == NULL || best_dag->rank < best_dag->min_rank) {
819 best_dag->min_rank = best_dag->rank;
822 if(!acceptable_rank(best_dag, best_dag->rank)) {
823 LOG_WARN(
"New rank unacceptable!\n");
824 rpl_set_preferred_parent(instance->current_dag, NULL);
825 if(RPL_IS_STORING(instance) && last_parent != NULL) {
827 dao_output(last_parent, RPL_ZERO_LIFETIME);
832 if(best_dag->preferred_parent != last_parent) {
833 rpl_set_default_route(instance, rpl_parent_get_ipaddr(best_dag->preferred_parent));
834 LOG_INFO(
"Changed preferred parent, rank changed from %u to %u\n",
835 (
unsigned)old_rank, best_dag->rank);
836 RPL_STAT(rpl_stats.parent_switch++);
837 if(RPL_IS_STORING(instance)) {
838 if(last_parent != NULL) {
840 dao_output(last_parent, RPL_ZERO_LIFETIME);
844 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
847 rpl_schedule_dao(instance);
848 rpl_reset_dio_timer(instance);
849 if(LOG_DBG_ENABLED) {
850 rpl_print_neighbor_list();
852 }
else if(best_dag->rank != old_rank) {
853 LOG_DBG(
"RPL: Preferred parent update, rank changed from %u to %u\n",
854 (
unsigned)old_rank, best_dag->rank);
859 static rpl_parent_t *
860 best_parent(
rpl_dag_t *dag,
int fresh_only)
864 rpl_parent_t *best = NULL;
866 if(dag == NULL || dag->instance == NULL || dag->instance->of == NULL) {
870 of = dag->instance->of;
872 for(p = nbr_table_head(rpl_parents); p != NULL; p = nbr_table_next(rpl_parents, p)) {
875 if(p->dag != dag || p->rank == RPL_INFINITE_RANK || p->rank <
ROOT_RANK(dag->instance)) {
877 LOG_WARN(
"Parent has invalid rank\n");
882 if(fresh_only && !rpl_parent_is_fresh(p)) {
889 if(rpl_get_nbr(p) == NULL) {
895 best = of->best_parent(best, p);
905 rpl_parent_t *best = best_parent(dag, 0);
909 if(rpl_parent_is_fresh(best)) {
910 rpl_set_preferred_parent(dag, best);
912 dag->instance->urgent_probing_target = NULL;
915 rpl_parent_t *best_fresh = best_parent(dag, 1);
916 if(best_fresh == NULL) {
918 rpl_set_preferred_parent(dag, best);
921 rpl_set_preferred_parent(dag, best_fresh);
924 dag->instance->urgent_probing_target = best;
928 rpl_set_preferred_parent(dag, best);
929 dag->rank = rpl_rank_via_parent(dag->preferred_parent);
932 rpl_set_preferred_parent(dag, NULL);
935 dag->rank = rpl_rank_via_parent(dag->preferred_parent);
936 return dag->preferred_parent;
940 rpl_remove_parent(rpl_parent_t *parent)
942 LOG_INFO(
"Removing parent ");
943 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(parent));
946 rpl_nullify_parent(parent);
948 nbr_table_remove(rpl_parents, parent);
952 rpl_nullify_parent(rpl_parent_t *parent)
957 if(parent == dag->preferred_parent || dag->preferred_parent == NULL) {
958 dag->rank = RPL_INFINITE_RANK;
960 if(dag->instance->def_route != NULL) {
961 LOG_DBG(
"Removing default route ");
962 LOG_DBG_6ADDR(rpl_parent_get_ipaddr(parent));
964 uip_ds6_defrt_rm(dag->instance->def_route);
965 dag->instance->def_route = NULL;
968 if(parent == dag->preferred_parent) {
969 if(RPL_IS_STORING(dag->instance)) {
970 dao_output(parent, RPL_ZERO_LIFETIME);
972 rpl_set_preferred_parent(dag, NULL);
977 LOG_INFO(
"Nullifying parent ");
978 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(parent));
985 if(parent == dag_src->preferred_parent) {
986 rpl_set_preferred_parent(dag_src, NULL);
987 dag_src->rank = RPL_INFINITE_RANK;
988 if(dag_src->joined && dag_src->instance->def_route != NULL) {
989 LOG_DBG(
"Removing default route ");
990 LOG_DBG_6ADDR(rpl_parent_get_ipaddr(parent));
992 LOG_DBG(
"rpl_move_parent\n");
993 uip_ds6_defrt_rm(dag_src->instance->def_route);
994 dag_src->instance->def_route = NULL;
996 }
else if(dag_src->joined) {
997 if(RPL_IS_STORING(dag_src->instance)) {
999 rpl_remove_routes_by_nexthop(rpl_parent_get_ipaddr(parent), dag_src);
1003 LOG_INFO(
"Moving parent ");
1004 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(parent));
1007 parent->dag = dag_dst;
1011 rpl_get_any_dag_with_parent(
bool requires_parent)
1015 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1016 if(instance_table[i].used
1017 && instance_table[i].current_dag->joined
1018 && (!requires_parent || instance_table[i].current_dag->preferred_parent != NULL)) {
1019 return instance_table[i].current_dag;
1031 return rpl_get_any_dag_with_parent(
true) != NULL;
1041 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1042 if(instance_table[i].used && instance_table[i].has_downward_route) {
1050 rpl_get_dag(
const uip_ipaddr_t *addr)
1054 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1055 if(instance_table[i].used) {
1056 for(j = 0; j < RPL_MAX_DAG_PER_INSTANCE; ++j) {
1057 if(instance_table[i].dag_table[j].joined
1058 && uip_ipaddr_prefixcmp(&instance_table[i].dag_table[j].dag_id, addr,
1059 instance_table[i].dag_table[j].prefix_info.length)) {
1060 return &instance_table[i].dag_table[j];
1071 return rpl_get_any_dag_with_parent(
false);
1075 rpl_get_instance(uint8_t instance_id)
1079 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1080 if(instance_table[i].used && instance_table[i].instance_id == instance_id) {
1081 return &instance_table[i];
1088 rpl_find_of(rpl_ocp_t ocp)
1093 i <
sizeof(objective_functions) /
sizeof(objective_functions[0]);
1095 if(objective_functions[i]->ocp == ocp) {
1096 return objective_functions[i];
1104 rpl_join_instance(uip_ipaddr_t *from, rpl_dio_t *dio)
1111 if((!RPL_WITH_NON_STORING && dio->mop == RPL_MOP_NON_STORING)
1112 || (!RPL_WITH_STORING && (dio->mop == RPL_MOP_STORING_NO_MULTICAST
1113 || dio->mop == RPL_MOP_STORING_MULTICAST))) {
1114 LOG_WARN(
"DIO advertising a non-supported MOP %u\n", dio->mop);
1120 of = rpl_find_of(dio->ocp);
1122 LOG_WARN(
"DIO for DAG instance %u does not specify a supported OF: %u\n",
1123 dio->instance_id, dio->ocp);
1127 dag = rpl_alloc_dag(dio->instance_id, &dio->dag_id);
1129 LOG_ERR(
"Failed to allocate a DAG object!\n");
1133 instance = dag->instance;
1135 p = rpl_add_parent(dag, dio, from);
1137 LOG_DBG_6ADDR(from);
1138 LOG_DBG_(
" as a parent: ");
1140 LOG_DBG_(
"failed\n");
1144 p->dtsn = dio->dtsn;
1145 LOG_DBG_(
"succeeded\n");
1149 if(dio->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
1150 check_prefix(NULL, &dio->prefix_info);
1154 dag->preference = dio->preference;
1155 dag->grounded = dio->grounded;
1156 dag->version = dio->version;
1159 instance->mop = dio->mop;
1160 instance->mc.type = dio->mc.type;
1161 instance->mc.flags = dio->mc.flags;
1162 instance->mc.aggr = dio->mc.aggr;
1163 instance->mc.prec = dio->mc.prec;
1164 instance->current_dag = dag;
1165 instance->dtsn_out = RPL_LOLLIPOP_INIT;
1167 instance->max_rankinc = dio->dag_max_rankinc;
1168 instance->min_hoprankinc = dio->dag_min_hoprankinc;
1169 instance->dio_intdoubl = dio->dag_intdoubl;
1170 instance->dio_intmin = dio->dag_intmin;
1171 instance->dio_intcurrent = instance->dio_intmin + instance->dio_intdoubl;
1172 instance->dio_redundancy = dio->dag_redund;
1173 instance->default_lifetime = dio->default_lifetime;
1174 instance->lifetime_unit = dio->lifetime_unit;
1176 memcpy(&dag->dag_id, &dio->dag_id,
sizeof(dio->dag_id));
1179 memcpy(&dag->prefix_info, &dio->prefix_info,
sizeof(
rpl_prefix_t));
1181 rpl_set_preferred_parent(dag, p);
1182 instance->of->update_metric_container(instance);
1183 dag->rank = rpl_rank_via_parent(p);
1185 dag->min_rank = dag->rank;
1187 if(default_instance == NULL) {
1188 default_instance = instance;
1191 LOG_INFO(
"Joined DAG with instance ID %u, rank %hu, DAG ID ",
1192 dio->instance_id, dag->rank);
1193 LOG_INFO_6ADDR(&dag->dag_id);
1196 LOG_ANNOTATE(
"#A join=%u\n", dag->dag_id.u8[
sizeof(dag->dag_id) - 1]);
1198 rpl_reset_dio_timer(instance);
1199 rpl_set_default_route(instance, from);
1201 if(instance->mop != RPL_MOP_NO_DOWNWARD_ROUTES) {
1202 rpl_schedule_dao(instance);
1204 LOG_WARN(
"The DIO does not meet the prerequisites for sending a DAO\n");
1207 instance->of->reset(dag);
1210 #if RPL_MAX_DAG_PER_INSTANCE > 1 1213 rpl_add_dag(uip_ipaddr_t *from, rpl_dio_t *dio)
1220 dag = rpl_alloc_dag(dio->instance_id, &dio->dag_id);
1222 LOG_ERR(
"Failed to allocate a DAG object!\n");
1226 instance = dag->instance;
1228 previous_dag = find_parent_dag(instance, from);
1229 if(previous_dag == NULL) {
1231 LOG_DBG_6ADDR(from);
1232 LOG_DBG_(
" as a parent: ");
1233 p = rpl_add_parent(dag, dio, from);
1235 LOG_DBG_(
"failed\n");
1239 LOG_DBG_(
"succeeded\n");
1241 p = rpl_find_parent(previous_dag, from);
1243 rpl_move_parent(previous_dag, dag, p);
1246 p->rank = dio->rank;
1250 of = rpl_find_of(dio->ocp);
1251 if(of != instance->of ||
1252 instance->mop != dio->mop ||
1253 instance->max_rankinc != dio->dag_max_rankinc ||
1254 instance->min_hoprankinc != dio->dag_min_hoprankinc ||
1255 instance->dio_intdoubl != dio->dag_intdoubl ||
1256 instance->dio_intmin != dio->dag_intmin ||
1257 instance->dio_redundancy != dio->dag_redund ||
1258 instance->default_lifetime != dio->default_lifetime ||
1259 instance->lifetime_unit != dio->lifetime_unit) {
1260 LOG_WARN(
"DIO for DAG instance %u incompatible with previous DIO\n",
1262 rpl_remove_parent(p);
1268 dag->grounded = dio->grounded;
1269 dag->preference = dio->preference;
1270 dag->version = dio->version;
1272 memcpy(&dag->dag_id, &dio->dag_id,
sizeof(dio->dag_id));
1275 memcpy(&dag->prefix_info, &dio->prefix_info,
sizeof(
rpl_prefix_t));
1277 rpl_set_preferred_parent(dag, p);
1278 dag->rank = rpl_rank_via_parent(p);
1279 dag->min_rank = dag->rank;
1281 LOG_INFO(
"Joined DAG with instance ID %u, rank %hu, DAG ID ",
1282 dio->instance_id, dag->rank);
1283 LOG_INFO_6ADDR(&dag->dag_id);
1286 LOG_ANNOTATE(
"#A join=%u\n", dag->dag_id.u8[
sizeof(dag->dag_id) - 1]);
1288 rpl_process_parent_event(instance, p);
1289 p->dtsn = dio->dtsn;
1297 global_repair(uip_ipaddr_t *from,
rpl_dag_t *dag, rpl_dio_t *dio)
1301 remove_parents(dag, 0);
1302 dag->version = dio->version;
1305 dag->instance->dio_intdoubl = dio->dag_intdoubl;
1306 dag->instance->dio_intmin = dio->dag_intmin;
1307 dag->instance->dio_redundancy = dio->dag_redund;
1308 dag->instance->default_lifetime = dio->default_lifetime;
1309 dag->instance->lifetime_unit = dio->lifetime_unit;
1311 dag->instance->of->reset(dag);
1312 dag->min_rank = RPL_INFINITE_RANK;
1313 RPL_LOLLIPOP_INCREMENT(dag->instance->dtsn_out);
1315 p = rpl_add_parent(dag, dio, from);
1317 LOG_ERR(
"Failed to add a parent during the global repair\n");
1318 dag->rank = RPL_INFINITE_RANK;
1320 dag->rank = rpl_rank_via_parent(p);
1321 dag->min_rank = dag->rank;
1322 LOG_DBG(
"rpl_process_parent_event global repair\n");
1323 rpl_process_parent_event(dag->instance, p);
1326 LOG_DBG(
"Participating in a global repair (version=%u, rank=%hu)\n",
1327 dag->version, dag->rank);
1329 RPL_STAT(rpl_stats.global_repairs++);
1338 if(instance == NULL) {
1339 LOG_WARN(
"local repair requested for instance NULL\n");
1342 LOG_INFO(
"Starting a local instance repair\n");
1343 for(i = 0; i < RPL_MAX_DAG_PER_INSTANCE; i++) {
1344 if(instance->dag_table[i].used) {
1345 instance->dag_table[i].rank = RPL_INFINITE_RANK;
1346 nullify_parents(&instance->dag_table[i], 0);
1351 instance->has_downward_route = 0;
1352 #if RPL_WITH_DAO_ACK 1356 rpl_reset_dio_timer(instance);
1357 if(RPL_IS_STORING(instance)) {
1361 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
1364 RPL_STAT(rpl_stats.local_repairs++);
1368 rpl_recalculate_ranks(
void)
1377 p = nbr_table_head(rpl_parents);
1379 if(p->dag != NULL && p->dag->instance && (p->flags & RPL_PARENT_FLAG_UPDATED)) {
1380 p->flags &= ~RPL_PARENT_FLAG_UPDATED;
1381 LOG_DBG(
"rpl_process_parent_event recalculate_ranks\n");
1382 if(!rpl_process_parent_event(p->dag->instance, p)) {
1383 LOG_DBG(
"A parent was dropped\n");
1386 p = nbr_table_next(rpl_parents, p);
1391 rpl_process_parent_event(
rpl_instance_t *instance, rpl_parent_t *p)
1394 rpl_parent_t *last_parent = instance->current_dag->preferred_parent;
1397 rpl_rank_t old_rank;
1398 old_rank = instance->current_dag->rank;
1403 if(RPL_IS_STORING(instance)
1404 && uip_ds6_route_is_nexthop(rpl_parent_get_ipaddr(p))
1405 && !rpl_parent_is_reachable(p) && instance->mop > RPL_MOP_NON_STORING) {
1406 LOG_WARN(
"Unacceptable link %u, removing routes via: ", rpl_get_parent_link_metric(p));
1407 LOG_WARN_6ADDR(rpl_parent_get_ipaddr(p));
1409 rpl_remove_routes_by_nexthop(rpl_parent_get_ipaddr(p), p->dag);
1412 if(!acceptable_rank(p->dag, rpl_rank_via_parent(p))) {
1415 LOG_WARN(
"Unacceptable rank %u (Current min %u, MaxRankInc %u)\n", (
unsigned)p->rank,
1416 p->dag->min_rank, p->dag->instance->max_rankinc);
1417 rpl_nullify_parent(p);
1418 if(p != instance->current_dag->preferred_parent) {
1425 if(rpl_select_dag(instance, p) == NULL) {
1426 if(last_parent != NULL) {
1428 LOG_ERR(
"No parents found in any DAG\n");
1435 if(
DAG_RANK(old_rank, instance) !=
DAG_RANK(instance->current_dag->rank, instance)) {
1436 LOG_INFO(
"Moving in the instance from rank %hu to %hu\n",
1437 DAG_RANK(old_rank, instance),
DAG_RANK(instance->current_dag->rank, instance));
1438 if(instance->current_dag->rank != RPL_INFINITE_RANK) {
1439 LOG_DBG(
"The preferred parent is ");
1440 LOG_DBG_6ADDR(rpl_parent_get_ipaddr(instance->current_dag->preferred_parent));
1441 LOG_DBG_(
" (rank %u)\n",
1442 (
unsigned)
DAG_RANK(instance->current_dag->preferred_parent->rank, instance));
1444 LOG_WARN(
"We don't have any parent");
1449 return return_value;
1453 add_nbr_from_dio(uip_ipaddr_t *from, rpl_dio_t *dio)
1457 LOG_ERR(
"Out of memory, dropping DIO from ");
1458 LOG_ERR_6ADDR(from);
1472 #if RPL_WITH_MULTICAST 1475 if(dio->mop < RPL_MOP_STORING_NO_MULTICAST) {
1477 if(dio->mop != RPL_MOP_DEFAULT) {
1479 LOG_ERR(
"Ignoring a DIO with an unsupported MOP: %d\n", dio->mop);
1483 dag = get_dag(dio->instance_id, &dio->dag_id);
1484 instance = rpl_get_instance(dio->instance_id);
1486 if(dag != NULL && instance != NULL) {
1487 if(lollipop_greater_than(dio->version, dag->version)) {
1489 LOG_WARN(
"Root received inconsistent DIO version number (current: %u, received: %u)\n", dag->version, dio->version);
1490 dag->version = dio->version;
1491 RPL_LOLLIPOP_INCREMENT(dag->version);
1492 rpl_reset_dio_timer(instance);
1494 LOG_DBG(
"Global repair\n");
1495 if(dio->prefix_info.length != 0) {
1496 if(dio->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
1497 LOG_DBG(
"Prefix announced in DIO\n");
1498 rpl_set_prefix(dag, &dio->prefix_info.prefix, dio->prefix_info.length);
1501 global_repair(from, dag, dio);
1506 if(lollipop_greater_than(dag->version, dio->version)) {
1508 LOG_WARN(
"old version received => inconsistency detected\n");
1510 rpl_reset_dio_timer(instance);
1516 if(instance == NULL) {
1517 LOG_INFO(
"New instance detected (ID=%u): Joining...\n", dio->instance_id);
1518 if(add_nbr_from_dio(from, dio)) {
1519 rpl_join_instance(from, dio);
1521 LOG_WARN(
"Not joining since could not add parent\n");
1526 if(instance->current_dag->rank ==
ROOT_RANK(instance) && instance->current_dag != dag) {
1527 LOG_WARN(
"Root ignored DIO for different DAG\n");
1532 #if RPL_MAX_DAG_PER_INSTANCE > 1 1533 LOG_INFO(
"Adding new DAG to known instance.\n");
1534 if(!add_nbr_from_dio(from, dio)) {
1535 LOG_WARN(
"Could not add new DAG, could not add parent\n");
1538 dag = rpl_add_dag(from, dio);
1540 LOG_WARN(
"Failed to add DAG.\n");
1544 LOG_WARN(
"Only one instance supported.\n");
1551 LOG_INFO(
"Ignoring DIO with too low rank: %u\n",
1552 (
unsigned)dio->rank);
1557 if(dio->prefix_info.length != 0) {
1558 if(dio->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
1559 LOG_DBG(
"Prefix announced in DIO\n");
1560 rpl_set_prefix(dag, &dio->prefix_info.prefix, dio->prefix_info.length);
1564 if(!add_nbr_from_dio(from, dio)) {
1565 LOG_WARN(
"Could not add parent based on DIO\n");
1570 if(dio->rank != RPL_INFINITE_RANK) {
1571 instance->dio_counter++;
1577 dag->lifetime = (1UL << (instance->dio_intmin + instance->dio_intdoubl)) * RPL_DAG_LIFETIME / 1000;
1578 LOG_INFO(
"Set dag ");
1579 LOG_INFO_6ADDR(&dag->dag_id);
1580 LOG_INFO_(
" lifetime to %ld\n", (
long int) dag->lifetime);
1589 p = rpl_find_parent(dag, from);
1591 previous_dag = find_parent_dag(instance, from);
1592 if(previous_dag == NULL) {
1594 p = rpl_add_parent(dag, dio, from);
1596 LOG_WARN(
"Failed to add a new parent (");
1597 LOG_WARN_6ADDR(from);
1601 LOG_INFO(
"New candidate parent with rank %u: ", (
unsigned)p->rank);
1602 LOG_INFO_6ADDR(from);
1605 p = rpl_find_parent(previous_dag, from);
1607 rpl_move_parent(previous_dag, dag, p);
1611 if(p->rank == dio->rank) {
1612 LOG_INFO(
"Received consistent DIO\n");
1614 instance->dio_counter++;
1618 p->rank = dio->rank;
1620 if(dio->rank == RPL_INFINITE_RANK && p == dag->preferred_parent) {
1622 rpl_reset_dio_timer(instance);
1626 p->flags |= RPL_PARENT_FLAG_UPDATED;
1628 LOG_INFO(
"preferred DAG ");
1629 LOG_INFO_6ADDR(&instance->current_dag->dag_id);
1630 LOG_INFO_(
", rank %u, min_rank %u, ",
1631 instance->current_dag->rank, instance->current_dag->min_rank);
1632 LOG_INFO_(
"parent rank %u, link metric %u\n",
1633 p->rank, rpl_get_parent_link_metric(p));
1638 memcpy(&p->mc, &dio->mc,
sizeof(p->mc));
1640 if(rpl_process_parent_event(instance, p) == 0) {
1641 LOG_WARN(
"The candidate parent is rejected\n");
1646 if(dag->joined && p == dag->preferred_parent) {
1647 if(should_refresh_routes(instance, dio, p)) {
1650 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
1651 rpl_schedule_dao(instance);
1655 uip_ds6_defrt_add(from, RPL_DEFAULT_ROUTE_INFINITE_LIFETIME ? 0 :
RPL_LIFETIME(instance, instance->default_lifetime));
1657 p->dtsn = dio->dtsn;
static uip_ipaddr_t ipaddr
Pointer to prefix information option in uip_buf.
uip_lladdr_t uip_lladdr
Host L2 address.
void ctimer_stop(struct ctimer *c)
Stop a pending callback timer.
#define ROOT_RANK
Rank of a root node.
static uip_ds6_addr_t * addr
Pointer to a nbr cache entry.
void rpl_schedule_probing_now(void)
Schedule probing within a few seconds.
IPv6 Neighbor cache (link-layer/IPv6 address mapping)
#define RPL_LIFETIME(lifetime)
Compute lifetime, accounting for the lifetime unit.
void uip_ds6_set_addr_iid(uip_ipaddr_t *ipaddr, uip_lladdr_t *lladdr)
set the last 64 bits of an IP address based on the MAC address
int rpl_dag_root_is_root(void)
Tells whether we are DAG root or not.
int uip_ds6_nbr_num(void)
Return the number of neighbor caches.
API for RPL objective functions (OF)
This header file contains configuration directives for uIPv6 multicast support.
#define CLOCK_SECOND
A second, measured in system clock time.
#define DAG_RANK(fixpt_rank)
Return DAG RANK as per RFC 6550 (rank divided by min_hoprankinc)
int rpl_has_downward_route(void)
Get the RPL's best guess on if we have downward route or not.
Header file for the callback timer
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.
uip_ds6_nbr_t * uip_ds6_nbr_lookup(const uip_ipaddr_t *ipaddr)
Get the neighbor cache associated with a specified IPv6 address.
Unicast address structure.
rpl_dag_t * rpl_get_any_dag(void)
Returns pointer to any DAG (for compatibility with legagy RPL code)
clock_time_t clock_time(void)
Get the current clock time.
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.
Memory block allocation routines.
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.
uip_ds6_nbr_t * rpl_icmp6_update_nbr_table(uip_ipaddr_t *from, nbr_table_reason_t reason, void *data)
Updates IPv6 neighbor cache on incoming link-local RPL ICMPv6 messages.
Header file for the uIP TCP/IP stack.
Header file for IPv6 Neighbor discovery (RFC 4861)
void rpl_process_dio(uip_ipaddr_t *from, rpl_dio_t *dio)
Processes incoming DIO.
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.
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.
void rpl_local_repair(const char *str)
Triggers a RPL local repair.
Header file for the logging system
rpl_instance_t * rpl_get_default_instance(void)
Returns pointer to the default instance (for compatibility with legagy RPL code)
void rpl_dag_init(void)
Initializes rpl-dag module.
The default nbr_table entry (when UIP_DS6_NBR_MULTI_IPV6_ADDRS is disabled), that implements nbr cach...
void rpl_schedule_probing(void)
Schedule probing with delay RPL_PROBING_DELAY_FUNC()