boost::beast::http::request<boost::beast::http::string_body>& request,
ApiUser::Ptr& authenticatedUser,
boost::beast::http::response<boost::beast::http::string_body>& response,
- double& seen,
boost::asio::yield_context& yc
)
{
try {
CpuBoundWork handlingRequest (yc);
- Defer updateSeen ([&seen]() { seen = Utility::GetTime(); });
-
HttpHandler::ProcessRequest(stream, authenticatedUser, request, response, yc, hasStartedStreaming);
} catch (const std::exception& ex) {
if (hasStartedStreaming) {
beast::flat_buffer buf;
for (;;) {
+ m_Seen = Utility::GetTime();
+
http::parser<true, http::string_body> parser;
http::response<http::string_body> response;
m_Seen = std::numeric_limits<decltype(m_Seen)>::max();
- if (!ProcessRequest(*m_Stream, request, authenticatedUser, response, m_Seen, yc)) {
+ if (!ProcessRequest(*m_Stream, request, authenticatedUser, response, yc)) {
break;
}