mirrors/bird
mirrors/bird
0
0
Fork 0
mirror of https://gitlab.nic.cz/labs/bird.git synced 2025-01-03 07:31:54 +00:00
Code Releases Activity

Hostentry: fix pool locking

Browse Source
This commit is contained in:
Maria Matejka 2023-05-01 14:20:27 +02:00
parent 7d8e541057
commit ed91d884d3
1 changed files with 15 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
nest/rt-table.c
View File

@ -4592,34 +4592,28 @@ hc_notify_export_one(struct rt_export_request *req, const net_addr *net, struct
{ {
struct hostcache *hc = SKIP_BACK(struct hostcache, req, req); struct hostcache *hc = SKIP_BACK(struct hostcache, req, req);
/* No interest in this update, mark seen only */
int interested = 1;
RT_LOCKED((rtable *) hc->update.data, tab) RT_LOCKED((rtable *) hc->update.data, tab)
if (ev_active(&hc->update) || !trie_match_net(hc->trie, net)) if (ev_active(&hc->update) || !trie_match_net(hc->trie, net))
{ /* No interest in this update, mark seen only */
rpe_mark_seen_all(req->hook, first, NULL, NULL); rpe_mark_seen_all(req->hook, first, NULL, NULL);
interested = 0; else
} {
/* This net may affect some hostentries, check the actual change */
rte *o = RTE_VALID_OR_NULL(first->old_best);
struct rte_storage *new_best = first->new_best;
if (!interested) RPE_WALK(first, rpe, NULL)
return; {
rpe_mark_seen(req->hook, rpe);
new_best = rpe->new_best;
}
/* This net may affect some hostentries, check the actual change */ /* Yes, something has actually changed. Do the hostcache update. */
rte *o = RTE_VALID_OR_NULL(first->old_best); if ((o != RTE_VALID_OR_NULL(new_best))
struct rte_storage *new_best = first->new_best; && (atomic_load_explicit(&req->hook->export_state, memory_order_acquire) == TES_READY)
RPE_WALK(first, rpe, NULL)
{
rpe_mark_seen(req->hook, rpe);
new_best = rpe->new_best;
}
/* Yes, something has actually changed. Do the hostcache update. */
if (o != RTE_VALID_OR_NULL(new_best))
RT_LOCKED((rtable *) hc->update.data, tab)
if ((atomic_load_explicit(&req->hook->export_state, memory_order_acquire) == TES_READY)
&& !ev_active(&hc->update)) && !ev_active(&hc->update))
ev_send_loop(tab->loop, &hc->update); ev_send_loop(tab->loop, &hc->update);
}
} }