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

Adjusts ordering guarantees on message sending references #149

Browse Source
This commit is contained in:
Peter Thorson
2012-10-12 07:56:05 -05:00
parent 52ce31bea4
commit 1c8ba9954e
1 changed files with 36 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

71
src/connection.hpp
View File

@@ -272,13 +272,13 @@ public:
control->set_payload(payload);
m_processor->prepare_frame(control);
m_endpoint.endpoint_base::m_io_service.post(
m_strand.wrap(boost::bind(
&type::write_message,
type::shared_from_this(),
control
))
);
// Using strand post here rather than ioservice.post(strand.wrap)
// to ensure that messages are sent in order
m_strand.post(boost::bind(
&type::write_message,
type::shared_from_this(),
control
));
}
/// Send Pong
@@ -306,13 +306,13 @@ public:
control->set_payload(payload);
m_processor->prepare_frame(control);
m_endpoint.endpoint_base::m_io_service.post(
m_strand.wrap(boost::bind(
&type::write_message,
type::shared_from_this(),
control
))
);
// Using strand post here rather than ioservice.post(strand.wrap)
// to ensure that messages are sent in order
m_strand.post(boost::bind(
&type::write_message,
type::shared_from_this(),
control
));
}
/// Return send buffer size (payload bytes)
@@ -1081,13 +1081,13 @@ public:
msg->reset(frame::opcode::CLOSE);
m_processor->prepare_close_frame(msg,m_local_close_code,m_local_close_reason);
m_endpoint.endpoint_base::m_io_service.post(
m_strand.wrap(boost::bind(
&type::write_message,
type::shared_from_this(),
msg
))
);
// Using strand post here rather than ioservice.post(strand.wrap)
// to ensure that messages are sent in order
m_strand.post(boost::bind(
&type::write_message,
type::shared_from_this(),
msg
));
}
/// send an acknowledgement close frame
@@ -1145,13 +1145,14 @@ public:
msg->reset(frame::opcode::CLOSE);
m_processor->prepare_close_frame(msg,m_local_close_code,m_local_close_reason);
m_endpoint.endpoint_base::m_io_service.post(
m_strand.wrap(boost::bind(
&type::write_message,
type::shared_from_this(),
msg
))
);
// Using strand post here rather than ioservice.post(strand.wrap)
// to ensure that messages are sent in order
m_strand.post(boost::bind(
&type::write_message,
type::shared_from_this(),
msg
));
//m_write_state = INTURRUPT;
}
@@ -1589,13 +1590,13 @@ void connection<endpoint,role,socket>::send(message::data_ptr msg) {
m_processor->prepare_frame(msg);
m_endpoint.endpoint_base::m_io_service.post(
m_strand.wrap(boost::bind(
&type::write_message,
type::shared_from_this(),
msg
))
);
// Using strand post here rather than ioservice.post(strand.wrap)
// to ensure that messages are sent in order
m_strand.post(boost::bind(
&type::write_message,
type::shared_from_this(),
msg
));
}
} // namespace websocketpp