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) {
228 if(nbr == NULL || nbr->state != NBR_REACHABLE) {
233 return !rpl_parent_is_fresh(p) || p->dag->instance->of->parent_has_usable_link(p);
238 rpl_set_preferred_parent(
rpl_dag_t *dag, rpl_parent_t *p)
240 if(dag != NULL && dag->preferred_parent != p) {
241 LOG_INFO(
"rpl_set_preferred_parent ");
243 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(p));
247 LOG_INFO_(
" used to be ");
248 if(dag->preferred_parent != NULL) {
249 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(dag->preferred_parent));
255 #ifdef RPL_CALLBACK_PARENT_SWITCH 256 RPL_CALLBACK_PARENT_SWITCH(dag->preferred_parent, p);
261 nbr_table_unlock(rpl_parents, dag->preferred_parent);
262 nbr_table_lock(rpl_parents, p);
263 dag->preferred_parent = p;
270 lollipop_greater_than(
int a,
int b)
273 if(a > RPL_LOLLIPOP_CIRCULAR_REGION && b <= RPL_LOLLIPOP_CIRCULAR_REGION) {
274 return (RPL_LOLLIPOP_MAX_VALUE + 1 + b - a) > RPL_LOLLIPOP_SEQUENCE_WINDOWS;
278 return (a > b && (a - b) < RPL_LOLLIPOP_SEQUENCE_WINDOWS) ||
279 (a < b && (b - a) > (RPL_LOLLIPOP_CIRCULAR_REGION + 1-
280 RPL_LOLLIPOP_SEQUENCE_WINDOWS));
285 remove_parents(
rpl_dag_t *dag, rpl_rank_t minimum_rank)
289 LOG_INFO(
"Removing parents (minimum rank %u)\n", minimum_rank);
291 p = nbr_table_head(rpl_parents);
293 if(dag == p->dag && p->rank >= minimum_rank) {
294 rpl_remove_parent(p);
296 p = nbr_table_next(rpl_parents, p);
301 nullify_parents(
rpl_dag_t *dag, rpl_rank_t minimum_rank)
305 LOG_INFO(
"Nullifying parents (minimum rank %u)\n", minimum_rank);
307 p = nbr_table_head(rpl_parents);
309 if(dag == p->dag && p->rank >= minimum_rank) {
310 rpl_nullify_parent(p);
312 p = nbr_table_next(rpl_parents, p);
317 should_refresh_routes(
rpl_instance_t *instance, rpl_dio_t *dio, rpl_parent_t *p)
320 if(instance->mop == RPL_MOP_NO_DOWNWARD_ROUTES) {
324 return p == instance->current_dag->preferred_parent &&
325 (lollipop_greater_than(dio->dtsn, p->dtsn));
329 acceptable_rank(
rpl_dag_t *dag, rpl_rank_t rank)
331 return rank != RPL_INFINITE_RANK &&
332 ((dag->instance->max_rankinc == 0) ||
333 DAG_RANK(rank, dag->instance) <=
DAG_RANK(dag->min_rank + dag->instance->max_rankinc, dag->instance));
337 get_dag(uint8_t instance_id, uip_ipaddr_t *dag_id)
343 instance = rpl_get_instance(instance_id);
344 if(instance == NULL) {
348 for(i = 0; i < RPL_MAX_DAG_PER_INSTANCE; ++i) {
349 dag = &instance->dag_table[i];
350 if(dag->used && uip_ipaddr_cmp(&dag->dag_id, dag_id)) {
359 rpl_set_root(uint8_t instance_id, uip_ipaddr_t *dag_id)
366 version = RPL_LOLLIPOP_INIT;
367 instance = rpl_get_instance(instance_id);
368 if(instance != NULL) {
369 for(i = 0; i < RPL_MAX_DAG_PER_INSTANCE; ++i) {
370 dag = &instance->dag_table[i];
372 if(uip_ipaddr_cmp(&dag->dag_id, dag_id)) {
373 version = dag->version;
374 RPL_LOLLIPOP_INCREMENT(version);
376 if(dag == dag->instance->current_dag) {
377 LOG_INFO(
"Dropping a joined DAG when setting this node as root\n");
378 rpl_set_default_route(instance, NULL);
379 dag->instance->current_dag = NULL;
381 LOG_INFO(
"Dropping a DAG when setting this node as root\n");
389 dag = rpl_alloc_dag(instance_id, dag_id);
391 LOG_ERR(
"Failed to allocate a DAG\n");
395 instance = dag->instance;
397 dag->version = version;
399 dag->grounded = RPL_GROUNDED;
400 dag->preference = RPL_PREFERENCE;
401 instance->mop = RPL_MOP_DEFAULT;
402 instance->of = rpl_find_of(RPL_OF_OCP);
403 if(instance->of == NULL) {
404 LOG_WARN(
"OF with OCP %u not supported\n", RPL_OF_OCP);
408 rpl_set_preferred_parent(dag, NULL);
410 memcpy(&dag->dag_id, dag_id,
sizeof(dag->dag_id));
412 instance->dio_intdoubl = RPL_DIO_INTERVAL_DOUBLINGS;
413 instance->dio_intmin = RPL_DIO_INTERVAL_MIN;
416 instance->dio_intcurrent = RPL_DIO_INTERVAL_MIN +
417 RPL_DIO_INTERVAL_DOUBLINGS;
418 instance->dio_redundancy = RPL_DIO_REDUNDANCY;
419 instance->max_rankinc = RPL_MAX_RANKINC;
420 instance->min_hoprankinc = RPL_MIN_HOPRANKINC;
421 instance->default_lifetime = RPL_DEFAULT_LIFETIME;
422 instance->lifetime_unit = RPL_DEFAULT_LIFETIME_UNIT;
426 if(instance->current_dag != dag && instance->current_dag != NULL) {
428 if(RPL_IS_STORING(instance)) {
429 rpl_remove_routes(instance->current_dag);
432 instance->current_dag->joined = 0;
435 instance->current_dag = dag;
436 instance->dtsn_out = RPL_LOLLIPOP_INIT;
437 instance->of->update_metric_container(instance);
438 default_instance = instance;
440 LOG_INFO(
"Node set to be a DAG root with DAG ID ");
441 LOG_INFO_6ADDR(&dag->dag_id);
444 LOG_ANNOTATE(
"#A root=%u\n", dag->dag_id.u8[
sizeof(dag->dag_id) - 1]);
446 rpl_reset_dio_timer(instance);
452 rpl_repair_root(uint8_t instance_id)
456 instance = rpl_get_instance(instance_id);
457 if(instance == NULL ||
458 instance->current_dag->rank !=
ROOT_RANK(instance)) {
459 LOG_WARN(
"rpl_repair_root triggered but not root\n");
462 RPL_STAT(rpl_stats.root_repairs++);
464 RPL_LOLLIPOP_INCREMENT(instance->current_dag->version);
465 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
466 LOG_INFO(
"rpl_repair_root initiating global repair with version %d\n", instance->current_dag->version);
467 rpl_reset_dio_timer(instance);
474 memset(ipaddr, 0,
sizeof(uip_ipaddr_t));
475 memcpy(ipaddr, &prefix->prefix, (prefix->length + 7) / 8);
485 if(last_prefix != NULL && new_prefix != NULL &&
486 last_prefix->length == new_prefix->length &&
487 uip_ipaddr_prefixcmp(&last_prefix->prefix, &new_prefix->prefix, new_prefix->length) &&
488 last_prefix->flags == new_prefix->flags) {
493 if(last_prefix != NULL) {
494 set_ip_from_prefix(&ipaddr, last_prefix);
495 rep = uip_ds6_addr_lookup(&ipaddr);
497 LOG_DBG(
"removing global IP address ");
498 LOG_DBG_6ADDR(&ipaddr);
500 uip_ds6_addr_rm(rep);
504 if(new_prefix != NULL) {
505 set_ip_from_prefix(&ipaddr, new_prefix);
506 if(uip_ds6_addr_lookup(&ipaddr) == NULL) {
507 LOG_DBG(
"adding global IP address ");
508 LOG_DBG_6ADDR(&ipaddr);
516 rpl_set_prefix(
rpl_dag_t *dag, uip_ipaddr_t *prefix,
unsigned len)
519 uint8_t last_len = dag->prefix_info.length;
524 if(dag->prefix_info.length != 0) {
525 memcpy(&last_prefix, &dag->prefix_info,
sizeof(
rpl_prefix_t));
527 memset(&dag->prefix_info.prefix, 0,
sizeof(dag->prefix_info.prefix));
528 memcpy(&dag->prefix_info.prefix, prefix, (len + 7) / 8);
529 dag->prefix_info.length = len;
530 dag->prefix_info.flags = UIP_ND6_RA_FLAG_AUTONOMOUS;
531 LOG_INFO(
"Prefix set - will announce this in DIOs\n");
532 if(dag->rank !=
ROOT_RANK(dag->instance)) {
536 LOG_INFO(
"rpl_set_prefix - prefix NULL\n");
537 check_prefix(NULL, &dag->prefix_info);
539 LOG_INFO(
"rpl_set_prefix - prefix NON-NULL\n");
540 check_prefix(&last_prefix, &dag->prefix_info);
547 rpl_set_default_route(
rpl_instance_t *instance, uip_ipaddr_t *from)
549 if(instance->def_route != NULL) {
550 LOG_DBG(
"Removing default route through ");
551 LOG_DBG_6ADDR(&instance->def_route->ipaddr);
553 uip_ds6_defrt_rm(instance->def_route);
554 instance->def_route = NULL;
558 LOG_DBG(
"Adding default route through ");
561 instance->def_route = uip_ds6_defrt_add(from,
562 RPL_DEFAULT_ROUTE_INFINITE_LIFETIME ? 0 :
RPL_LIFETIME(instance, instance->default_lifetime));
563 if(instance->def_route == NULL) {
571 rpl_alloc_instance(uint8_t instance_id)
575 for(instance = &instance_table[0], end = instance + RPL_MAX_INSTANCES;
576 instance < end; ++instance) {
577 if(instance->used == 0) {
578 memset(instance, 0,
sizeof(*instance));
579 instance->instance_id = instance_id;
580 instance->def_route = NULL;
592 rpl_alloc_dag(uint8_t instance_id, uip_ipaddr_t *dag_id)
597 instance = rpl_get_instance(instance_id);
598 if(instance == NULL) {
599 instance = rpl_alloc_instance(instance_id);
600 if(instance == NULL) {
601 RPL_STAT(rpl_stats.mem_overflows++);
606 for(dag = &instance->dag_table[0], end = dag + RPL_MAX_DAG_PER_INSTANCE; dag < end; ++dag) {
608 memset(dag, 0,
sizeof(*dag));
610 dag->rank = RPL_INFINITE_RANK;
611 dag->min_rank = RPL_INFINITE_RANK;
612 dag->instance = instance;
617 RPL_STAT(rpl_stats.mem_overflows++);
624 default_instance = instance;
630 return default_instance;
639 LOG_INFO(
"Leaving the instance %u\n", instance->instance_id);
642 for(dag = &instance->dag_table[0], end = dag + RPL_MAX_DAG_PER_INSTANCE; dag < end; ++dag) {
648 rpl_set_default_route(instance, NULL);
657 if(default_instance == instance) {
658 default_instance = NULL;
668 LOG_INFO(
"Leaving the DAG ");
669 LOG_INFO_6ADDR(&dag->dag_id);
674 if(RPL_IS_STORING(dag->instance)) {
675 rpl_remove_routes(dag);
683 if((dag->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS)) {
684 check_prefix(&dag->prefix_info, NULL);
687 remove_parents(dag, 0);
693 rpl_add_parent(
rpl_dag_t *dag, rpl_dio_t *dio, uip_ipaddr_t *addr)
695 rpl_parent_t *p = NULL;
700 LOG_DBG(
"rpl_add_parent lladdr %p ", lladdr);
705 p = nbr_table_add_lladdr(rpl_parents, (linkaddr_t *)lladdr,
706 NBR_TABLE_REASON_RPL_DIO, dio);
708 LOG_DBG(
"rpl_add_parent p NULL\n");
714 memcpy(&p->mc, &dio->mc,
sizeof(p->mc));
722 static rpl_parent_t *
723 find_parent_any_dag_any_instance(uip_ipaddr_t *addr)
727 return nbr_table_get_from_lladdr(rpl_parents, (linkaddr_t *)lladdr);
731 rpl_find_parent(
rpl_dag_t *dag, uip_ipaddr_t *addr)
733 rpl_parent_t *p = find_parent_any_dag_any_instance(addr);
734 if(p != NULL && p->dag == dag) {
744 rpl_parent_t *p = find_parent_any_dag_any_instance(addr);
753 rpl_find_parent_any_dag(
rpl_instance_t *instance, uip_ipaddr_t *addr)
755 rpl_parent_t *p = find_parent_any_dag_any_instance(addr);
756 if(p && p->dag && p->dag->instance == instance) {
766 rpl_parent_t *last_parent;
770 old_rank = instance->current_dag->rank;
771 last_parent = instance->current_dag->preferred_parent;
773 if(instance->current_dag->rank !=
ROOT_RANK(instance)) {
774 rpl_select_parent(p->dag);
778 for(dag = &instance->dag_table[0], end = dag + RPL_MAX_DAG_PER_INSTANCE; dag < end; ++dag) {
779 if(dag->used && dag->preferred_parent != NULL && dag->preferred_parent->rank != RPL_INFINITE_RANK) {
780 if(best_dag == NULL) {
783 best_dag = instance->of->best_dag(best_dag, dag);
788 if(best_dag == NULL) {
793 if(instance->current_dag != best_dag) {
795 if(RPL_IS_STORING(instance)) {
796 rpl_remove_routes(instance->current_dag);
799 LOG_INFO(
"New preferred DAG: ");
800 LOG_INFO_6ADDR(&best_dag->dag_id);
803 if(best_dag->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
804 check_prefix(&instance->current_dag->prefix_info, &best_dag->prefix_info);
805 }
else if(instance->current_dag->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
806 check_prefix(&instance->current_dag->prefix_info, NULL);
809 best_dag->joined = 1;
810 instance->current_dag->joined = 0;
811 instance->current_dag = best_dag;
814 instance->of->update_metric_container(instance);
816 best_dag->rank = rpl_rank_via_parent(best_dag->preferred_parent);
817 if(last_parent == NULL || best_dag->rank < best_dag->min_rank) {
820 best_dag->min_rank = best_dag->rank;
823 if(!acceptable_rank(best_dag, best_dag->rank)) {
824 LOG_WARN(
"New rank unacceptable!\n");
825 rpl_set_preferred_parent(instance->current_dag, NULL);
826 if(RPL_IS_STORING(instance) && last_parent != NULL) {
828 dao_output(last_parent, RPL_ZERO_LIFETIME);
833 if(best_dag->preferred_parent != last_parent) {
834 rpl_set_default_route(instance, rpl_parent_get_ipaddr(best_dag->preferred_parent));
835 LOG_INFO(
"Changed preferred parent, rank changed from %u to %u\n",
836 (
unsigned)old_rank, best_dag->rank);
837 RPL_STAT(rpl_stats.parent_switch++);
838 if(RPL_IS_STORING(instance)) {
839 if(last_parent != NULL) {
841 dao_output(last_parent, RPL_ZERO_LIFETIME);
845 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
848 rpl_schedule_dao(instance);
849 rpl_reset_dio_timer(instance);
850 if(LOG_DBG_ENABLED) {
851 rpl_print_neighbor_list();
853 }
else if(best_dag->rank != old_rank) {
854 LOG_DBG(
"RPL: Preferred parent update, rank changed from %u to %u\n",
855 (
unsigned)old_rank, best_dag->rank);
860 static rpl_parent_t *
861 best_parent(
rpl_dag_t *dag,
int fresh_only)
865 rpl_parent_t *best = NULL;
867 if(dag == NULL || dag->instance == NULL || dag->instance->of == NULL) {
871 of = dag->instance->of;
873 for(p = nbr_table_head(rpl_parents); p != NULL; p = nbr_table_next(rpl_parents, p)) {
876 if(p->dag != dag || p->rank == RPL_INFINITE_RANK || p->rank <
ROOT_RANK(dag->instance)) {
878 LOG_WARN(
"Parent has invalid rank\n");
883 if(fresh_only && !rpl_parent_is_fresh(p)) {
892 if(nbr == NULL || nbr->state != NBR_REACHABLE) {
899 best = of->best_parent(best, p);
909 rpl_parent_t *best = best_parent(dag, 0);
913 if(rpl_parent_is_fresh(best)) {
914 rpl_set_preferred_parent(dag, best);
916 dag->instance->urgent_probing_target = NULL;
919 rpl_parent_t *best_fresh = best_parent(dag, 1);
920 if(best_fresh == NULL) {
922 rpl_set_preferred_parent(dag, best);
925 rpl_set_preferred_parent(dag, best_fresh);
928 dag->instance->urgent_probing_target = best;
932 rpl_set_preferred_parent(dag, best);
933 dag->rank = rpl_rank_via_parent(dag->preferred_parent);
936 rpl_set_preferred_parent(dag, NULL);
939 dag->rank = rpl_rank_via_parent(dag->preferred_parent);
940 return dag->preferred_parent;
944 rpl_remove_parent(rpl_parent_t *parent)
946 LOG_INFO(
"Removing parent ");
947 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(parent));
950 rpl_nullify_parent(parent);
952 nbr_table_remove(rpl_parents, parent);
956 rpl_nullify_parent(rpl_parent_t *parent)
961 if(parent == dag->preferred_parent || dag->preferred_parent == NULL) {
962 dag->rank = RPL_INFINITE_RANK;
964 if(dag->instance->def_route != NULL) {
965 LOG_DBG(
"Removing default route ");
966 LOG_DBG_6ADDR(rpl_parent_get_ipaddr(parent));
968 uip_ds6_defrt_rm(dag->instance->def_route);
969 dag->instance->def_route = NULL;
972 if(parent == dag->preferred_parent) {
973 if(RPL_IS_STORING(dag->instance)) {
974 dao_output(parent, RPL_ZERO_LIFETIME);
976 rpl_set_preferred_parent(dag, NULL);
981 LOG_INFO(
"Nullifying parent ");
982 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(parent));
989 if(parent == dag_src->preferred_parent) {
990 rpl_set_preferred_parent(dag_src, NULL);
991 dag_src->rank = RPL_INFINITE_RANK;
992 if(dag_src->joined && dag_src->instance->def_route != NULL) {
993 LOG_DBG(
"Removing default route ");
994 LOG_DBG_6ADDR(rpl_parent_get_ipaddr(parent));
996 LOG_DBG(
"rpl_move_parent\n");
997 uip_ds6_defrt_rm(dag_src->instance->def_route);
998 dag_src->instance->def_route = NULL;
1000 }
else if(dag_src->joined) {
1001 if(RPL_IS_STORING(dag_src->instance)) {
1003 rpl_remove_routes_by_nexthop(rpl_parent_get_ipaddr(parent), dag_src);
1007 LOG_INFO(
"Moving parent ");
1008 LOG_INFO_6ADDR(rpl_parent_get_ipaddr(parent));
1011 parent->dag = dag_dst;
1027 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1028 if(instance_table[i].used && instance_table[i].has_downward_route) {
1036 rpl_get_dag(
const uip_ipaddr_t *addr)
1040 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1041 if(instance_table[i].used) {
1042 for(j = 0; j < RPL_MAX_DAG_PER_INSTANCE; ++j) {
1043 if(instance_table[i].dag_table[j].joined
1044 && uip_ipaddr_prefixcmp(&instance_table[i].dag_table[j].dag_id, addr,
1045 instance_table[i].dag_table[j].prefix_info.length)) {
1046 return &instance_table[i].dag_table[j];
1059 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1060 if(instance_table[i].used && instance_table[i].current_dag->joined) {
1061 return instance_table[i].current_dag;
1068 rpl_get_instance(uint8_t instance_id)
1072 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1073 if(instance_table[i].used && instance_table[i].instance_id == instance_id) {
1074 return &instance_table[i];
1081 rpl_find_of(rpl_ocp_t ocp)
1086 i <
sizeof(objective_functions) /
sizeof(objective_functions[0]);
1088 if(objective_functions[i]->ocp == ocp) {
1089 return objective_functions[i];
1097 rpl_join_instance(uip_ipaddr_t *from, rpl_dio_t *dio)
1104 if((!RPL_WITH_NON_STORING && dio->mop == RPL_MOP_NON_STORING)
1105 || (!RPL_WITH_STORING && (dio->mop == RPL_MOP_STORING_NO_MULTICAST
1106 || dio->mop == RPL_MOP_STORING_MULTICAST))) {
1107 LOG_WARN(
"DIO advertising a non-supported MOP %u\n", dio->mop);
1113 of = rpl_find_of(dio->ocp);
1115 LOG_WARN(
"DIO for DAG instance %u does not specify a supported OF: %u\n",
1116 dio->instance_id, dio->ocp);
1120 dag = rpl_alloc_dag(dio->instance_id, &dio->dag_id);
1122 LOG_ERR(
"Failed to allocate a DAG object!\n");
1126 instance = dag->instance;
1128 p = rpl_add_parent(dag, dio, from);
1130 LOG_DBG_6ADDR(from);
1131 LOG_DBG_(
" as a parent: ");
1133 LOG_DBG_(
"failed\n");
1137 p->dtsn = dio->dtsn;
1138 LOG_DBG_(
"succeeded\n");
1142 if(dio->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
1143 check_prefix(NULL, &dio->prefix_info);
1147 dag->preference = dio->preference;
1148 dag->grounded = dio->grounded;
1149 dag->version = dio->version;
1152 instance->mop = dio->mop;
1153 instance->mc.type = dio->mc.type;
1154 instance->mc.flags = dio->mc.flags;
1155 instance->mc.aggr = dio->mc.aggr;
1156 instance->mc.prec = dio->mc.prec;
1157 instance->current_dag = dag;
1158 instance->dtsn_out = RPL_LOLLIPOP_INIT;
1160 instance->max_rankinc = dio->dag_max_rankinc;
1161 instance->min_hoprankinc = dio->dag_min_hoprankinc;
1162 instance->dio_intdoubl = dio->dag_intdoubl;
1163 instance->dio_intmin = dio->dag_intmin;
1164 instance->dio_intcurrent = instance->dio_intmin + instance->dio_intdoubl;
1165 instance->dio_redundancy = dio->dag_redund;
1166 instance->default_lifetime = dio->default_lifetime;
1167 instance->lifetime_unit = dio->lifetime_unit;
1169 memcpy(&dag->dag_id, &dio->dag_id,
sizeof(dio->dag_id));
1172 memcpy(&dag->prefix_info, &dio->prefix_info,
sizeof(
rpl_prefix_t));
1174 rpl_set_preferred_parent(dag, p);
1175 instance->of->update_metric_container(instance);
1176 dag->rank = rpl_rank_via_parent(p);
1178 dag->min_rank = dag->rank;
1180 if(default_instance == NULL) {
1181 default_instance = instance;
1184 LOG_INFO(
"Joined DAG with instance ID %u, rank %hu, DAG ID ",
1185 dio->instance_id, dag->rank);
1186 LOG_INFO_6ADDR(&dag->dag_id);
1189 LOG_ANNOTATE(
"#A join=%u\n", dag->dag_id.u8[
sizeof(dag->dag_id) - 1]);
1191 rpl_reset_dio_timer(instance);
1192 rpl_set_default_route(instance, from);
1194 if(instance->mop != RPL_MOP_NO_DOWNWARD_ROUTES) {
1195 rpl_schedule_dao(instance);
1197 LOG_WARN(
"The DIO does not meet the prerequisites for sending a DAO\n");
1200 instance->of->reset(dag);
1203 #if RPL_MAX_DAG_PER_INSTANCE > 1 1206 rpl_add_dag(uip_ipaddr_t *from, rpl_dio_t *dio)
1213 dag = rpl_alloc_dag(dio->instance_id, &dio->dag_id);
1215 LOG_ERR(
"Failed to allocate a DAG object!\n");
1219 instance = dag->instance;
1221 previous_dag = find_parent_dag(instance, from);
1222 if(previous_dag == NULL) {
1224 LOG_DBG_6ADDR(from);
1225 LOG_DBG_(
" as a parent: ");
1226 p = rpl_add_parent(dag, dio, from);
1228 LOG_DBG_(
"failed\n");
1232 LOG_DBG_(
"succeeded\n");
1234 p = rpl_find_parent(previous_dag, from);
1236 rpl_move_parent(previous_dag, dag, p);
1239 p->rank = dio->rank;
1243 of = rpl_find_of(dio->ocp);
1244 if(of != instance->of ||
1245 instance->mop != dio->mop ||
1246 instance->max_rankinc != dio->dag_max_rankinc ||
1247 instance->min_hoprankinc != dio->dag_min_hoprankinc ||
1248 instance->dio_intdoubl != dio->dag_intdoubl ||
1249 instance->dio_intmin != dio->dag_intmin ||
1250 instance->dio_redundancy != dio->dag_redund ||
1251 instance->default_lifetime != dio->default_lifetime ||
1252 instance->lifetime_unit != dio->lifetime_unit) {
1253 LOG_WARN(
"DIO for DAG instance %u incompatible with previous DIO\n",
1255 rpl_remove_parent(p);
1261 dag->grounded = dio->grounded;
1262 dag->preference = dio->preference;
1263 dag->version = dio->version;
1265 memcpy(&dag->dag_id, &dio->dag_id,
sizeof(dio->dag_id));
1268 memcpy(&dag->prefix_info, &dio->prefix_info,
sizeof(
rpl_prefix_t));
1270 rpl_set_preferred_parent(dag, p);
1271 dag->rank = rpl_rank_via_parent(p);
1272 dag->min_rank = dag->rank;
1274 LOG_INFO(
"Joined DAG with instance ID %u, rank %hu, DAG ID ",
1275 dio->instance_id, dag->rank);
1276 LOG_INFO_6ADDR(&dag->dag_id);
1279 LOG_ANNOTATE(
"#A join=%u\n", dag->dag_id.u8[
sizeof(dag->dag_id) - 1]);
1281 rpl_process_parent_event(instance, p);
1282 p->dtsn = dio->dtsn;
1290 global_repair(uip_ipaddr_t *from,
rpl_dag_t *dag, rpl_dio_t *dio)
1294 remove_parents(dag, 0);
1295 dag->version = dio->version;
1298 dag->instance->dio_intdoubl = dio->dag_intdoubl;
1299 dag->instance->dio_intmin = dio->dag_intmin;
1300 dag->instance->dio_redundancy = dio->dag_redund;
1301 dag->instance->default_lifetime = dio->default_lifetime;
1302 dag->instance->lifetime_unit = dio->lifetime_unit;
1304 dag->instance->of->reset(dag);
1305 dag->min_rank = RPL_INFINITE_RANK;
1306 RPL_LOLLIPOP_INCREMENT(dag->instance->dtsn_out);
1308 p = rpl_add_parent(dag, dio, from);
1310 LOG_ERR(
"Failed to add a parent during the global repair\n");
1311 dag->rank = RPL_INFINITE_RANK;
1313 dag->rank = rpl_rank_via_parent(p);
1314 dag->min_rank = dag->rank;
1315 LOG_DBG(
"rpl_process_parent_event global repair\n");
1316 rpl_process_parent_event(dag->instance, p);
1319 LOG_DBG(
"Participating in a global repair (version=%u, rank=%hu)\n",
1320 dag->version, dag->rank);
1322 RPL_STAT(rpl_stats.global_repairs++);
1331 if(instance == NULL) {
1332 LOG_WARN(
"local repair requested for instance NULL\n");
1335 LOG_INFO(
"Starting a local instance repair\n");
1336 for(i = 0; i < RPL_MAX_DAG_PER_INSTANCE; i++) {
1337 if(instance->dag_table[i].used) {
1338 instance->dag_table[i].rank = RPL_INFINITE_RANK;
1339 nullify_parents(&instance->dag_table[i], 0);
1344 instance->has_downward_route = 0;
1345 #if RPL_WITH_DAO_ACK 1349 rpl_reset_dio_timer(instance);
1350 if(RPL_IS_STORING(instance)) {
1354 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
1357 RPL_STAT(rpl_stats.local_repairs++);
1361 rpl_recalculate_ranks(
void)
1370 p = nbr_table_head(rpl_parents);
1372 if(p->dag != NULL && p->dag->instance && (p->flags & RPL_PARENT_FLAG_UPDATED)) {
1373 p->flags &= ~RPL_PARENT_FLAG_UPDATED;
1374 LOG_DBG(
"rpl_process_parent_event recalculate_ranks\n");
1375 if(!rpl_process_parent_event(p->dag->instance, p)) {
1376 LOG_DBG(
"A parent was dropped\n");
1379 p = nbr_table_next(rpl_parents, p);
1384 rpl_process_parent_event(
rpl_instance_t *instance, rpl_parent_t *p)
1387 rpl_parent_t *last_parent = instance->current_dag->preferred_parent;
1390 rpl_rank_t old_rank;
1391 old_rank = instance->current_dag->rank;
1396 if(RPL_IS_STORING(instance)
1397 && uip_ds6_route_is_nexthop(rpl_parent_get_ipaddr(p))
1398 && !rpl_parent_is_reachable(p) && instance->mop > RPL_MOP_NON_STORING) {
1399 LOG_WARN(
"Unacceptable link %u, removing routes via: ", rpl_get_parent_link_metric(p));
1400 LOG_WARN_6ADDR(rpl_parent_get_ipaddr(p));
1402 rpl_remove_routes_by_nexthop(rpl_parent_get_ipaddr(p), p->dag);
1405 if(!acceptable_rank(p->dag, rpl_rank_via_parent(p))) {
1408 LOG_WARN(
"Unacceptable rank %u (Current min %u, MaxRankInc %u)\n", (
unsigned)p->rank,
1409 p->dag->min_rank, p->dag->instance->max_rankinc);
1410 rpl_nullify_parent(p);
1411 if(p != instance->current_dag->preferred_parent) {
1418 if(rpl_select_dag(instance, p) == NULL) {
1419 if(last_parent != NULL) {
1421 LOG_ERR(
"No parents found in any DAG\n");
1428 if(
DAG_RANK(old_rank, instance) !=
DAG_RANK(instance->current_dag->rank, instance)) {
1429 LOG_INFO(
"Moving in the instance from rank %hu to %hu\n",
1430 DAG_RANK(old_rank, instance),
DAG_RANK(instance->current_dag->rank, instance));
1431 if(instance->current_dag->rank != RPL_INFINITE_RANK) {
1432 LOG_DBG(
"The preferred parent is ");
1433 LOG_DBG_6ADDR(rpl_parent_get_ipaddr(instance->current_dag->preferred_parent));
1434 LOG_DBG_(
" (rank %u)\n",
1435 (
unsigned)
DAG_RANK(instance->current_dag->preferred_parent->rank, instance));
1437 LOG_WARN(
"We don't have any parent");
1442 return return_value;
1446 add_nbr_from_dio(uip_ipaddr_t *from, rpl_dio_t *dio)
1450 LOG_ERR(
"Out of memory, dropping DIO from ");
1451 LOG_ERR_6ADDR(from);
1465 #if RPL_WITH_MULTICAST 1468 if(dio->mop < RPL_MOP_STORING_NO_MULTICAST) {
1470 if(dio->mop != RPL_MOP_DEFAULT) {
1472 LOG_ERR(
"Ignoring a DIO with an unsupported MOP: %d\n", dio->mop);
1476 dag = get_dag(dio->instance_id, &dio->dag_id);
1477 instance = rpl_get_instance(dio->instance_id);
1479 if(dag != NULL && instance != NULL) {
1480 if(lollipop_greater_than(dio->version, dag->version)) {
1482 LOG_WARN(
"Root received inconsistent DIO version number (current: %u, received: %u)\n", dag->version, dio->version);
1483 dag->version = dio->version;
1484 RPL_LOLLIPOP_INCREMENT(dag->version);
1485 rpl_reset_dio_timer(instance);
1487 LOG_DBG(
"Global repair\n");
1488 if(dio->prefix_info.length != 0) {
1489 if(dio->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
1490 LOG_DBG(
"Prefix announced in DIO\n");
1491 rpl_set_prefix(dag, &dio->prefix_info.prefix, dio->prefix_info.length);
1494 global_repair(from, dag, dio);
1499 if(lollipop_greater_than(dag->version, dio->version)) {
1501 LOG_WARN(
"old version received => inconsistency detected\n");
1503 rpl_reset_dio_timer(instance);
1509 if(instance == NULL) {
1510 LOG_INFO(
"New instance detected (ID=%u): Joining...\n", dio->instance_id);
1511 if(add_nbr_from_dio(from, dio)) {
1512 rpl_join_instance(from, dio);
1514 LOG_WARN(
"Not joining since could not add parent\n");
1519 if(instance->current_dag->rank ==
ROOT_RANK(instance) && instance->current_dag != dag) {
1520 LOG_WARN(
"Root ignored DIO for different DAG\n");
1525 #if RPL_MAX_DAG_PER_INSTANCE > 1 1526 LOG_INFO(
"Adding new DAG to known instance.\n");
1527 if(!add_nbr_from_dio(from, dio)) {
1528 LOG_WARN(
"Could not add new DAG, could not add parent\n");
1531 dag = rpl_add_dag(from, dio);
1533 LOG_WARN(
"Failed to add DAG.\n");
1537 LOG_WARN(
"Only one instance supported.\n");
1544 LOG_INFO(
"Ignoring DIO with too low rank: %u\n",
1545 (
unsigned)dio->rank);
1550 if(dio->prefix_info.length != 0) {
1551 if(dio->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
1552 LOG_DBG(
"Prefix announced in DIO\n");
1553 rpl_set_prefix(dag, &dio->prefix_info.prefix, dio->prefix_info.length);
1557 if(!add_nbr_from_dio(from, dio)) {
1558 LOG_WARN(
"Could not add parent based on DIO\n");
1563 if(dio->rank != RPL_INFINITE_RANK) {
1564 instance->dio_counter++;
1570 dag->lifetime = (1UL << (instance->dio_intmin + instance->dio_intdoubl)) * RPL_DAG_LIFETIME / 1000;
1571 LOG_INFO(
"Set dag ");
1572 LOG_INFO_6ADDR(&dag->dag_id);
1573 LOG_INFO_(
" lifetime to %ld\n", (
long int) dag->lifetime);
1582 p = rpl_find_parent(dag, from);
1584 previous_dag = find_parent_dag(instance, from);
1585 if(previous_dag == NULL) {
1587 p = rpl_add_parent(dag, dio, from);
1589 LOG_WARN(
"Failed to add a new parent (");
1590 LOG_WARN_6ADDR(from);
1594 LOG_INFO(
"New candidate parent with rank %u: ", (
unsigned)p->rank);
1595 LOG_INFO_6ADDR(from);
1598 p = rpl_find_parent(previous_dag, from);
1600 rpl_move_parent(previous_dag, dag, p);
1604 if(p->rank == dio->rank) {
1605 LOG_WARN(
"Received consistent DIO\n");
1607 instance->dio_counter++;
1611 p->rank = dio->rank;
1613 if(dio->rank == RPL_INFINITE_RANK && p == dag->preferred_parent) {
1615 rpl_reset_dio_timer(instance);
1619 p->flags |= RPL_PARENT_FLAG_UPDATED;
1621 LOG_INFO(
"preferred DAG ");
1622 LOG_INFO_6ADDR(&instance->current_dag->dag_id);
1623 LOG_INFO_(
", rank %u, min_rank %u, ",
1624 instance->current_dag->rank, instance->current_dag->min_rank);
1625 LOG_INFO_(
"parent rank %u, link metric %u\n",
1626 p->rank, rpl_get_parent_link_metric(p));
1631 memcpy(&p->mc, &dio->mc,
sizeof(p->mc));
1633 if(rpl_process_parent_event(instance, p) == 0) {
1634 LOG_WARN(
"The candidate parent is rejected\n");
1639 if(dag->joined && p == dag->preferred_parent) {
1640 if(should_refresh_routes(instance, dio, p)) {
1643 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
1644 rpl_schedule_dao(instance);
1648 uip_ds6_defrt_add(from, RPL_DEFAULT_ROUTE_INFINITE_LIFETIME ? 0 :
RPL_LIFETIME(instance, instance->default_lifetime));
1650 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.
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()