X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=ofproto%2Fofproto-dpif.h;h=6a4ae078bc77bc1be58b3468917e29ac47443b10;hb=591cb419cf3694e0ae66a95973e73c61bad9e03d;hp=f683281692e746dfa7086f4d2a65fdd819fcbc9b;hpb=a16160631a38e3c1881beead1cec8bff0534495b;p=sliver-openvswitch.git diff --git a/ofproto/ofproto-dpif.h b/ofproto/ofproto-dpif.h index f68328169..6a4ae078b 100644 --- a/ofproto/ofproto-dpif.h +++ b/ofproto/ofproto-dpif.h @@ -18,13 +18,45 @@ #include #include "hmapx.h" +#include "odp-util.h" #include "ofproto/ofproto-provider.h" +#include "ovs-thread.h" #include "timer.h" #include "util.h" +#include "ovs-thread.h" union user_action_cookie; struct ofproto_dpif; struct ofport_dpif; +struct dpif_backer; + +/* 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. */ struct rule_dpif { struct rule up; @@ -42,8 +74,9 @@ struct rule_dpif { * packet_count or byte_count member or that can be obtained from the * datapath by, e.g., dpif_flow_get() for any subfacet. */ - uint64_t packet_count; /* Number of packets received. */ - uint64_t byte_count; /* Number of bytes received. */ + 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) @@ -51,40 +84,33 @@ static inline struct rule_dpif *rule_dpif_cast(const struct rule *rule) return rule ? CONTAINER_OF(rule, struct rule_dpif, up) : NULL; } -struct rule_dpif *rule_dpif_lookup_in_table(struct ofproto_dpif *, - const struct flow *, - struct flow_wildcards *, - uint8_t table_id); +void rule_dpif_lookup(struct ofproto_dpif *, const struct flow *, + struct flow_wildcards *, struct rule_dpif **rule) + OVS_ACQ_RDLOCK((*rule)->up.evict); -struct rule_dpif *rule_dpif_miss_rule(struct ofproto_dpif *ofproto, - const struct flow *); +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); -void rule_credit_stats(struct rule_dpif *, const struct dpif_flow_stats *); - -void ofproto_trace(struct ofproto_dpif *, const struct flow *, - const struct ofpbuf *packet, struct ds *); +void rule_release(struct rule_dpif *rule) OVS_RELEASES(rule->up.evict); -size_t put_userspace_action(const struct ofproto_dpif *, - struct ofpbuf *odp_actions, const struct flow *, - const union user_action_cookie *, - const size_t cookie_size); +void rule_credit_stats(struct rule_dpif *, const struct dpif_flow_stats *); -bool stp_should_process_flow(const struct flow *, struct flow_wildcards *); -void stp_process_packet(const struct ofport_dpif *, - const struct ofpbuf *packet); +struct rule_dpif *choose_miss_rule(enum ofputil_port_config, + struct rule_dpif *miss_rule, + struct rule_dpif *no_packet_in_rule); bool ofproto_has_vlan_splinters(const struct ofproto_dpif *); ofp_port_t vsp_realdev_to_vlandev(const struct ofproto_dpif *, ofp_port_t realdev_ofp_port, ovs_be16 vlan_tci); - -bool ofproto_dpif_dscp_from_priority(const struct ofport_dpif *, - uint32_t priority, uint8_t *dscp); -int ofproto_dpif_queue_to_priority(const struct ofproto_dpif *, - uint32_t queue_id, uint32_t *priority); +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_flow_mod(struct ofproto_dpif *, struct ofputil_flow_mod *); +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); #endif /* ofproto-dpif.h */