X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=ofproto%2Fofproto-dpif.h;h=7efc8d736e6b6e297b6b0f2ba3c0138b56d21f33;hb=3442636d01d2a73a557952ad9140de07418c28c2;hp=f683281692e746dfa7086f4d2a65fdd819fcbc9b;hpb=a16160631a38e3c1881beead1cec8bff0534495b;p=sliver-openvswitch.git diff --git a/ofproto/ofproto-dpif.h b/ofproto/ofproto-dpif.h index f68328169..7efc8d736 100644 --- a/ofproto/ofproto-dpif.h +++ b/ofproto/ofproto-dpif.h @@ -18,73 +18,89 @@ #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. - */ - uint64_t packet_count; /* Number of packets received. */ - uint64_t byte_count; /* 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; -} - -struct rule_dpif *rule_dpif_lookup_in_table(struct ofproto_dpif *, - const struct flow *, - struct flow_wildcards *, - uint8_t table_id); - -struct rule_dpif *rule_dpif_miss_rule(struct ofproto_dpif *ofproto, - const struct flow *); - -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 *); - -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); - -bool stp_should_process_flow(const struct flow *, struct flow_wildcards *); -void stp_process_packet(const struct ofport_dpif *, - const struct ofpbuf *packet); +/* 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); + +bool rule_dpif_lookup_in_table(struct ofproto_dpif *, const struct flow *, + struct flow_wildcards *, uint8_t table_id, + struct rule_dpif **rule) + OVS_TRY_RDLOCK(true, *rule); + +void rule_dpif_release(struct rule_dpif *rule) OVS_RELEASES(rule); + +void rule_dpif_credit_stats(struct rule_dpif *rule , + const struct dpif_flow_stats *); + +bool rule_dpif_fail_open(const struct rule_dpif *rule); + +void rule_dpif_get_actions(const struct rule_dpif *rule, + const struct ofpact **ofpacts, + size_t *ofpacts_len); + +ovs_be64 rule_dpif_get_flow_cookie(const struct rule_dpif *rule); + +void rule_dpif_reduce_timeouts(struct rule_dpif *rule, uint16_t idle_timeout, + uint16_t hard_timeout); + +void choose_miss_rule(enum ofputil_port_config, + struct rule_dpif *miss_rule, + struct rule_dpif *no_packet_in_rule, + struct rule_dpif **rule) + OVS_ACQ_RDLOCK(*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 */