2022-03-31 17:09:38 +00:00
|
|
|
/*
|
|
|
|
* BIRD Internet Routing Daemon -- Routing data structures
|
|
|
|
*
|
|
|
|
* (c) 1998--2000 Martin Mares <mj@ucw.cz>
|
|
|
|
* (c) 2022 Maria Matejka <mq@jmq.cz>
|
|
|
|
*
|
|
|
|
* Can be freely distributed and used under the terms of the GNU GPL.
|
|
|
|
*/
|
|
|
|
|
|
|
|
#ifndef _BIRD_LIB_ROUTE_H_
|
|
|
|
#define _BIRD_LIB_ROUTE_H_
|
|
|
|
|
2022-08-03 12:07:53 +00:00
|
|
|
#undef RT_SOURCE_DEBUG
|
2024-11-22 13:49:13 +00:00
|
|
|
#undef EA_FREE_DEBUG
|
2022-08-03 12:07:53 +00:00
|
|
|
|
2022-03-31 17:29:17 +00:00
|
|
|
#include "lib/type.h"
|
2022-08-02 20:08:59 +00:00
|
|
|
#include "lib/rcu.h"
|
|
|
|
#include "lib/hash.h"
|
|
|
|
#include "lib/event.h"
|
2023-11-24 07:46:50 +00:00
|
|
|
#include "lib/lockfree.h"
|
2022-03-31 17:29:17 +00:00
|
|
|
|
2022-03-31 17:09:38 +00:00
|
|
|
struct network;
|
|
|
|
struct proto;
|
|
|
|
struct cli;
|
2022-09-07 11:54:20 +00:00
|
|
|
struct rtable_private;
|
2023-07-03 18:38:24 +00:00
|
|
|
struct rte_storage;
|
|
|
|
|
|
|
|
#define RTE_IN_TABLE_WRITABLE \
|
|
|
|
byte pflags; /* Protocol-specific flags; may change in-table (!) */ \
|
2024-03-13 12:46:16 +00:00
|
|
|
byte flags; /* Table-specific flags */ \
|
2023-07-03 18:38:24 +00:00
|
|
|
u8 stale_cycle; /* Auxiliary value for route refresh; may change in-table (!) */ \
|
2022-05-30 14:20:35 +00:00
|
|
|
|
2022-03-31 17:09:38 +00:00
|
|
|
typedef struct rte {
|
2023-07-03 18:38:24 +00:00
|
|
|
RTE_IN_TABLE_WRITABLE;
|
|
|
|
u8 generation; /* If this route import is based on other previously exported route,
|
|
|
|
this value should be 1 + MAX(generation of the parent routes).
|
|
|
|
Otherwise the route is independent and this value is zero. */
|
|
|
|
u32 id; /* Table specific route id */
|
2022-05-30 10:03:03 +00:00
|
|
|
struct ea_list *attrs; /* Attributes of this route */
|
2022-05-30 14:20:35 +00:00
|
|
|
const net_addr *net; /* Network this RTE belongs to */
|
|
|
|
struct rte_src *src; /* Route source that created the route */
|
|
|
|
struct rt_import_hook *sender; /* Import hook used to send the route to the routing table */
|
|
|
|
btime lastmod; /* Last modified (set by table) */
|
2022-03-31 17:09:38 +00:00
|
|
|
} rte;
|
|
|
|
|
|
|
|
#define REF_FILTERED 2 /* Route is rejected by import filter */
|
2024-03-13 12:46:16 +00:00
|
|
|
#define REF_OBSOLETE 16 /* Route is obsolete, pending propagation */
|
2022-06-20 17:10:49 +00:00
|
|
|
#define REF_PENDING 32 /* Route has not propagated completely yet */
|
2022-03-31 17:09:38 +00:00
|
|
|
|
|
|
|
/* Route is valid for propagation (may depend on other flags in the future), accepts NULL */
|
2023-03-30 09:37:16 +00:00
|
|
|
static inline int rte_is_valid(const rte *r) { return r && !(r->flags & REF_FILTERED); }
|
2022-03-31 17:09:38 +00:00
|
|
|
|
|
|
|
/* Route just has REF_FILTERED flag */
|
2023-03-30 09:37:16 +00:00
|
|
|
static inline int rte_is_filtered(const rte *r) { return !!(r->flags & REF_FILTERED); }
|
2022-03-31 17:09:38 +00:00
|
|
|
|
2023-03-08 20:38:18 +00:00
|
|
|
/* Strip the route of the table-specific values */
|
|
|
|
static inline rte rte_init_from(const rte *r)
|
|
|
|
{
|
|
|
|
return (rte) {
|
|
|
|
.attrs = r->attrs,
|
|
|
|
.net = r->net,
|
|
|
|
.src = r->src,
|
|
|
|
};
|
|
|
|
}
|
|
|
|
|
2023-10-31 08:58:42 +00:00
|
|
|
int rte_same(const rte *, const rte *);
|
|
|
|
|
2022-03-31 17:09:38 +00:00
|
|
|
struct rte_src {
|
|
|
|
struct rte_src *next; /* Hash chain */
|
2022-08-02 20:08:59 +00:00
|
|
|
struct rte_owner *owner; /* Route source owner */
|
2023-11-01 17:08:49 +00:00
|
|
|
u64 private_id; /* Private ID, assigned by the protocol */
|
2022-03-31 17:09:38 +00:00
|
|
|
u32 global_id; /* Globally unique ID of the source */
|
2023-11-24 07:46:50 +00:00
|
|
|
struct lfuc uc; /* Use count */
|
2022-08-02 20:08:59 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
struct rte_owner_class {
|
2023-03-30 09:37:16 +00:00
|
|
|
void (*get_route_info)(const rte *, byte *buf); /* Get route information (for `show route' command) */
|
|
|
|
int (*rte_better)(const rte *, const rte *);
|
|
|
|
int (*rte_mergable)(const rte *, const rte *);
|
2022-08-02 20:08:59 +00:00
|
|
|
u32 (*rte_igp_metric)(const rte *);
|
|
|
|
};
|
|
|
|
|
|
|
|
struct rte_owner {
|
|
|
|
struct rte_owner_class *class;
|
2023-07-03 18:38:24 +00:00
|
|
|
int (*rte_recalculate)(struct rtable_private *, struct network *, struct rte_storage *new, struct rte_storage *, struct rte_storage *);
|
2022-08-02 20:08:59 +00:00
|
|
|
HASH(struct rte_src) hash;
|
|
|
|
const char *name;
|
|
|
|
u32 hash_key;
|
|
|
|
u32 uc;
|
2023-12-08 10:33:43 +00:00
|
|
|
u32 debug;
|
2022-08-02 20:08:59 +00:00
|
|
|
event_list *list;
|
|
|
|
event *prune;
|
|
|
|
event *stop;
|
2022-03-31 17:09:38 +00:00
|
|
|
};
|
|
|
|
|
2022-08-02 20:08:59 +00:00
|
|
|
extern DOMAIN(attrs) attrs_domain;
|
|
|
|
|
|
|
|
#define RTA_LOCK LOCK_DOMAIN(attrs, attrs_domain)
|
|
|
|
#define RTA_UNLOCK UNLOCK_DOMAIN(attrs, attrs_domain)
|
|
|
|
|
|
|
|
#define RTE_SRC_PU_SHIFT 44
|
|
|
|
#define RTE_SRC_IN_PROGRESS (1ULL << RTE_SRC_PU_SHIFT)
|
|
|
|
|
|
|
|
/* Get a route source. This also locks the source, therefore the caller has to
|
|
|
|
* unlock the source after the route has been propagated. */
|
|
|
|
struct rte_src *rt_get_source_o(struct rte_owner *o, u32 id);
|
|
|
|
#define rt_get_source(p, id) rt_get_source_o(&(p)->sources, (id))
|
2022-03-31 17:09:38 +00:00
|
|
|
|
2022-06-20 17:10:49 +00:00
|
|
|
struct rte_src *rt_find_source_global(u32 id);
|
2022-08-02 20:08:59 +00:00
|
|
|
|
2022-08-03 12:07:53 +00:00
|
|
|
#ifdef RT_SOURCE_DEBUG
|
|
|
|
#define rt_lock_source _rt_lock_source_internal
|
|
|
|
#define rt_unlock_source _rt_unlock_source_internal
|
|
|
|
#endif
|
|
|
|
|
2022-08-02 20:08:59 +00:00
|
|
|
static inline void rt_lock_source(struct rte_src *src)
|
|
|
|
{
|
2023-11-24 07:46:50 +00:00
|
|
|
lfuc_lock(&src->uc);
|
2022-08-02 20:08:59 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
static inline void rt_unlock_source(struct rte_src *src)
|
|
|
|
{
|
2023-11-24 07:46:50 +00:00
|
|
|
lfuc_unlock(&src->uc, src->owner->list, src->owner->prune);
|
2022-08-02 20:08:59 +00:00
|
|
|
}
|
|
|
|
|
2022-08-03 12:07:53 +00:00
|
|
|
#ifdef RT_SOURCE_DEBUG
|
|
|
|
#undef rt_lock_source
|
|
|
|
#undef rt_unlock_source
|
|
|
|
|
|
|
|
#define rt_lock_source(x) ( log(L_INFO "Lock source %uG at %s:%d", (x)->global_id, __FILE__, __LINE__), _rt_lock_source_internal(x) )
|
|
|
|
#define rt_unlock_source(x) ( log(L_INFO "Unlock source %uG at %s:%d", (x)->global_id, __FILE__, __LINE__), _rt_unlock_source_internal(x) )
|
|
|
|
#endif
|
|
|
|
|
2022-08-02 20:08:59 +00:00
|
|
|
void rt_init_sources(struct rte_owner *, const char *name, event_list *list);
|
|
|
|
void rt_destroy_sources(struct rte_owner *, event *);
|
2022-03-31 17:09:38 +00:00
|
|
|
|
2023-11-01 17:25:40 +00:00
|
|
|
void rt_dump_sources(struct rte_owner *);
|
|
|
|
|
2022-03-31 17:09:38 +00:00
|
|
|
/*
|
|
|
|
* Route Attributes
|
|
|
|
*
|
|
|
|
* Beware: All standard BGP attributes must be represented here instead
|
|
|
|
* of making them local to the route. This is needed to ensure proper
|
|
|
|
* construction of BGP route attribute lists.
|
|
|
|
*/
|
|
|
|
|
|
|
|
/* Nexthop structure */
|
|
|
|
struct nexthop {
|
|
|
|
ip_addr gw; /* Next hop */
|
|
|
|
struct iface *iface; /* Outgoing interface */
|
|
|
|
byte flags;
|
|
|
|
byte weight;
|
|
|
|
byte labels; /* Number of all labels */
|
|
|
|
u32 label[0];
|
|
|
|
};
|
|
|
|
|
2022-05-05 16:08:37 +00:00
|
|
|
/* For packing one into eattrs */
|
|
|
|
struct nexthop_adata {
|
|
|
|
struct adata ad;
|
2022-05-15 16:09:30 +00:00
|
|
|
/* There is either a set of nexthops or a special destination (RTD_*) */
|
|
|
|
union {
|
|
|
|
struct nexthop nh;
|
|
|
|
uint dest;
|
|
|
|
};
|
2022-05-05 16:08:37 +00:00
|
|
|
};
|
|
|
|
|
2024-01-29 12:58:23 +00:00
|
|
|
/* For MPLS label stack generation */
|
|
|
|
struct nexthop_adata_mpls {
|
|
|
|
struct nexthop_adata nhad;
|
|
|
|
u32 label_space[MPLS_MAX_LABEL_STACK];
|
|
|
|
};
|
|
|
|
|
2022-05-15 16:09:30 +00:00
|
|
|
#define NEXTHOP_DEST_SIZE (OFFSETOF(struct nexthop_adata, dest) + sizeof(uint) - OFFSETOF(struct adata, data))
|
|
|
|
#define NEXTHOP_DEST_LITERAL(x) ((struct nexthop_adata) { \
|
|
|
|
.ad.length = NEXTHOP_DEST_SIZE, .dest = (x), })
|
|
|
|
|
2022-03-31 17:09:38 +00:00
|
|
|
#define RNF_ONLINK 0x1 /* Gateway is onlink regardless of IP ranges */
|
|
|
|
|
|
|
|
|
|
|
|
#define RTS_STATIC 1 /* Normal static route */
|
|
|
|
#define RTS_INHERIT 2 /* Route inherited from kernel */
|
|
|
|
#define RTS_DEVICE 3 /* Device route */
|
|
|
|
#define RTS_STATIC_DEVICE 4 /* Static device route */
|
|
|
|
#define RTS_REDIRECT 5 /* Learned via redirect */
|
|
|
|
#define RTS_RIP 6 /* RIP route */
|
|
|
|
#define RTS_OSPF 7 /* OSPF route */
|
|
|
|
#define RTS_OSPF_IA 8 /* OSPF inter-area route */
|
|
|
|
#define RTS_OSPF_EXT1 9 /* OSPF external route type 1 */
|
|
|
|
#define RTS_OSPF_EXT2 10 /* OSPF external route type 2 */
|
|
|
|
#define RTS_BGP 11 /* BGP route */
|
|
|
|
#define RTS_PIPE 12 /* Inter-table wormhole */
|
|
|
|
#define RTS_BABEL 13 /* Babel route */
|
|
|
|
#define RTS_RPKI 14 /* Route Origin Authorization */
|
|
|
|
#define RTS_PERF 15 /* Perf checker */
|
2023-11-09 14:20:13 +00:00
|
|
|
#define RTS_L3VPN 16 /* MPLS L3VPN */
|
|
|
|
#define RTS_AGGREGATED 17 /* Aggregated route */
|
|
|
|
#define RTS_MAX 18
|
2022-03-31 17:09:38 +00:00
|
|
|
|
|
|
|
#define RTD_NONE 0 /* Undefined next hop */
|
2022-05-15 16:09:30 +00:00
|
|
|
#define RTD_UNICAST 1 /* A standard next hop */
|
2022-03-31 17:09:38 +00:00
|
|
|
#define RTD_BLACKHOLE 2 /* Silently drop packets */
|
|
|
|
#define RTD_UNREACHABLE 3 /* Reject as unreachable */
|
|
|
|
#define RTD_PROHIBIT 4 /* Administratively prohibited */
|
|
|
|
#define RTD_MAX 5
|
|
|
|
|
|
|
|
extern const char * rta_dest_names[RTD_MAX];
|
|
|
|
|
|
|
|
static inline const char *rta_dest_name(uint n)
|
|
|
|
{ return (n < RTD_MAX) ? rta_dest_names[n] : "???"; }
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Extended Route Attributes
|
|
|
|
*/
|
|
|
|
|
|
|
|
typedef struct eattr {
|
|
|
|
word id; /* EA_CODE(PROTOCOL_..., protocol-dependent ID) */
|
|
|
|
byte flags; /* Protocol-dependent flags */
|
2022-05-04 12:41:51 +00:00
|
|
|
byte type; /* Attribute type */
|
|
|
|
byte rfu:5;
|
2022-03-31 17:09:38 +00:00
|
|
|
byte originated:1; /* The attribute has originated locally */
|
|
|
|
byte fresh:1; /* An uncached attribute (e.g. modified in export filter) */
|
|
|
|
byte undef:1; /* Explicitly undefined */
|
|
|
|
|
2022-05-04 12:41:51 +00:00
|
|
|
PADDING(unused, 3, 3);
|
2022-04-14 14:51:18 +00:00
|
|
|
|
2022-03-31 17:09:38 +00:00
|
|
|
union bval u;
|
|
|
|
} eattr;
|
|
|
|
|
|
|
|
|
|
|
|
#define EA_CODE_MASK 0xffff
|
|
|
|
#define EA_ALLOW_UNDEF 0x10000 /* ea_find: allow EAF_TYPE_UNDEF */
|
|
|
|
#define EA_BIT(n) ((n) << 24) /* Used in bitfield accessors */
|
|
|
|
#define EA_BIT_GET(ea) ((ea) >> 24)
|
|
|
|
|
|
|
|
typedef struct ea_list {
|
|
|
|
struct ea_list *next; /* In case we have an override list */
|
|
|
|
byte flags; /* Flags: EALF_... */
|
2024-04-04 10:01:35 +00:00
|
|
|
byte stored:5; /* enum ea_stored */
|
|
|
|
byte rfu:3;
|
2022-03-31 17:09:38 +00:00
|
|
|
word count; /* Number of attributes */
|
|
|
|
eattr attrs[0]; /* Attribute definitions themselves */
|
|
|
|
} ea_list;
|
|
|
|
|
2024-04-04 10:01:35 +00:00
|
|
|
enum ea_stored {
|
|
|
|
EALS_NONE = 0, /* This is a temporary ea_list */
|
|
|
|
EALS_PREIMPORT = 1, /* State when route entered rte_update() */
|
|
|
|
EALS_FILTERED = 2, /* State after filters */
|
|
|
|
EALS_IN_TABLE = 3, /* State in table */
|
|
|
|
EALS_KEY = 4, /* EA list used as key */
|
|
|
|
EALS_CUSTOM = 0x10, /* OR this with custom values */
|
|
|
|
EALS_MAX = 0x20,
|
|
|
|
};
|
|
|
|
|
2022-06-28 08:51:00 +00:00
|
|
|
struct ea_storage {
|
|
|
|
struct ea_storage *next_hash; /* Next in hash chain */
|
2024-06-11 11:16:50 +00:00
|
|
|
_Atomic u64 uc; /* Use count */
|
2022-06-28 08:51:00 +00:00
|
|
|
u32 hash_key; /* List hash */
|
2024-06-11 11:16:50 +00:00
|
|
|
PADDING(unused, 0, 4); /* Sorry, we need u64 for the usecount */
|
2022-06-28 08:51:00 +00:00
|
|
|
ea_list l[0]; /* The list itself */
|
|
|
|
};
|
|
|
|
|
2022-03-31 17:09:38 +00:00
|
|
|
#define EALF_SORTED 1 /* Attributes are sorted by code */
|
|
|
|
#define EALF_BISECT 2 /* Use interval bisection for searching */
|
2022-10-12 16:04:39 +00:00
|
|
|
#define EALF_HUGE 8 /* List is too big to fit into slab */
|
2022-03-31 17:09:38 +00:00
|
|
|
|
2022-03-19 15:23:42 +00:00
|
|
|
struct ea_class {
|
|
|
|
#define EA_CLASS_INSIDE \
|
|
|
|
const char *name; /* Name (both print and filter) */ \
|
|
|
|
struct symbol *sym; /* Symbol to export to configs */ \
|
|
|
|
uint id; /* Autoassigned attribute ID */ \
|
|
|
|
uint uc; /* Reference count */ \
|
|
|
|
btype type; /* Data type ID */ \
|
2024-04-01 00:53:25 +00:00
|
|
|
u16 flags; /* Protocol-dependent flags */ \
|
2022-03-19 15:23:42 +00:00
|
|
|
uint readonly:1; /* This attribute can't be changed by filters */ \
|
|
|
|
uint conf:1; /* Requested by config */ \
|
2022-06-27 10:14:05 +00:00
|
|
|
uint hidden:1; /* Technical attribute, do not show, do not expose to filters */ \
|
2022-03-19 15:23:42 +00:00
|
|
|
void (*format)(const eattr *ea, byte *buf, uint size); \
|
2022-05-15 13:53:35 +00:00
|
|
|
void (*stored)(const eattr *ea); /* When stored into global hash */ \
|
|
|
|
void (*freed)(const eattr *ea); /* When released from global hash */ \
|
2024-11-25 16:14:32 +00:00
|
|
|
struct f_val (*empty)(const struct ea_class *); /* Return this instead of T_VOID as default value for filters */ \
|
2022-03-19 15:23:42 +00:00
|
|
|
|
|
|
|
EA_CLASS_INSIDE;
|
|
|
|
};
|
|
|
|
|
|
|
|
struct ea_class_ref {
|
|
|
|
resource r;
|
|
|
|
struct ea_class *class;
|
|
|
|
};
|
|
|
|
|
|
|
|
void ea_register_init(struct ea_class *);
|
|
|
|
struct ea_class_ref *ea_register_alloc(pool *, struct ea_class);
|
2023-10-29 14:42:46 +00:00
|
|
|
struct ea_class_ref *ea_ref_class(pool *, struct ea_class *); /* Reference for an attribute alias */
|
2022-03-19 15:23:42 +00:00
|
|
|
|
|
|
|
#define EA_REGISTER_ALL_HELPER(x) ea_register_init(x);
|
|
|
|
#define EA_REGISTER_ALL(...) MACRO_FOREACH(EA_REGISTER_ALL_HELPER, __VA_ARGS__)
|
|
|
|
|
|
|
|
struct ea_class *ea_class_find_by_id(uint id);
|
|
|
|
struct ea_class *ea_class_find_by_name(const char *name);
|
|
|
|
static inline struct ea_class *ea_class_self(struct ea_class *self) { return self; }
|
|
|
|
#define ea_class_find(_arg) _Generic((_arg), \
|
|
|
|
uint: ea_class_find_by_id, \
|
|
|
|
word: ea_class_find_by_id, \
|
|
|
|
char *: ea_class_find_by_name, \
|
|
|
|
const char *: ea_class_find_by_name, \
|
|
|
|
struct ea_class *: ea_class_self)(_arg)
|
|
|
|
|
2022-03-31 17:09:38 +00:00
|
|
|
struct ea_walk_state {
|
|
|
|
ea_list *eattrs; /* Ccurrent ea_list, initially set by caller */
|
|
|
|
eattr *ea; /* Current eattr, initially NULL */
|
|
|
|
u32 visited[4]; /* Bitfield, limiting max to 128 */
|
|
|
|
};
|
|
|
|
|
2022-03-19 15:23:42 +00:00
|
|
|
#define ea_find(_l, _arg) _Generic((_arg), uint: ea_find_by_id, struct ea_class *: ea_find_by_class, char *: ea_find_by_name)(_l, _arg)
|
|
|
|
eattr *ea_find_by_id(ea_list *, unsigned ea);
|
|
|
|
static inline eattr *ea_find_by_class(ea_list *l, const struct ea_class *def)
|
|
|
|
{ return ea_find_by_id(l, def->id); }
|
|
|
|
static inline eattr *ea_find_by_name(ea_list *l, const char *name)
|
2022-03-31 17:09:38 +00:00
|
|
|
{
|
2022-03-19 15:23:42 +00:00
|
|
|
const struct ea_class *def = ea_class_find_by_name(name);
|
|
|
|
return def ? ea_find_by_class(l, def) : NULL;
|
2022-03-31 17:09:38 +00:00
|
|
|
}
|
|
|
|
|
2022-03-19 15:23:42 +00:00
|
|
|
#define ea_get_int(_l, _ident, _def) ({ \
|
|
|
|
struct ea_class *cls = ea_class_find((_ident)); \
|
2024-10-15 08:50:29 +00:00
|
|
|
ASSERT_DIE(cls->type & EAF_EMBEDDED && cls->type != T_PTR); \
|
2022-03-19 15:23:42 +00:00
|
|
|
const eattr *ea = ea_find((_l), cls->id); \
|
|
|
|
(ea ? ea->u.data : (_def)); \
|
|
|
|
})
|
|
|
|
|
2024-10-15 08:50:29 +00:00
|
|
|
#define ea_get_ptr(_l, _ident, _def) ({ \
|
|
|
|
struct ea_class *cls = ea_class_find((_ident)); \
|
|
|
|
ASSERT_DIE(cls->type == T_PTR); \
|
|
|
|
const eattr *ea = ea_find((_l), cls->id); \
|
|
|
|
(ea ? ea->u.v_ptr : (_def)); \
|
|
|
|
})
|
|
|
|
|
2022-04-20 11:56:04 +00:00
|
|
|
#define ea_get_ip(_l, _ident, _def) ({ \
|
|
|
|
struct ea_class *cls = ea_class_find((_ident)); \
|
|
|
|
ASSERT_DIE(cls->type == T_IP); \
|
|
|
|
const eattr *ea = ea_find((_l), cls->id); \
|
|
|
|
(ea ? *((const ip_addr *) ea->u.ptr->data) : (_def)); \
|
|
|
|
})
|
|
|
|
|
2023-11-09 14:20:13 +00:00
|
|
|
#define ea_get_adata(_l, _ident) ({ \
|
|
|
|
struct ea_class *cls = ea_class_find((_ident)); \
|
|
|
|
ASSERT_DIE(!(cls->type & EAF_EMBEDDED)); \
|
|
|
|
const eattr *ea = ea_find((_l), cls->id); \
|
|
|
|
(ea ? ea->u.ptr : &null_adata); \
|
|
|
|
})
|
|
|
|
|
2022-03-19 15:23:42 +00:00
|
|
|
eattr *ea_walk(struct ea_walk_state *s, uint id, uint max);
|
2022-03-31 17:09:38 +00:00
|
|
|
void ea_dump(ea_list *);
|
|
|
|
int ea_same(ea_list *x, ea_list *y); /* Test whether two ea_lists are identical */
|
2024-04-04 10:01:35 +00:00
|
|
|
uint ea_hash(ea_list *e); /* Calculate attributes hash value */
|
2022-03-31 17:09:38 +00:00
|
|
|
ea_list *ea_append(ea_list *to, ea_list *what);
|
|
|
|
void ea_format_bitfield(const struct eattr *a, byte *buf, int bufsize, const char **names, int min, int max);
|
|
|
|
|
2022-04-10 12:11:46 +00:00
|
|
|
/* Normalize ea_list; allocates the result from tmp_linpool */
|
2024-04-04 10:01:35 +00:00
|
|
|
ea_list *ea_normalize(ea_list *e, u32 upto);
|
2022-04-10 12:11:46 +00:00
|
|
|
|
|
|
|
uint ea_list_size(ea_list *);
|
|
|
|
void ea_list_copy(ea_list *dest, ea_list *src, uint size);
|
2022-03-31 17:09:38 +00:00
|
|
|
|
2022-04-14 16:32:19 +00:00
|
|
|
#define EA_LOCAL_LIST(N) struct { ea_list l; eattr a[N]; }
|
2022-03-31 17:09:38 +00:00
|
|
|
|
2022-03-19 15:23:42 +00:00
|
|
|
#define EA_LITERAL_EMBEDDED(_class, _flags, _val) ({ \
|
|
|
|
btype _type = (_class)->type; \
|
2024-10-15 08:50:29 +00:00
|
|
|
ASSERT_DIE(_type & EAF_EMBEDDED && _type != T_PTR); \
|
2022-03-19 15:23:42 +00:00
|
|
|
EA_LITERAL_GENERIC((_class)->id, _type, _flags, .u.i = _val); \
|
2022-04-10 17:15:18 +00:00
|
|
|
})
|
|
|
|
|
2024-10-15 08:50:29 +00:00
|
|
|
#define EA_LITERAL_STORE_PTR(_class, _flags, _ptr) ({ \
|
|
|
|
btype _type = (_class)->type; \
|
|
|
|
ASSERT_DIE(_type == T_PTR); \
|
|
|
|
EA_LITERAL_GENERIC((_class)->id, _type, _flags, .u.v_ptr = _ptr); \
|
|
|
|
})
|
|
|
|
|
2022-03-19 15:23:42 +00:00
|
|
|
#define EA_LITERAL_STORE_ADATA(_class, _flags, _buf, _len) ({ \
|
|
|
|
btype _type = (_class)->type; \
|
2022-04-10 17:15:18 +00:00
|
|
|
ASSERT_DIE(!(_type & EAF_EMBEDDED)); \
|
2022-03-19 15:23:42 +00:00
|
|
|
EA_LITERAL_GENERIC((_class)->id, _type, _flags, .u.ad = tmp_store_adata((_buf), (_len))); \
|
2022-04-10 17:31:50 +00:00
|
|
|
})
|
|
|
|
|
2022-03-19 15:23:42 +00:00
|
|
|
#define EA_LITERAL_DIRECT_ADATA(_class, _flags, _adata) ({ \
|
|
|
|
btype _type = (_class)->type; \
|
2022-04-10 17:15:18 +00:00
|
|
|
ASSERT_DIE(!(_type & EAF_EMBEDDED)); \
|
2022-03-19 15:23:42 +00:00
|
|
|
EA_LITERAL_GENERIC((_class)->id, _type, _flags, .u.ad = _adata); \
|
2022-04-10 17:15:18 +00:00
|
|
|
})
|
|
|
|
|
|
|
|
#define EA_LITERAL_GENERIC(_id, _type, _flags, ...) \
|
|
|
|
((eattr) { .id = _id, .type = _type, .flags = _flags, __VA_ARGS__ })
|
|
|
|
|
2024-10-15 08:50:29 +00:00
|
|
|
#define EA_LITERAL_STORE_STRING(_class, _flags, string) ({EA_LITERAL_STORE_ADATA(_class, _flags, string, strlen(string)+1);})
|
|
|
|
|
2022-03-31 17:09:38 +00:00
|
|
|
static inline eattr *
|
2022-04-10 17:15:18 +00:00
|
|
|
ea_set_attr(ea_list **to, eattr a)
|
2022-03-31 17:09:38 +00:00
|
|
|
{
|
2024-06-07 19:41:17 +00:00
|
|
|
if (!a.id)
|
|
|
|
bug("You have forgotten to register your EA class");
|
|
|
|
|
2022-04-14 16:32:19 +00:00
|
|
|
EA_LOCAL_LIST(1) *ea = tmp_alloc(sizeof(*ea));
|
|
|
|
*ea = (typeof(*ea)) {
|
2022-03-31 17:09:38 +00:00
|
|
|
.l.flags = EALF_SORTED,
|
|
|
|
.l.count = 1,
|
|
|
|
.l.next = *to,
|
2022-04-14 16:32:19 +00:00
|
|
|
.a[0] = a,
|
2022-03-31 17:09:38 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
*to = &ea->l;
|
2022-04-14 16:32:19 +00:00
|
|
|
return &ea->a[0];
|
2022-03-31 17:09:38 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
static inline void
|
2024-06-26 15:19:24 +00:00
|
|
|
ea_unset_attr(ea_list **to, bool local, const struct ea_class *def)
|
2022-03-31 17:09:38 +00:00
|
|
|
{
|
2022-03-19 15:23:42 +00:00
|
|
|
ea_set_attr(to, EA_LITERAL_GENERIC(def->id, 0, 0,
|
2022-04-10 17:15:18 +00:00
|
|
|
.fresh = local, .originated = local, .undef = 1));
|
2022-03-31 17:09:38 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
static inline void
|
2022-03-19 15:23:42 +00:00
|
|
|
ea_set_attr_u32(ea_list **to, const struct ea_class *def, uint flags, u64 data)
|
|
|
|
{ ea_set_attr(to, EA_LITERAL_EMBEDDED(def, flags, data)); }
|
2022-03-31 17:09:38 +00:00
|
|
|
|
2024-10-15 08:50:29 +00:00
|
|
|
static inline void
|
2024-12-09 10:21:01 +00:00
|
|
|
ea_set_attr_ptr(ea_list **to, const struct ea_class *def, uint flags, void *data)
|
2024-10-15 08:50:29 +00:00
|
|
|
{ ea_set_attr(to, EA_LITERAL_STORE_PTR(def, flags, data)); }
|
|
|
|
|
2022-03-31 17:09:38 +00:00
|
|
|
static inline void
|
2022-05-05 16:08:37 +00:00
|
|
|
ea_set_attr_data(ea_list **to, const struct ea_class *def, uint flags, const void *data, uint len)
|
2022-03-19 15:23:42 +00:00
|
|
|
{ ea_set_attr(to, EA_LITERAL_STORE_ADATA(def, flags, data, len)); }
|
2022-03-31 17:09:38 +00:00
|
|
|
|
2022-05-05 16:08:37 +00:00
|
|
|
static inline void
|
|
|
|
ea_copy_attr(ea_list **to, ea_list *from, const struct ea_class *def)
|
|
|
|
{
|
|
|
|
eattr *e = ea_find_by_class(from, def);
|
|
|
|
if (e)
|
2024-10-15 08:50:29 +00:00
|
|
|
if (e->type == T_PTR)
|
|
|
|
ea_set_attr_ptr(to, def, e->flags, (void *)e->u.v_ptr);
|
|
|
|
else if (e->type & EAF_EMBEDDED)
|
2022-05-05 16:08:37 +00:00
|
|
|
ea_set_attr_u32(to, def, e->flags, e->u.data);
|
|
|
|
else
|
|
|
|
ea_set_attr_data(to, def, e->flags, e->u.ptr->data, e->u.ptr->length);
|
|
|
|
else
|
|
|
|
ea_unset_attr(to, 0, def);
|
|
|
|
}
|
|
|
|
|
2022-04-20 10:24:26 +00:00
|
|
|
/*
|
|
|
|
* Common route attributes
|
|
|
|
*/
|
|
|
|
|
|
|
|
/* Preference: first-order comparison */
|
|
|
|
extern struct ea_class ea_gen_preference;
|
2023-03-30 09:37:16 +00:00
|
|
|
static inline u32 rt_get_preference(const rte *rt)
|
2022-05-30 10:03:03 +00:00
|
|
|
{ return ea_get_int(rt->attrs, &ea_gen_preference, 0); }
|
2022-04-20 10:24:26 +00:00
|
|
|
|
|
|
|
/* IGP metric: second-order comparison */
|
|
|
|
extern struct ea_class ea_gen_igp_metric;
|
2022-05-30 15:18:03 +00:00
|
|
|
u32 rt_get_igp_metric(const rte *rt);
|
2022-04-20 10:24:26 +00:00
|
|
|
#define IGP_METRIC_UNKNOWN 0x80000000 /* Default igp_metric used when no other
|
|
|
|
protocol-specific metric is availabe */
|
|
|
|
|
2022-04-20 11:56:04 +00:00
|
|
|
/* From: Advertising router */
|
|
|
|
extern struct ea_class ea_gen_from;
|
2022-04-20 10:24:26 +00:00
|
|
|
|
2023-11-08 20:51:46 +00:00
|
|
|
|
|
|
|
/* MPLS Label, Policy and Class */
|
|
|
|
extern struct ea_class ea_gen_mpls_label,
|
|
|
|
ea_gen_mpls_policy, ea_gen_mpls_class;
|
|
|
|
|
|
|
|
|
2022-05-04 12:41:51 +00:00
|
|
|
/* Source: An old method to devise the route source protocol and kind.
|
|
|
|
* To be superseded in a near future by something more informative. */
|
|
|
|
extern struct ea_class ea_gen_source;
|
2022-05-30 15:26:25 +00:00
|
|
|
static inline u32 rt_get_source_attr(const rte *rt)
|
2022-05-30 10:03:03 +00:00
|
|
|
{ return ea_get_int(rt->attrs, &ea_gen_source, 0); }
|
2022-05-04 12:41:51 +00:00
|
|
|
|
2022-05-15 16:09:30 +00:00
|
|
|
/* Flowspec validation result */
|
2022-06-08 09:47:49 +00:00
|
|
|
enum flowspec_valid {
|
|
|
|
FLOWSPEC_UNKNOWN = 0,
|
|
|
|
FLOWSPEC_VALID = 1,
|
|
|
|
FLOWSPEC_INVALID = 2,
|
|
|
|
FLOWSPEC__MAX,
|
|
|
|
};
|
|
|
|
|
|
|
|
extern const char * flowspec_valid_names[FLOWSPEC__MAX];
|
|
|
|
static inline const char *flowspec_valid_name(enum flowspec_valid v)
|
|
|
|
{ return (v < FLOWSPEC__MAX) ? flowspec_valid_names[v] : "???"; }
|
2022-05-15 16:09:30 +00:00
|
|
|
|
|
|
|
extern struct ea_class ea_gen_flowspec_valid;
|
2023-07-03 18:38:24 +00:00
|
|
|
static inline enum flowspec_valid rt_get_flowspec_valid(const rte *rt)
|
2022-05-30 10:03:03 +00:00
|
|
|
{ return ea_get_int(rt->attrs, &ea_gen_flowspec_valid, FLOWSPEC_UNKNOWN); }
|
2022-05-15 16:09:30 +00:00
|
|
|
|
2022-05-05 16:08:37 +00:00
|
|
|
/* Next hop: For now, stored as adata */
|
|
|
|
extern struct ea_class ea_gen_nexthop;
|
|
|
|
|
2022-05-15 16:09:30 +00:00
|
|
|
static inline void ea_set_dest(struct ea_list **to, uint flags, uint dest)
|
|
|
|
{
|
|
|
|
struct nexthop_adata nhad = NEXTHOP_DEST_LITERAL(dest);
|
|
|
|
ea_set_attr_data(to, &ea_gen_nexthop, flags, &nhad.ad.data, nhad.ad.length);
|
|
|
|
}
|
|
|
|
|
2022-04-20 10:24:26 +00:00
|
|
|
/* Next hop structures */
|
2022-03-31 17:09:38 +00:00
|
|
|
|
2022-05-05 16:08:37 +00:00
|
|
|
#define NEXTHOP_ALIGNMENT (_Alignof(struct nexthop))
|
|
|
|
#define NEXTHOP_MAX_SIZE (sizeof(struct nexthop) + sizeof(u32)*MPLS_MAX_LABEL_STACK)
|
|
|
|
#define NEXTHOP_SIZE(_nh) NEXTHOP_SIZE_CNT(((_nh)->labels))
|
|
|
|
#define NEXTHOP_SIZE_CNT(cnt) BIRD_ALIGN((sizeof(struct nexthop) + sizeof(u32) * (cnt)), NEXTHOP_ALIGNMENT)
|
|
|
|
#define nexthop_size(nh) NEXTHOP_SIZE((nh))
|
|
|
|
|
|
|
|
#define NEXTHOP_NEXT(_nh) ((void *) (_nh) + NEXTHOP_SIZE(_nh))
|
|
|
|
#define NEXTHOP_END(_nhad) ((_nhad)->ad.data + (_nhad)->ad.length)
|
|
|
|
#define NEXTHOP_VALID(_nh, _nhad) ((void *) (_nh) < (void *) NEXTHOP_END(_nhad))
|
|
|
|
#define NEXTHOP_ONE(_nhad) (NEXTHOP_NEXT(&(_nhad)->nh) == NEXTHOP_END(_nhad))
|
|
|
|
|
|
|
|
#define NEXTHOP_WALK(_iter, _nhad) for ( \
|
|
|
|
struct nexthop *_iter = &(_nhad)->nh; \
|
|
|
|
(void *) _iter < (void *) NEXTHOP_END(_nhad); \
|
|
|
|
_iter = NEXTHOP_NEXT(_iter))
|
|
|
|
|
|
|
|
|
|
|
|
static inline int nexthop_same(struct nexthop_adata *x, struct nexthop_adata *y)
|
|
|
|
{ return adata_same(&x->ad, &y->ad); }
|
|
|
|
struct nexthop_adata *nexthop_merge(struct nexthop_adata *x, struct nexthop_adata *y, int max, linpool *lp);
|
|
|
|
struct nexthop_adata *nexthop_sort(struct nexthop_adata *x, linpool *lp);
|
|
|
|
int nexthop_is_sorted(struct nexthop_adata *x);
|
|
|
|
|
2022-05-15 16:09:30 +00:00
|
|
|
#define NEXTHOP_IS_REACHABLE(nhad) ((nhad)->ad.length > NEXTHOP_DEST_SIZE)
|
2022-03-31 17:09:38 +00:00
|
|
|
|
2023-11-09 14:20:13 +00:00
|
|
|
static inline struct nexthop_adata *
|
|
|
|
rte_get_nexthops(rte *r)
|
2022-05-15 16:09:30 +00:00
|
|
|
{
|
2022-05-30 10:03:03 +00:00
|
|
|
eattr *nhea = ea_find(r->attrs, &ea_gen_nexthop);
|
2023-11-09 14:20:13 +00:00
|
|
|
return nhea ? SKIP_BACK(struct nexthop_adata, ad, nhea->u.ptr) : NULL;
|
|
|
|
}
|
2022-05-15 16:09:30 +00:00
|
|
|
|
2023-11-09 14:20:13 +00:00
|
|
|
/* Route has regular, reachable nexthop (i.e. not RTD_UNREACHABLE and like) */
|
|
|
|
static inline int rte_is_reachable(rte *r)
|
|
|
|
{
|
|
|
|
struct nexthop_adata *nhad = rte_get_nexthops(r);
|
|
|
|
return nhad && NEXTHOP_IS_REACHABLE(nhad);
|
2022-05-15 16:09:30 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
static inline int nhea_dest(eattr *nhea)
|
|
|
|
{
|
|
|
|
if (!nhea)
|
|
|
|
return RTD_NONE;
|
|
|
|
|
|
|
|
struct nexthop_adata *nhad = nhea ? (struct nexthop_adata *) nhea->u.ptr : NULL;
|
|
|
|
if (NEXTHOP_IS_REACHABLE(nhad))
|
|
|
|
return RTD_UNICAST;
|
|
|
|
else
|
|
|
|
return nhad->dest;
|
|
|
|
}
|
|
|
|
|
2022-06-08 09:47:49 +00:00
|
|
|
static inline int rte_dest(const rte *r)
|
2022-05-15 16:09:30 +00:00
|
|
|
{
|
2022-05-30 10:03:03 +00:00
|
|
|
return nhea_dest(ea_find(r->attrs, &ea_gen_nexthop));
|
2022-05-15 16:09:30 +00:00
|
|
|
}
|
2022-03-31 17:09:38 +00:00
|
|
|
|
2024-11-28 07:22:06 +00:00
|
|
|
/* ASPA Providers eattr */
|
|
|
|
extern struct ea_class ea_gen_aspa_providers;
|
|
|
|
|
|
|
|
|
2022-03-31 17:09:38 +00:00
|
|
|
void rta_init(void);
|
2024-04-04 10:01:35 +00:00
|
|
|
|
|
|
|
ea_list *ea_lookup_slow(ea_list *r, u32 squash_upto, enum ea_stored oid);
|
|
|
|
|
2022-06-28 08:51:00 +00:00
|
|
|
static inline struct ea_storage *ea_get_storage(ea_list *r)
|
|
|
|
{
|
2024-04-04 10:01:35 +00:00
|
|
|
ASSERT_DIE(r->stored);
|
2022-07-18 08:56:20 +00:00
|
|
|
return SKIP_BACK(struct ea_storage, l[0], r);
|
2022-06-28 08:51:00 +00:00
|
|
|
}
|
|
|
|
|
2024-04-04 10:01:35 +00:00
|
|
|
static inline ea_list *ea_ref(ea_list *r)
|
|
|
|
{
|
2024-06-11 08:48:21 +00:00
|
|
|
ASSERT_DIE(0 < atomic_fetch_add_explicit(&ea_get_storage(r)->uc, 1, memory_order_acq_rel));
|
2022-08-03 15:37:16 +00:00
|
|
|
return r;
|
|
|
|
}
|
2024-04-04 10:01:35 +00:00
|
|
|
|
|
|
|
static inline ea_list *ea_lookup(ea_list *r, u32 squash_upto, enum ea_stored oid)
|
|
|
|
{
|
|
|
|
ASSERT_DIE(oid);
|
|
|
|
if ((r->stored == oid) || BIT32_TEST(&squash_upto, r->stored))
|
|
|
|
return ea_ref(r);
|
|
|
|
else
|
|
|
|
return ea_lookup_slow(r, squash_upto, oid);
|
|
|
|
}
|
|
|
|
|
2024-06-11 08:48:21 +00:00
|
|
|
struct ea_free_deferred {
|
|
|
|
struct deferred_call dc;
|
|
|
|
ea_list *attrs;
|
|
|
|
};
|
|
|
|
|
|
|
|
void ea_free_deferred(struct deferred_call *dc);
|
|
|
|
|
2024-11-24 17:43:09 +00:00
|
|
|
#ifdef EA_FREE_DEBUG
|
|
|
|
#define ea_free_later _ea_free_later_internal
|
|
|
|
#endif
|
|
|
|
|
2024-06-11 08:48:21 +00:00
|
|
|
static inline ea_list *ea_free_later(ea_list *r)
|
2024-04-23 16:28:34 +00:00
|
|
|
{
|
2024-06-11 08:48:21 +00:00
|
|
|
if (!r)
|
|
|
|
return NULL;
|
|
|
|
|
|
|
|
struct ea_free_deferred efd = {
|
|
|
|
.dc.hook = ea_free_deferred,
|
|
|
|
.attrs = r,
|
|
|
|
};
|
|
|
|
|
|
|
|
defer_call(&efd.dc, sizeof efd);
|
|
|
|
return r;
|
2024-04-23 16:28:34 +00:00
|
|
|
}
|
|
|
|
|
2024-11-24 17:43:09 +00:00
|
|
|
#ifdef EA_FREE_DEBUG
|
|
|
|
#undef ea_free_later
|
|
|
|
#define ea_free_later(x) ( log(L_INFO "EA free request %p at %s:%d", (x), __FILE__, __LINE__), _ea_free_later_internal(x) )
|
|
|
|
#endif
|
|
|
|
|
2024-06-11 08:48:21 +00:00
|
|
|
#define ea_free ea_free_later
|
|
|
|
|
2024-04-23 16:28:34 +00:00
|
|
|
static inline ea_list *ea_lookup_tmp(ea_list *r, u32 squash_upto, enum ea_stored oid)
|
|
|
|
{
|
2024-06-11 08:48:21 +00:00
|
|
|
return ea_free_later(ea_lookup(r, squash_upto, oid));
|
2024-04-23 16:28:34 +00:00
|
|
|
}
|
|
|
|
|
2024-05-29 07:33:42 +00:00
|
|
|
static inline ea_list *ea_ref_tmp(ea_list *r)
|
|
|
|
{
|
|
|
|
ASSERT_DIE(r->stored);
|
2024-06-11 08:48:21 +00:00
|
|
|
return ea_free_later(ea_ref(r));
|
2024-05-29 07:33:42 +00:00
|
|
|
}
|
|
|
|
|
2024-04-04 10:01:35 +00:00
|
|
|
static inline ea_list *ea_strip_to(ea_list *r, u32 strip_to)
|
|
|
|
{
|
|
|
|
ASSERT_DIE(strip_to);
|
|
|
|
while (r && !BIT32_TEST(&strip_to, r->stored))
|
|
|
|
r = r->next;
|
|
|
|
|
|
|
|
return r;
|
|
|
|
}
|
|
|
|
|
2022-05-30 10:03:03 +00:00
|
|
|
void ea_dump(ea_list *);
|
|
|
|
void ea_dump_all(void);
|
|
|
|
void ea_show_list(struct cli *, ea_list *);
|
|
|
|
|
2022-03-31 17:09:38 +00:00
|
|
|
#endif
|