Method update

src/Stream.cpp:274–328

}

bool Stream::update(int clientID, bool start) {
	base::MutexLock lock(_mutex);

	// first time streaming?
	if (!_streaming && start) {
		switch (_streamingType) {
			case StreamingType::NONE:
				_streaming.reset(nullptr);
				SI_LOG_ERROR("Stream: %d, No streaming type found!!", _streamID);
				break;
			case StreamingType::HTTP:
				SI_LOG_DEBUG("Stream: %d, Found Streaming type: HTTP", _streamID);
				_streaming.reset(new output::StreamThreadHttp(*this));
				break;
			case StreamingType::RTSP_UNICAST:
				SI_LOG_DEBUG("Stream: %d, Found Streaming type: RTSP Unicast", _streamID);
				_streaming.reset(new output::StreamThreadRtp(*this));
				break;
			case StreamingType::RTSP_MULTICAST:
				SI_LOG_DEBUG("Stream: %d, Found Streaming type: RTSP Multicast", _streamID);
				_streaming.reset(new output::StreamThreadRtp(*this));
				break;
			case StreamingType::RTP_TCP:
				SI_LOG_DEBUG("Stream: %d, Found Streaming type: RTP/TCP", _streamID);
				_streaming.reset(new output::StreamThreadRtpTcp(*this));
				break;
			case StreamingType::FILE:
				SI_LOG_DEBUG("Stream: %d, Found Streaming type: FILE", _streamID);
				_streaming.reset(new output::StreamThreadTSWriter(*this, "test.ts"));
				break;
			default:
				_streaming.reset(nullptr);
				SI_LOG_ERROR("Stream: %d, Unknown streaming type!", _streamID);
		};
		if (!_streaming) {
			return false;
		}
	}
	// Get changed flag, before device update, because it resets it
	const bool changed = _device->hasDeviceDataChanged();

	if (!_device->update()) {
		return false;
	}

	// start or restart streaming again
	if (_streaming) {
		if (!_streamActive) {
			_streamActive = _streaming->startStreaming(clientID);
		} else if (changed) {
			_streaming->restartStreaming(clientID);
		}
	}
	return true;
}

bool Stream::teardown(int clientID) {
	base::MutexLock lock(_mutex);