Rename struct queue to struct ofp_queue.
authorBen Pfaff <blp@nicira.com>
Thu, 4 Sep 2008 18:10:46 +0000 (11:10 -0700)
committerBen Pfaff <blp@nicira.com>
Thu, 4 Sep 2008 20:53:26 +0000 (13:53 -0700)
Fixes namespace conflict for partner development.

include/queue.h
lib/queue.c
lib/rconn.c
secchan/secchan.c

index cecc15ddb3f7f77fd62b2ea810a94cc3878afac7..8221c447c18a4a48a66c8c3f9d78bf814a9ada53 100644 (file)
 #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 */
index 33acc7eb538b15b9327d44da2afd6c8cc2817c04..04610cfa29699b3cb0b3050e9ac063c18434b016 100644 (file)
 #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;
@@ -49,7 +49,7 @@ queue_init(struct queue *q)
 
 /* 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) {
@@ -60,7 +60,7 @@ queue_destroy(struct queue *q)
 
 /* 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);
@@ -73,7 +73,7 @@ queue_clear(struct queue *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);
@@ -86,7 +86,7 @@ queue_advance_head(struct queue *q, struct ofpbuf *next)
 
 /* 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);
 
@@ -105,7 +105,7 @@ queue_push_tail(struct queue *q, struct ofpbuf *b)
  * 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);
@@ -114,7 +114,7 @@ queue_pop_head(struct queue *q)
 
 /* 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;
index 3fce80e65c0b7c8604b5aa1fb4f9b3f85ca5db34..ceeb137ae78b32119217bf58a940de270f797c39 100644 (file)
@@ -83,7 +83,7 @@ struct rconn {
     char *name;
     bool reliable;
 
-    struct queue txq;
+    struct ofp_queue txq;
 
     int backoff;
     int max_backoff;
index 42e99da254888967124c9f74063102235e37d7e1..d1df8283dedfe21b74226d552e7ffb27a3e64c80 100644 (file)
@@ -810,7 +810,7 @@ struct rate_limiter {
     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. */
 
@@ -837,9 +837,9 @@ struct rate_limiter {
 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;
@@ -871,7 +871,7 @@ dequeue_packet(struct rate_limiter *rl)
 
     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--;