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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
|
/* ISC license. */
#include <stdint.h>
#include <errno.h>
#include <skalibs/uint16.h>
#include <skalibs/uint32.h>
#include <skalibs/stralloc.h>
#include <skalibs/unix-timed.h>
#include <skalibs/lolstdio.h>
#include <tipidee/fcgi.h>
#include <skalibs/posixishard.h>
int tipidee_fcgi_read (tipidee_fcgi *fc, uint32_t *status, stralloc *sa, tain *stamp)
{
int stream ;
uint16_t u ;
char hdr[8] ;
if (buffer_timed_get(&fc->b, hdr, 8, &fc->deadline, stamp) < 8) return -1 ;
LOLDEBUG("reading a header: version is %hhu - type is %hhu", hdr[0], hdr[1]) ;
if (hdr[0] != 1) return (errno = EPROTO, -1) ;
uint16_unpack_big(hdr + 2, &u) ;
LOLDEBUG(" id is %hu, client's was %hu", u, fc->id) ;
if (u != fc->id) return (errno = EPROTO, -1) ;
uint16_unpack_big(hdr + 4, &u) ;
LOLDEBUG("payload length is %hu", u) ;
switch (hdr[1])
{
case FCGI_STDOUT : stream = 1 ; break ;
case FCGI_STDERR : stream = 2 ; break ;
case FCGI_END_REQUEST : stream = 0 ; break ;
default : return (errno = EPROTO, -1) ;
}
if (stream)
{
LOLDEBUG("stream is %d - reading %hu bytes", stream, u) ;
if (!stralloc_readyplus(sa, u)) return -1 ;
if (buffer_timed_get(&fc->b, sa->s + sa->len, u, &fc->deadline, stamp) < u) return -1 ;
sa->len += u ;
}
else
{
char endreq[8] ;
LOLDEBUG("end request detected, %hu bytes", u) ;
if (u != 8) return (errno = EPROTO, -1) ;
if (buffer_timed_get(&fc->b, endreq, 8, &fc->deadline, stamp) < 8) return -1 ;
switch (endreq[4])
{
case FCGI_REQUEST_COMPLETE : break ;
case FCGI_CANT_MPX_CONN : return (errno = ECONNREFUSED, -1) ;
case FCGI_OVERLOADED : return (errno = ENFILE, -1) ;
case FCGI_UNKNOWN_ROLE : return (errno = EAFNOSUPPORT, -1) ;
default : return (errno = EPROTO, 1) ;
}
uint32_unpack_big(endreq, status) ;
}
if (hdr[6])
{
char tmp[(uint8_t)hdr[6]] ;
LOLDEBUG("reading %hhu bytes of padding", (uint8_t)hdr[6]) ;
if (buffer_timed_get(&fc->b, tmp, (uint8_t)hdr[6], &fc->deadline, stamp) < (uint8_t)hdr[6]) return -1 ;
}
return stream ;
}
|
