From 25a1dccc56a7e544a855bfeda5751c91b53a03fb Mon Sep 17 00:00:00 2001 From: David Lamparter Date: Thu, 23 Nov 2023 15:03:35 +0100 Subject: lib: remove `.receive_notify` zclient option This should just be set with `ZEBRA_ROUTE_NOTIFY_REQUEST` instead. Signed-off-by: David Lamparter --- lib/zclient.c | 11 ++++------- 1 file changed, 4 insertions(+), 7 deletions(-) (limited to 'lib/zclient.c') diff --git a/lib/zclient.c b/lib/zclient.c index 9f261e2f29..47ce111b33 100644 --- a/lib/zclient.c +++ b/lib/zclient.c @@ -41,8 +41,9 @@ static void zclient_event(enum zclient_event, struct zclient *); static void zebra_interface_if_set_value(struct stream *s, struct interface *ifp); -struct zclient_options zclient_options_default = {.receive_notify = false, - .synchronous = false}; +struct zclient_options zclient_options_default = { + .synchronous = false, +}; struct sockaddr_storage zclient_addr; socklen_t zclient_addr_len; @@ -69,7 +70,6 @@ struct zclient *zclient_new(struct event_loop *master, zclient->handlers = handlers; zclient->n_handlers = n_handlers; - zclient->receive_notify = opt->receive_notify; zclient->synchronous = opt->synchronous; return zclient; @@ -392,10 +392,7 @@ enum zclient_send_status zclient_send_hello(struct zclient *zclient) stream_putc(s, zclient->redist_default); stream_putw(s, zclient->instance); stream_putl(s, zclient->session_id); - if (zclient->receive_notify) - stream_putc(s, 1); - else - stream_putc(s, 0); + stream_putc(s, 0); /* receive_notify - removed */ if (zclient->synchronous) stream_putc(s, 1); else -- cgit v1.2.3 From a13d2933b755e159f78251d6a790eb153c6500fb Mon Sep 17 00:00:00 2001 From: David Lamparter Date: Thu, 23 Nov 2023 15:08:32 +0100 Subject: zebra, lib: remove notify field from hello message This is no longer used. Signed-off-by: David Lamparter --- lib/zclient.c | 1 - zebra/zapi_msg.c | 4 ---- 2 files changed, 5 deletions(-) (limited to 'lib/zclient.c') diff --git a/lib/zclient.c b/lib/zclient.c index 47ce111b33..39756933e7 100644 --- a/lib/zclient.c +++ b/lib/zclient.c @@ -392,7 +392,6 @@ enum zclient_send_status zclient_send_hello(struct zclient *zclient) stream_putc(s, zclient->redist_default); stream_putw(s, zclient->instance); stream_putl(s, zclient->session_id); - stream_putc(s, 0); /* receive_notify - removed */ if (zclient->synchronous) stream_putc(s, 1); else diff --git a/zebra/zapi_msg.c b/zebra/zapi_msg.c index 390ebc8f4c..679023fd84 100644 --- a/zebra/zapi_msg.c +++ b/zebra/zapi_msg.c @@ -2376,17 +2376,13 @@ static void zread_hello(ZAPI_HANDLER_ARGS) /* type of protocol (lib/zebra.h) */ uint8_t proto; unsigned short instance; - uint8_t notify; uint8_t synchronous; uint32_t session_id; STREAM_GETC(msg, proto); STREAM_GETW(msg, instance); STREAM_GETL(msg, session_id); - STREAM_GETC(msg, notify); STREAM_GETC(msg, synchronous); - if (notify) - client->notify_owner = true; if (synchronous) client->synchronous = true; -- cgit v1.2.3 From cc90c54b36818a13774edfed8d7ac9a6e36c9373 Mon Sep 17 00:00:00 2001 From: David Lamparter Date: Thu, 23 Nov 2023 15:18:44 +0100 Subject: *: add `zclient_options_sync` ... and use it instead of fiddling with the `.synchronous` field. (Make it const while at it.) Signed-off-by: David Lamparter --- bgpd/bgp_zebra.c | 5 +---- isisd/isis_zebra.c | 4 +--- ldpd/lde.c | 6 +----- lib/zclient.c | 8 ++++++-- lib/zclient.h | 5 +++-- ospfd/ospf_zebra.c | 4 +--- pathd/path_zebra.c | 5 +---- pimd/pim_zlookup.c | 5 +---- 8 files changed, 15 insertions(+), 27 deletions(-) (limited to 'lib/zclient.c') diff --git a/bgpd/bgp_zebra.c b/bgpd/bgp_zebra.c index 57d419fabe..3b25348c4e 100644 --- a/bgpd/bgp_zebra.c +++ b/bgpd/bgp_zebra.c @@ -3430,9 +3430,6 @@ static void bgp_zebra_capabilities(struct zclient_capabilities *cap) void bgp_zebra_init(struct event_loop *master, unsigned short instance) { - struct zclient_options options = zclient_options_default; - - options.synchronous = true; zclient_num_connects = 0; hook_register_prio(if_real, 0, bgp_ifp_create); @@ -3450,7 +3447,7 @@ void bgp_zebra_init(struct event_loop *master, unsigned short instance) zclient->instance = instance; /* Initialize special zclient for synchronous message exchanges. */ - zclient_sync = zclient_new(master, &options, NULL, 0); + zclient_sync = zclient_new(master, &zclient_options_sync, NULL, 0); zclient_sync->sock = -1; zclient_sync->redist_default = ZEBRA_ROUTE_BGP; zclient_sync->instance = instance; diff --git a/isisd/isis_zebra.c b/isisd/isis_zebra.c index 8252c1ac25..18a0c49ceb 100644 --- a/isisd/isis_zebra.c +++ b/isisd/isis_zebra.c @@ -1395,9 +1395,7 @@ void isis_zebra_init(struct event_loop *master, int instance) zclient->zebra_connected = isis_zebra_connected; /* Initialize special zclient for synchronous message exchanges. */ - struct zclient_options options = zclient_options_default; - options.synchronous = true; - zclient_sync = zclient_new(master, &options, NULL, 0); + zclient_sync = zclient_new(master, &zclient_options_sync, NULL, 0); zclient_sync->sock = -1; zclient_sync->redist_default = ZEBRA_ROUTE_ISIS; zclient_sync->instance = instance; diff --git a/ldpd/lde.c b/ldpd/lde.c index c7e915deb3..ef4aecadad 100644 --- a/ldpd/lde.c +++ b/ldpd/lde.c @@ -2135,12 +2135,8 @@ static void zclient_sync_retry(struct event *thread) */ static void zclient_sync_init(void) { - struct zclient_options options = zclient_options_default; - - options.synchronous = true; - /* Initialize special zclient for synchronous message exchanges. */ - zclient_sync = zclient_new(master, &options, NULL, 0); + zclient_sync = zclient_new(master, &zclient_options_sync, NULL, 0); zclient_sync->sock = -1; zclient_sync->redist_default = ZEBRA_ROUTE_LDP; zclient_sync->session_id = 1; /* Distinguish from main session */ diff --git a/lib/zclient.c b/lib/zclient.c index 39756933e7..61533aecc6 100644 --- a/lib/zclient.c +++ b/lib/zclient.c @@ -41,10 +41,14 @@ static void zclient_event(enum zclient_event, struct zclient *); static void zebra_interface_if_set_value(struct stream *s, struct interface *ifp); -struct zclient_options zclient_options_default = { +const struct zclient_options zclient_options_default = { .synchronous = false, }; +const struct zclient_options zclient_options_sync = { + .synchronous = true, +}; + struct sockaddr_storage zclient_addr; socklen_t zclient_addr_len; @@ -53,7 +57,7 @@ static int zclient_debug; /* Allocate zclient structure. */ struct zclient *zclient_new(struct event_loop *master, - struct zclient_options *opt, + const struct zclient_options *opt, zclient_handler *const *handlers, size_t n_handlers) { struct zclient *zclient; diff --git a/lib/zclient.h b/lib/zclient.h index 8332f2a057..c8dff18bb9 100644 --- a/lib/zclient.h +++ b/lib/zclient.h @@ -834,7 +834,8 @@ struct zclient_options { bool synchronous; }; -extern struct zclient_options zclient_options_default; +extern const struct zclient_options zclient_options_default; +extern const struct zclient_options zclient_options_sync; /* link layer representation for GRE like interfaces * ip_in is the underlay IP, ip_out is the tunnel dest @@ -881,7 +882,7 @@ int zclient_neigh_ip_encode(struct stream *s, uint16_t cmd, union sockunion *in, extern uint32_t zclient_get_nhg_start(uint32_t proto); extern struct zclient *zclient_new(struct event_loop *m, - struct zclient_options *opt, + const struct zclient_options *opt, zclient_handler *const *handlers, size_t n_handlers); diff --git a/ospfd/ospf_zebra.c b/ospfd/ospf_zebra.c index 19d3c9a083..bb6cc3a89c 100644 --- a/ospfd/ospf_zebra.c +++ b/ospfd/ospf_zebra.c @@ -2189,9 +2189,7 @@ void ospf_zebra_init(struct event_loop *master, unsigned short instance) zclient->nexthop_update = ospf_zebra_import_check_update; /* Initialize special zclient for synchronous message exchanges. */ - struct zclient_options options = zclient_options_default; - options.synchronous = true; - zclient_sync = zclient_new(master, &options, NULL, 0); + zclient_sync = zclient_new(master, &zclient_options_sync, NULL, 0); zclient_sync->sock = -1; zclient_sync->redist_default = ZEBRA_ROUTE_OSPF; zclient_sync->instance = instance; diff --git a/pathd/path_zebra.c b/pathd/path_zebra.c index 826443f979..645fa50856 100644 --- a/pathd/path_zebra.c +++ b/pathd/path_zebra.c @@ -320,9 +320,6 @@ static zclient_handler *const path_handlers[] = { */ void path_zebra_init(struct event_loop *master) { - struct zclient_options options = zclient_options_default; - options.synchronous = true; - /* Initialize asynchronous zclient. */ zclient = zclient_new(master, &zclient_options_default, path_handlers, array_size(path_handlers)); @@ -330,7 +327,7 @@ void path_zebra_init(struct event_loop *master) zclient->zebra_connected = path_zebra_connected; /* Initialize special zclient for synchronous message exchanges. */ - zclient_sync = zclient_new(master, &options, NULL, 0); + zclient_sync = zclient_new(master, &zclient_options_sync, NULL, 0); zclient_sync->sock = -1; zclient_sync->redist_default = ZEBRA_ROUTE_SRTE; zclient_sync->instance = 1; diff --git a/pimd/pim_zlookup.c b/pimd/pim_zlookup.c index 6a026f9947..c19119fa47 100644 --- a/pimd/pim_zlookup.c +++ b/pimd/pim_zlookup.c @@ -122,10 +122,7 @@ void zclient_lookup_free(void) void zclient_lookup_new(void) { - struct zclient_options options = zclient_options_default; - options.synchronous = true; - - zlookup = zclient_new(router->master, &options, NULL, 0); + zlookup = zclient_new(router->master, &zclient_options_sync, NULL, 0); if (!zlookup) { flog_err(EC_LIB_ZAPI_SOCKET, "%s: zclient_new() failure", __func__); -- cgit v1.2.3 From 5a40f2b0e75bbb43c0d6e2f9cfe190dfaa61f386 Mon Sep 17 00:00:00 2001 From: David Lamparter Date: Thu, 23 Nov 2023 15:40:38 +0100 Subject: lib, bgp/vnc: add `.auxiliary` zclient option Avoids calling VRF/interface/... handlers in library code more than once. It's kinda surprising that this hasn't been blowing up already for the VNC code, luckily these handlers are (mostly?) idempotent. Signed-off-by: David Lamparter --- bgpd/rfapi/vnc_zebra.c | 2 +- lib/zclient.c | 11 ++++++++++- lib/zclient.h | 12 ++++++++++++ 3 files changed, 23 insertions(+), 2 deletions(-) (limited to 'lib/zclient.c') diff --git a/bgpd/rfapi/vnc_zebra.c b/bgpd/rfapi/vnc_zebra.c index c886beea91..82c08cabde 100644 --- a/bgpd/rfapi/vnc_zebra.c +++ b/bgpd/rfapi/vnc_zebra.c @@ -872,7 +872,7 @@ static zclient_handler *const vnc_handlers[] = { void vnc_zebra_init(struct event_loop *master) { /* Set default values. */ - zclient_vnc = zclient_new(master, &zclient_options_default, + zclient_vnc = zclient_new(master, &zclient_options_auxiliary, vnc_handlers, array_size(vnc_handlers)); zclient_init(zclient_vnc, ZEBRA_ROUTE_VNC, 0, &bgpd_privs); } diff --git a/lib/zclient.c b/lib/zclient.c index 61533aecc6..1b2ff02f61 100644 --- a/lib/zclient.c +++ b/lib/zclient.c @@ -43,10 +43,17 @@ static void zebra_interface_if_set_value(struct stream *s, const struct zclient_options zclient_options_default = { .synchronous = false, + .auxiliary = false, }; const struct zclient_options zclient_options_sync = { .synchronous = true, + .auxiliary = true, +}; + +const struct zclient_options zclient_options_auxiliary = { + .synchronous = false, + .auxiliary = true, }; struct sockaddr_storage zclient_addr; @@ -75,6 +82,7 @@ struct zclient *zclient_new(struct event_loop *master, zclient->n_handlers = n_handlers; zclient->synchronous = opt->synchronous; + zclient->auxiliary = opt->auxiliary; return zclient; } @@ -4444,7 +4452,8 @@ static void zclient_read(struct event *thread) zlog_debug("zclient %p command %s VRF %u", zclient, zserv_command_string(command), vrf_id); - if (command < array_size(lib_handlers) && lib_handlers[command]) + if (!zclient->auxiliary && command < array_size(lib_handlers) && + lib_handlers[command]) lib_handlers[command](command, zclient, length, vrf_id); if (command < zclient->n_handlers && zclient->handlers[command]) zclient->handlers[command](command, zclient, length, vrf_id); diff --git a/lib/zclient.h b/lib/zclient.h index c8dff18bb9..05eb6b20ee 100644 --- a/lib/zclient.h +++ b/lib/zclient.h @@ -306,6 +306,11 @@ struct zclient { /* Is this a synchronous client? */ bool synchronous; + /* Auxiliary clients don't execute standard library handlers + * (which otherwise would duplicate VRF/interface add/delete/etc. + */ + bool auxiliary; + /* BFD enabled with bfd_protocol_integration_init() */ bool bfd_integration; @@ -832,10 +837,17 @@ enum zebra_neigh_state { ZEBRA_NEIGH_INACTIVE = 0, ZEBRA_NEIGH_ACTIVE = 1 }; struct zclient_options { bool synchronous; + + /* auxiliary = don't call common lib/ handlers that manage bits. + * Those should only run once, on the "main" zclient, which this is + * not. (This is also set for synchronous clients.) + */ + bool auxiliary; }; extern const struct zclient_options zclient_options_default; extern const struct zclient_options zclient_options_sync; +extern const struct zclient_options zclient_options_auxiliary; /* link layer representation for GRE like interfaces * ip_in is the underlay IP, ip_out is the tunnel dest -- cgit v1.2.3