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" 63 #define DEBUG DEBUG_NONE 67 #ifdef RPL_CALLBACK_PARENT_SWITCH 68 void RPL_CALLBACK_PARENT_SWITCH(rpl_parent_t *old, rpl_parent_t *
new);
73 static rpl_of_t *
const objective_functions[] = RPL_SUPPORTED_OFS;
78 #ifndef RPL_CONF_GROUNDED 79 #define RPL_GROUNDED 0 81 #define RPL_GROUNDED RPL_CONF_GROUNDED 86 NBR_TABLE_GLOBAL(rpl_parent_t, rpl_parents);
94 rpl_print_neighbor_list(
void)
96 if(default_instance != NULL && default_instance->current_dag != NULL &&
97 default_instance->of != NULL) {
98 int curr_dio_interval = default_instance->dio_intcurrent;
99 int curr_rank = default_instance->current_dag->rank;
100 rpl_parent_t *p = nbr_table_head(rpl_parents);
103 printf(
"RPL: MOP %u OCP %u rank %u dioint %u, nbr count %u\n",
104 default_instance->mop, default_instance->of->ocp, curr_rank, curr_dio_interval, uip_ds6_nbr_num());
106 const struct link_stats *stats = rpl_get_parent_link_stats(p);
107 printf(
"RPL: nbr %3u %5u, %5u => %5u -- %2u %c%c (last tx %u min ago)\n",
108 rpl_parent_get_ipaddr(p)->u8[15],
110 rpl_get_parent_link_metric(p),
111 rpl_rank_via_parent(p),
112 stats != NULL ? stats->freshness : 0,
113 link_stats_is_fresh(stats) ?
'f' :
' ',
114 p == default_instance->current_dag->preferred_parent ?
'p' :
' ',
115 (
unsigned)((clock_now - stats->last_tx_time) / (60 *
CLOCK_SECOND))
117 p = nbr_table_next(rpl_parents, p);
119 printf(
"RPL: end of list\n");
124 rpl_get_nbr(rpl_parent_t *parent)
126 const linkaddr_t *lladdr = rpl_get_parent_lladdr(parent);
128 return nbr_table_get_from_lladdr(ds6_neighbors, lladdr);
135 nbr_callback(
void *ptr)
137 rpl_remove_parent(ptr);
143 nbr_table_register(rpl_parents, (nbr_table_callback *)nbr_callback);
147 rpl_get_parent(uip_lladdr_t *
addr)
149 rpl_parent_t *p = nbr_table_get_from_lladdr(rpl_parents, (linkaddr_t *)addr);
154 rpl_get_parent_rank(uip_lladdr_t *addr)
156 rpl_parent_t *p = nbr_table_get_from_lladdr(rpl_parents, (linkaddr_t *)addr);
160 return RPL_INFINITE_RANK;
165 rpl_get_parent_link_metric(rpl_parent_t *p)
167 if(p != NULL && p->dag != NULL) {
169 if(instance != NULL && instance->of != NULL && instance->of->parent_link_metric != NULL) {
170 return instance->of->parent_link_metric(p);
177 rpl_rank_via_parent(rpl_parent_t *p)
179 if(p != NULL && p->dag != NULL) {
181 if(instance != NULL && instance->of != NULL && instance->of->rank_via_parent != NULL) {
182 return instance->of->rank_via_parent(p);
185 return RPL_INFINITE_RANK;
189 rpl_get_parent_lladdr(rpl_parent_t *p)
191 return nbr_table_get_lladdr(rpl_parents, p);
195 rpl_parent_get_ipaddr(rpl_parent_t *p)
197 const linkaddr_t *lladdr = rpl_get_parent_lladdr(p);
198 return uip_ds6_nbr_ipaddr_from_lladdr((uip_lladdr_t *)lladdr);
201 const struct link_stats *
202 rpl_get_parent_link_stats(rpl_parent_t *p)
204 const linkaddr_t *lladdr = rpl_get_parent_lladdr(p);
205 return link_stats_from_lladdr(lladdr);
209 rpl_parent_is_fresh(rpl_parent_t *p)
211 const struct link_stats *stats = rpl_get_parent_link_stats(p);
212 return link_stats_is_fresh(stats);
216 rpl_parent_is_reachable(rpl_parent_t *p) {
217 if(p == NULL || p->dag == NULL || p->dag->instance == NULL || p->dag->instance->of == NULL) {
223 if(nbr == NULL || nbr->state != NBR_REACHABLE) {
228 return !rpl_parent_is_fresh(p) || p->dag->instance->of->parent_has_usable_link(p);
233 rpl_set_preferred_parent(
rpl_dag_t *dag, rpl_parent_t *p)
235 if(dag != NULL && dag->preferred_parent != p) {
236 PRINTF(
"RPL: rpl_set_preferred_parent ");
238 PRINT6ADDR(rpl_parent_get_ipaddr(p));
242 PRINTF(
" used to be ");
243 if(dag->preferred_parent != NULL) {
244 PRINT6ADDR(rpl_parent_get_ipaddr(dag->preferred_parent));
250 #ifdef RPL_CALLBACK_PARENT_SWITCH 251 RPL_CALLBACK_PARENT_SWITCH(dag->preferred_parent, p);
256 nbr_table_unlock(rpl_parents, dag->preferred_parent);
257 nbr_table_lock(rpl_parents, p);
258 dag->preferred_parent = p;
265 lollipop_greater_than(
int a,
int b)
268 if(a > RPL_LOLLIPOP_CIRCULAR_REGION && b <= RPL_LOLLIPOP_CIRCULAR_REGION) {
269 return (RPL_LOLLIPOP_MAX_VALUE + 1 + b - a) > RPL_LOLLIPOP_SEQUENCE_WINDOWS;
273 return (a > b && (a - b) < RPL_LOLLIPOP_SEQUENCE_WINDOWS) ||
274 (a < b && (b - a) > (RPL_LOLLIPOP_CIRCULAR_REGION + 1-
275 RPL_LOLLIPOP_SEQUENCE_WINDOWS));
280 remove_parents(
rpl_dag_t *dag, rpl_rank_t minimum_rank)
284 PRINTF(
"RPL: Removing parents (minimum rank %u)\n",
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 PRINTF(
"RPL: Nullifying parents (minimum rank %u)\n",
304 p = nbr_table_head(rpl_parents);
306 if(dag == p->dag && p->rank >= minimum_rank) {
307 rpl_nullify_parent(p);
309 p = nbr_table_next(rpl_parents, p);
314 should_refresh_routes(
rpl_instance_t *instance, rpl_dio_t *dio, rpl_parent_t *p)
317 if(instance->mop == RPL_MOP_NO_DOWNWARD_ROUTES) {
321 return p == instance->current_dag->preferred_parent &&
322 (lollipop_greater_than(dio->dtsn, p->dtsn));
326 acceptable_rank(
rpl_dag_t *dag, rpl_rank_t rank)
328 return rank != RPL_INFINITE_RANK &&
329 ((dag->instance->max_rankinc == 0) ||
330 DAG_RANK(rank, dag->instance) <=
DAG_RANK(dag->min_rank + dag->instance->max_rankinc, dag->instance));
334 get_dag(uint8_t instance_id, uip_ipaddr_t *dag_id)
340 instance = rpl_get_instance(instance_id);
341 if(instance == NULL) {
345 for(i = 0; i < RPL_MAX_DAG_PER_INSTANCE; ++i) {
346 dag = &instance->dag_table[i];
347 if(dag->used && uip_ipaddr_cmp(&dag->dag_id, dag_id)) {
356 rpl_set_root(uint8_t instance_id, uip_ipaddr_t *dag_id)
363 version = RPL_LOLLIPOP_INIT;
364 instance = rpl_get_instance(instance_id);
365 if(instance != NULL) {
366 for(i = 0; i < RPL_MAX_DAG_PER_INSTANCE; ++i) {
367 dag = &instance->dag_table[i];
369 if(uip_ipaddr_cmp(&dag->dag_id, dag_id)) {
370 version = dag->version;
371 RPL_LOLLIPOP_INCREMENT(version);
373 if(dag == dag->instance->current_dag) {
374 PRINTF(
"RPL: Dropping a joined DAG when setting this node as root");
375 rpl_set_default_route(instance, NULL);
376 dag->instance->current_dag = NULL;
378 PRINTF(
"RPL: Dropping a DAG when setting this node as root");
385 dag = rpl_alloc_dag(instance_id, dag_id);
387 PRINTF(
"RPL: Failed to allocate a DAG\n");
391 instance = dag->instance;
393 dag->version = version;
395 dag->grounded = RPL_GROUNDED;
396 dag->preference = RPL_PREFERENCE;
397 instance->mop = RPL_MOP_DEFAULT;
398 instance->of = rpl_find_of(RPL_OF_OCP);
399 if(instance->of == NULL) {
400 PRINTF(
"RPL: OF with OCP %u not supported\n", RPL_OF_OCP);
404 rpl_set_preferred_parent(dag, NULL);
406 memcpy(&dag->dag_id, dag_id,
sizeof(dag->dag_id));
408 instance->dio_intdoubl = RPL_DIO_INTERVAL_DOUBLINGS;
409 instance->dio_intmin = RPL_DIO_INTERVAL_MIN;
412 instance->dio_intcurrent = RPL_DIO_INTERVAL_MIN +
413 RPL_DIO_INTERVAL_DOUBLINGS;
414 instance->dio_redundancy = RPL_DIO_REDUNDANCY;
415 instance->max_rankinc = RPL_MAX_RANKINC;
416 instance->min_hoprankinc = RPL_MIN_HOPRANKINC;
417 instance->default_lifetime = RPL_DEFAULT_LIFETIME;
418 instance->lifetime_unit = RPL_DEFAULT_LIFETIME_UNIT;
422 if(instance->current_dag != dag && instance->current_dag != NULL) {
424 if(RPL_IS_STORING(instance)) {
425 rpl_remove_routes(instance->current_dag);
428 instance->current_dag->joined = 0;
431 instance->current_dag = dag;
432 instance->dtsn_out = RPL_LOLLIPOP_INIT;
433 instance->of->update_metric_container(instance);
434 default_instance = instance;
436 PRINTF(
"RPL: Node set to be a DAG root with DAG ID ");
437 PRINT6ADDR(&dag->dag_id);
440 ANNOTATE(
"#A root=%u\n", dag->dag_id.u8[
sizeof(dag->dag_id) - 1]);
442 rpl_reset_dio_timer(instance);
448 rpl_repair_root(uint8_t instance_id)
452 instance = rpl_get_instance(instance_id);
453 if(instance == NULL ||
454 instance->current_dag->rank !=
ROOT_RANK(instance)) {
455 PRINTF(
"RPL: rpl_repair_root triggered but not root\n");
458 RPL_STAT(rpl_stats.root_repairs++);
460 RPL_LOLLIPOP_INCREMENT(instance->current_dag->version);
461 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
462 PRINTF(
"RPL: rpl_repair_root initiating global repair with version %d\n", instance->current_dag->version);
463 rpl_reset_dio_timer(instance);
470 memset(ipaddr, 0,
sizeof(uip_ipaddr_t));
471 memcpy(ipaddr, &prefix->prefix, (prefix->length + 7) / 8);
481 if(last_prefix != NULL && new_prefix != NULL &&
482 last_prefix->length == new_prefix->length &&
483 uip_ipaddr_prefixcmp(&last_prefix->prefix, &new_prefix->prefix, new_prefix->length) &&
484 last_prefix->flags == new_prefix->flags) {
489 if(last_prefix != NULL) {
490 set_ip_from_prefix(&ipaddr, last_prefix);
491 rep = uip_ds6_addr_lookup(&ipaddr);
493 PRINTF(
"RPL: removing global IP address ");
496 uip_ds6_addr_rm(rep);
500 if(new_prefix != NULL) {
501 set_ip_from_prefix(&ipaddr, new_prefix);
502 if(uip_ds6_addr_lookup(&ipaddr) == NULL) {
503 PRINTF(
"RPL: adding global IP address ");
512 rpl_set_prefix(
rpl_dag_t *dag, uip_ipaddr_t *prefix,
unsigned len)
515 uint8_t last_len = dag->prefix_info.length;
520 if(dag->prefix_info.length != 0) {
521 memcpy(&last_prefix, &dag->prefix_info,
sizeof(
rpl_prefix_t));
523 memset(&dag->prefix_info.prefix, 0,
sizeof(dag->prefix_info.prefix));
524 memcpy(&dag->prefix_info.prefix, prefix, (len + 7) / 8);
525 dag->prefix_info.length = len;
526 dag->prefix_info.flags = UIP_ND6_RA_FLAG_AUTONOMOUS;
527 PRINTF(
"RPL: Prefix set - will announce this in DIOs\n");
528 if(dag->rank !=
ROOT_RANK(dag->instance)) {
532 PRINTF(
"rpl_set_prefix - prefix NULL\n");
533 check_prefix(NULL, &dag->prefix_info);
535 PRINTF(
"rpl_set_prefix - prefix NON-NULL\n");
536 check_prefix(&last_prefix, &dag->prefix_info);
543 rpl_set_default_route(
rpl_instance_t *instance, uip_ipaddr_t *from)
545 if(instance->def_route != NULL) {
546 PRINTF(
"RPL: Removing default route through ");
547 PRINT6ADDR(&instance->def_route->ipaddr);
549 uip_ds6_defrt_rm(instance->def_route);
550 instance->def_route = NULL;
554 PRINTF(
"RPL: Adding default route through ");
557 instance->def_route = uip_ds6_defrt_add(from,
558 RPL_DEFAULT_ROUTE_INFINITE_LIFETIME ? 0 :
RPL_LIFETIME(instance, instance->default_lifetime));
559 if(instance->def_route == NULL) {
567 rpl_alloc_instance(uint8_t instance_id)
571 for(instance = &instance_table[0], end = instance + RPL_MAX_INSTANCES;
572 instance < end; ++instance) {
573 if(instance->used == 0) {
574 memset(instance, 0,
sizeof(*instance));
575 instance->instance_id = instance_id;
576 instance->def_route = NULL;
588 rpl_alloc_dag(uint8_t instance_id, uip_ipaddr_t *dag_id)
593 instance = rpl_get_instance(instance_id);
594 if(instance == NULL) {
595 instance = rpl_alloc_instance(instance_id);
596 if(instance == NULL) {
597 RPL_STAT(rpl_stats.mem_overflows++);
602 for(dag = &instance->dag_table[0], end = dag + RPL_MAX_DAG_PER_INSTANCE; dag < end; ++dag) {
604 memset(dag, 0,
sizeof(*dag));
606 dag->rank = RPL_INFINITE_RANK;
607 dag->min_rank = RPL_INFINITE_RANK;
608 dag->instance = instance;
613 RPL_STAT(rpl_stats.mem_overflows++);
620 default_instance = instance;
626 return default_instance;
635 PRINTF(
"RPL: Leaving the instance %u\n", instance->instance_id);
638 for(dag = &instance->dag_table[0], end = dag + RPL_MAX_DAG_PER_INSTANCE; dag < end; ++dag) {
644 rpl_set_default_route(instance, NULL);
653 if(default_instance == instance) {
654 default_instance = NULL;
664 PRINTF(
"RPL: Leaving the DAG ");
665 PRINT6ADDR(&dag->dag_id);
670 if(RPL_IS_STORING(dag->instance)) {
671 rpl_remove_routes(dag);
679 if((dag->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS)) {
680 check_prefix(&dag->prefix_info, NULL);
683 remove_parents(dag, 0);
689 rpl_add_parent(
rpl_dag_t *dag, rpl_dio_t *dio, uip_ipaddr_t *addr)
691 rpl_parent_t *p = NULL;
694 const uip_lladdr_t *lladdr = uip_ds6_nbr_lladdr_from_ipaddr(addr);
696 PRINTF(
"RPL: rpl_add_parent lladdr %p ", lladdr);
701 p = nbr_table_add_lladdr(rpl_parents, (linkaddr_t *)lladdr,
702 NBR_TABLE_REASON_RPL_DIO, dio);
704 PRINTF(
"RPL: rpl_add_parent p NULL\n");
710 memcpy(&p->mc, &dio->mc,
sizeof(p->mc));
718 static rpl_parent_t *
719 find_parent_any_dag_any_instance(uip_ipaddr_t *addr)
722 const uip_lladdr_t *lladdr = uip_ds6_nbr_get_ll(ds6_nbr);
723 return nbr_table_get_from_lladdr(rpl_parents, (linkaddr_t *)lladdr);
727 rpl_find_parent(
rpl_dag_t *dag, uip_ipaddr_t *addr)
729 rpl_parent_t *p = find_parent_any_dag_any_instance(addr);
730 if(p != NULL && p->dag == dag) {
740 rpl_parent_t *p = find_parent_any_dag_any_instance(addr);
749 rpl_find_parent_any_dag(
rpl_instance_t *instance, uip_ipaddr_t *addr)
751 rpl_parent_t *p = find_parent_any_dag_any_instance(addr);
752 if(p && p->dag && p->dag->instance == instance) {
762 rpl_parent_t *last_parent;
766 old_rank = instance->current_dag->rank;
767 last_parent = instance->current_dag->preferred_parent;
769 if(instance->current_dag->rank !=
ROOT_RANK(instance)) {
770 rpl_select_parent(p->dag);
774 for(dag = &instance->dag_table[0], end = dag + RPL_MAX_DAG_PER_INSTANCE; dag < end; ++dag) {
775 if(dag->used && dag->preferred_parent != NULL && dag->preferred_parent->rank != RPL_INFINITE_RANK) {
776 if(best_dag == NULL) {
779 best_dag = instance->of->best_dag(best_dag, dag);
784 if(best_dag == NULL) {
789 if(instance->current_dag != best_dag) {
791 if(RPL_IS_STORING(instance)) {
792 rpl_remove_routes(instance->current_dag);
795 PRINTF(
"RPL: New preferred DAG: ");
796 PRINT6ADDR(&best_dag->dag_id);
799 if(best_dag->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
800 check_prefix(&instance->current_dag->prefix_info, &best_dag->prefix_info);
801 }
else if(instance->current_dag->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
802 check_prefix(&instance->current_dag->prefix_info, NULL);
805 best_dag->joined = 1;
806 instance->current_dag->joined = 0;
807 instance->current_dag = best_dag;
810 instance->of->update_metric_container(instance);
812 best_dag->rank = rpl_rank_via_parent(best_dag->preferred_parent);
813 if(last_parent == NULL || best_dag->rank < best_dag->min_rank) {
816 best_dag->min_rank = best_dag->rank;
819 if(!acceptable_rank(best_dag, best_dag->rank)) {
820 PRINTF(
"RPL: New rank unacceptable!\n");
821 rpl_set_preferred_parent(instance->current_dag, NULL);
822 if(RPL_IS_STORING(instance) && last_parent != NULL) {
824 dao_output(last_parent, RPL_ZERO_LIFETIME);
829 if(best_dag->preferred_parent != last_parent) {
830 rpl_set_default_route(instance, rpl_parent_get_ipaddr(best_dag->preferred_parent));
831 PRINTF(
"RPL: Changed preferred parent, rank changed from %u to %u\n",
832 (
unsigned)old_rank, best_dag->rank);
833 RPL_STAT(rpl_stats.parent_switch++);
834 if(RPL_IS_STORING(instance)) {
835 if(last_parent != NULL) {
837 dao_output(last_parent, RPL_ZERO_LIFETIME);
841 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
844 rpl_schedule_dao(instance);
845 rpl_reset_dio_timer(instance);
847 rpl_print_neighbor_list();
849 }
else if(best_dag->rank != old_rank) {
850 PRINTF(
"RPL: Preferred parent update, rank changed from %u to %u\n",
851 (
unsigned)old_rank, best_dag->rank);
856 static rpl_parent_t *
857 best_parent(
rpl_dag_t *dag,
int fresh_only)
861 rpl_parent_t *best = NULL;
863 if(dag == NULL || dag->instance == NULL || dag->instance->of == NULL) {
867 of = dag->instance->of;
869 for(p = nbr_table_head(rpl_parents); p != NULL; p = nbr_table_next(rpl_parents, p)) {
872 if(p->dag != dag || p->rank == RPL_INFINITE_RANK || p->rank <
ROOT_RANK(dag->instance)) {
874 PRINTF(
"RPL: Parent has invalid rank\n");
879 if(fresh_only && !rpl_parent_is_fresh(p)) {
888 if(nbr == NULL || nbr->state != NBR_REACHABLE) {
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 PRINTF(
"RPL: Removing parent ");
943 PRINT6ADDR(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 PRINTF(
"RPL: Removing default route ");
962 PRINT6ADDR(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 PRINTF(
"RPL: Nullifying parent ");
978 PRINT6ADDR(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 PRINTF(
"RPL: Removing default route ");
990 PRINT6ADDR(rpl_parent_get_ipaddr(parent));
992 PRINTF(
"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 PRINTF(
"RPL: Moving parent ");
1004 PRINT6ADDR(rpl_parent_get_ipaddr(parent));
1007 parent->dag = dag_dst;
1023 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1024 if(instance_table[i].used && instance_table[i].has_downward_route) {
1032 rpl_get_dag(
const uip_ipaddr_t *addr)
1036 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1037 if(instance_table[i].used) {
1038 for(j = 0; j < RPL_MAX_DAG_PER_INSTANCE; ++j) {
1039 if(instance_table[i].dag_table[j].joined
1040 && uip_ipaddr_prefixcmp(&instance_table[i].dag_table[j].dag_id, addr,
1041 instance_table[i].dag_table[j].prefix_info.length)) {
1042 return &instance_table[i].dag_table[j];
1055 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1056 if(instance_table[i].used && instance_table[i].current_dag->joined) {
1057 return instance_table[i].current_dag;
1064 rpl_get_instance(uint8_t instance_id)
1068 for(i = 0; i < RPL_MAX_INSTANCES; ++i) {
1069 if(instance_table[i].used && instance_table[i].instance_id == instance_id) {
1070 return &instance_table[i];
1077 rpl_find_of(rpl_ocp_t ocp)
1082 i <
sizeof(objective_functions) /
sizeof(objective_functions[0]);
1084 if(objective_functions[i]->ocp == ocp) {
1085 return objective_functions[i];
1093 rpl_join_instance(uip_ipaddr_t *from, rpl_dio_t *dio)
1100 if((!RPL_WITH_NON_STORING && dio->mop == RPL_MOP_NON_STORING)
1101 || (!RPL_WITH_STORING && (dio->mop == RPL_MOP_STORING_NO_MULTICAST
1102 || dio->mop == RPL_MOP_STORING_MULTICAST))) {
1103 PRINTF(
"RPL: DIO advertising a non-supported MOP %u\n", dio->mop);
1109 of = rpl_find_of(dio->ocp);
1111 PRINTF(
"RPL: DIO for DAG instance %u does not specify a supported OF: %u\n",
1112 dio->instance_id, dio->ocp);
1116 dag = rpl_alloc_dag(dio->instance_id, &dio->dag_id);
1118 PRINTF(
"RPL: Failed to allocate a DAG object!\n");
1122 instance = dag->instance;
1124 p = rpl_add_parent(dag, dio, from);
1125 PRINTF(
"RPL: Adding ");
1127 PRINTF(
" as a parent: ");
1133 p->dtsn = dio->dtsn;
1134 PRINTF(
"succeeded\n");
1138 if(dio->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
1139 check_prefix(NULL, &dio->prefix_info);
1143 dag->preference = dio->preference;
1144 dag->grounded = dio->grounded;
1145 dag->version = dio->version;
1148 instance->mop = dio->mop;
1149 instance->mc.type = dio->mc.type;
1150 instance->mc.flags = dio->mc.flags;
1151 instance->mc.aggr = dio->mc.aggr;
1152 instance->mc.prec = dio->mc.prec;
1153 instance->current_dag = dag;
1154 instance->dtsn_out = RPL_LOLLIPOP_INIT;
1156 instance->max_rankinc = dio->dag_max_rankinc;
1157 instance->min_hoprankinc = dio->dag_min_hoprankinc;
1158 instance->dio_intdoubl = dio->dag_intdoubl;
1159 instance->dio_intmin = dio->dag_intmin;
1160 instance->dio_intcurrent = instance->dio_intmin + instance->dio_intdoubl;
1161 instance->dio_redundancy = dio->dag_redund;
1162 instance->default_lifetime = dio->default_lifetime;
1163 instance->lifetime_unit = dio->lifetime_unit;
1165 memcpy(&dag->dag_id, &dio->dag_id,
sizeof(dio->dag_id));
1168 memcpy(&dag->prefix_info, &dio->prefix_info,
sizeof(
rpl_prefix_t));
1170 rpl_set_preferred_parent(dag, p);
1171 instance->of->update_metric_container(instance);
1172 dag->rank = rpl_rank_via_parent(p);
1174 dag->min_rank = dag->rank;
1176 if(default_instance == NULL) {
1177 default_instance = instance;
1180 PRINTF(
"RPL: Joined DAG with instance ID %u, rank %hu, DAG ID ",
1181 dio->instance_id, dag->rank);
1182 PRINT6ADDR(&dag->dag_id);
1185 ANNOTATE(
"#A join=%u\n", dag->dag_id.u8[
sizeof(dag->dag_id) - 1]);
1187 rpl_reset_dio_timer(instance);
1188 rpl_set_default_route(instance, from);
1190 if(instance->mop != RPL_MOP_NO_DOWNWARD_ROUTES) {
1191 rpl_schedule_dao(instance);
1193 PRINTF(
"RPL: The DIO does not meet the prerequisites for sending a DAO\n");
1196 instance->of->reset(dag);
1199 #if RPL_MAX_DAG_PER_INSTANCE > 1 1202 rpl_add_dag(uip_ipaddr_t *from, rpl_dio_t *dio)
1209 dag = rpl_alloc_dag(dio->instance_id, &dio->dag_id);
1211 PRINTF(
"RPL: Failed to allocate a DAG object!\n");
1215 instance = dag->instance;
1217 previous_dag = find_parent_dag(instance, from);
1218 if(previous_dag == NULL) {
1219 PRINTF(
"RPL: Adding ");
1221 PRINTF(
" as a parent: ");
1222 p = rpl_add_parent(dag, dio, from);
1228 PRINTF(
"succeeded\n");
1230 p = rpl_find_parent(previous_dag, from);
1232 rpl_move_parent(previous_dag, dag, p);
1235 p->rank = dio->rank;
1239 of = rpl_find_of(dio->ocp);
1240 if(of != instance->of ||
1241 instance->mop != dio->mop ||
1242 instance->max_rankinc != dio->dag_max_rankinc ||
1243 instance->min_hoprankinc != dio->dag_min_hoprankinc ||
1244 instance->dio_intdoubl != dio->dag_intdoubl ||
1245 instance->dio_intmin != dio->dag_intmin ||
1246 instance->dio_redundancy != dio->dag_redund ||
1247 instance->default_lifetime != dio->default_lifetime ||
1248 instance->lifetime_unit != dio->lifetime_unit) {
1249 PRINTF(
"RPL: DIO for DAG instance %u incompatible with previous DIO\n",
1251 rpl_remove_parent(p);
1257 dag->grounded = dio->grounded;
1258 dag->preference = dio->preference;
1259 dag->version = dio->version;
1261 memcpy(&dag->dag_id, &dio->dag_id,
sizeof(dio->dag_id));
1264 memcpy(&dag->prefix_info, &dio->prefix_info,
sizeof(
rpl_prefix_t));
1266 rpl_set_preferred_parent(dag, p);
1267 dag->rank = rpl_rank_via_parent(p);
1268 dag->min_rank = dag->rank;
1270 PRINTF(
"RPL: Joined DAG with instance ID %u, rank %hu, DAG ID ",
1271 dio->instance_id, dag->rank);
1272 PRINT6ADDR(&dag->dag_id);
1275 ANNOTATE(
"#A join=%u\n", dag->dag_id.u8[
sizeof(dag->dag_id) - 1]);
1277 rpl_process_parent_event(instance, p);
1278 p->dtsn = dio->dtsn;
1286 global_repair(uip_ipaddr_t *from,
rpl_dag_t *dag, rpl_dio_t *dio)
1290 remove_parents(dag, 0);
1291 dag->version = dio->version;
1294 dag->instance->dio_intdoubl = dio->dag_intdoubl;
1295 dag->instance->dio_intmin = dio->dag_intmin;
1296 dag->instance->dio_redundancy = dio->dag_redund;
1297 dag->instance->default_lifetime = dio->default_lifetime;
1298 dag->instance->lifetime_unit = dio->lifetime_unit;
1300 dag->instance->of->reset(dag);
1301 dag->min_rank = RPL_INFINITE_RANK;
1302 RPL_LOLLIPOP_INCREMENT(dag->instance->dtsn_out);
1304 p = rpl_add_parent(dag, dio, from);
1306 PRINTF(
"RPL: Failed to add a parent during the global repair\n");
1307 dag->rank = RPL_INFINITE_RANK;
1309 dag->rank = rpl_rank_via_parent(p);
1310 dag->min_rank = dag->rank;
1311 PRINTF(
"RPL: rpl_process_parent_event global repair\n");
1312 rpl_process_parent_event(dag->instance, p);
1315 PRINTF(
"RPL: Participating in a global repair (version=%u, rank=%hu)\n",
1316 dag->version, dag->rank);
1318 RPL_STAT(rpl_stats.global_repairs++);
1327 if(instance == NULL) {
1328 PRINTF(
"RPL: local repair requested for instance NULL\n");
1331 PRINTF(
"RPL: Starting a local instance repair\n");
1332 for(i = 0; i < RPL_MAX_DAG_PER_INSTANCE; i++) {
1333 if(instance->dag_table[i].used) {
1334 instance->dag_table[i].rank = RPL_INFINITE_RANK;
1335 nullify_parents(&instance->dag_table[i], 0);
1340 instance->has_downward_route = 0;
1341 #if RPL_WITH_DAO_ACK 1345 rpl_reset_dio_timer(instance);
1346 if(RPL_IS_STORING(instance)) {
1350 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
1353 RPL_STAT(rpl_stats.local_repairs++);
1357 rpl_recalculate_ranks(
void)
1366 p = nbr_table_head(rpl_parents);
1368 if(p->dag != NULL && p->dag->instance && (p->flags & RPL_PARENT_FLAG_UPDATED)) {
1369 p->flags &= ~RPL_PARENT_FLAG_UPDATED;
1370 PRINTF(
"RPL: rpl_process_parent_event recalculate_ranks\n");
1371 if(!rpl_process_parent_event(p->dag->instance, p)) {
1372 PRINTF(
"RPL: A parent was dropped\n");
1375 p = nbr_table_next(rpl_parents, p);
1380 rpl_process_parent_event(
rpl_instance_t *instance, rpl_parent_t *p)
1383 rpl_parent_t *last_parent = instance->current_dag->preferred_parent;
1386 rpl_rank_t old_rank;
1387 old_rank = instance->current_dag->rank;
1392 if(RPL_IS_STORING(instance)
1393 && uip_ds6_route_is_nexthop(rpl_parent_get_ipaddr(p))
1394 && !rpl_parent_is_reachable(p) && instance->mop > RPL_MOP_NON_STORING) {
1395 PRINTF(
"RPL: Unacceptable link %u, removing routes via: ", rpl_get_parent_link_metric(p));
1396 PRINT6ADDR(rpl_parent_get_ipaddr(p));
1398 rpl_remove_routes_by_nexthop(rpl_parent_get_ipaddr(p), p->dag);
1401 if(!acceptable_rank(p->dag, p->rank)) {
1404 PRINTF(
"RPL: Unacceptable rank %u (Current min %u, MaxRankInc %u)\n", (
unsigned)p->rank,
1405 p->dag->min_rank, p->dag->instance->max_rankinc);
1406 rpl_nullify_parent(p);
1407 if(p != instance->current_dag->preferred_parent) {
1414 if(rpl_select_dag(instance, p) == NULL) {
1415 if(last_parent != NULL) {
1417 PRINTF(
"RPL: No parents found in any DAG\n");
1424 if(
DAG_RANK(old_rank, instance) !=
DAG_RANK(instance->current_dag->rank, instance)) {
1425 PRINTF(
"RPL: Moving in the instance from rank %hu to %hu\n",
1426 DAG_RANK(old_rank, instance),
DAG_RANK(instance->current_dag->rank, instance));
1427 if(instance->current_dag->rank != RPL_INFINITE_RANK) {
1428 PRINTF(
"RPL: The preferred parent is ");
1429 PRINT6ADDR(rpl_parent_get_ipaddr(instance->current_dag->preferred_parent));
1430 PRINTF(
" (rank %u)\n",
1431 (
unsigned)
DAG_RANK(instance->current_dag->preferred_parent->rank, instance));
1433 PRINTF(
"RPL: We don't have any parent");
1438 return return_value;
1442 add_nbr_from_dio(uip_ipaddr_t *from, rpl_dio_t *dio)
1446 PRINTF(
"RPL: Out of memory, dropping DIO from ");
1461 #if RPL_WITH_MULTICAST 1464 if(dio->mop < RPL_MOP_STORING_NO_MULTICAST) {
1466 if(dio->mop != RPL_MOP_DEFAULT) {
1468 PRINTF(
"RPL: Ignoring a DIO with an unsupported MOP: %d\n", dio->mop);
1472 dag = get_dag(dio->instance_id, &dio->dag_id);
1473 instance = rpl_get_instance(dio->instance_id);
1475 if(dag != NULL && instance != NULL) {
1476 if(lollipop_greater_than(dio->version, dag->version)) {
1478 PRINTF(
"RPL: Root received inconsistent DIO version number (current: %u, received: %u)\n", dag->version, dio->version);
1479 dag->version = dio->version;
1480 RPL_LOLLIPOP_INCREMENT(dag->version);
1481 rpl_reset_dio_timer(instance);
1483 PRINTF(
"RPL: Global repair\n");
1484 if(dio->prefix_info.length != 0) {
1485 if(dio->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
1486 PRINTF(
"RPL: Prefix announced in DIO\n");
1487 rpl_set_prefix(dag, &dio->prefix_info.prefix, dio->prefix_info.length);
1490 global_repair(from, dag, dio);
1495 if(lollipop_greater_than(dag->version, dio->version)) {
1497 PRINTF(
"RPL: old version received => inconsistency detected\n");
1499 rpl_reset_dio_timer(instance);
1505 if(instance == NULL) {
1506 PRINTF(
"RPL: New instance detected (ID=%u): Joining...\n", dio->instance_id);
1507 if(add_nbr_from_dio(from, dio)) {
1508 rpl_join_instance(from, dio);
1510 PRINTF(
"RPL: Not joining since could not add parent\n");
1515 if(instance->current_dag->rank ==
ROOT_RANK(instance) && instance->current_dag != dag) {
1516 PRINTF(
"RPL: Root ignored DIO for different DAG\n");
1521 #if RPL_MAX_DAG_PER_INSTANCE > 1 1522 PRINTF(
"RPL: Adding new DAG to known instance.\n");
1523 if(!add_nbr_from_dio(from, dio)) {
1524 PRINTF(
"RPL: Could not add new DAG, could not add parent\n");
1527 dag = rpl_add_dag(from, dio);
1529 PRINTF(
"RPL: Failed to add DAG.\n");
1533 PRINTF(
"RPL: Only one instance supported.\n");
1540 PRINTF(
"RPL: Ignoring DIO with too low rank: %u\n",
1541 (
unsigned)dio->rank);
1546 if(dio->prefix_info.length != 0) {
1547 if(dio->prefix_info.flags & UIP_ND6_RA_FLAG_AUTONOMOUS) {
1548 PRINTF(
"RPL: Prefix announced in DIO\n");
1549 rpl_set_prefix(dag, &dio->prefix_info.prefix, dio->prefix_info.length);
1553 if(!add_nbr_from_dio(from, dio)) {
1554 PRINTF(
"RPL: Could not add parent based on DIO\n");
1559 if(dio->rank != RPL_INFINITE_RANK) {
1560 instance->dio_counter++;
1566 dag->lifetime = (1UL << (instance->dio_intmin + instance->dio_intdoubl)) * RPL_DAG_LIFETIME / 1000;
1568 PRINT6ADDR(&dag->dag_id);
1569 PRINTF(
" lifetime to %ld\n", dag->lifetime);
1578 p = rpl_find_parent(dag, from);
1580 previous_dag = find_parent_dag(instance, from);
1581 if(previous_dag == NULL) {
1583 p = rpl_add_parent(dag, dio, from);
1585 PRINTF(
"RPL: Failed to add a new parent (");
1590 PRINTF(
"RPL: New candidate parent with rank %u: ", (
unsigned)p->rank);
1594 p = rpl_find_parent(previous_dag, from);
1596 rpl_move_parent(previous_dag, dag, p);
1600 if(p->rank == dio->rank) {
1601 PRINTF(
"RPL: Received consistent DIO\n");
1603 instance->dio_counter++;
1607 p->rank = dio->rank;
1609 if(dio->rank == RPL_INFINITE_RANK && p == dag->preferred_parent) {
1611 rpl_reset_dio_timer(instance);
1615 p->flags |= RPL_PARENT_FLAG_UPDATED;
1617 PRINTF(
"RPL: preferred DAG ");
1618 PRINT6ADDR(&instance->current_dag->dag_id);
1619 PRINTF(
", rank %u, min_rank %u, ",
1620 instance->current_dag->rank, instance->current_dag->min_rank);
1621 PRINTF(
"parent rank %u, link metric %u\n",
1622 p->rank, rpl_get_parent_link_metric(p));
1627 memcpy(&p->mc, &dio->mc,
sizeof(p->mc));
1629 if(rpl_process_parent_event(instance, p) == 0) {
1630 PRINTF(
"RPL: The candidate parent is rejected\n");
1635 if(dag->joined && p == dag->preferred_parent) {
1636 if(should_refresh_routes(instance, dio, p)) {
1639 RPL_LOLLIPOP_INCREMENT(instance->dtsn_out);
1640 rpl_schedule_dao(instance);
1644 uip_ds6_defrt_add(from, RPL_DEFAULT_ROUTE_INFINITE_LIFETIME ? 0 :
RPL_LIFETIME(instance, instance->default_lifetime));
1646 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)
A set of debugging macros for the IP stack
#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.
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()