struct list_head prefixes = LIST_HEAD_INIT(prefixes);
-static struct list_head source_tables = LIST_HEAD_INIT(source_tables);
static struct device_prefix *ula_prefix = NULL;
static struct uloop_timeout valid_until_timeout;
}
}
-static struct device_source_table*
-find_source_table(const struct device_route *route)
-{
- struct device_source_table key = {
- .v6 = (route->flags & DEVADDR_FAMILY) == DEVADDR_INET6,
- .addr = route->source,
- .mask = route->sourcemask
- };
- struct device_source_table *c;
- list_for_each_entry(c, &source_tables, head)
- if (!memcmp(&c->v6, &key.v6, sizeof(key) -
- offsetof(struct device_source_table, v6)))
- return c;
- return NULL;
-}
-
-static uint32_t
-get_source_table(const struct device_route *route)
-{
- if (route->table || route->sourcemask == 0)
- return route->table;
-
- struct device_source_table *tbl = find_source_table(route);
-
- if (!tbl) {
- tbl = calloc(1, sizeof(*tbl));
- tbl->addr = route->source;
- tbl->mask = route->sourcemask;
- tbl->v6 = (route->flags & DEVADDR_FAMILY) == DEVADDR_INET6;
- tbl->table = IPRULE_PRIORITY_SOURCE | (((~tbl->mask) & 0x7f) << 20);
-
- struct list_head *before = NULL;
- struct device_source_table *c;
- list_for_each_entry(c, &source_tables, head) {
- if (c->table > tbl->table) {
- before = &c->head;
- break;
- } else if (c->table == tbl->table) {
- ++tbl->table;
- }
- }
-
- if (!before)
- before = &source_tables;
-
- list_add_tail(&tbl->head, before);
- set_ip_source_policy(true, tbl->v6, tbl->table, &tbl->addr,
- tbl->mask, tbl->table, NULL, NULL);
- }
-
- ++tbl->refcount;
- return tbl->table;
-}
-
-static void
-put_source_table(const struct device_route *route)
-{
- struct device_source_table *tbl = find_source_table(route);
- if (tbl && tbl->table == route->table && --tbl->refcount == 0) {
- set_ip_source_policy(false, tbl->v6, tbl->table, &tbl->addr,
- tbl->mask, tbl->table, NULL, NULL);
- list_del(&tbl->head);
- free(tbl);
- }
-}
-
static bool
interface_ip_find_addr_target(struct interface *iface, union if_addr *a, bool v6)
{
}
route->sourcemask = atoi(mask);
- } else if (is_proto_route) {
+ }
+
+ if (is_proto_route) {
route->table = (v6) ? iface->ip6table : iface->ip4table;
route->flags |= DEVROUTE_SRCTABLE;
}
route->valid_until = valid_until;
}
- if (route->sourcemask) {
- route->table = get_source_table(route);
- route->flags |= DEVROUTE_SRCTABLE;
- }
-
vlist_add(&ip->route, &route->node, route);
return;
if (!(route_old->flags & DEVADDR_EXTERNAL) && route_old->enabled && !keep)
system_del_route(dev, route_old);
- put_source_table(route_old);
free(route_old);
}
struct rtmsg rtm = {
.rtm_family = (alen == 4) ? AF_INET : AF_INET6,
.rtm_dst_len = route->mask,
+ .rtm_src_len = route->sourcemask,
.rtm_table = (table < 256) ? table : RT_TABLE_UNSPEC,
.rtm_protocol = (route->flags & DEVADDR_KERNEL) ? RTPROT_KERNEL : RTPROT_STATIC,
.rtm_scope = scope,
if (route->mask)
nla_put(msg, RTA_DST, alen, &route->addr);
+ if (route->sourcemask)
+ nla_put(msg, RTA_SRC, alen, &route->source);
+
if (route->metric > 0)
nla_put_u32(msg, RTA_PRIORITY, route->metric);