Function decoder_stream_decode

src/decoder/Thread.cxx:112–151

* Decode a stream with the given decoder plugin. * * Caller holds DecoderControl::mutex. */

 * Caller holds DecoderControl::mutex.
 */
static DecodeResult
decoder_stream_decode(const DecoderPlugin &plugin,
		      DecoderBridge &bridge,
		      InputStream &input_stream,
		      std::unique_lock<Mutex> &lock)
{
	assert(plugin.stream_decode != nullptr);
	assert(bridge.stream_tag == nullptr);
	assert(bridge.decoder_tag == nullptr);
	assert(input_stream.IsReady());
	assert(bridge.dc.state == DecoderState::START);

	FmtDebug(decoder_thread_domain, "probing plugin {}", plugin.name);

	if (bridge.dc.command == DecoderCommand::STOP)
		return DecodeResult::STOP;

	/* rewind the stream, so each plugin gets a fresh start */
	try {
		input_stream.Rewind(lock);
	} catch (...) {
	}

	{
		const ScopeUnlock unlock{lock};

		FmtThreadName("decoder:{}", plugin.name);

		plugin.StreamDecode(bridge, input_stream);

		SetThreadName("decoder");
	}

	assert(bridge.dc.state == DecoderState::START ||
	       bridge.dc.state == DecoderState::DECODE);

	return bridge.dc.state == DecoderState::START
	       ? DecodeResult::UNRECOGNIZED_FILE
	       : DecodeResult::SUCCESS;
}

/**
 * Decode a file with the given decoder plugin.