ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2026-04-29 15:37:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

adds WS handshake timeout

Browse Source
This commit is contained in:
Peter Thorson
2012-04-13 07:36:00 -05:00
parent 419178dead
commit 7875f03f76
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/roles/server.hpp
View File

@@ -426,6 +426,10 @@ void server<endpoint>::connection<connection_type>::async_init() {
boost::lock_guard<boost::recursive_mutex> lock(m_connection.m_lock);
m_connection.get_handler()->on_handshake_init(m_connection.shared_from_this());
// TODO: make this value configurable
m_connection.register_timeout(5000,"Timeout on WebSocket handshake");
boost::asio::async_read_until(
m_connection.get_socket(),
m_connection.buffer(),
@@ -620,8 +624,6 @@ template <class connection_type>
void server<endpoint>::connection<connection_type>::handle_write_response(
const boost::system::error_code& error)
{
// TODO: handshake timer
if (error) {
m_endpoint.m_elog->at(log::elevel::RERROR)
<< "Network error writing handshake respons. code: " << error
@@ -646,11 +648,13 @@ void server<endpoint>::connection<connection_type>::handle_write_response(
return;
}
m_connection.cancel_timeout();
log_open_result();
m_connection.m_state = session::state::OPEN;
m_endpoint.get_handler()->on_open(m_connection.shared_from_this());
m_connection.get_handler()->on_open(m_connection.shared_from_this());
get_io_service().post(
m_connection.m_strand.wrap(boost::bind(