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

enqueue command messages at the end

Browse source
This commit is contained in:
badaix 2018-07-05 22:50:53 +02:00
parent cab4fd8d84
commit dff17ca2fc
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
server/streamServer.cpp
View file

@ -220,7 +220,7 @@ void StreamServer::ProcessRequest(const jsonrpcpp::request_ptr request, jsonrpcp
GroupPtr group = Config::instance().getGroupFromClient(clientInfo); GroupPtr group = Config::instance().getGroupFromClient(clientInfo);
serverSettings->setMuted(clientInfo->config.volume.muted || group->muted); serverSettings->setMuted(clientInfo->config.volume.muted || group->muted);
serverSettings->setLatency(clientInfo->config.latency); serverSettings->setLatency(clientInfo->config.latency);
session->sendAsync(serverSettings, true); session->sendAsync(serverSettings);
} }
} }
} }
@ -256,7 +256,7 @@ void StreamServer::ProcessRequest(const jsonrpcpp::request_ptr request, jsonrpcp
GroupPtr group = Config::instance().getGroupFromClient(client); GroupPtr group = Config::instance().getGroupFromClient(client);
serverSettings->setMuted(client->config.volume.muted || group->muted); serverSettings->setMuted(client->config.volume.muted || group->muted);
serverSettings->setLatency(client->config.latency); serverSettings->setLatency(client->config.latency);
session->sendAsync(serverSettings, true); session->sendAsync(serverSettings);
} }
} }
@ -513,7 +513,7 @@ void StreamServer::onMessageReceived(StreamSession* streamSession, const msg::Ba
timeMsg->refersTo = timeMsg->id; timeMsg->refersTo = timeMsg->id;
timeMsg->latency = timeMsg->received - timeMsg->sent; timeMsg->latency = timeMsg->received - timeMsg->sent;
// LOG(INFO) << "Latency sec: " << timeMsg.latency.sec << ", usec: " << timeMsg.latency.usec << ", refers to: " << timeMsg.refersTo << "\n"; // LOG(INFO) << "Latency sec: " << timeMsg.latency.sec << ", usec: " << timeMsg.latency.usec << ", refers to: " << timeMsg.refersTo << "\n";
streamSession->sendAsync(timeMsg, true); streamSession->sendAsync(timeMsg);
// refresh streamSession state // refresh streamSession state
ClientInfoPtr client = Config::instance().getClientInfo(streamSession->clientId); ClientInfoPtr client = Config::instance().getClientInfo(streamSession->clientId);