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

updates output_stream member variable name to be consistent with WebSocket++ style

Browse Source
This commit is contained in:
Peter Thorson
2013-03-17 18:24:07 -05:00
parent f7c36c46e9
commit 727328cc9a
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
websocketpp/transport/iostream/connection.hpp
View File

@@ -72,7 +72,7 @@ public:
void register_ostream(std::ostream* o) {
// TODO: lock transport state?
scoped_lock_type lock(m_read_mutex);
output_stream = o;
m_output_stream = o;
}
friend std::istream& operator>> (std::istream &in, type &t) {
@@ -130,14 +130,14 @@ protected:
m_alog.write(log::alevel::devel,"iostream_con async_write");
// TODO: lock transport state?
if (!output_stream) {
if (!m_output_stream) {
handler(make_error_code(error::output_stream_required));
return;
}
output_stream->write(buf,len);
m_output_stream->write(buf,len);
if (output_stream->bad()) {
if (m_output_stream->bad()) {
handler(make_error_code(error::bad_stream));
} else {
handler(lib::error_code());
@@ -152,16 +152,16 @@ protected:
m_alog.write(log::alevel::devel,"iostream_con async_write buffer list");
// TODO: lock transport state?
if (!output_stream) {
if (!m_output_stream) {
handler(make_error_code(error::output_stream_required));
return;
}
std::vector<buffer>::const_iterator it;
for (it = bufs.begin(); it != bufs.end(); it++) {
output_stream->write((*it).buf,(*it).len);
m_output_stream->write((*it).buf,(*it).len);
if (output_stream->bad()) {
if (m_output_stream->bad()) {
handler(make_error_code(error::bad_stream));
} else {
handler(lib::error_code());
@@ -225,7 +225,7 @@ private:
size_t m_cursor;
// transport resources
std::ostream* output_stream;
std::ostream* m_output_stream;
connection_hdl m_connection_hdl;
bool m_reading;