Fixes namespace conflict for partner development.
#define QUEUE_H 1
/* Packet queue. */
-struct queue {
+struct ofp_queue {
int n; /* Number of queued packets. */
struct ofpbuf *head; /* First queued packet, null if n == 0. */
struct ofpbuf *tail; /* Last queued packet, null if n == 0. */
};
-void queue_init(struct queue *);
-void queue_destroy(struct queue *);
-void queue_clear(struct queue *);
-void queue_advance_head(struct queue *, struct ofpbuf *next);
-void queue_push_tail(struct queue *, struct ofpbuf *);
-struct ofpbuf *queue_pop_head(struct queue *);
+void queue_init(struct ofp_queue *);
+void queue_destroy(struct ofp_queue *);
+void queue_clear(struct ofp_queue *);
+void queue_advance_head(struct ofp_queue *, struct ofpbuf *next);
+void queue_push_tail(struct ofp_queue *, struct ofpbuf *);
+struct ofpbuf *queue_pop_head(struct ofp_queue *);
#endif /* queue.h */
#include <assert.h>
#include "ofpbuf.h"
-static void check_queue(struct queue *q);
+static void check_queue(struct ofp_queue *q);
/* Initializes 'q' as an empty packet queue. */
void
-queue_init(struct queue *q)
+queue_init(struct ofp_queue *q)
{
q->n = 0;
q->head = NULL;
/* Destroys 'q' and all of the packets that it contains. */
void
-queue_destroy(struct queue *q)
+queue_destroy(struct ofp_queue *q)
{
struct ofpbuf *cur, *next;
for (cur = q->head; cur != NULL; cur = next) {
/* Removes and destroys all of the packets in 'q', rendering it empty. */
void
-queue_clear(struct queue *q)
+queue_clear(struct ofp_queue *q)
{
queue_destroy(q);
queue_init(q);
* passed to a function for possible consumption (and destruction) and only
* dropped from the queue if that function actually accepts it. */
void
-queue_advance_head(struct queue *q, struct ofpbuf *next)
+queue_advance_head(struct ofp_queue *q, struct ofpbuf *next)
{
assert(q->n);
assert(q->head);
/* Appends 'b' to the tail of 'q'. */
void
-queue_push_tail(struct queue *q, struct ofpbuf *b)
+queue_push_tail(struct ofp_queue *q, struct ofpbuf *b)
{
check_queue(q);
* it. The caller must free the buffer (with ofpbuf_delete()) when it is no
* longer needed. */
struct ofpbuf *
-queue_pop_head(struct queue *q)
+queue_pop_head(struct ofp_queue *q)
{
struct ofpbuf *head = q->head;
queue_advance_head(q, head->next);
/* Checks the internal integrity of 'q'. For use in debugging. */
static void
-check_queue(struct queue *q)
+check_queue(struct ofp_queue *q)
{
#if 0
struct ofpbuf *iter;
char *name;
bool reliable;
- struct queue txq;
+ struct ofp_queue txq;
int backoff;
int max_backoff;
struct rconn *remote_rconn;
/* One queue per physical port. */
- struct queue queues[OFPP_MAX];
+ struct ofp_queue queues[OFPP_MAX];
int n_queued; /* Sum over queues[*].n. */
int next_tx_port; /* Next port to check in round-robin. */
static void
drop_packet(struct rate_limiter *rl)
{
- struct queue *longest; /* Queue currently selected as longest. */
+ struct ofp_queue *longest; /* Queue currently selected as longest. */
int n_longest; /* # of queues of same length as 'longest'. */
- struct queue *q;
+ struct ofp_queue *q;
longest = &rl->queues[0];
n_longest = 1;
for (i = 0; i < OFPP_MAX; i++) {
unsigned int port = (rl->next_tx_port + i) % OFPP_MAX;
- struct queue *q = &rl->queues[port];
+ struct ofp_queue *q = &rl->queues[port];
if (q->n) {
rl->next_tx_port = (port + 1) % OFPP_MAX;
rl->n_queued--;