X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=lib%2Frconn.h;h=aa3023836fc55f650efa4fb0d80256639f9801f7;hb=0141e875a14cc30fe9c207a83616861055531d4d;hp=e4b73fc1909de5d651a274171f39860f065fff7e;hpb=0442efd9b1a88d923b56eab6b72b6be8231a49f7;p=sliver-openvswitch.git diff --git a/lib/rconn.h b/lib/rconn.h index e4b73fc19..aa3023836 100644 --- a/lib/rconn.h +++ b/lib/rconn.h @@ -38,8 +38,10 @@ struct vconn; struct rconn_packet_counter; struct rconn *rconn_create(int inactivity_probe_interval, - int max_backoff, uint8_t dscp); + int max_backoff, uint8_t dscp, + uint32_t allowed_versions); void rconn_set_dscp(struct rconn *rc, uint8_t dscp); +uint32_t rconn_get_allowed_versions(const struct rconn *); uint8_t rconn_get_dscp(const struct rconn *rc); void rconn_set_max_backoff(struct rconn *, int max_backoff); int rconn_get_max_backoff(const struct rconn *); @@ -81,34 +83,22 @@ ovs_be16 rconn_get_local_port(const struct rconn *); int rconn_get_version(const struct rconn *); const char *rconn_get_state(const struct rconn *); -unsigned int rconn_get_attempted_connections(const struct rconn *); -unsigned int rconn_get_successful_connections(const struct rconn *); time_t rconn_get_last_connection(const struct rconn *); time_t rconn_get_last_disconnect(const struct rconn *); -time_t rconn_get_last_received(const struct rconn *); -time_t rconn_get_creation_time(const struct rconn *); -unsigned long int rconn_get_total_time_connected(const struct rconn *); -int rconn_get_backoff(const struct rconn *); -unsigned int rconn_get_state_elapsed(const struct rconn *); unsigned int rconn_get_connection_seqno(const struct rconn *); int rconn_get_last_error(const struct rconn *); unsigned int rconn_count_txqlen(const struct rconn *); -/* Counts the number of packets queued into an rconn by a given source. */ +/* Counts packets and bytes queued into an rconn by a given source. */ struct rconn_packet_counter { - int n; /* Number of packets queued. */ + unsigned int n_packets; /* Number of packets queued. */ + unsigned int n_bytes; /* Number of bytes queued. */ int ref_cnt; /* Number of owners. */ }; struct rconn_packet_counter *rconn_packet_counter_create(void); void rconn_packet_counter_destroy(struct rconn_packet_counter *); -void rconn_packet_counter_inc(struct rconn_packet_counter *); -void rconn_packet_counter_dec(struct rconn_packet_counter *); - -static inline int -rconn_packet_counter_read(const struct rconn_packet_counter *counter) -{ - return counter->n; -} +void rconn_packet_counter_inc(struct rconn_packet_counter *, unsigned n_bytes); +void rconn_packet_counter_dec(struct rconn_packet_counter *, unsigned n_bytes); #endif /* rconn.h */