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

wrap async calls with strand

Browse Source
This commit is contained in:
Peter Thorson
2012-03-19 15:53:49 -06:00
parent 9d221c6a84
commit 59efe59466
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/roles/server.hpp
View File

@@ -237,7 +237,7 @@ private:
template <class endpoint>
void server<endpoint>::listen(const boost::asio::ip::tcp::endpoint& e) {
boost::unique_lock<boost::recursive_mutex> lock(m_endpoint.get_lock());
boost::unique_lock<boost::recursive_mutex> lock(m_endpoint.m_lock);
if (m_state != IDLE) {
throw exception("listen called from invalid state.");
@@ -275,7 +275,7 @@ void server<endpoint>::listen(const std::string &host, const std::string &servic
template <class endpoint>
void server<endpoint>::start_accept() {
boost::lock_guard<boost::recursive_mutex> lock(m_endpoint.get_lock());
boost::lock_guard<boost::recursive_mutex> lock(m_endpoint.m_lock);
connection_ptr con = m_endpoint.create_connection();
@@ -305,7 +305,7 @@ template <class endpoint>
void server<endpoint>::handle_accept(connection_ptr con,
const boost::system::error_code& error)
{
boost::lock_guard<boost::recursive_mutex> lock(m_endpoint.get_lock());
boost::lock_guard<boost::recursive_mutex> lock(m_endpoint.m_lock);
if (error) {
if (error == boost::system::errc::too_many_files_open) {
@@ -405,12 +405,12 @@ void server<endpoint>::connection<connection_type>::async_init() {
m_connection.get_socket(),
m_connection.buffer(),
"\r\n\r\n",
boost::bind(
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
)
))
);
}