| 2211 | } |
| 2212 | |
| 2213 | inline void stream_line_reader::append(char c) { |
| 2214 | if (fixed_buffer_used_size_ < fixed_buffer_size_ - 1) { |
| 2215 | fixed_buffer_[fixed_buffer_used_size_++] = c; |
| 2216 | fixed_buffer_[fixed_buffer_used_size_] = '\0'; |
| 2217 | } else { |
| 2218 | if (glowable_buffer_.empty()) { |
| 2219 | assert(fixed_buffer_[fixed_buffer_used_size_] == '\0'); |
| 2220 | glowable_buffer_.assign(fixed_buffer_, fixed_buffer_used_size_); |
| 2221 | } |
| 2222 | glowable_buffer_ += c; |
| 2223 | } |
| 2224 | } |
| 2225 | |
| 2226 | inline int close_socket(socket_t sock) { |
| 2227 | #ifdef _WIN32 |