diff options
| author | Ben Pfaff <blp@nicira.com> | 2012-07-12 14:18:05 -0700 |
|---|---|---|
| committer | Ben Pfaff <blp@nicira.com> | 2012-07-12 14:18:05 -0700 |
| commit | 2b07c8b182b76e4e3a162796d3ae273ef51d4131 (patch) | |
| tree | a27e0faafd0f228ec8199b47b1fea027efc42c3f /ofproto/connmgr.h | |
| parent | e2a3d183f60b93265c095ede1379194916444822 (diff) | |
ofproto: New feature to notify controllers of flow table changes.
OpenFlow switching monitoring and controller coordination can be made more
efficient if the switch can notify a controller of flow table changes as
they occur, rather than periodically polling for changes. This commit
implements such a feature.
Feature #6633.
CC: Natasha Gude <natasha@nicira.com>
Signed-off-by: Ben Pfaff <blp@nicira.com>
Diffstat (limited to 'ofproto/connmgr.h')
| -rw-r--r-- | ofproto/connmgr.h | 32 |
1 files changed, 32 insertions, 0 deletions
diff --git a/ofproto/connmgr.h b/ofproto/connmgr.h index dec5b71c..24a33fb0 100644 --- a/ofproto/connmgr.h +++ b/ofproto/connmgr.h @@ -17,6 +17,7 @@ #ifndef CONNMGR_H #define CONNMGR_H 1 +#include "classifier.h" #include "hmap.h" #include "list.h" #include "ofp-errors.h" @@ -30,6 +31,7 @@ struct ofopgroup; struct ofputil_flow_removed; struct ofputil_packet_in; struct ofputil_phy_port; +struct rule; struct simap; struct sset; @@ -159,4 +161,34 @@ bool connmgr_may_set_up_flow(struct connmgr *, const struct flow *, /* Fail-open and in-band implementation. */ void connmgr_flushed(struct connmgr *); +/* A flow monitor managed by NXST_FLOW_MONITOR and related requests. */ +struct ofmonitor { + struct ofconn *ofconn; /* Owning 'ofconn'. */ + struct hmap_node ofconn_node; /* In ofconn's 'monitors' hmap. */ + uint32_t id; + + enum nx_flow_monitor_flags flags; + + /* Matching. */ + uint16_t out_port; + uint8_t table_id; + struct cls_rule match; +}; + +struct ofputil_flow_monitor_request; + +enum ofperr ofmonitor_create(const struct ofputil_flow_monitor_request *, + struct ofconn *, struct ofmonitor **); +struct ofmonitor *ofmonitor_lookup(struct ofconn *, uint32_t id); +void ofmonitor_destroy(struct ofmonitor *); + +void ofmonitor_report(struct connmgr *, struct rule *, + enum nx_flow_update_event, enum ofp_flow_removed_reason, + const struct ofconn *abbrev_ofconn, ovs_be32 abbrev_xid); +void ofmonitor_flush(struct connmgr *); + +void ofmonitor_collect_resume_rules(struct ofmonitor *, uint64_t seqno, + struct list *rules); +void ofmonitor_compose_refresh_updates(struct list *rules, struct list *msgs); + #endif /* connmgr.h */ |