src/lib/remote_j2k_encoder_thread.h


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

#include "encode_server_description.h"
#include "j2k_sync_encoder_thread.h"


class RemoteJ2KEncoderThread : public J2KSyncEncoderThread
{
public:
	RemoteJ2KEncoderThread(J2KEncoder& encoder, EncodeServerDescription server);

	void log_thread_start() const override;
	std::shared_ptr<dcp::ArrayData> encode(DCPVideo const& frame) override;

	EncodeServerDescription server() const {
		return _server;
	}

private:
	EncodeServerDescription _server;
	/** Number of seconds that we currently wait between attempts to connect to the server */
	int _remote_backoff = 0;
};