diff options
Diffstat (limited to 'nest')
| -rw-r--r-- | nest/proto.c | 5 | ||||
| -rw-r--r-- | nest/rt-table.c | 3 |
2 files changed, 8 insertions, 0 deletions
diff --git a/nest/proto.c b/nest/proto.c index 7a09ed64..2d30e640 100644 --- a/nest/proto.c +++ b/nest/proto.c @@ -589,6 +589,10 @@ channel_export_stopped(struct rt_export_request *req) { c->refeeding = 1; c->refeed_pending = 0; + + bmap_reset(&c->export_map, 1024); + bmap_reset(&c->export_reject_map, 1024); + rt_request_export(c->table, req); return; } @@ -621,6 +625,7 @@ channel_feed_end(struct channel *c) (l->count <= l->max)) { log(L_INFO "Protocol %s resets route export limit (%u)", c->proto->name, l->max); + channel_reset_limit(c, &c->out_limit, PLD_OUT); c->refeed_pending = 1; rt_stop_export(req, channel_export_stopped); diff --git a/nest/rt-table.c b/nest/rt-table.c index c53fd195..e4c85fd4 100644 --- a/nest/rt-table.c +++ b/nest/rt-table.c @@ -618,6 +618,9 @@ rt_notify_basic(struct channel *c, const net_addr *net, rte *new, rte *old) if (old && !bmap_test(&c->export_map, old->id)) old = NULL; + if (old && (old->sender == c->in_req.hook)) + bug("bad-behaved pipe"); + if (!new && !old) return; |