/*
    Copyright (C) 2024 Carl Hetherington <cth@carlh.net>

    This file is part of DCP-o-matic.

    DCP-o-matic is free software; you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation; either version 2 of the License, or
    (at your option) any later version.

    DCP-o-matic is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with DCP-o-matic.  If not, see <http://www.gnu.org/licenses/>.

*/


#include "lib/config.h"
#include "lib/cross.h"
#include "lib/image.h"
#include "lib/j2k_encoder.h"
#include "lib/player_video.h"
#include "lib/raw_image_proxy.h"
#include "lib/writer.h"
#include "test.h"
extern "C" {
#include <libavutil/pixfmt.h>
}
#include <boost/test/unit_test.hpp>


using std::make_shared;
using std::weak_ptr;
using boost::optional;


BOOST_AUTO_TEST_CASE(j2k_encoder_deadlock_test)
{
	ConfigRestorer cr;

	auto film = new_test_film2("j2k_encoder_deadlock_test");

	auto constexpr threads = 4;

	/* Don't call ::start() on this Writer, so it can never write anything */
	Writer writer(film, {});
	writer.set_encoder_threads(threads);

	/* We want to test the case where the writer queue fills, and this can't happen unless there
	 * are enough encoding threads (each of which will end up waiting for the writer to empty,
	 * which will never happen).
	 */
	Config::instance()->set_master_encoding_threads(threads);
	J2KEncoder encoder(film, writer);
	encoder.begin();

	/* The queue will be full when we write another frame when there are already
	 * more than (threads * frames_in_memory_multiplier [i.e. 3])
	 * in the queue, so to fill the queue we must add threads * 3 + 2.
	 */
	for (int i = 0; i < (threads * 3) + 2; ++i) {
		auto image = make_shared<Image>(AV_PIX_FMT_RGB24, dcp::Size(1998, 1080), Image::Alignment::PADDED);
		auto image_proxy = make_shared<RawImageProxy>(image);
		encoder.encode(
			std::make_shared<PlayerVideo>(
				image_proxy,
				Crop(),
				optional<double>(),
				dcp::Size(1998, 1080),
				dcp::Size(1998, 1080),
				Eyes::BOTH,
				Part::WHOLE,
				optional<ColourConversion>(),
				VideoRange::VIDEO,
				weak_ptr<Content>(),
				optional<Frame>(),
				false
				),
			{}
			);
	}

	dcpomatic_sleep_seconds(10);
}