2 * Copyright (c) 2013, 2014 Alexandru Copot <alex.mihai.c@gmail.com>, with support from IXIA.
3 * Copyright (c) 2013, 2014 Daniel Baluta <dbaluta@ixiacom.com>
4 * Copyright (c) 2014, 2015 Nicira, Inc.
6 * Licensed under the Apache License, Version 2.0 (the "License");
7 * you may not use this file except in compliance with the License.
8 * You may obtain a copy of the License at:
10 * http://www.apache.org/licenses/LICENSE-2.0
12 * Unless required by applicable law or agreed to in writing, software
13 * distributed under the License is distributed on an "AS IS" BASIS,
14 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 * See the License for the specific language governing permissions and
16 * limitations under the License.
22 #include <sys/types.h>
27 #include "ofproto-provider.h"
34 struct ofp_bundle_entry {
36 enum ofptype type; /* OFPTYPE_FLOW_MOD or OFPTYPE_PORT_MOD. */
37 long long version; /* Version in which the changes take
40 struct ofputil_flow_mod fm; /* 'fm.ofpacts' must be malloced. */
41 struct ofputil_port_mod pm;
44 /* Used during commit. */
45 struct ofport *port; /* Affected port. */
46 struct rule_collection old_rules; /* Affected rules. */
47 struct rule_collection new_rules; /* Replacement rules. */
49 /* OpenFlow header and some of the message contents for error reporting. */
50 struct ofp_header ofp_msg[DIV_ROUND_UP(64, sizeof(struct ofp_header))];
59 struct hmap_node node; /* In struct ofconn's "bundles" hmap. */
62 enum bundle_state state;
64 /* List of 'struct bundle_message's */
65 struct ovs_list msg_list;
68 static inline struct ofp_bundle_entry *ofp_bundle_entry_alloc(
69 enum ofptype type, const struct ofp_header *oh);
70 static inline void ofp_bundle_entry_free(struct ofp_bundle_entry *);
72 enum ofperr ofp_bundle_open(struct ofconn *, uint32_t id, uint16_t flags);
73 enum ofperr ofp_bundle_close(struct ofconn *, uint32_t id, uint16_t flags);
74 enum ofperr ofp_bundle_discard(struct ofconn *, uint32_t id);
75 enum ofperr ofp_bundle_add_message(struct ofconn *, uint32_t id,
76 uint16_t flags, struct ofp_bundle_entry *);
78 void ofp_bundle_remove__(struct ofconn *, struct ofp_bundle *, bool success);
80 static inline struct ofp_bundle_entry *
81 ofp_bundle_entry_alloc(enum ofptype type, const struct ofp_header *oh)
83 struct ofp_bundle_entry *entry = xmalloc(sizeof *entry);
88 /* Max 64 bytes for error reporting. */
89 memcpy(entry->ofp_msg, oh, MIN(ntohs(oh->length), sizeof entry->ofp_msg));
95 ofp_bundle_entry_free(struct ofp_bundle_entry *entry)
98 if (entry->type == OFPTYPE_FLOW_MOD) {
99 free(entry->fm.ofpacts);