HttpServerConnection: drop the now superfluous CheckStream method

This commit is contained in:
Yonas Habteab 2025-07-14 18:00:51 +02:00
parent 739ee5dc56
commit 57533a65b8
2 changed files with 0 additions and 20 deletions

View File

@ -65,7 +65,6 @@ void HttpServerConnection::Start()
IoEngine::SpawnCoroutine(m_IoStrand, [this, keepAlive](asio::yield_context yc) { ProcessMessages(yc); }); IoEngine::SpawnCoroutine(m_IoStrand, [this, keepAlive](asio::yield_context yc) { ProcessMessages(yc); });
IoEngine::SpawnCoroutine(m_IoStrand, [this, keepAlive](asio::yield_context yc) { CheckLiveness(yc); }); IoEngine::SpawnCoroutine(m_IoStrand, [this, keepAlive](asio::yield_context yc) { CheckLiveness(yc); });
IoEngine::SpawnCoroutine(m_IoStrand, [this, keepAlive](asio::yield_context yc) { CheckStream(yc); });
} }
/** /**
@ -513,21 +512,3 @@ void HttpServerConnection::CheckLiveness(boost::asio::yield_context yc)
} }
} }
} }
/**
* Checks if the @c AsioTlsStream has been closed to shut down the connection.
*
* @param yc The yield context for the coroutine of this function
*/
void HttpServerConnection::CheckStream(boost::asio::yield_context yc)
{
using wait_type = boost::asio::socket_base::wait_type;
while(!m_ShuttingDown){
boost::system::error_code ec;
m_Stream->async_fill(yc[ec]);
if (ec) {
Disconnect(yc);
}
}
}

View File

@ -49,7 +49,6 @@ private:
void ProcessMessages(boost::asio::yield_context yc); void ProcessMessages(boost::asio::yield_context yc);
void CheckLiveness(boost::asio::yield_context yc); void CheckLiveness(boost::asio::yield_context yc);
void CheckStream(boost::asio::yield_context yc);
}; };
} }