pintos-os.org Git - openvswitch/blob - lib/queue.c

   1 /* Copyright (c) 2008 The Board of Trustees of The Leland Stanford
   2  * Junior University
   3  *
   4  * We are making the OpenFlow specification and associated documentation
   5  * (Software) available for public use and benefit with the expectation
   6  * that others will use, modify and enhance the Software and contribute
   7  * those enhancements back to the community. However, since we would
   8  * like to make the Software available for broadest use, with as few
   9  * restrictions as possible permission is hereby granted, free of
  10  * charge, to any person obtaining a copy of this Software to deal in
  11  * the Software under the copyrights without restriction, including
  12  * without limitation the rights to use, copy, modify, merge, publish,
  13  * distribute, sublicense, and/or sell copies of the Software, and to
  14  * permit persons to whom the Software is furnished to do so, subject to
  15  * the following conditions:
  16  *
  17  * The above copyright notice and this permission notice shall be
  18  * included in all copies or substantial portions of the Software.
  19  *
  20  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  21  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  22  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  23  * NONINFRINGEMENT.  IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
  24  * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
  25  * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
  26  * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  27  * SOFTWARE.
  28  *
  29  * The name and trademarks of copyright holder(s) may NOT be used in
  30  * advertising or publicity pertaining to the Software or any
  31  * derivatives without specific, written prior permission.
  32  */
  33
  34 #include "queue.h"
  35 #include <assert.h>
  36 #include "buffer.h"
  37
  38 static void check_queue(struct queue *q);
  39
  40 void
  41 queue_init(struct queue *q)
  42 {
  43     q->n = 0;
  44     q->head = NULL;
  45     q->tail = NULL;
  46 }
  47
  48 void
  49 queue_destroy(struct queue *q)
  50 {
  51     struct buffer *cur, *next;
  52     for (cur = q->head; cur != NULL; cur = next) {
  53         next = cur->next;
  54         buffer_delete(cur);
  55     }
  56 }
  57
  58 void
  59 queue_clear(struct queue *q)
  60 {
  61     queue_destroy(q);
  62     queue_init(q);
  63 }
  64
  65 void
  66 queue_advance_head(struct queue *q, struct buffer *next)
  67 {
  68     assert(q->n);
  69     assert(q->head);
  70     q->head = next;
  71     if (q->head == NULL) {
  72         q->tail = NULL;
  73     }
  74     q->n--;
  75 }
  76
  77 void
  78 queue_push_tail(struct queue *q, struct buffer *b)
  79 {
  80     check_queue(q);
  81
  82     b->next = NULL;
  83     if (q->n++) {
  84         q->tail->next = b;
  85     } else {
  86         q->head = b;
  87     }
  88     q->tail = b;
  89
  90     check_queue(q);
  91 }
  92
  93 static void
  94 check_queue(struct queue *q)
  95 {
  96 #if 0
  97     struct buffer *iter;
  98     size_t n;
  99
 100     assert(q->n == 0
 101            ? q->head == NULL && q->tail == NULL
 102            : q->head != NULL && q->tail != NULL);
 103
 104     n = 0;
 105     for (iter = q->head; iter != NULL; iter = iter->next) {
 106         n++;
 107         assert((iter->next != NULL) == (iter != q->tail));
 108     }
 109     assert(n == q->n);
 110 #endif
 111 }