From 24cac01e4718061ebc19757fe4567620b43d9275 Mon Sep 17 00:00:00 2001 From: JoelKatz Date: Wed, 23 Jan 2013 16:53:31 -0800 Subject: [PATCH] Rollback. --- src/cpp/websocketpp/src/roles/server.hpp | 70 +++++------------------- 1 file changed, 13 insertions(+), 57 deletions(-) diff --git a/src/cpp/websocketpp/src/roles/server.hpp b/src/cpp/websocketpp/src/roles/server.hpp index 48b4906b0..270a478a0 100644 --- a/src/cpp/websocketpp/src/roles/server.hpp +++ b/src/cpp/websocketpp/src/roles/server.hpp @@ -53,32 +53,6 @@ namespace websocketpp { -typedef boost::asio::buffers_iterator bufIterator; - -static std::pair match_header(bufIterator begin, bufIterator end) -{ - // Do we have a complete HTTP request - const std::string header_match = "\r\n\r\n"; - bufIterator it = std::search(begin, end, header_match.begin(), header_match.end()); - if (it != end) - return std::make_pair(it, true); - - // If we don't have a flash policy request, we're done - const std::string flash_match = ""; - it = std::search(begin, end, flash_match.begin(), flash_match.end()); - if (it == end) - return std::make_pair(end, false); - - // If we have a line ending before the flash policy request, treat as http - const std::string eol_match = "\r\n"; - bufIterator it2 = std::search(begin, end, eol_match.begin(), eol_match.end()); - if ((it2 != end) || (it < it2)) - return std::make_pair(end, false); - - // Treat as flash policy request - return std::make_pair(it, true); -} - // Forward declarations template struct endpoint_traits; @@ -539,36 +513,18 @@ void server::connection::async_init() { // TODO: make this value configurable m_connection.register_timeout(5000,fail::status::TIMEOUT_WS, "Timeout on WebSocket handshake"); - - if (m_connection.isSecure()) - { - boost::asio::async_read_until( - m_connection.SSLSocket(), - m_connection.buffer(), -// match_header, - "\r\n\r\n", - m_connection.get_strand().wrap(boost::bind( - &type::handle_read_request, - m_connection.shared_from_this(), - boost::asio::placeholders::error, - boost::asio::placeholders::bytes_transferred - )) - ); - } - else - { - boost::asio::async_read_until( - m_connection.PlainSocket(), - m_connection.buffer(), - match_header, - m_connection.get_strand().wrap(boost::bind( - &type::handle_read_request, - m_connection.shared_from_this(), - boost::asio::placeholders::error, - boost::asio::placeholders::bytes_transferred - )) - ); - } + + boost::asio::async_read_until( + m_connection.get_socket(), + m_connection.buffer(), + "\r\n\r\n", + m_connection.get_strand().wrap(boost::bind( + &type::handle_read_request, + m_connection.shared_from_this(), + boost::asio::placeholders::error, + boost::asio::placeholders::bytes_transferred + )) + ); } /// processes the response from an async read for an HTTP header @@ -840,7 +796,7 @@ void server::connection::write_response() { m_endpoint.m_alog->at(log::alevel::DEBUG_HANDSHAKE) << raw << log::endl; - boost::asio::async_write( // FIXME + boost::asio::async_write( m_connection.get_socket(), //boost::asio::buffer(raw), buffer,