1 files changed, 32 insertions, 0 deletions
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 <string.h>
+
+#include <skalibs/alloc.h>
+#include <skalibs/genalloc.h>
+
+#include <skabus/pub.h>
+#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 ;
+}