test/spmc_queue_s.c

   1 /*
   2         libnbds
   3         Copyright (C) 2014 Paweł Dziepak
   4
   5         This program is free software: you can redistribute it and/or modify
   6         it under the terms of the GNU General Public License as published by
   7         the Free Software Foundation, either version 3 of the License, or
   8         (at your option) any later version.
   9
  10         This program is distributed in the hope that it will be useful,
  11         but WITHOUT ANY WARRANTY; without even the implied warranty of
  12         MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13         GNU General Public License for more details.
  14
  15         You should have received a copy of the GNU General Public License
  16         along with this program.  If not, see <http://www.gnu.org/licenses/>.
  17 */
  18
  19 #include <stdint.h>
  20
  21 #include "spmc_queue.h"
  22
  23 struct spmc_queue queue;
  24
  25 #define SIZE    1024u
  26
  27 int main(int argc, char** argv)
  28 {
  29         uintptr_t i;
  30         int error;
  31
  32         (void)argc;
  33         (void)argv;
  34
  35         error = spmc_queue_init(&queue);
  36         if (error)
  37                 return 1;
  38
  39         if (spmc_queue_dequeue(&queue))
  40                 return 1;
  41
  42         for (i = 1; i < SIZE; i++) {
  43                 error = spmc_queue_enqueue(&queue, (void*)i);
  44                 if (error)
  45                         return 1;
  46         }
  47
  48         for (i = 1; i < SIZE; i++) {
  49                 if ((uintptr_t)spmc_queue_dequeue(&queue) != i)
  50                         return 1;
  51         }
  52
  53         if (spmc_queue_dequeue(&queue))
  54                 return 1;
  55
  56         for (i = 1; i < SIZE; i++) {
  57                 spmc_queue_enqueue(&queue, (void*)i);
  58                 if ((uintptr_t)spmc_queue_dequeue(&queue) != i)
  59                         return 1;
  60         }
  61
  62         if (spmc_queue_dequeue(&queue))
  63                 return 1;
  64
  65         spmc_queue_destroy(&queue);
  66         error = spmc_queue_init(&queue);
  67         if (error)
  68                 return 1;
  69
  70         for (i = 1; i < SIZE; i++) {
  71                 error = spmc_queue_enqueue(&queue, (void*)i);
  72                 if (error)
  73                         return 1;
  74         }
  75
  76         spmc_queue_destroy(&queue);
  77         error = spmc_queue_init(&queue);
  78         if (error)
  79                 return 1;
  80
  81         if (spmc_queue_dequeue(&queue))
  82                 return 1;
  83
  84         spmc_queue_destroy(&queue);
  85 }