X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=ofproto%2Fofproto.h;h=6377e51e218baa89c45f15972688d3159f477e4d;hb=66aeba23bd8effd71e0a3cf9c0cab75f3d75f6f1;hp=398cac4fd4401216c2da96806c1e79d50dd1522c;hpb=00908dc27a4d93bd1c5bda3bcdc84ec351e9a09a;p=sliver-openvswitch.git diff --git a/ofproto/ofproto.h b/ofproto/ofproto.h index 398cac4fd..6377e51e2 100644 --- a/ofproto/ofproto.h +++ b/ofproto/ofproto.h @@ -21,6 +21,7 @@ #include #include #include "flow.h" +#include "netflow.h" #include "tag.h" struct odp_actions; @@ -28,14 +29,26 @@ struct ofhooks; struct ofproto; struct svec; +enum { + DP_GROUP_FLOOD = 0, + DP_GROUP_ALL = 1 +}; + struct ofexpired { flow_t flow; - uint64_t packet_count; /* Packets from *expired* subrules. */ - uint64_t byte_count; /* Bytes from *expired* subrules. */ + uint64_t packet_count; /* Packets from subrules. */ + uint64_t byte_count; /* Bytes from subrules. */ long long int used; /* Last-used time (0 if never used). */ - long long int created; /* Creation time. */ - uint8_t tcp_flags; /* Bitwise-OR of all TCP flags seen. */ - uint8_t ip_tos; /* Last-seen IP type-of-service. */ +}; + +struct ofproto_sflow_options { + struct svec targets; + uint32_t sampling_rate; + uint32_t polling_interval; + uint32_t header_len; + uint32_t sub_id; + char *agent_device; + char *control_ip; }; int ofproto_create(const char *datapath, const struct ofhooks *, void *aux, @@ -62,8 +75,9 @@ int ofproto_set_discovery(struct ofproto *, bool discovery, int ofproto_set_controller(struct ofproto *, const char *controller); int ofproto_set_listeners(struct ofproto *, const struct svec *listeners); int ofproto_set_snoops(struct ofproto *, const struct svec *snoops); -int ofproto_set_netflow(struct ofproto *, const struct svec *collectors, - uint8_t engine_type, uint8_t engine_id, bool add_id_to_iface); +int ofproto_set_netflow(struct ofproto *, + const struct netflow_options *nf_options); +void ofproto_set_sflow(struct ofproto *, const struct ofproto_sflow_options *); void ofproto_set_failure(struct ofproto *, bool fail_open); void ofproto_set_rate_limit(struct ofproto *, int rate_limit, int burst_limit); int ofproto_set_stp(struct ofproto *, bool enable_stp); @@ -99,7 +113,8 @@ struct ofhooks { void (*port_changed_cb)(enum ofp_port_reason, const struct ofp_phy_port *, void *aux); bool (*normal_cb)(const flow_t *, const struct ofpbuf *packet, - struct odp_actions *, tag_type *, void *aux); + struct odp_actions *, tag_type *, + uint16_t *nf_output_iface, void *aux); void (*account_flow_cb)(const flow_t *, const union odp_action *, size_t n_actions, unsigned long long int n_bytes, void *aux);