3pp-mirror/snapcast
1
0
Fork 0
mirror of https://github.com/badaix/snapcast.git synced 2025-04-28 17:57:05 +02:00
Code Issues Projects Releases Packages Wiki Activity

Improve time sync over websocket

Browse source
This commit is contained in:
badaix 2025-01-13 20:23:29 +01:00
parent 0fb90802b5
commit a638da0ff7
3 changed files with 4 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
server/control_session_ws.cpp
View file

@ -130,8 +130,6 @@ void ControlSessionWebsocket::do_read_ws()
void ControlSessionWebsocket::on_read_ws(beast::error_code ec, std::size_t bytes_transferred) 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 // This indicates that the session was closed
if (ec == websocket::error::closed) if (ec == websocket::error::closed)
return; return;

4
server/stream_session_tcp.cpp
View file

@ -123,8 +123,8 @@ void StreamSessionTcp::read_next()
return; return;
} }
tv t; tv now;
baseMessage_.received = t; baseMessage_.received = now;
if (messageReceiver_ != nullptr) if (messageReceiver_ != nullptr)
messageReceiver_->onMessageReceived(this, baseMessage_, buffer_.data()); messageReceiver_->onMessageReceived(this, baseMessage_, buffer_.data());
read_next(); read_next();

5
server/stream_session_ws.cpp
View file

@ -122,8 +122,8 @@ void StreamSessionWebsocket::do_read_ws()
void StreamSessionWebsocket::on_read_ws(beast::error_code ec, std::size_t bytes_transferred) 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"; 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 // This indicates that the session was closed
if (ec == websocket::error::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 LOG(DEBUG, LOG_TAG) << "getNextMessage: " << baseMessage_.type << ", size: " << baseMessage_.size << ", id: " << baseMessage_.id
<< ", refers: " << baseMessage_.refersTo << "\n"; << ", refers: " << baseMessage_.refersTo << "\n";
tv t; baseMessage_.received = now;
baseMessage_.received = t;
if (messageReceiver_ != nullptr) if (messageReceiver_ != nullptr)
messageReceiver_->onMessageReceived(this, baseMessage_, data + base_msg_size_); messageReceiver_->onMessageReceived(this, baseMessage_, data + base_msg_size_);