X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;ds=sidebyside;f=ofproto%2Fofproto-dpif.h;h=0863efda204b0a57e55d4d670fe05475c31e3955;hb=53d98a1e9c8c2e5ea2bde30d3461c1d5bfbbfa97;hp=30ba566a45d9ae26f0c4101d27611c502f3c2835;hpb=ad3efdcb0d5812df189ab08f19dac4b39f3a9e27;p=sliver-openvswitch.git diff --git a/ofproto/ofproto-dpif.h b/ofproto/ofproto-dpif.h index 30ba566a4..0863efda2 100644 --- a/ofproto/ofproto-dpif.h +++ b/ofproto/ofproto-dpif.h @@ -18,59 +18,74 @@ #include #include "hmapx.h" -#include "ofproto/ofproto-provider.h" +#include "odp-util.h" +#include "ofp-util.h" #include "ovs-thread.h" #include "timer.h" #include "util.h" #include "ovs-thread.h" union user_action_cookie; +struct dpif_flow_stats; struct ofproto_dpif; struct ofport_dpif; struct dpif_backer; +struct OVS_LOCKABLE rule_dpif; -struct rule_dpif { - struct rule up; - - /* These statistics: - * - * - Do include packets and bytes from facets that have been deleted or - * whose own statistics have been folded into the rule. - * - * - Do include packets and bytes sent "by hand" that were accounted to - * the rule without any facet being involved (this is a rare corner - * case in rule_execute()). - * - * - Do not include packet or bytes that can be obtained from any facet's - * packet_count or byte_count member or that can be obtained from the - * datapath by, e.g., dpif_flow_get() for any subfacet. - */ - struct ovs_mutex stats_mutex; - uint64_t packet_count OVS_GUARDED; /* Number of packets received. */ - uint64_t byte_count OVS_GUARDED; /* Number of bytes received. */ -}; - -static inline struct rule_dpif *rule_dpif_cast(const struct rule *rule) -{ - return rule ? CONTAINER_OF(rule, struct rule_dpif, up) : NULL; -} +/* Ofproto-dpif -- DPIF based ofproto implementation. + * + * Ofproto-dpif provides an ofproto implementation for those platforms which + * implement the netdev and dpif interface defined in netdev.h and dpif.h. The + * most important of which is the Linux Kernel Module (dpif-linux), but + * alternatives are supported such as a userspace only implementation + * (dpif-netdev), and a dummy implementation used for unit testing. + * + * Ofproto-dpif is divided into three major chunks. + * + * - ofproto-dpif.c + * The main ofproto-dpif module is responsible for implementing the + * provider interface, installing and removing datapath flows, maintaining + * packet statistics, running protocols (BFD, LACP, STP, etc), and + * configuring relevant submodules. + * + * - ofproto-dpif-upcall.c + * Ofproto-dpif-upcall is responsible for retrieving upcalls from the kernel, + * processing miss upcalls, and handing more complex ones up to the main + * ofproto-dpif module. Miss upcall processing boils down to figuring out + * what each packet's actions are, executing them (i.e. asking the kernel to + * forward it), and handing it up to ofproto-dpif to decided whether or not + * to install a kernel flow. + * + * - ofproto-dpif-xlate.c + * Ofproto-dpif-xlate is responsible for translating translating OpenFlow + * actions into datapath actions. */ void rule_dpif_lookup(struct ofproto_dpif *, const struct flow *, - struct flow_wildcards *, struct rule_dpif **rule) - OVS_ACQ_RDLOCK((*rule)->up.evict); + struct flow_wildcards *, struct rule_dpif **rule); bool rule_dpif_lookup_in_table(struct ofproto_dpif *, const struct flow *, struct flow_wildcards *, uint8_t table_id, - struct rule_dpif **rule) - OVS_ACQ_RDLOCK((*rule)->up.evict); + struct rule_dpif **rule); + +void rule_dpif_ref(struct rule_dpif *); +void rule_dpif_unref(struct rule_dpif *); + +void rule_dpif_credit_stats(struct rule_dpif *rule , + const struct dpif_flow_stats *); + +bool rule_dpif_fail_open(const struct rule_dpif *rule); + +struct rule_actions *rule_dpif_get_actions(const struct rule_dpif *); -void rule_release(struct rule_dpif *rule) OVS_RELEASES(rule->up.evict); +ovs_be64 rule_dpif_get_flow_cookie(const struct rule_dpif *rule); -void rule_credit_stats(struct rule_dpif *, const struct dpif_flow_stats *); +void rule_dpif_reduce_timeouts(struct rule_dpif *rule, uint16_t idle_timeout, + uint16_t hard_timeout); -struct rule_dpif *choose_miss_rule(enum ofputil_port_config, - struct rule_dpif *miss_rule, - struct rule_dpif *no_packet_in_rule); +void choose_miss_rule(enum ofputil_port_config, + struct rule_dpif *miss_rule, + struct rule_dpif *no_packet_in_rule, + struct rule_dpif **rule); bool ofproto_has_vlan_splinters(const struct ofproto_dpif *); ofp_port_t vsp_realdev_to_vlandev(const struct ofproto_dpif *, @@ -80,6 +95,7 @@ bool vsp_adjust_flow(const struct ofproto_dpif *, struct flow *); void ofproto_dpif_send_packet_in(struct ofproto_dpif *, struct ofputil_packet_in *pin); +int ofproto_dpif_send_packet(const struct ofport_dpif *, struct ofpbuf *); void ofproto_dpif_flow_mod(struct ofproto_dpif *, struct ofputil_flow_mod *); struct ofport_dpif *odp_port_to_ofport(const struct dpif_backer *, odp_port_t);