forked from ovn-org/ovn
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
controller: Watch for route changes.
for each vrf/network namespace we use we open a netlink watcher. This allows us to reconcile on changed route entries from outside routing agents. Signed-off-by: Felix Huettner <felix.huettner@stackit.cloud> Signed-off-by: 0-day Robot <robot@bytheb.org>
- Loading branch information
1 parent
d4d8c38
commit ac35ba5
Showing
9 changed files
with
290 additions
and
11 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,37 @@ | ||
| /* | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at: | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
|
|
||
| #include <config.h> | ||
|
|
||
| #include <stdbool.h> | ||
|
|
||
| #include "openvswitch/compiler.h" | ||
| #include "route-table-notify.h" | ||
|
|
||
| bool | ||
| route_table_notify_run(void) | ||
| { | ||
| return false; | ||
| } | ||
|
|
||
| void | ||
| route_table_notify_wait(void) | ||
| { | ||
| } | ||
|
|
||
| void | ||
| route_table_notify_update_watches(struct hmap *route_table_watches OVS_UNUSED) | ||
| { | ||
| } | ||
|
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,148 @@ | ||
| /* | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at: | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
|
|
||
| #include <config.h> | ||
|
|
||
| #include <net/if.h> | ||
| #include <linux/rtnetlink.h> | ||
|
|
||
| #include "netlink-notifier.h" | ||
| #include "openvswitch/vlog.h" | ||
|
|
||
| #include "binding.h" | ||
| #include "route-table.h" | ||
| #include "route.h" | ||
| #include "route-table-notify.h" | ||
| #include "route-exchange-netlink.h" | ||
|
|
||
|
|
||
| VLOG_DEFINE_THIS_MODULE(route_table_notify); | ||
|
|
||
| struct route_table_watch_entry { | ||
| struct hmap_node node; | ||
| uint32_t table_id; | ||
| bool is_netns; | ||
| struct nln *nln; | ||
| struct nln_notifier *route_notifier; | ||
| struct nln_notifier *route6_notifier; | ||
| /* used in update_watches to ensure we clean up */ | ||
| bool stale; | ||
| }; | ||
|
|
||
| static struct hmap watches = HMAP_INITIALIZER(&watches); | ||
| static bool any_route_table_changed = false; | ||
| static struct route_table_msg rtmsg; | ||
|
|
||
| static struct route_table_watch_entry* | ||
| find_watch_entry(uint32_t table_id) | ||
| { | ||
| struct route_table_watch_entry *we; | ||
| uint32_t hash = route_table_notify_hash_watch(table_id); | ||
| HMAP_FOR_EACH_WITH_HASH (we, node, hash, &watches) { | ||
| if (table_id == we->table_id) { | ||
| return we; | ||
| } | ||
| } | ||
| return NULL; | ||
| } | ||
|
|
||
| static void | ||
| route_table_change(const struct route_table_msg *change OVS_UNUSED, | ||
| void *aux OVS_UNUSED) | ||
| { | ||
| if (change && change->rd.rtm_protocol != RTPROT_OVN) { | ||
| any_route_table_changed = true; | ||
| } | ||
| } | ||
|
|
||
| static void | ||
| add_watch_entry(uint32_t table_id) | ||
| { | ||
| struct route_table_watch_entry *we; | ||
| uint32_t hash = route_table_notify_hash_watch(table_id); | ||
| we = xzalloc(sizeof(*we)); | ||
| we->table_id = table_id; | ||
| we->stale = false; | ||
| VLOG_DBG("registering new route table watcher for table %d", | ||
| table_id); | ||
| we->nln = nln_create( NETLINK_ROUTE, route_table_parse, &rtmsg); | ||
|
|
||
| we->route_notifier = | ||
| nln_notifier_create(we->nln, RTNLGRP_IPV4_ROUTE, | ||
| (nln_notify_func *) route_table_change, NULL); | ||
| we->route6_notifier = | ||
| nln_notifier_create(we->nln, RTNLGRP_IPV6_ROUTE, | ||
| (nln_notify_func *) route_table_change, NULL); | ||
| hmap_insert(&watches, &we->node, hash); | ||
| } | ||
|
|
||
| static void | ||
| remove_watch_entry(struct route_table_watch_entry *we) | ||
| { | ||
| hmap_remove(&watches, &we->node); | ||
| nln_notifier_destroy(we->route_notifier); | ||
| nln_notifier_destroy(we->route6_notifier); | ||
| nln_destroy(we->nln); | ||
| free(we); | ||
| } | ||
|
|
||
| bool | ||
| route_table_notify_run(void) | ||
| { | ||
| any_route_table_changed = false; | ||
|
|
||
| struct route_table_watch_entry *we; | ||
| HMAP_FOR_EACH (we, node, &watches) { | ||
| nln_run(we->nln); | ||
| } | ||
|
|
||
| return any_route_table_changed; | ||
| } | ||
|
|
||
| void | ||
| route_table_notify_wait(void) | ||
| { | ||
| struct route_table_watch_entry *we; | ||
| HMAP_FOR_EACH (we, node, &watches) { | ||
| nln_wait(we->nln); | ||
| } | ||
| } | ||
|
|
||
| void | ||
| route_table_notify_update_watches(struct hmap *route_table_watches) | ||
| { | ||
| struct route_table_watch_entry *we; | ||
| HMAP_FOR_EACH (we, node, &watches) { | ||
| we->stale = true; | ||
| } | ||
|
|
||
| struct route_table_watch_request *wr; | ||
| HMAP_FOR_EACH_SAFE (wr, node, route_table_watches) { | ||
| we = find_watch_entry(wr->table_id); | ||
| if (we) { | ||
| we->stale = false; | ||
| } else { | ||
| add_watch_entry(wr->table_id); | ||
| } | ||
| hmap_remove(route_table_watches, &wr->node); | ||
| free(wr); | ||
| } | ||
|
|
||
| HMAP_FOR_EACH_SAFE (we, node, &watches) { | ||
| if (we->stale) { | ||
| remove_watch_entry(we); | ||
| } | ||
| } | ||
|
|
||
| } |
Oops, something went wrong.