ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2026-06-03 00:36:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

temporary fix for outgoing frame corruption issue #references 179

Browse Source
This commit is contained in:
Peter Thorson
2013-01-31 08:41:37 -06:00
parent 4928f84feb
commit 6925a68f95
2 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
websocketpp/connection.hpp
View File

@@ -167,6 +167,7 @@ public:
, m_internal_state(session::internal_state::USER_INIT)
, m_msg_manager(new con_msg_manager_type())
, m_send_buffer_size(0)
, m_temp_lock(false)
, m_is_server(is_server)
, m_alog(alog)
, m_elog(elog)
@@ -860,6 +861,7 @@ private:
* Lock m_write_lock
*/
std::vector<transport::buffer> m_send_buffer;
bool m_temp_lock;
// connection data
request_type m_request;

8
websocketpp/impl/connection_impl.hpp
View File

@@ -1032,6 +1032,12 @@ void connection<config>::write_frame() {
{
scoped_lock_type lock(m_write_lock);
if (m_temp_lock) {
return;
} else {
m_temp_lock = true;
}
if (m_send_queue.empty()) {
return;
}
@@ -1096,6 +1102,8 @@ void connection<config>::handle_write_frame(bool terminate,
scoped_lock_type lock(m_write_lock);
needs_writing = !m_send_queue.empty();
m_temp_lock = false;
}
if (needs_writing) {