test/mpsc_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 "mpsc_queue.h"
  22
  23 struct mpsc_queue queue;
  24
  25 #define SIZE    1024u
  26
  27 int main(int argc, char** argv)
  28 {
  29         uintptr_t i, val;
  30         int error;
  31
  32         (void)argc;
  33         (void)argv;
  34
  35         error = mpsc_queue_init(&queue);
  36         if (error)
  37                 return 1;
  38
  39         if (mpsc_queue_dequeue(&queue))
  40                 return 1;
  41
  42         for (i = 1; i < SIZE; i++) {
  43                 error = mpsc_queue_enqueue(&queue, (void*)i);
  44                 if (error)
  45                         return 1;
  46         }
  47
  48         for (i = 1; i < SIZE; i++) {
  49                 val = (uintptr_t)mpsc_queue_dequeue(&queue);
  50                 if (val != i)
  51                         return 1;
  52         }
  53
  54         if (mpsc_queue_dequeue(&queue))
  55                 return 1;
  56
  57         for (i = 1; i < SIZE; i++) {
  58                 mpsc_queue_enqueue(&queue,(void*)i);
  59                 if ((uintptr_t)mpsc_queue_dequeue(&queue) != i)
  60                         return 1;
  61         }
  62
  63         if (mpsc_queue_dequeue(&queue))
  64                 return 1;
  65
  66         mpsc_queue_destroy(&queue);
  67         error = mpsc_queue_init(&queue);
  68         if (error)
  69                 return 1;
  70
  71         for (i = 1; i < SIZE; i++) {
  72                 error = mpsc_queue_enqueue(&queue, (void*)i);
  73                 if (error)
  74                         return 1;
  75         }
  76
  77         mpsc_queue_destroy(&queue);
  78         error = mpsc_queue_init(&queue);
  79         if (error)
  80                 return 1;
  81
  82         if (mpsc_queue_dequeue(&queue))
  83                 return 1;
  84
  85         mpsc_queue_destroy(&queue);
  86 }