From 7ae80340d621d6add95f6c7d9e5e7a0e921f0b42 Mon Sep 17 00:00:00 2001 From: Laurent Bercot Date: Sat, 25 Nov 2017 14:15:08 +0000 Subject: Finish skabus_rpc doc, add missing functions --- src/libskabus/skabus_rpc_qlist_ack.c | 15 +++++++++++++++ 1 file changed, 15 insertions(+) create mode 100644 src/libskabus/skabus_rpc_qlist_ack.c (limited to 'src/libskabus/skabus_rpc_qlist_ack.c') diff --git a/src/libskabus/skabus_rpc_qlist_ack.c b/src/libskabus/skabus_rpc_qlist_ack.c new file mode 100644 index 0000000..894f530 --- /dev/null +++ b/src/libskabus/skabus_rpc_qlist_ack.c @@ -0,0 +1,15 @@ +/* ISC license. */ + +#include +#include +#include +#include + +void skabus_rpc_qlist_ack (skabus_rpc_t *a, size_t n) +{ + uint64_t len = genalloc_len(uint64_t, &a->qlist) ; + uint64_t *p = genalloc_s(uint64_t, &a->qlist) ; + if (n > len) n = len ; + memmove(p, p + n * sizeof(uint64_t), (len - n) * sizeof(uint64_t)) ; + genalloc_setlen(uint64_t, &a->qlist, len - n) ; +} -- cgit v1.3.1