stdlib/msgqueue.ajla

   1 {*
   2  * Copyright (C) 2024 Mikulas Patocka
   3  *
   4  * This file is part of Ajla.
   5  *
   6  * Ajla is free software: you can redistribute it and/or modify it under the
   7  * terms of the GNU General Public License as published by the Free Software
   8  * Foundation, either version 3 of the License, or (at your option) any later
   9  * version.
  10  *
  11  * Ajla is distributed in the hope that it will be useful, but WITHOUT ANY
  12  * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
  13  * A PARTICULAR PURPOSE. See the GNU General Public License for more details.
  14  *
  15  * You should have received a copy of the GNU General Public License along with
  16  * Ajla. If not, see <https://www.gnu.org/licenses/>.
  17  *}
  18
  19 unit msgqueue;
  20
  21 uses io;
  22
  23 type msgqueue(t : type);
  24
  25 fn msgqueue_new(w : world, t : type) : (world, msgqueue(t));
  26 fn msgqueue_send(w : world, t : type, q : msgqueue(t), tag : int, v : t) : world;
  27 fn msgqueue_replace(w : world, t : type, q : msgqueue(t), tag : int, v : t) : world;
  28 fn msgqueue_receive(w : world, t : type, q : msgqueue(t)) : (world, int, t);
  29 fn msgqueue_receive_tag(w : world, t : type, q : msgqueue(t), tag : int) : (world, int, t);
  30 fn msgqueue_receive_nonblock(w : world, t : type, q : msgqueue(t)) : (world, int, t);
  31 fn msgqueue_receive_tag_nonblock(w : world, t : type, q : msgqueue(t), tag : int) : (world, int, t);
  32 fn msgqueue_peek_nonblock(w : world, t : type, q : msgqueue(t)) : (world, int, t);
  33 fn msgqueue_peek_tag_nonblock(w : world, t : type, q : msgqueue(t), tag : int) : (world, int, t);
  34 fn msgqueue_wait~lazy(w : world, t : type, q : msgqueue(t)) : unit_type;
  35 fn msgqueue_is_nonempty(w : world, t : type, q : msgqueue(t)) : bool;
  36 fn msgqueue_any~lazy(w : world, t1 t2 : type, q1 : msgqueue(t1), q2 : msgqueue(t2)) : bool;
  37
  38 implementation
  39
  40 type msgqueue(t : type) := internal_type;
  41
  42 fn msgqueue_new(w : world, t : type) : (world, msgqueue(t))
  43 [
  44         var w2 : world;
  45         var q : msgqueue(t);
  46         pcode IO IO_MsgQueue_New 2 1 0 =w2 =q w;
  47         return w2, q;
  48 ]
  49
  50 fn msgqueue_send(w : world, t : type, q : msgqueue(t), tag : int, v : t) : world
  51 [
  52         var w2 : world;
  53         pcode IO IO_MsgQueue_Send 1 4 1 =w2 w q tag v 0;
  54         return w2;
  55 ]
  56
  57 fn msgqueue_replace(w : world, t : type, q : msgqueue(t), tag : int, v : t) : world
  58 [
  59         var w2 : world;
  60         pcode IO IO_MsgQueue_Send 1 4 1 =w2 w q tag v 1;
  61         return w2;
  62 ]
  63
  64 fn msgqueue_receive(w : world, t : type, q : msgqueue(t)) : (world, int, t)
  65 [
  66         var w2 : world;
  67         var tg : int;
  68         var v : t;
  69         pcode IO IO_MsgQueue_Receive 3 2 1 =w2 =tg =v w q 0;
  70         return w2, tg, v;
  71 ]
  72
  73 fn msgqueue_receive_tag(w : world, t : type, q : msgqueue(t), tag : int) : (world, int, t)
  74 [
  75         var w2 : world;
  76         var tg : int;
  77         var v : t;
  78         pcode IO IO_MsgQueue_Receive 3 3 1 =w2 =tg =v w q tag 1;
  79         return w2, tg, v;
  80 ]
  81
  82 fn msgqueue_receive_nonblock(w : world, t : type, q : msgqueue(t)) : (world, int, t)
  83 [
  84         var w2 : world;
  85         var tg : int;
  86         var v : t;
  87         pcode IO IO_MsgQueue_Receive 3 2 1 =w2 =tg =v w q 2;
  88         return w2, tg, v;
  89 ]
  90
  91 fn msgqueue_receive_tag_nonblock(w : world, t : type, q : msgqueue(t), tag : int) : (world, int, t)
  92 [
  93         var w2 : world;
  94         var tg : int;
  95         var v : t;
  96         pcode IO IO_MsgQueue_Receive 3 3 1 =w2 =tg =v w q tag 3;
  97         return w2, tg, v;
  98 ]
  99
 100 fn msgqueue_peek_nonblock(w : world, t : type, q : msgqueue(t)) : (world, int, t)
 101 [
 102         var w2 : world;
 103         var tg : int;
 104         var v : t;
 105         pcode IO IO_MsgQueue_Receive 3 2 1 =w2 =tg =v w q 6;
 106         return w2, tg, v;
 107 ]
 108
 109 fn msgqueue_peek_tag_nonblock(w : world, t : type, q : msgqueue(t), tag : int) : (world, int, t)
 110 [
 111         var w2 : world;
 112         var tg : int;
 113         var v : t;
 114         pcode IO IO_MsgQueue_Receive 3 3 1 =w2 =tg =v w q tag 7;
 115         return w2, tg, v;
 116 ]
 117
 118 fn msgqueue_wait~lazy(w : world, t : type, q : msgqueue(t)) : unit_type
 119 [
 120         pcode IO IO_MsgQueue_Wait 0 2 0 w q;
 121         return unit_value;
 122 ]
 123
 124 fn msgqueue_is_nonempty(w : world, t : type, q : msgqueue(t)) : bool
 125 [
 126         var e : bool;
 127         pcode IO IO_MsgQueue_Is_Nonempty 1 2 0 =e w q;
 128         return e;
 129 ]
 130
 131 fn msgqueue_any~lazy(implicit w : world, t1 t2 : type, q1 : msgqueue(t1), q2 : msgqueue(t2)) : bool
 132 [
 133         var wait1 := msgqueue_wait(t1, q1);
 134         var wait2 := msgqueue_wait(t2, q2);
 135         return any(wait1, wait2);
 136 ]