1 /* Copyright (c) 2015, 2016 Nicira, Inc.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at:
7 * http://www.apache.org/licenses/LICENSE-2.0
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
19 #include "lib/bitmap.h"
23 #include "lib/vswitch-idl.h"
24 #include "openvswitch/vlog.h"
25 #include "ovn/lib/ovn-sb-idl.h"
26 #include "ovn-controller.h"
28 VLOG_DEFINE_THIS_MODULE(binding);
31 binding_register_ovs_idl(struct ovsdb_idl *ovs_idl)
33 ovsdb_idl_add_table(ovs_idl, &ovsrec_table_open_vswitch);
34 ovsdb_idl_add_column(ovs_idl, &ovsrec_open_vswitch_col_bridges);
36 ovsdb_idl_add_table(ovs_idl, &ovsrec_table_bridge);
37 ovsdb_idl_add_column(ovs_idl, &ovsrec_bridge_col_name);
38 ovsdb_idl_add_column(ovs_idl, &ovsrec_bridge_col_ports);
40 ovsdb_idl_add_table(ovs_idl, &ovsrec_table_port);
41 ovsdb_idl_add_column(ovs_idl, &ovsrec_port_col_name);
42 ovsdb_idl_add_column(ovs_idl, &ovsrec_port_col_interfaces);
44 ovsdb_idl_add_table(ovs_idl, &ovsrec_table_interface);
45 ovsdb_idl_add_column(ovs_idl, &ovsrec_interface_col_name);
46 ovsdb_idl_add_column(ovs_idl, &ovsrec_interface_col_external_ids);
47 ovsdb_idl_add_column(ovs_idl, &ovsrec_interface_col_ingress_policing_rate);
48 ovsdb_idl_add_column(ovs_idl,
49 &ovsrec_interface_col_ingress_policing_burst);
53 get_local_iface_ids(const struct ovsrec_bridge *br_int, struct shash *lports)
57 for (i = 0; i < br_int->n_ports; i++) {
58 const struct ovsrec_port *port_rec = br_int->ports[i];
62 if (!strcmp(port_rec->name, br_int->name)) {
66 for (j = 0; j < port_rec->n_interfaces; j++) {
67 const struct ovsrec_interface *iface_rec;
69 iface_rec = port_rec->interfaces[j];
70 iface_id = smap_get(&iface_rec->external_ids, "iface-id");
74 shash_add(lports, iface_id, iface_rec);
80 update_ct_zones(struct sset *lports, struct simap *ct_zones,
81 unsigned long *ct_zone_bitmap)
83 struct simap_node *ct_zone, *ct_zone_next;
87 /* xxx This is wasteful to assign a zone to each port--even if no
88 * xxx security policy is applied. */
90 /* Delete any zones that are associated with removed ports. */
91 SIMAP_FOR_EACH_SAFE(ct_zone, ct_zone_next, ct_zones) {
92 if (!sset_contains(lports, ct_zone->name)) {
93 bitmap_set0(ct_zone_bitmap, ct_zone->data);
94 simap_delete(ct_zones, ct_zone);
98 /* Assign a unique zone id for each logical port. */
99 SSET_FOR_EACH(iface_id, lports) {
102 if (simap_contains(ct_zones, iface_id)) {
106 /* We assume that there are 64K zones and that we own them all. */
107 zone = bitmap_scan(ct_zone_bitmap, 0, scan_start, MAX_CT_ZONES + 1);
108 if (zone == MAX_CT_ZONES + 1) {
109 static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 1);
110 VLOG_WARN_RL(&rl, "exhausted all ct zones");
113 scan_start = zone + 1;
115 bitmap_set1(ct_zone_bitmap, zone);
116 simap_put(ct_zones, iface_id, zone);
118 /* xxx We should erase any old entries for this
119 * xxx zone, but we need a generic interface to the conntrack
125 add_local_datapath(struct hmap *local_datapaths,
126 const struct sbrec_port_binding *binding_rec)
128 struct hmap_node *ld;
129 ld = hmap_first_with_hash(local_datapaths,
130 binding_rec->datapath->tunnel_key);
132 ld = xmalloc(sizeof *ld);
133 hmap_insert(local_datapaths, ld,
134 binding_rec->datapath->tunnel_key);
139 update_qos(const struct ovsrec_interface *iface_rec,
140 const struct sbrec_port_binding *pb)
142 int rate = smap_get_int(&pb->options, "policing_rate", 0);
143 int burst = smap_get_int(&pb->options, "policing_burst", 0);
145 ovsrec_interface_set_ingress_policing_rate(iface_rec, MAX(0, rate));
146 ovsrec_interface_set_ingress_policing_burst(iface_rec, MAX(0, burst));
150 binding_run(struct controller_ctx *ctx, const struct ovsrec_bridge *br_int,
151 const char *chassis_id, struct simap *ct_zones,
152 unsigned long *ct_zone_bitmap, struct hmap *local_datapaths)
154 const struct sbrec_chassis *chassis_rec;
155 const struct sbrec_port_binding *binding_rec;
157 if (!ctx->ovnsb_idl_txn) {
161 chassis_rec = get_chassis(ctx->ovnsb_idl, chassis_id);
166 struct shash lports = SHASH_INITIALIZER(&lports);
168 get_local_iface_ids(br_int, &lports);
170 /* We have no integration bridge, therefore no local logical ports.
171 * We'll remove our chassis from all port binding records below. */
174 struct sset all_lports = SSET_INITIALIZER(&all_lports);
175 struct shash_node *node;
176 SHASH_FOR_EACH (node, &lports) {
177 sset_add(&all_lports, node->name);
180 ovsdb_idl_txn_add_comment(
181 ctx->ovnsb_idl_txn,"ovn-controller: updating port bindings for '%s'",
184 /* Run through each binding record to see if it is resident on this
185 * chassis and update the binding accordingly. This includes both
186 * directly connected logical ports and children of those ports. */
187 SBREC_PORT_BINDING_FOR_EACH(binding_rec, ctx->ovnsb_idl) {
188 const struct ovsrec_interface *iface_rec
189 = shash_find_and_delete(&lports, binding_rec->logical_port);
191 || (binding_rec->parent_port && binding_rec->parent_port[0] &&
192 sset_contains(&all_lports, binding_rec->parent_port))) {
193 if (binding_rec->parent_port && binding_rec->parent_port[0]) {
194 /* Add child logical port to the set of all local ports. */
195 sset_add(&all_lports, binding_rec->logical_port);
197 add_local_datapath(local_datapaths, binding_rec);
198 if (iface_rec && ctx->ovs_idl_txn) {
199 update_qos(iface_rec, binding_rec);
201 if (binding_rec->chassis == chassis_rec) {
204 if (binding_rec->chassis) {
205 VLOG_INFO("Changing chassis for lport %s from %s to %s",
206 binding_rec->logical_port,
207 binding_rec->chassis->name,
210 sbrec_port_binding_set_chassis(binding_rec, chassis_rec);
211 } else if (binding_rec->chassis == chassis_rec) {
212 sbrec_port_binding_set_chassis(binding_rec, NULL);
213 } else if (!binding_rec->chassis
214 && !strcmp(binding_rec->type, "localnet")) {
215 /* localnet ports will never be bound to a chassis, but we want
216 * to list them in all_lports because we want to allocate
217 * a conntrack zone ID for each one, as we'll be creating
218 * a patch port for each one. */
219 sset_add(&all_lports, binding_rec->logical_port);
223 SHASH_FOR_EACH (node, &lports) {
224 VLOG_DBG("No port binding record for lport %s", node->name);
227 update_ct_zones(&all_lports, ct_zones, ct_zone_bitmap);
229 shash_destroy(&lports);
230 sset_destroy(&all_lports);
233 /* Returns true if the database is all cleaned up, false if more work is
236 binding_cleanup(struct controller_ctx *ctx, const char *chassis_id)
238 if (!ctx->ovnsb_idl_txn) {
246 const struct sbrec_chassis *chassis_rec
247 = get_chassis(ctx->ovnsb_idl, chassis_id);
252 ovsdb_idl_txn_add_comment(
254 "ovn-controller: removing all port bindings for '%s'", chassis_id);
256 const struct sbrec_port_binding *binding_rec;
257 bool any_changes = false;
258 SBREC_PORT_BINDING_FOR_EACH(binding_rec, ctx->ovnsb_idl) {
259 if (binding_rec->chassis == chassis_rec) {
260 sbrec_port_binding_set_chassis(binding_rec, NULL);