src/lib/remote_j2k_encoder_thread.h

   1 #include "encode_server_description.h"
   2 #include "j2k_sync_encoder_thread.h"
   3
   4
   5 class RemoteJ2KEncoderThread : public J2KSyncEncoderThread
   6 {
   7 public:
   8         RemoteJ2KEncoderThread(J2KEncoder& encoder, EncodeServerDescription server);
   9
  10         void log_thread_start() const override;
  11         std::shared_ptr<dcp::ArrayData> encode(DCPVideo const& frame) override;
  12
  13         EncodeServerDescription server() const {
  14                 return _server;
  15         }
  16
  17 private:
  18         EncodeServerDescription _server;
  19         /** Number of seconds that we currently wait between attempts to connect to the server */
  20         int _remote_backoff = 0;
  21 };