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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
|
// file : web/apache/stream -*- C++ -*-
// copyright : Copyright (c) 2014-2017 Code Synthesis Ltd
// license : MIT; see accompanying LICENSE file
#ifndef WEB_APACHE_STREAM
#define WEB_APACHE_STREAM
#include <httpd.h> // request_rec, HTTP_*
#include <http_protocol.h> // ap_*()
#include <ios> // streamsize
#include <vector>
#include <cstring> // memmove(), size_t
#include <streambuf>
#include <algorithm> // min(), max()
#include <web/module> // invalid_request
namespace web
{
namespace apache
{
// Object of a class implementing this interface is intended for keeping
// the state of communication with the client.
//
struct stream_state
{
// Called by istreambuf functions when content is about to be read from
// the client. Can throw invalid_request or sequence_error.
//
virtual void
set_read_state () = 0;
// Called by ostreambuf functions when some content is about to be
// written to the client. Can throw invalid_request or sequence_error.
//
virtual void
set_write_state () = 0;
};
// Base class for ostreambuf and istreambuf. References request and
// communication state structures.
//
class rbuf: public std::streambuf
{
protected:
rbuf (request_rec* r, stream_state& s): rec_ (r), state_ (s) {}
protected:
request_rec* rec_;
stream_state& state_;
};
class ostreambuf: public rbuf
{
public:
ostreambuf (request_rec* r, stream_state& s): rbuf (r, s) {}
private:
virtual int_type
overflow (int_type c)
{
if (c != traits_type::eof ())
{
state_.set_write_state ();
char chr (c);
// Throwing allows to distinguish comm failure from other IO error
// conditions.
//
if (ap_rwrite (&chr, sizeof (chr), rec_) == -1)
throw invalid_request (HTTP_REQUEST_TIME_OUT);
}
return c;
}
virtual std::streamsize
xsputn (const char* s, std::streamsize num)
{
state_.set_write_state ();
if (ap_rwrite (s, num, rec_) < 0)
throw invalid_request (HTTP_REQUEST_TIME_OUT);
return num;
}
virtual int
sync ()
{
if (ap_rflush (rec_) < 0)
throw invalid_request (HTTP_REQUEST_TIME_OUT);
return 0;
}
};
class istreambuf: public rbuf
{
public:
istreambuf (request_rec* r,
stream_state& s,
size_t bufsize = 1024,
size_t putback = 1)
: rbuf (r, s),
bufsize_ (std::max (bufsize, (size_t)1)),
putback_ (std::min (putback, bufsize_ - 1)),
buf_ (bufsize_)
{
char* p (buf_.data () + putback_);
setg (p, p, p);
}
protected:
virtual int_type
underflow ()
{
if (gptr () < egptr ())
return traits_type::to_int_type (*gptr ());
state_.set_read_state ();
size_t pb (std::min ((size_t)(gptr () - eback ()), putback_));
std::memmove (buf_.data () + putback_ - pb, gptr () - pb, pb);
char* p (buf_.data () + putback_);
int rb (ap_get_client_block (rec_, p, bufsize_ - putback_));
if (rb == 0)
return traits_type::eof ();
if (rb < 0)
throw invalid_request (HTTP_REQUEST_TIME_OUT);
setg (p - pb, p, p + rb);
return traits_type::to_int_type (*gptr ());
}
protected:
size_t bufsize_;
size_t putback_;
std::vector<char> buf_;
};
}
}
#endif // WEB_APACHE_STREAM
|
