summaryrefslogtreecommitdiff
path: root/src/lib/resampler_manager.h
blob: fb10d96b661aefaf6d3a95d7d7c0cdf6c2b3fa71 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
#include "audio_content.h"
#include "dcpomatic_time.h"
#include <boost/noncopyable.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/weak_ptr.hpp>
#include <vector>


class AudioContent;
class AudioDecoder;
class AudioStream;
class Resampler;


class ResamplerManager
{
public:
	ResamplerManager (std::weak_ptr<const Film> film)
		: _film (film)
	{}

	ResamplerManager (ResamplerManager const&) = delete;
	ResamplerManager& operator= (ResamplerManager const&) = delete;

	void add (dcpomatic::DCPTime start, dcpomatic::DCPTime end, std::shared_ptr<AudioContent> content, std::shared_ptr<AudioDecoder> decoder);
	std::shared_ptr<Resampler> get (AudioDecoder* decoder, AudioStreamPtr stream, bool fast);

	void flush (AudioDecoder* decoder)

private:
	friend struct resampler_manager_setup_test;

	class Group
	{
	public:
		Group (dcpomatic::DCPTime start_, dcpomatic::DCPTime end_, std::shared_ptr<AudioContent> content, std::shared_ptr<AudioDecoder> decoder)
			: start(start_)
			, end(end_)
		{
			contents.push_back (content);
			decoders.push_back (decoder);
			resamplers.resize (content->streams().size());
		}

		dcpomatic::DCPTime start;
		dcpomatic::DCPTime end;
		std::vector<std::shared_ptr<AudioContent>> contents;
		std::vector<std::shared_ptr<AudioDecoder>> decoders;
		std::vector<std::shared_ptr<Resampler>> resamplers;
	};

	bool can_share (Group const& a, Group const& b) const;
	void coalesce ();
	bool coalesce_pass ();

	std::weak_ptr<const Film> _film;
	std::vector<Group> _groups;
};