sent += txbuf.sputn(timestr, strlen(timestr));
}
- if (parser.is_keep_alive()) {
+ if (parser.keep_alive()) {
constexpr char CONN_KEEP_ALIVE[] = "Connection: Keep-Alive\r\n";
sent += txbuf.sputn(CONN_KEEP_ALIVE, sizeof(CONN_KEEP_ALIVE) - 1);
} else {
class Connection {
RGWProcessEnv& env;
- boost::asio::strand strand;
+ boost::asio::io_service::strand strand;
tcp::socket socket;
// references are bound to callbacks for async operations. if a callback
process_request(env.store, env.rest, &req, env.uri_prefix,
*env.auth_registry, &client, env.olog);
- if (parser->is_keep_alive()) {
+ if (parser->keep_alive()) {
// parse any unread bytes from the previous message (in case we replied
// before reading the entire body) before reading the next
discard_unread_message();