mirror of
https://github.com/XRPLF/rippled.git
synced 2026-04-29 15:37:57 +00:00
ugh tabs
This commit is contained in:
@@ -206,7 +206,7 @@ protected:
|
||||
*/
|
||||
void init(init_handler callback) {
|
||||
if (m_alog.static_test(log::alevel::devel)) {
|
||||
m_alog.write(log::alevel::devel,"asio connection init");
|
||||
m_alog.write(log::alevel::devel,"asio connection init");
|
||||
}
|
||||
|
||||
socket_con_type::pre_init(
|
||||
@@ -221,7 +221,7 @@ protected:
|
||||
|
||||
void handle_pre_init(init_handler callback, const lib::error_code& ec) {
|
||||
if (m_alog.static_test(log::alevel::devel)) {
|
||||
m_alog.write(log::alevel::devel,"asio connection handle pre_init");
|
||||
m_alog.write(log::alevel::devel,"asio connection handle pre_init");
|
||||
}
|
||||
|
||||
if (m_tcp_init_handler) {
|
||||
@@ -241,10 +241,10 @@ protected:
|
||||
}
|
||||
|
||||
void post_init(init_handler callback) {
|
||||
if (m_alog.static_test(log::alevel::devel)) {
|
||||
m_alog.write(log::alevel::devel,"asio connection post_init");
|
||||
if (m_alog.static_test(log::alevel::devel)) {
|
||||
m_alog.write(log::alevel::devel,"asio connection post_init");
|
||||
}
|
||||
|
||||
|
||||
socket_con_type::post_init(
|
||||
lib::bind(
|
||||
&type::handle_post_init,
|
||||
@@ -257,7 +257,7 @@ protected:
|
||||
|
||||
void handle_post_init(init_handler callback, const lib::error_code& ec) {
|
||||
if (m_alog.static_test(log::alevel::devel)) {
|
||||
m_alog.write(log::alevel::devel,"asio connection handle_post_init");
|
||||
m_alog.write(log::alevel::devel,"asio connection handle_post_init");
|
||||
}
|
||||
|
||||
callback(ec);
|
||||
@@ -265,7 +265,7 @@ protected:
|
||||
|
||||
void proxy_write(init_handler callback) {
|
||||
if (m_alog.static_test(log::alevel::devel)) {
|
||||
m_alog.write(log::alevel::devel,"asio connection proxy_write");
|
||||
m_alog.write(log::alevel::devel,"asio connection proxy_write");
|
||||
}
|
||||
|
||||
if (!m_proxy_data) {
|
||||
@@ -298,7 +298,7 @@ protected:
|
||||
boost::system::error_code& ec)
|
||||
{
|
||||
if (m_alog.static_test(log::alevel::devel)) {
|
||||
m_alog.write(log::alevel::devel,"asio connection handle_proxy_write");
|
||||
m_alog.write(log::alevel::devel,"asio connection handle_proxy_write");
|
||||
}
|
||||
|
||||
m_bufs.clear();
|
||||
@@ -314,7 +314,7 @@ protected:
|
||||
|
||||
void proxy_read(init_handler callback) {
|
||||
if (m_alog.static_test(log::alevel::devel)) {
|
||||
m_alog.write(log::alevel::devel,"asio connection proxy_read");
|
||||
m_alog.write(log::alevel::devel,"asio connection proxy_read");
|
||||
}
|
||||
|
||||
if (!m_proxy_data) {
|
||||
@@ -342,7 +342,7 @@ protected:
|
||||
boost::system::error_code& ec, size_t bytes_transferred)
|
||||
{
|
||||
if (m_alog.static_test(log::alevel::devel)) {
|
||||
m_alog.write(log::alevel::devel,"asio connection handle_proxy_read");
|
||||
m_alog.write(log::alevel::devel,"asio connection handle_proxy_read");
|
||||
}
|
||||
|
||||
if (ec) {
|
||||
|
||||
@@ -394,7 +394,7 @@ protected:
|
||||
|
||||
if (m_alog->static_test(log::alevel::devel)) {
|
||||
m_alog->write(log::alevel::devel,
|
||||
"starting async DNS resolve for "+host+":"+port);
|
||||
"starting async DNS resolve for "+host+":"+port);
|
||||
}
|
||||
|
||||
m_resolver->async_resolve(
|
||||
@@ -426,16 +426,16 @@ protected:
|
||||
}
|
||||
|
||||
if (m_alog->static_test(log::alevel::devel)) {
|
||||
std::stringstream s;
|
||||
|
||||
s << "Async DNS resolve successful. Results: ";
|
||||
|
||||
boost::asio::ip::tcp::resolver::iterator it, end;
|
||||
|
||||
for (it = iterator; it != end; ++it) {
|
||||
s << (*it).endpoint() << " ";
|
||||
}
|
||||
|
||||
std::stringstream s;
|
||||
|
||||
s << "Async DNS resolve successful. Results: ";
|
||||
|
||||
boost::asio::ip::tcp::resolver::iterator it, end;
|
||||
|
||||
for (it = iterator; it != end; ++it) {
|
||||
s << (*it).endpoint() << " ";
|
||||
}
|
||||
|
||||
m_alog->write(log::alevel::devel,s.str());
|
||||
}
|
||||
|
||||
@@ -469,7 +469,7 @@ protected:
|
||||
|
||||
if (m_alog->static_test(log::alevel::devel)) {
|
||||
m_alog->write(log::alevel::devel,
|
||||
"Async connect to "+tcon->get_remote_endpoint()+" successful.");
|
||||
"Async connect to "+tcon->get_remote_endpoint()+" successful.");
|
||||
}
|
||||
|
||||
callback(tcon->get_handle(),lib::error_code());
|
||||
|
||||
Reference in New Issue
Block a user