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 printf(
"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 printf(
"RPL: nbr %3u %5u, %5u => %5u -- %2u %c%c (last tx %u min ago)\n",
109 rpl_parent_get_ipaddr(p)->u8[15],
111 rpl_get_parent_link_metric(p),
112 rpl_rank_via_parent(p),
113 stats != NULL ? stats->freshness : 0,
114 link_stats_is_fresh(stats) ?
'f' :
' ',
115 p == default_instance->current_dag->preferred_parent ?
'p' :
' ',
116 (
unsigned)((clock_now - stats->last_tx_time) / (60 *
CLOCK_SECOND))
118 p = nbr_table_next(rpl_parents, p);
120 printf(
"RPL: end of list\n");
125 rpl_get_nbr(rpl_parent_t *parent)
127 const linkaddr_t *lladdr = rpl_get_parent_lladdr(parent);
129 return nbr_table_get_from_lladdr(ds6_neighbors, lladdr);
136 nbr_callback(
void *ptr)
138 rpl_remove_parent(ptr);
144 nbr_table_register(rpl_parents, (nbr_table_callback *)nbr_callback);
148 rpl_get_parent(uip_lladdr_t *
addr)
150 rpl_parent_t *p = nbr_table_get_from_lladdr(rpl_parents, (linkaddr_t *)addr);
155 rpl_get_parent_rank(uip_lladdr_t *addr)
157 rpl_parent_t *p = nbr_table_get_from_lladdr(rpl_parents, (linkaddr_t *)addr);
161 return RPL_INFINITE_RANK;
166 rpl_get_parent_link_metric(rpl_parent_t *p)
168 if(p != NULL && p->dag != NULL) {
170 if(instance != NULL && instance->of != NULL && instance->of->parent_link_metric != NULL) {
171 return instance->of->parent_link_metric(p);
178 rpl_rank_via_parent(rpl_parent_t *p)
180 if(p != NULL && p->dag != NULL) {
182 if(instance != NULL && instance->of != NULL && instance->of->rank_via_parent != NULL) {
183 return instance->of->rank_via_parent(p);
186 return RPL_INFINITE_RANK;
190 rpl_get_parent_lladdr(rpl_parent_t *p)
192 return nbr_table_get_lladdr(rpl_parents, p);
196 rpl_parent_get_ipaddr(rpl_parent_t *p)
198 const linkaddr_t *lladdr = rpl_get_parent_lladdr(p);
199 return uip_ds6_nbr_ipaddr_from_lladdr((uip_lladdr_t *)lladdr);
202 const struct link_stats *
203 rpl_get_parent_link_stats(rpl_parent_t *p)
205 const linkaddr_t *lladdr = rpl_get_parent_lladdr(p);
206 return link_stats_from_lladdr(lladdr);
210 rpl_parent_is_fresh(rpl_parent_t *p)
212 const struct link_stats *stats = rpl_get_parent_link_stats(p);
213 return link_stats_is_fresh(stats);
217 rpl_parent_is_reachable(rpl_parent_t *p) {
218 if(p == NULL || p->dag == NULL || p->dag->instance == NULL || p->dag->instance->of == NULL) {
224 if(nbr == NULL || nbr->state != NBR_REACHABLE) {
229 return !rpl_parent_is_fresh(p) || p->dag->instance->of->parent_has_usable_link(p);
234 rpl_set_preferred_parent(
rpl_dag_t *dag, rpl_parent_t *p)
236 if(dag != NULL && dag->preferred_parent != p) {
237 LOG_INFO(
"rpl_set_preferred_parent ");
239 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(p));
243 LOG_INFO_(
" used to be ");
244 if(dag->preferred_parent != NULL) {
245 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(dag->preferred_parent));
251 #ifdef RPL_CALLBACK_PARENT_SWITCH 252 RPL_CALLBACK_PARENT_SWITCH(dag->preferred_parent, p);
257 nbr_table_unlock(rpl_parents, dag->preferred_parent);
258 nbr_table_lock(rpl_parents, p);
259 dag->preferred_parent = p;
266 lollipop_greater_than(
int a,
int b)
269 if(a > RPL_LOLLIPOP_CIRCULAR_REGION && b <= RPL_LOLLIPOP_CIRCULAR_REGION) {
270 return (RPL_LOLLIPOP_MAX_VALUE + 1 + b - a) > RPL_LOLLIPOP_SEQUENCE_WINDOWS;
274 return (a > b && (a - b) < RPL_LOLLIPOP_SEQUENCE_WINDOWS) ||
275 (a < b && (b - a) > (RPL_LOLLIPOP_CIRCULAR_REGION + 1-
276 RPL_LOLLIPOP_SEQUENCE_WINDOWS));
281 remove_parents(
rpl_dag_t *dag, rpl_rank_t minimum_rank)
285 LOG_INFO(
"Removing parents (minimum rank %u)\n", minimum_rank);
287 p = nbr_table_head(rpl_parents);
289 if(dag == p->dag && p->rank >= minimum_rank) {
290 rpl_remove_parent(p);
292 p = nbr_table_next(rpl_parents, p);
297 nullify_parents(
rpl_dag_t *dag, rpl_rank_t minimum_rank)
301 LOG_INFO(
"Nullifying parents (minimum rank %u)\n", minimum_rank);
303 p = nbr_table_head(rpl_parents);
305 if(dag == p->dag && p->rank >= minimum_rank) {
306 rpl_nullify_parent(p);
308 p = nbr_table_next(rpl_parents, p);
313 should_refresh_routes(
rpl_instance_t *instance, rpl_dio_t *dio, rpl_parent_t *p)
316 if(instance->mop == RPL_MOP_NO_DOWNWARD_ROUTES) {
320 return p == instance->current_dag->preferred_parent &&
321 (lollipop_greater_than(dio->dtsn, p->dtsn));
325 acceptable_rank(
rpl_dag_t *dag, rpl_rank_t rank)
327 return rank != RPL_INFINITE_RANK &&
328 ((dag->instance->max_rankinc == 0) ||
329 DAG_RANK(rank, dag->instance) <=
DAG_RANK(dag->min_rank + dag->instance->max_rankinc, dag->instance));
333 get_dag(uint8_t instance_id, uip_ipaddr_t *dag_id)
339 instance = rpl_get_instance(instance_id);
340 if(instance == NULL) {
344 for(i = 0; i < RPL_MAX_DAG_PER_INSTANCE; ++i) {
345 dag = &instance->dag_table[i];
346 if(dag->used && uip_ipaddr_cmp(&dag->dag_id, dag_id)) {
355 rpl_set_root(uint8_t instance_id, uip_ipaddr_t *dag_id)
362 version = RPL_LOLLIPOP_INIT;
363 instance = rpl_get_instance(instance_id);
364 if(instance != NULL) {
365 for(i = 0; i < RPL_MAX_DAG_PER_INSTANCE; ++i) {
366 dag = &instance->dag_table[i];
368 if(uip_ipaddr_cmp(&dag->dag_id, dag_id)) {
369 version = dag->version;
370 RPL_LOLLIPOP_INCREMENT(version);
372 if(dag == dag->instance->current_dag) {
373 LOG_INFO(
"Dropping a joined DAG when setting this node as root\n");
374 rpl_set_default_route(instance, NULL);
375 dag->instance->current_dag = NULL;
377 LOG_INFO(
"Dropping a DAG when setting this node as root\n");
384 dag = rpl_alloc_dag(instance_id, dag_id);
386 LOG_ERR(
"Failed to allocate a DAG\n");
390 instance = dag->instance;
392 dag->version = version;
394 dag->grounded = RPL_GROUNDED;
395 dag->preference = RPL_PREFERENCE;
396 instance->mop = RPL_MOP_DEFAULT;
397 instance->of = rpl_find_of(RPL_OF_OCP);
398 if(instance->of == NULL) {
399 LOG_WARN(
"OF with OCP %u not supported\n", RPL_OF_OCP);
403 rpl_set_preferred_parent(dag, NULL);
405 memcpy(&dag->dag_id, dag_id,
sizeof(dag->dag_id));
407 instance->dio_intdoubl = RPL_DIO_INTERVAL_DOUBLINGS;
408 instance->dio_intmin = RPL_DIO_INTERVAL_MIN;
411 instance->dio_intcurrent = RPL_DIO_INTERVAL_MIN +
412 RPL_DIO_INTERVAL_DOUBLINGS;
413 instance->dio_redundancy = RPL_DIO_REDUNDANCY;
414 instance->max_rankinc = RPL_MAX_RANKINC;
415 instance->min_hoprankinc = RPL_MIN_HOPRANKINC;
416 instance->default_lifetime = RPL_DEFAULT_LIFETIME;
417 instance->lifetime_unit = RPL_DEFAULT_LIFETIME_UNIT;
421 if(instance->current_dag != dag && instance->current_dag != NULL) {
423 if(RPL_IS_STORING(instance)) {
424 rpl_remove_routes(instance->current_dag);
427 instance->current_dag->joined = 0;
430 instance->current_dag = dag;
431 instance->dtsn_out = RPL_LOLLIPOP_INIT;
432 instance->of->update_metric_container(instance);
433 default_instance = instance;
435 LOG_INFO(
"Node set to be a DAG root with DAG ID ");
436 LOG_INFO_6ADDR(&dag->dag_id);
439 LOG_ANNOTATE(
"#A root=%u\n", dag->dag_id.u8[
sizeof(dag->dag_id) - 1]);
441 rpl_reset_dio_timer(instance);
447 rpl_repair_root(uint8_t instance_id)
451 instance = rpl_get_instance(instance_id);
452 if(instance == NULL ||
453 instance->current_dag->rank !=
ROOT_RANK(instance)) {
454 LOG_WARN(
"rpl_repair_root triggered but not root\n");
457 RPL_STAT(rpl_stats.root_repairs++);
459 RPL_LOLLIPOP_INCREMENT(instance->current_dag->version);
460 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
461 LOG_INFO(
"rpl_repair_root initiating global repair with version %d\n", instance->current_dag->version);
462 rpl_reset_dio_timer(instance);
469 memset(ipaddr, 0,
sizeof(uip_ipaddr_t));
470 memcpy(ipaddr, &prefix->prefix, (prefix->length + 7) / 8);
480 if(last_prefix != NULL && new_prefix != NULL &&
481 last_prefix->length == new_prefix->length &&
482 uip_ipaddr_prefixcmp(&last_prefix->prefix, &new_prefix->prefix, new_prefix->length) &&
483 last_prefix->flags == new_prefix->flags) {
488 if(last_prefix != NULL) {
489 set_ip_from_prefix(&ipaddr, last_prefix);
490 rep = uip_ds6_addr_lookup(&ipaddr);
492 LOG_DBG(
"removing global IP address ");
493 LOG_DBG_6ADDR(&ipaddr);
495 uip_ds6_addr_rm(rep);
499 if(new_prefix != NULL) {
500 set_ip_from_prefix(&ipaddr, new_prefix);
501 if(uip_ds6_addr_lookup(&ipaddr) == NULL) {
502 LOG_DBG(
"adding global IP address ");
503 LOG_DBG_6ADDR(&ipaddr);
511 rpl_set_prefix(
rpl_dag_t *dag, uip_ipaddr_t *prefix,
unsigned len)
514 uint8_t last_len = dag->prefix_info.length;
519 if(dag->prefix_info.length != 0) {
520 memcpy(&last_prefix, &dag->prefix_info,
sizeof(
rpl_prefix_t));
522 memset(&dag->prefix_info.prefix, 0,
sizeof(dag->prefix_info.prefix));
523 memcpy(&dag->prefix_info.prefix, prefix, (len + 7) / 8);
524 dag->prefix_info.length = len;
525 dag->prefix_info.flags = UIP_ND6_RA_FLAG_AUTONOMOUS;
526 LOG_INFO(
"Prefix set - will announce this in DIOs\n");
527 if(dag->rank !=
ROOT_RANK(dag->instance)) {
531 LOG_INFO(
"rpl_set_prefix - prefix NULL\n");
532 check_prefix(NULL, &dag->prefix_info);
534 LOG_INFO(
"rpl_set_prefix - prefix NON-NULL\n");
535 check_prefix(&last_prefix, &dag->prefix_info);
542 rpl_set_default_route(
rpl_instance_t *instance, uip_ipaddr_t *from)
544 if(instance->def_route != NULL) {
545 LOG_DBG(
"Removing default route through ");
546 LOG_DBG_6ADDR(&instance->def_route->ipaddr);
548 uip_ds6_defrt_rm(instance->def_route);
549 instance->def_route = NULL;
553 LOG_DBG(
"Adding default route through ");
556 instance->def_route = uip_ds6_defrt_add(from,
557 RPL_DEFAULT_ROUTE_INFINITE_LIFETIME ? 0 :
RPL_LIFETIME(instance, instance->default_lifetime));
558 if(instance->def_route == NULL) {
566 rpl_alloc_instance(uint8_t instance_id)
570 for(instance = &instance_table[0], end = instance + RPL_MAX_INSTANCES;
571 instance < end; ++instance) {
572 if(instance->used == 0) {
573 memset(instance, 0,
sizeof(*instance));
574 instance->instance_id = instance_id;
575 instance->def_route = NULL;
587 rpl_alloc_dag(uint8_t instance_id, uip_ipaddr_t *dag_id)
592 instance = rpl_get_instance(instance_id);
593 if(instance == NULL) {
594 instance = rpl_alloc_instance(instance_id);
595 if(instance == NULL) {
596 RPL_STAT(rpl_stats.mem_overflows++);
601 for(dag = &instance->dag_table[0], end = dag + RPL_MAX_DAG_PER_INSTANCE; dag < end; ++dag) {
603 memset(dag, 0,
sizeof(*dag));
605 dag->rank = RPL_INFINITE_RANK;
606 dag->min_rank = RPL_INFINITE_RANK;
607 dag->instance = instance;
612 RPL_STAT(rpl_stats.mem_overflows++);
619 default_instance = instance;
625 return default_instance;
634 LOG_INFO(
"Leaving the instance %u\n", instance->instance_id);
637 for(dag = &instance->dag_table[0], end = dag + RPL_MAX_DAG_PER_INSTANCE; dag < end; ++dag) {
643 rpl_set_default_route(instance, NULL);
652 if(default_instance == instance) {
653 default_instance = NULL;
663 LOG_INFO(
"Leaving the DAG ");
664 LOG_INFO_6ADDR(&dag->dag_id);
669 if(RPL_IS_STORING(dag->instance)) {
670 rpl_remove_routes(dag);
678 if((dag->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS)) {
679 check_prefix(&dag->prefix_info, NULL);
682 remove_parents(dag, 0);
688 rpl_add_parent(
rpl_dag_t *dag, rpl_dio_t *dio, uip_ipaddr_t *addr)
690 rpl_parent_t *p = NULL;
693 const uip_lladdr_t *lladdr = uip_ds6_nbr_lladdr_from_ipaddr(addr);
695 LOG_DBG(
"rpl_add_parent lladdr %p ", lladdr);
700 p = nbr_table_add_lladdr(rpl_parents, (linkaddr_t *)lladdr,
701 NBR_TABLE_REASON_RPL_DIO, dio);
703 LOG_DBG(
"rpl_add_parent p NULL\n");
709 memcpy(&p->mc, &dio->mc,
sizeof(p->mc));
717 static rpl_parent_t *
718 find_parent_any_dag_any_instance(uip_ipaddr_t *addr)
721 const uip_lladdr_t *lladdr = uip_ds6_nbr_get_ll(ds6_nbr);
722 return nbr_table_get_from_lladdr(rpl_parents, (linkaddr_t *)lladdr);
726 rpl_find_parent(
rpl_dag_t *dag, uip_ipaddr_t *addr)
728 rpl_parent_t *p = find_parent_any_dag_any_instance(addr);
729 if(p != NULL && p->dag == dag) {
739 rpl_parent_t *p = find_parent_any_dag_any_instance(addr);
748 rpl_find_parent_any_dag(
rpl_instance_t *instance, uip_ipaddr_t *addr)
750 rpl_parent_t *p = find_parent_any_dag_any_instance(addr);
751 if(p && p->dag && p->dag->instance == instance) {
761 rpl_parent_t *last_parent;
765 old_rank = instance->current_dag->rank;
766 last_parent = instance->current_dag->preferred_parent;
768 if(instance->current_dag->rank !=
ROOT_RANK(instance)) {
769 rpl_select_parent(p->dag);
773 for(dag = &instance->dag_table[0], end = dag + RPL_MAX_DAG_PER_INSTANCE; dag < end; ++dag) {
774 if(dag->used && dag->preferred_parent != NULL && dag->preferred_parent->rank != RPL_INFINITE_RANK) {
775 if(best_dag == NULL) {
778 best_dag = instance->of->best_dag(best_dag, dag);
783 if(best_dag == NULL) {
788 if(instance->current_dag != best_dag) {
790 if(RPL_IS_STORING(instance)) {
791 rpl_remove_routes(instance->current_dag);
794 LOG_INFO(
"New preferred DAG: ");
795 LOG_INFO_6ADDR(&best_dag->dag_id);
798 if(best_dag->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
799 check_prefix(&instance->current_dag->prefix_info, &best_dag->prefix_info);
800 }
else if(instance->current_dag->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
801 check_prefix(&instance->current_dag->prefix_info, NULL);
804 best_dag->joined = 1;
805 instance->current_dag->joined = 0;
806 instance->current_dag = best_dag;
809 instance->of->update_metric_container(instance);
811 best_dag->rank = rpl_rank_via_parent(best_dag->preferred_parent);
812 if(last_parent == NULL || best_dag->rank < best_dag->min_rank) {
815 best_dag->min_rank = best_dag->rank;
818 if(!acceptable_rank(best_dag, best_dag->rank)) {
819 LOG_WARN(
"New rank unacceptable!\n");
820 rpl_set_preferred_parent(instance->current_dag, NULL);
821 if(RPL_IS_STORING(instance) && last_parent != NULL) {
823 dao_output(last_parent, RPL_ZERO_LIFETIME);
828 if(best_dag->preferred_parent != last_parent) {
829 rpl_set_default_route(instance, rpl_parent_get_ipaddr(best_dag->preferred_parent));
830 LOG_INFO(
"Changed preferred parent, rank changed from %u to %u\n",
831 (
unsigned)old_rank, best_dag->rank);
832 RPL_STAT(rpl_stats.parent_switch++);
833 if(RPL_IS_STORING(instance)) {
834 if(last_parent != NULL) {
836 dao_output(last_parent, RPL_ZERO_LIFETIME);
840 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
843 rpl_schedule_dao(instance);
844 rpl_reset_dio_timer(instance);
845 if(LOG_DBG_ENABLED) {
846 rpl_print_neighbor_list();
848 }
else if(best_dag->rank != old_rank) {
849 LOG_DBG(
"RPL: Preferred parent update, rank changed from %u to %u\n",
850 (
unsigned)old_rank, best_dag->rank);
855 static rpl_parent_t *
856 best_parent(
rpl_dag_t *dag,
int fresh_only)
860 rpl_parent_t *best = NULL;
862 if(dag == NULL || dag->instance == NULL || dag->instance->of == NULL) {
866 of = dag->instance->of;
868 for(p = nbr_table_head(rpl_parents); p != NULL; p = nbr_table_next(rpl_parents, p)) {
871 if(p->dag != dag || p->rank == RPL_INFINITE_RANK || p->rank <
ROOT_RANK(dag->instance)) {
873 LOG_WARN(
"Parent has invalid rank\n");
878 if(fresh_only && !rpl_parent_is_fresh(p)) {
887 if(nbr == NULL || nbr->state != NBR_REACHABLE) {
894 best = of->best_parent(best, p);
904 rpl_parent_t *best = best_parent(dag, 0);
908 if(rpl_parent_is_fresh(best)) {
909 rpl_set_preferred_parent(dag, best);
911 dag->instance->urgent_probing_target = NULL;
914 rpl_parent_t *best_fresh = best_parent(dag, 1);
915 if(best_fresh == NULL) {
917 rpl_set_preferred_parent(dag, best);
920 rpl_set_preferred_parent(dag, best_fresh);
923 dag->instance->urgent_probing_target = best;
927 rpl_set_preferred_parent(dag, best);
928 dag->rank = rpl_rank_via_parent(dag->preferred_parent);
931 rpl_set_preferred_parent(dag, NULL);
934 dag->rank = rpl_rank_via_parent(dag->preferred_parent);
935 return dag->preferred_parent;
939 rpl_remove_parent(rpl_parent_t *parent)
941 LOG_INFO(
"Removing parent ");
942 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(parent));
945 rpl_nullify_parent(parent);
947 nbr_table_remove(rpl_parents, parent);
951 rpl_nullify_parent(rpl_parent_t *parent)
956 if(parent == dag->preferred_parent || dag->preferred_parent == NULL) {
957 dag->rank = RPL_INFINITE_RANK;
959 if(dag->instance->def_route != NULL) {
960 LOG_DBG(
"Removing default route ");
961 LOG_DBG_6ADDR(rpl_parent_get_ipaddr(parent));
963 uip_ds6_defrt_rm(dag->instance->def_route);
964 dag->instance->def_route = NULL;
967 if(parent == dag->preferred_parent) {
968 if(RPL_IS_STORING(dag->instance)) {
969 dao_output(parent, RPL_ZERO_LIFETIME);
971 rpl_set_preferred_parent(dag, NULL);
976 LOG_INFO(
"Nullifying parent ");
977 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(parent));
984 if(parent == dag_src->preferred_parent) {
985 rpl_set_preferred_parent(dag_src, NULL);
986 dag_src->rank = RPL_INFINITE_RANK;
987 if(dag_src->joined && dag_src->instance->def_route != NULL) {
988 LOG_DBG(
"Removing default route ");
989 LOG_DBG_6ADDR(rpl_parent_get_ipaddr(parent));
991 LOG_DBG(
"rpl_move_parent\n");
992 uip_ds6_defrt_rm(dag_src->instance->def_route);
993 dag_src->instance->def_route = NULL;
995 }
else if(dag_src->joined) {
996 if(RPL_IS_STORING(dag_src->instance)) {
998 rpl_remove_routes_by_nexthop(rpl_parent_get_ipaddr(parent), dag_src);
1002 LOG_INFO(
"Moving parent ");
1003 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(parent));
1006 parent->dag = dag_dst;
1022 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1023 if(instance_table[i].used && instance_table[i].has_downward_route) {
1031 rpl_get_dag(
const uip_ipaddr_t *addr)
1035 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1036 if(instance_table[i].used) {
1037 for(j = 0; j < RPL_MAX_DAG_PER_INSTANCE; ++j) {
1038 if(instance_table[i].dag_table[j].joined
1039 && uip_ipaddr_prefixcmp(&instance_table[i].dag_table[j].dag_id, addr,
1040 instance_table[i].dag_table[j].prefix_info.length)) {
1041 return &instance_table[i].dag_table[j];
1054 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1055 if(instance_table[i].used && instance_table[i].current_dag->joined) {
1056 return instance_table[i].current_dag;
1063 rpl_get_instance(uint8_t instance_id)
1067 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1068 if(instance_table[i].used && instance_table[i].instance_id == instance_id) {
1069 return &instance_table[i];
1076 rpl_find_of(rpl_ocp_t ocp)
1081 i <
sizeof(objective_functions) /
sizeof(objective_functions[0]);
1083 if(objective_functions[i]->ocp == ocp) {
1084 return objective_functions[i];
1092 rpl_join_instance(uip_ipaddr_t *from, rpl_dio_t *dio)
1099 if((!RPL_WITH_NON_STORING && dio->mop == RPL_MOP_NON_STORING)
1100 || (!RPL_WITH_STORING && (dio->mop == RPL_MOP_STORING_NO_MULTICAST
1101 || dio->mop == RPL_MOP_STORING_MULTICAST))) {
1102 LOG_WARN(
"DIO advertising a non-supported MOP %u\n", dio->mop);
1108 of = rpl_find_of(dio->ocp);
1110 LOG_WARN(
"DIO for DAG instance %u does not specify a supported OF: %u\n",
1111 dio->instance_id, dio->ocp);
1115 dag = rpl_alloc_dag(dio->instance_id, &dio->dag_id);
1117 LOG_ERR(
"Failed to allocate a DAG object!\n");
1121 instance = dag->instance;
1123 p = rpl_add_parent(dag, dio, from);
1125 LOG_DBG_6ADDR(from);
1126 LOG_DBG_(
" as a parent: ");
1128 LOG_DBG_(
"failed\n");
1132 p->dtsn = dio->dtsn;
1133 LOG_DBG_(
"succeeded\n");
1137 if(dio->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
1138 check_prefix(NULL, &dio->prefix_info);
1142 dag->preference = dio->preference;
1143 dag->grounded = dio->grounded;
1144 dag->version = dio->version;
1147 instance->mop = dio->mop;
1148 instance->mc.type = dio->mc.type;
1149 instance->mc.flags = dio->mc.flags;
1150 instance->mc.aggr = dio->mc.aggr;
1151 instance->mc.prec = dio->mc.prec;
1152 instance->current_dag = dag;
1153 instance->dtsn_out = RPL_LOLLIPOP_INIT;
1155 instance->max_rankinc = dio->dag_max_rankinc;
1156 instance->min_hoprankinc = dio->dag_min_hoprankinc;
1157 instance->dio_intdoubl = dio->dag_intdoubl;
1158 instance->dio_intmin = dio->dag_intmin;
1159 instance->dio_intcurrent = instance->dio_intmin + instance->dio_intdoubl;
1160 instance->dio_redundancy = dio->dag_redund;
1161 instance->default_lifetime = dio->default_lifetime;
1162 instance->lifetime_unit = dio->lifetime_unit;
1164 memcpy(&dag->dag_id, &dio->dag_id,
sizeof(dio->dag_id));
1167 memcpy(&dag->prefix_info, &dio->prefix_info,
sizeof(
rpl_prefix_t));
1169 rpl_set_preferred_parent(dag, p);
1170 instance->of->update_metric_container(instance);
1171 dag->rank = rpl_rank_via_parent(p);
1173 dag->min_rank = dag->rank;
1175 if(default_instance == NULL) {
1176 default_instance = instance;
1179 LOG_INFO(
"Joined DAG with instance ID %u, rank %hu, DAG ID ",
1180 dio->instance_id, dag->rank);
1181 LOG_INFO_6ADDR(&dag->dag_id);
1184 LOG_ANNOTATE(
"#A join=%u\n", dag->dag_id.u8[
sizeof(dag->dag_id) - 1]);
1186 rpl_reset_dio_timer(instance);
1187 rpl_set_default_route(instance, from);
1189 if(instance->mop != RPL_MOP_NO_DOWNWARD_ROUTES) {
1190 rpl_schedule_dao(instance);
1192 LOG_WARN(
"The DIO does not meet the prerequisites for sending a DAO\n");
1195 instance->of->reset(dag);
1198 #if RPL_MAX_DAG_PER_INSTANCE > 1 1201 rpl_add_dag(uip_ipaddr_t *from, rpl_dio_t *dio)
1208 dag = rpl_alloc_dag(dio->instance_id, &dio->dag_id);
1210 LOG_ERR(
"Failed to allocate a DAG object!\n");
1214 instance = dag->instance;
1216 previous_dag = find_parent_dag(instance, from);
1217 if(previous_dag == NULL) {
1219 LOG_DBG_6ADDR(from);
1220 LOG_DBG_(
" as a parent: ");
1221 p = rpl_add_parent(dag, dio, from);
1223 LOG_DBG_(
"failed\n");
1227 LOG_DBG_(
"succeeded\n");
1229 p = rpl_find_parent(previous_dag, from);
1231 rpl_move_parent(previous_dag, dag, p);
1234 p->rank = dio->rank;
1238 of = rpl_find_of(dio->ocp);
1239 if(of != instance->of ||
1240 instance->mop != dio->mop ||
1241 instance->max_rankinc != dio->dag_max_rankinc ||
1242 instance->min_hoprankinc != dio->dag_min_hoprankinc ||
1243 instance->dio_intdoubl != dio->dag_intdoubl ||
1244 instance->dio_intmin != dio->dag_intmin ||
1245 instance->dio_redundancy != dio->dag_redund ||
1246 instance->default_lifetime != dio->default_lifetime ||
1247 instance->lifetime_unit != dio->lifetime_unit) {
1248 LOG_WARN(
"DIO for DAG instance %u incompatible with previous DIO\n",
1250 rpl_remove_parent(p);
1256 dag->grounded = dio->grounded;
1257 dag->preference = dio->preference;
1258 dag->version = dio->version;
1260 memcpy(&dag->dag_id, &dio->dag_id,
sizeof(dio->dag_id));
1263 memcpy(&dag->prefix_info, &dio->prefix_info,
sizeof(
rpl_prefix_t));
1265 rpl_set_preferred_parent(dag, p);
1266 dag->rank = rpl_rank_via_parent(p);
1267 dag->min_rank = dag->rank;
1269 LOG_INFO(
"Joined DAG with instance ID %u, rank %hu, DAG ID ",
1270 dio->instance_id, dag->rank);
1271 LOG_INFO_6ADDR(&dag->dag_id);
1274 LOG_ANNOTATE(
"#A join=%u\n", dag->dag_id.u8[
sizeof(dag->dag_id) - 1]);
1276 rpl_process_parent_event(instance, p);
1277 p->dtsn = dio->dtsn;
1285 global_repair(uip_ipaddr_t *from,
rpl_dag_t *dag, rpl_dio_t *dio)
1289 remove_parents(dag, 0);
1290 dag->version = dio->version;
1293 dag->instance->dio_intdoubl = dio->dag_intdoubl;
1294 dag->instance->dio_intmin = dio->dag_intmin;
1295 dag->instance->dio_redundancy = dio->dag_redund;
1296 dag->instance->default_lifetime = dio->default_lifetime;
1297 dag->instance->lifetime_unit = dio->lifetime_unit;
1299 dag->instance->of->reset(dag);
1300 dag->min_rank = RPL_INFINITE_RANK;
1301 RPL_LOLLIPOP_INCREMENT(dag->instance->dtsn_out);
1303 p = rpl_add_parent(dag, dio, from);
1305 LOG_ERR(
"Failed to add a parent during the global repair\n");
1306 dag->rank = RPL_INFINITE_RANK;
1308 dag->rank = rpl_rank_via_parent(p);
1309 dag->min_rank = dag->rank;
1310 LOG_DBG(
"rpl_process_parent_event global repair\n");
1311 rpl_process_parent_event(dag->instance, p);
1314 LOG_DBG(
"Participating in a global repair (version=%u, rank=%hu)\n",
1315 dag->version, dag->rank);
1317 RPL_STAT(rpl_stats.global_repairs++);
1326 if(instance == NULL) {
1327 LOG_WARN(
"local repair requested for instance NULL\n");
1330 LOG_INFO(
"Starting a local instance repair\n");
1331 for(i = 0; i < RPL_MAX_DAG_PER_INSTANCE; i++) {
1332 if(instance->dag_table[i].used) {
1333 instance->dag_table[i].rank = RPL_INFINITE_RANK;
1334 nullify_parents(&instance->dag_table[i], 0);
1339 instance->has_downward_route = 0;
1340 #if RPL_WITH_DAO_ACK 1344 rpl_reset_dio_timer(instance);
1345 if(RPL_IS_STORING(instance)) {
1349 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
1352 RPL_STAT(rpl_stats.local_repairs++);
1356 rpl_recalculate_ranks(
void)
1365 p = nbr_table_head(rpl_parents);
1367 if(p->dag != NULL && p->dag->instance && (p->flags & RPL_PARENT_FLAG_UPDATED)) {
1368 p->flags &= ~RPL_PARENT_FLAG_UPDATED;
1369 LOG_DBG(
"rpl_process_parent_event recalculate_ranks\n");
1370 if(!rpl_process_parent_event(p->dag->instance, p)) {
1371 LOG_DBG(
"A parent was dropped\n");
1374 p = nbr_table_next(rpl_parents, p);
1379 rpl_process_parent_event(
rpl_instance_t *instance, rpl_parent_t *p)
1382 rpl_parent_t *last_parent = instance->current_dag->preferred_parent;
1385 rpl_rank_t old_rank;
1386 old_rank = instance->current_dag->rank;
1391 if(RPL_IS_STORING(instance)
1392 && uip_ds6_route_is_nexthop(rpl_parent_get_ipaddr(p))
1393 && !rpl_parent_is_reachable(p) && instance->mop > RPL_MOP_NON_STORING) {
1394 LOG_WARN(
"Unacceptable link %u, removing routes via: ", rpl_get_parent_link_metric(p));
1395 LOG_WARN_6ADDR(rpl_parent_get_ipaddr(p));
1397 rpl_remove_routes_by_nexthop(rpl_parent_get_ipaddr(p), p->dag);
1400 if(!acceptable_rank(p->dag, p->rank)) {
1403 LOG_WARN(
"Unacceptable rank %u (Current min %u, MaxRankInc %u)\n", (
unsigned)p->rank,
1404 p->dag->min_rank, p->dag->instance->max_rankinc);
1405 rpl_nullify_parent(p);
1406 if(p != instance->current_dag->preferred_parent) {
1413 if(rpl_select_dag(instance, p) == NULL) {
1414 if(last_parent != NULL) {
1416 LOG_ERR(
"No parents found in any DAG\n");
1423 if(
DAG_RANK(old_rank, instance) !=
DAG_RANK(instance->current_dag->rank, instance)) {
1424 LOG_INFO(
"Moving in the instance from rank %hu to %hu\n",
1425 DAG_RANK(old_rank, instance),
DAG_RANK(instance->current_dag->rank, instance));
1426 if(instance->current_dag->rank != RPL_INFINITE_RANK) {
1427 LOG_DBG(
"The preferred parent is ");
1428 LOG_DBG_6ADDR(rpl_parent_get_ipaddr(instance->current_dag->preferred_parent));
1429 LOG_DBG_(
" (rank %u)\n",
1430 (
unsigned)
DAG_RANK(instance->current_dag->preferred_parent->rank, instance));
1432 LOG_WARN(
"We don't have any parent");
1437 return return_value;
1441 add_nbr_from_dio(uip_ipaddr_t *from, rpl_dio_t *dio)
1445 LOG_ERR(
"Out of memory, dropping DIO from ");
1446 LOG_ERR_6ADDR(from);
1460 #if RPL_WITH_MULTICAST 1463 if(dio->mop < RPL_MOP_STORING_NO_MULTICAST) {
1465 if(dio->mop != RPL_MOP_DEFAULT) {
1467 LOG_ERR(
"Ignoring a DIO with an unsupported MOP: %d\n", dio->mop);
1471 dag = get_dag(dio->instance_id, &dio->dag_id);
1472 instance = rpl_get_instance(dio->instance_id);
1474 if(dag != NULL && instance != NULL) {
1475 if(lollipop_greater_than(dio->version, dag->version)) {
1477 LOG_WARN(
"Root received inconsistent DIO version number (current: %u, received: %u)\n", dag->version, dio->version);
1478 dag->version = dio->version;
1479 RPL_LOLLIPOP_INCREMENT(dag->version);
1480 rpl_reset_dio_timer(instance);
1482 LOG_DBG(
"Global repair\n");
1483 if(dio->prefix_info.length != 0) {
1484 if(dio->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
1485 LOG_DBG(
"Prefix announced in DIO\n");
1486 rpl_set_prefix(dag, &dio->prefix_info.prefix, dio->prefix_info.length);
1489 global_repair(from, dag, dio);
1494 if(lollipop_greater_than(dag->version, dio->version)) {
1496 LOG_WARN(
"old version received => inconsistency detected\n");
1498 rpl_reset_dio_timer(instance);
1504 if(instance == NULL) {
1505 LOG_INFO(
"New instance detected (ID=%u): Joining...\n", dio->instance_id);
1506 if(add_nbr_from_dio(from, dio)) {
1507 rpl_join_instance(from, dio);
1509 LOG_WARN(
"Not joining since could not add parent\n");
1514 if(instance->current_dag->rank ==
ROOT_RANK(instance) && instance->current_dag != dag) {
1515 LOG_WARN(
"Root ignored DIO for different DAG\n");
1520 #if RPL_MAX_DAG_PER_INSTANCE > 1 1521 LOG_INFO(
"Adding new DAG to known instance.\n");
1522 if(!add_nbr_from_dio(from, dio)) {
1523 LOG_WARN(
"Could not add new DAG, could not add parent\n");
1526 dag = rpl_add_dag(from, dio);
1528 LOG_WARN(
"Failed to add DAG.\n");
1532 LOG_WARN(
"Only one instance supported.\n");
1539 LOG_INFO(
"Ignoring DIO with too low rank: %u\n",
1540 (
unsigned)dio->rank);
1545 if(dio->prefix_info.length != 0) {
1546 if(dio->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
1547 LOG_DBG(
"Prefix announced in DIO\n");
1548 rpl_set_prefix(dag, &dio->prefix_info.prefix, dio->prefix_info.length);
1552 if(!add_nbr_from_dio(from, dio)) {
1553 LOG_WARN(
"Could not add parent based on DIO\n");
1558 if(dio->rank != RPL_INFINITE_RANK) {
1559 instance->dio_counter++;
1565 dag->lifetime = (1UL << (instance->dio_intmin + instance->dio_intdoubl)) * RPL_DAG_LIFETIME / 1000;
1566 LOG_INFO(
"Set dag ");
1567 LOG_INFO_6ADDR(&dag->dag_id);
1568 LOG_INFO_(
" lifetime to %ld\n", (
long int) dag->lifetime);
1577 p = rpl_find_parent(dag, from);
1579 previous_dag = find_parent_dag(instance, from);
1580 if(previous_dag == NULL) {
1582 p = rpl_add_parent(dag, dio, from);
1584 LOG_WARN(
"Failed to add a new parent (");
1585 LOG_WARN_6ADDR(from);
1589 LOG_INFO(
"New candidate parent with rank %u: ", (
unsigned)p->rank);
1590 LOG_INFO_6ADDR(from);
1593 p = rpl_find_parent(previous_dag, from);
1595 rpl_move_parent(previous_dag, dag, p);
1599 if(p->rank == dio->rank) {
1600 LOG_WARN(
"Received consistent DIO\n");
1602 instance->dio_counter++;
1606 p->rank = dio->rank;
1608 if(dio->rank == RPL_INFINITE_RANK && p == dag->preferred_parent) {
1610 rpl_reset_dio_timer(instance);
1614 p->flags |= RPL_PARENT_FLAG_UPDATED;
1616 LOG_INFO(
"preferred DAG ");
1617 LOG_INFO_6ADDR(&instance->current_dag->dag_id);
1618 LOG_INFO_(
", rank %u, min_rank %u, ",
1619 instance->current_dag->rank, instance->current_dag->min_rank);
1620 LOG_INFO_(
"parent rank %u, link metric %u\n",
1621 p->rank, rpl_get_parent_link_metric(p));
1626 memcpy(&p->mc, &dio->mc,
sizeof(p->mc));
1628 if(rpl_process_parent_event(instance, p) == 0) {
1629 LOG_WARN(
"The candidate parent is rejected\n");
1634 if(dag->joined && p == dag->preferred_parent) {
1635 if(should_refresh_routes(instance, dio, p)) {
1638 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
1639 rpl_schedule_dao(instance);
1643 uip_ds6_defrt_add(from, RPL_DEFAULT_ROUTE_INFINITE_LIFETIME ? 0 :
RPL_LIFETIME(instance, instance->default_lifetime));
1645 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.
static uip_ds6_nbr_t * nbr
Pointer to llao option in uip_buf.
#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.
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
Linked list manipulation routines.
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.
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.
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.
An entry in the nbr cache.
void rpl_schedule_probing(void)
Schedule probing with delay RPL_PROBING_DELAY_FUNC()