mirror of
https://github.com/badaix/snapcast.git
synced 2025-04-30 10:47:12 +02:00
82 lines
2 KiB
C++
82 lines
2 KiB
C++
#include "controlServer.h"
|
|
#include "common/timeMsg.h"
|
|
#include <iostream>
|
|
|
|
|
|
ControlServer::ControlServer(unsigned short port) : port_(port), headerChunk(NULL), sampleFormat(NULL)
|
|
{
|
|
}
|
|
|
|
|
|
void ControlServer::onMessageReceived(SocketConnection* connection, const BaseMessage& baseMessage, char* buffer)
|
|
{
|
|
// cout << "onMessageReceived: " << baseMessage.type << ", size: " << baseMessage.size << ", sent: " << baseMessage.sent.sec << "," << baseMessage.sent.usec << ", recv: " << baseMessage.received.sec << "," << baseMessage.received.usec << "\n";
|
|
if (baseMessage.type == message_type::timemsg)
|
|
{
|
|
TimeMsg timeMsg;
|
|
timeMsg.deserialize(baseMessage, buffer);
|
|
// timeMsg.latency = (timeMsg.received.sec - timeMsg.sent.sec) * 1000000 + (timeMsg.received.usec - timeMsg.sent.usec);
|
|
timeMsg.latency = (timeMsg.received.sec - timeMsg.sent.sec) + (timeMsg.received.usec - timeMsg.sent.usec) / 1000000.;
|
|
// tv diff = timeMsg.received - timeMsg.sent;
|
|
// cout << "Latency: " << diff.sec << "." << diff.usec << "\n";
|
|
timeMsg.refersTo = timeMsg.id;
|
|
connection->send(&timeMsg);
|
|
}
|
|
}
|
|
|
|
|
|
void ControlServer::acceptor()
|
|
{
|
|
tcp::acceptor a(io_service_, tcp::endpoint(tcp::v4(), port_));
|
|
for (;;)
|
|
{
|
|
socket_ptr sock(new tcp::socket(io_service_));
|
|
a.accept(*sock);
|
|
cout << "ControlServer::NewConnection: " << sock->remote_endpoint().address().to_string() << "\n";
|
|
ServerConnection* session = new ServerConnection(this, sock);
|
|
sessions.insert(shared_ptr<ServerConnection>(session));
|
|
session->start();
|
|
session->send(serverSettings);
|
|
session->send(sampleFormat);
|
|
session->send(headerChunk);
|
|
}
|
|
}
|
|
|
|
|
|
void ControlServer::start()
|
|
{
|
|
acceptThread = new thread(&ControlServer::acceptor, this);
|
|
}
|
|
|
|
|
|
void ControlServer::stop()
|
|
{
|
|
// acceptThread->join();
|
|
}
|
|
|
|
|
|
void ControlServer::setHeader(HeaderMessage* header)
|
|
{
|
|
if (header)
|
|
headerChunk = header;
|
|
}
|
|
|
|
|
|
void ControlServer::setFormat(SampleFormat* format)
|
|
{
|
|
if (format)
|
|
sampleFormat = format;
|
|
}
|
|
|
|
|
|
|
|
void ControlServer::setServerSettings(ServerSettings* settings)
|
|
{
|
|
if (settings)
|
|
serverSettings = settings;
|
|
}
|
|
|
|
|
|
|
|
|
|
|