From c455e7b67d2e55e6ed03e3449203d4e307f5a7dd Mon Sep 17 00:00:00 2001 From: Bruce Hill Date: Fri, 13 Sep 2024 20:18:08 -0400 Subject: Rename builtins/ -> stdlib/ --- stdlib/channels.h | 28 ++++++++++++++++++++++++++++ 1 file changed, 28 insertions(+) create mode 100644 stdlib/channels.h (limited to 'stdlib/channels.h') diff --git a/stdlib/channels.h b/stdlib/channels.h new file mode 100644 index 00000000..8deb0569 --- /dev/null +++ b/stdlib/channels.h @@ -0,0 +1,28 @@ +#pragma once + +// Functions that operate on channels (thread-safe arrays) + +#include + +#include "datatypes.h" +#include "types.h" +#include "util.h" + +Channel_t *Channel$new(Int_t max_size); +void Channel$give(Channel_t *channel, const void *item, bool front, int64_t padded_item_size); +#define Channel$give_value(channel, item, front, padded_item_size) \ + ({ __typeof(item) _item = item; Channel$give(channel, &_item, front, padded_item_size); }) +void Channel$give_all(Channel_t *channel, Array_t to_give, bool front, int64_t padded_item_size); +void Channel$get(Channel_t *channel, void *out, bool front, int64_t item_size, int64_t padded_item_size); +#define Channel$get_value(channel, front, t, padded_item_size) \ + ({ t _val; Channel$get(channel, &_val, front, sizeof(t), padded_item_size); _val; }) +void Channel$peek(Channel_t *channel, void *out, bool front, int64_t item_size); +#define Channel$peek_value(channel, front, t) ({ t _val; Channel$peek(channel, &_val, front, sizeof(t)); _val; }) +void Channel$clear(Channel_t *channel); +Array_t Channel$view(Channel_t *channel); +PUREFUNC uint64_t Channel$hash(Channel_t **channel, const TypeInfo *type); +PUREFUNC int32_t Channel$compare(Channel_t **x, Channel_t **y, const TypeInfo *type); +PUREFUNC bool Channel$equal(Channel_t **x, Channel_t **y, const TypeInfo *type); +Text_t Channel$as_text(Channel_t **channel, bool colorize, const TypeInfo *type); + +// vim: ts=4 sw=0 et cino=L2,l1,(0,W4,m1,\:0 -- cgit v1.2.3