diff --git a/server/control_session_ws.cpp b/server/control_session_ws.cpp index 960d8f7e..5234e03a 100644 --- a/server/control_session_ws.cpp +++ b/server/control_session_ws.cpp @@ -130,8 +130,6 @@ void ControlSessionWebsocket::do_read_ws() void ControlSessionWebsocket::on_read_ws(beast::error_code ec, std::size_t bytes_transferred) { - boost::ignore_unused(bytes_transferred); - // This indicates that the session was closed if (ec == websocket::error::closed) return; diff --git a/server/stream_session_tcp.cpp b/server/stream_session_tcp.cpp index 4e84abfd..37751b06 100644 --- a/server/stream_session_tcp.cpp +++ b/server/stream_session_tcp.cpp @@ -123,8 +123,8 @@ void StreamSessionTcp::read_next() return; } - tv t; - baseMessage_.received = t; + tv now; + baseMessage_.received = now; if (messageReceiver_ != nullptr) messageReceiver_->onMessageReceived(this, baseMessage_, buffer_.data()); read_next(); diff --git a/server/stream_session_ws.cpp b/server/stream_session_ws.cpp index dc234432..a723aaad 100644 --- a/server/stream_session_ws.cpp +++ b/server/stream_session_ws.cpp @@ -122,8 +122,8 @@ void StreamSessionWebsocket::do_read_ws() void StreamSessionWebsocket::on_read_ws(beast::error_code ec, std::size_t bytes_transferred) { + tv now; LOG(DEBUG, LOG_TAG) << "on_read_ws, ec: " << ec << ", bytes_transferred: " << bytes_transferred << "\n"; - boost::ignore_unused(bytes_transferred); // This indicates that the session was closed if (ec == websocket::error::closed) @@ -144,8 +144,7 @@ void StreamSessionWebsocket::on_read_ws(beast::error_code ec, std::size_t bytes_ LOG(DEBUG, LOG_TAG) << "getNextMessage: " << baseMessage_.type << ", size: " << baseMessage_.size << ", id: " << baseMessage_.id << ", refers: " << baseMessage_.refersTo << "\n"; - tv t; - baseMessage_.received = t; + baseMessage_.received = now; if (messageReceiver_ != nullptr) messageReceiver_->onMessageReceived(this, baseMessage_, data + base_msg_size_);