diff options
author | Laurent Bercot <ska-skaware@skarnet.org> | 2024-07-05 09:07:33 +0000 |
---|---|---|
committer | Laurent Bercot <ska@appnovation.com> | 2024-07-05 09:07:33 +0000 |
commit | cc57ca6ab355784f4901009184ea95a9f915ef21 (patch) | |
tree | 31df5b84abb3f336f52622def7ab86bb41a8127f /src/libstddjb/mininetstring_read.c | |
parent | 1640b8835a1f25d41e9768eacbeae295604b3144 (diff) | |
download | skalibs-cc57ca6ab355784f4901009184ea95a9f915ef21.tar.xz |
Prepare for 2.14.3.0; add mininetstring_read, cplz.h
Signed-off-by: Laurent Bercot <ska@appnovation.com>
Diffstat (limited to 'src/libstddjb/mininetstring_read.c')
-rw-r--r-- | src/libstddjb/mininetstring_read.c | 45 |
1 files changed, 45 insertions, 0 deletions
diff --git a/src/libstddjb/mininetstring_read.c b/src/libstddjb/mininetstring_read.c new file mode 100644 index 0000000..b4439c9 --- /dev/null +++ b/src/libstddjb/mininetstring_read.c @@ -0,0 +1,45 @@ +/* ISC license. */ + +#include <stdint.h> +#include <errno.h> + +#include <skalibs/allreadwrite.h> +#include <skalibs/stralloc.h> +#include <skalibs/netstring.h> + +int mininetstring_read (int fd, stralloc *sa, uint32_t *w) +{ + if (!*w) + { + unsigned char pack[2] ; + switch (fd_read(fd, (char *)pack, 2)) + { + case -1 : return -1 ; + case 0 : return 0 ; + case 1 : *w = ((uint32_t)pack[0] << 8) | (1U << 31) ; break ; + case 2 : *w = ((uint32_t)pack[0] << 8) | (uint32_t)pack[1] | (1U << 30) ; break ; + default : return (errno = EDOM, -1) ; + } + } + if (*w & (1U << 31)) + { + unsigned char c ; + switch (fd_read(fd, (char *)&c, 1)) + { + case -1 : return -1 ; + case 0 : return (errno = EPIPE, -1) ; + case 1 : *w |= (uint32_t)c | (1U << 30) ; *w &= ~(1U << 31) ; break ; + default : return (errno = EDOM, -1) ; + } + } + if (*w & (1U << 30)) + { + if (!stralloc_readyplus(sa, *w & ~(1U << 30))) return -1 ; + *w &= ~(1U << 30) ; + } + { + size_t r = allread(fd, sa->s + sa->len, *w) ; + sa->len += r ; *w -= r ; + } + return *w ? -1 : 1 ; +} |