burble.dn42/bird
1
0
Fork 0
Code Packages Releases Activity

Add patch from JRB0001 to reload protocols on RPKI change

Browse Source
This commit is contained in:
Simon Marsh 2019-06-03 18:28:51 +01:00
parent b9deced219
commit aff07ee7ed
Signed by: burble
GPG Key ID: 7B9FE8780CFB6593
3 changed files with 27 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
nest/proto.c
View File

@ -1968,3 +1968,27 @@ proto_get_named(struct symbol *sym, struct protocol *pr)
return p; return p;
} }
void
reload_all(void)
{
log(L_INFO "Reloading all protocols.");
struct proto *p;
WALK_LIST(p, proto_list)
{
if (!p->disabled && p->proto_state == PS_UP)
{
log(L_INFO "Reloading protocol %s.", p->name);
struct channel *c;
WALK_LIST(c, p->channels)
{
if (channel_reloadable(c) && c->channel_state == CS_UP)
{
channel_request_reload(c);
channel_request_feeding(c);
}
}
}
}
}

1
nest/protocol.h
View File

@ -624,6 +624,7 @@ void *channel_config_new(const struct channel_class *cc, const char *name, uint
void *channel_config_get(const struct channel_class *cc, const char *name, uint net_type, struct proto_config *proto); void *channel_config_get(const struct channel_class *cc, const char *name, uint net_type, struct proto_config *proto);
int channel_reconfigure(struct channel *c, struct channel_config *cf); int channel_reconfigure(struct channel *c, struct channel_config *cf);
void reload_all(void);
/* Moved from route.h to avoid dependency conflicts */ /* Moved from route.h to avoid dependency conflicts */
static inline void rte_update(struct proto *p, const net_addr *n, rte *new) { rte_update2(p->main_channel, n, new, p->main_source); } static inline void rte_update(struct proto *p, const net_addr *n, rte *new) { rte_update2(p->main_channel, n, new, p->main_source); }

2
proto/rpki/packets.c
View File

@ -817,6 +817,8 @@ rpki_handle_end_of_data_pdu(struct rpki_cache *cache, const struct pdu_end_of_da
cache->last_update = current_time(); cache->last_update = current_time();
cache->serial_num = pdu->serial_num; cache->serial_num = pdu->serial_num;
rpki_cache_change_state(cache, RPKI_CS_ESTABLISHED); rpki_cache_change_state(cache, RPKI_CS_ESTABLISHED);
reload_all();
} }
/** /**