From 9dafc75bb51c0f350330277a2e96b04f5a1c73b3 Mon Sep 17 00:00:00 2001 From: Laurent Bercot Date: Fri, 10 Jan 2020 10:35:55 +0000 Subject: Add pub library and daemon --- src/libskabus/skabus_pub_message_get.c | 32 ++++++++++++++++++++++++++++++++ 1 file changed, 32 insertions(+) create mode 100644 src/libskabus/skabus_pub_message_get.c (limited to 'src/libskabus/skabus_pub_message_get.c') diff --git a/src/libskabus/skabus_pub_message_get.c b/src/libskabus/skabus_pub_message_get.c new file mode 100644 index 0000000..aabefaa --- /dev/null +++ b/src/libskabus/skabus_pub_message_get.c @@ -0,0 +1,32 @@ +/* ISC license. */ + +#include + +#include +#include + +#include +#include "skabus-pub-internal.h" + +size_t skabus_pub_message_get (skabus_pub_t *a, skabus_pub_msginfo_t *info, int *fd, int *fds) +{ + size_t n = genalloc_len(skabus_pub_cltinfo_t, &a->info) ; + skabus_pub_cltinfo_t *p = genalloc_s(skabus_pub_cltinfo_t, &a->info) + a->head ; + if (!n) return 0 ; + *info = p->msginfo ; + *fd = p->fd ; + if (p->nfds) + { + for (size_t i = 0 ; i < p->nfds ; i++) fds[i] = p->fds[i] ; + alloc_free(p->fds) ; + } + + if (++a->head == n || a->head > SKABUS_HEAD_MAX) + { + n -= a->head ; + memmove(a->info.s, a->info.s + a->head * sizeof(skabus_pub_cltinfo_t), n * sizeof(skabus_pub_cltinfo_t)) ; + genalloc_setlen(skabus_pub_cltinfo_t, &a->info, n) ; + a->head = 0 ; + } + return 1 + n - a->head ; +} -- cgit v1.3.1