X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=blobdiff_plain;f=lib%2Frconn.h;h=64eca5320fb8b55eada7be905d7ba8d530ce28cb;hb=c50c79431efa7b85688fb4be61d97c5ee7a9c459;hp=d0326e65a1843022be537cdee5e1e28ecb4d83e2;hpb=27527aa09ce456796eeea728cef9528aa5612b70;p=openvswitch diff --git a/lib/rconn.h b/lib/rconn.h index d0326e65..64eca532 100644 --- a/lib/rconn.h +++ b/lib/rconn.h @@ -1,5 +1,5 @@ /* - * Copyright (c) 2008, 2009, 2010, 2011 Nicira Networks. + * Copyright (c) 2008, 2009, 2010, 2011, 2012 Nicira, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -37,8 +37,10 @@ struct vconn; struct rconn_packet_counter; -struct rconn *rconn_create(int inactivity_probe_interval, int max_backoff); - +struct rconn *rconn_create(int inactivity_probe_interval, + int max_backoff, uint8_t dscp); +void rconn_set_dscp(struct rconn *rc, uint8_t dscp); +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 *); void rconn_set_probe_interval(struct rconn *, int inactivity_probe_interval); @@ -90,22 +92,18 @@ 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 */