1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
/* ISC license. */
#include <string.h>
#include <errno.h>
#include <skalibs/types.h>
#include <skalibs/stralloc.h>
#include <skalibs/unix-timed.h>
#include <tipidee/util.h>
#include <skalibs/posixishard.h>
int tipidee_util_chunked_read (buffer *b, stralloc *sa, size_t maxlen, tain const *deadline, tain *stamp)
{
char line[512] ;
for (;;)
{
size_t chunklen, pos, w = 0 ;
ssize_t r = timed_getlnmax(b, line, 512, &w, '\n', deadline, stamp) ;
if (r < 0) return 0 ;
if (!r) return (errno = EPIPE, 0) ;
pos = size_scan(line, &chunklen) ;
if (!pos) return (errno = EPROTO, 0) ;
if (!memchr("\r\n; \t", line[pos], 5)) return (errno = EPROTO, 0) ;
if (!chunklen) break ;
if (sa->len + chunklen > maxlen) return (errno = EMSGSIZE, 0) ;
if (!stralloc_readyplus(sa, chunklen)) return 0 ;
if (buffer_timed_get(b, sa->s + sa->len, chunklen, deadline, stamp) < chunklen) return 0 ;
sa->len += chunklen ;
}
for (;;)
{
size_t w = 0 ;
ssize_t r = timed_getlnmax(b, line, 512, &w, '\n', deadline, stamp) ;
if (r < 0) return 0 ;
if (!r) return (errno = EPIPE, 0) ;
if (w == 1 || (w == 2 && line[0] == '\r')) break ;
}
return 1 ;
}
|
