fix warnings

This commit is contained in:
badaix 2019-10-23 12:04:57 +02:00
parent b6142967c7
commit 43bc4c26b8

View file

@ -46,7 +46,7 @@ void StreamSession::read_next()
boost::asio::bind_executor(strand_, [this, self](boost::system::error_code ec, std::size_t length) mutable { boost::asio::bind_executor(strand_, [this, self](boost::system::error_code ec, std::size_t length) mutable {
if (ec) if (ec)
{ {
LOG(ERROR) << "Error reading message header: " << ec.message() << "\n"; LOG(ERROR) << "Error reading message header of length " << length << ": " << ec.message() << "\n";
messageReceiver_->onDisconnect(this); messageReceiver_->onDisconnect(this);
return; return;
} }
@ -75,7 +75,7 @@ void StreamSession::read_next()
boost::asio::bind_executor(strand_, [this, self](boost::system::error_code ec, std::size_t length) mutable { boost::asio::bind_executor(strand_, [this, self](boost::system::error_code ec, std::size_t length) mutable {
if (ec) if (ec)
{ {
LOG(ERROR) << "Error reading message body: " << ec.message() << "\n"; LOG(ERROR) << "Error reading message body of length " << length << ": " << ec.message() << "\n";
messageReceiver_->onDisconnect(this); messageReceiver_->onDisconnect(this);
return; return;
} }
@ -131,7 +131,7 @@ void StreamSession::send_next()
messages_.pop_front(); messages_.pop_front();
if (ec) if (ec)
{ {
LOG(ERROR) << "StreamSession write error: " << ec.message() << "\n"; LOG(ERROR) << "StreamSession write error (msg lenght: " << length << "): " << ec.message() << "\n";
messageReceiver_->onDisconnect(this); messageReceiver_->onDisconnect(this);
return; return;
} }
@ -158,7 +158,7 @@ void StreamSession::sendAsync(shared_const_buffer const_buf, bool send_now)
} }
void StreamSession::sendAsync(msg::message_ptr message, bool sendNow) void StreamSession::sendAsync(msg::message_ptr message, bool send_now)
{ {
if (!message) if (!message)
return; return;
@ -167,7 +167,7 @@ void StreamSession::sendAsync(msg::message_ptr message, bool sendNow)
message->sent = t; message->sent = t;
std::ostringstream oss; std::ostringstream oss;
message->serialize(oss); message->serialize(oss);
sendAsync(shared_const_buffer(oss.str())); sendAsync(shared_const_buffer(oss.str()), send_now);
} }