11 Buffered::Buffered(Base &b, unsigned s):
14 buf(new char[buf_size]),
19 mode = below.get_mode();
20 below.signal_flush_required.connect(sigc::mem_fun(this, &Buffered::flush));
35 void Buffered::set_block(bool)
37 throw logic_error("Buffered::set_block");
40 void Buffered::flush()
44 unsigned used = end-begin;
47 unsigned len = below.write(begin, used);
52 throw runtime_error("Couldn't flush all data");
55 else if(cur_op==M_READ)
59 unsigned Buffered::do_write(const char *data, unsigned size)
63 if(end+size<buf+buf_size)
65 // All data fits in buffer with whatever is already there
66 memcpy(end, data, size);
73 // Clear the buffer to make more room
78 // Put new data in the buffer to wait for more
79 memcpy(end, data, size);
85 // New data still doesn't fit in the buffer, so write it directly
86 return below.write(data, size);
90 unsigned Buffered::do_read(char *data, unsigned size)
96 // The request can be served from the buffer
97 memcpy(data, begin, size);
100 eof_flag = (below.eof() && begin==end);
106 // Give out whatever is in the buffer already
107 memcpy(data, begin, end-begin);
108 unsigned ret = end-begin;
116 // Fill the buffer and serve the rest of the request from it
117 unsigned len = below.read(end, buf+buf_size-end);
120 len = min(static_cast<unsigned>(end-begin), size);
121 memcpy(data, begin, len);
126 // Read the rest directly from the underlying object
127 ret += below.read(data, size);
129 eof_flag = (below.eof() && begin==end);
135 unsigned Buffered::put(char c)
145 return do_write(&c, 1);
148 bool Buffered::getline(std::string &line)
152 for(char *i=begin; i!=end; ++i)
155 line.assign(begin, i-begin);
160 return Base::getline(line);
168 return static_cast<unsigned char>(*begin++);
171 if(do_read(&c, 1)==0)
173 return static_cast<unsigned char>(c);
176 const Handle &Buffered::get_handle(Mode)
178 throw logic_error("Buffered::get_handle");
181 void Buffered::set_op(Mode op)
188 unsigned Buffered::get_current_size() const