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

Fix crash during shutdown

Browse source 
In case there are multiple PosixStreams with the same name, the server crashed during shutdown
This commit is contained in:
badaix 2020-01-06 18:50:57 +01:00
parent e12fa3fc7d
commit 062e46060c
4 changed files with 9 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
server/stream_server.cpp
View file

@ -799,10 +799,11 @@ void StreamServer::start()
{
try
{
controlServer_.reset(new ControlServer(io_context_, settings_.tcp, settings_.http, this));
controlServer_ = std::make_unique<ControlServer>(io_context_, settings_.tcp, settings_.http, this);
controlServer_->start();
streamManager_.reset(new StreamManager(this, io_context_, settings_.stream.sampleFormat, settings_.stream.codec, settings_.stream.streamChunkMs));
streamManager_ =
std::make_unique<StreamManager>(this, io_context_, settings_.stream.sampleFormat, settings_.stream.codec, settings_.stream.streamChunkMs);
// throw SnapException("xxx");
for (const auto& streamUri : settings_.stream.pcmStreams)
{

2
server/stream_server.hpp
View file

@ -51,7 +51,7 @@ using session_ptr = std::shared_ptr<StreamSession>;
* Receives (via the MessageReceiver interface) and answers messages from the clients
* Forwards PCM data to the clients
*/
class StreamServer : public MessageReceiver, ControlMessageReceiver, PcmListener
class StreamServer : public MessageReceiver, public ControlMessageReceiver, public PcmListener
{
public:
StreamServer(boost::asio::io_context& io_context, const ServerSettings& serverSettings);

2
server/streamreader/posix_stream.cpp
View file

@ -68,7 +68,7 @@ void PosixStream::connect()
void PosixStream::do_disconnect()
{
if (stream_->is_open())
if (stream_ && stream_->is_open())
stream_->close();
}

7
server/streamreader/stream_manager.cpp
View file

@ -143,15 +143,16 @@ const PcmStreamPtr StreamManager::getStream(const std::string& id)
void StreamManager::start()
{
for (auto stream : streams_)
for (const auto& stream : streams_)
stream->start();
}
void StreamManager::stop()
{
for (auto stream : streams_)
stream->stop();
for (const auto& stream : streams_)
if (stream)
stream->stop();
}