diff options
| author | Maria Matejka <mq@ucw.cz> | 2023-05-07 23:04:47 +0200 |
|---|---|---|
| committer | Maria Matejka <mq@ucw.cz> | 2023-05-11 11:41:01 +0200 |
| commit | a818a3011e6543f6e224e37fb8eb46f64bafa490 (patch) | |
| tree | 5110e8e95397dc404b61f5447c1b471be3dd5867 /nest/proto.c | |
| parent | bb28b16fd6b9173ffdfaedddb3b2fd6de772674f (diff) | |
Channel: configurable feed block size
Diffstat (limited to 'nest/proto.c')
| -rw-r--r-- | nest/proto.c | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/nest/proto.c b/nest/proto.c index c07560c6..b06f7b72 100644 --- a/nest/proto.c +++ b/nest/proto.c @@ -207,6 +207,8 @@ proto_add_channel(struct proto *p, struct channel_config *cf) c->out_filter = cf->out_filter; c->out_subprefix = cf->out_subprefix; + c->feed_block_size = cf->feed_block_size; + channel_init_limit(c, &c->rx_limit, PLD_RX, &cf->rx_limit); channel_init_limit(c, &c->in_limit, PLD_IN, &cf->in_limit); channel_init_limit(c, &c->out_limit, PLD_OUT, &cf->out_limit); @@ -497,6 +499,7 @@ channel_start_export(struct channel *c) .name = mb_sprintf(c->proto->pool, "%s.%s", c->proto->name, c->name), .list = proto_work_list(c->proto), .pool = c->proto->pool, + .feed_block_size = c->feed_block_size, .addr = c->out_subprefix, .addr_mode = c->out_subprefix ? TE_ADDR_IN : TE_ADDR_NONE, .trace_routes = c->debug | c->proto->debug, @@ -688,6 +691,7 @@ channel_setup_in_table(struct channel *c) .name = mb_sprintf(c->proto->pool, "%s.%s.import", c->proto->name, c->name), .list = proto_work_list(c->proto), .pool = c->proto->pool, + .feed_block_size = c->feed_block_size, .trace_routes = c->debug | c->proto->debug, .export_bulk = channel_reload_export_bulk, .dump_req = channel_reload_dump_req, @@ -913,6 +917,8 @@ channel_config_new(const struct channel_class *cc, const char *name, uint net_ty cf->table = tab; cf->out_filter = FILTER_REJECT; + cf->feed_block_size = 16384; + cf->net_type = net_type; cf->ra_mode = RA_OPTIMAL; cf->preference = proto->protocol->preference; |