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

complete handshake timeout references #226

Browse Source
This commit is contained in:
Peter Thorson
2013-06-08 18:32:06 -05:00
parent f35918ce6e
commit c228f70a9f
1 changed files with 16 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
websocketpp/impl/connection_impl.hpp
View File

@@ -623,7 +623,14 @@ template <typename config>
void connection<config>::read_handshake(size_t num_bytes) {
m_alog.write(log::alevel::devel,"connection read");
// start timer
m_handshake_timer = transport_con_type::set_timer(
config::timeout_open_handshake,
lib::bind(
&type::handle_open_handshake_timeout,
type::shared_from_this(),
lib::placeholders::_1
)
);
transport_con_type::async_read_at_least(
num_bytes,
@@ -652,6 +659,14 @@ void connection<config>::handle_read_handshake(const lib::error_code& ec,
);
if (ec) {
if (ec == transport::error::eof) {
// we expect to get eof if the connection is closed already
if (m_state == session::state::closed) {
m_alog.write(log::alevel::devel,"got eof from closed con");
return;
}
}
std::stringstream s;
s << "error in handle_read_handshake: "<< ec.message();
m_elog.write(log::elevel::fatal,s.str());