diff options
| author | Carl Hetherington <cth@carlh.net> | 2026-02-16 01:29:52 +0100 |
|---|---|---|
| committer | Carl Hetherington <cth@carlh.net> | 2026-02-16 01:29:55 +0100 |
| commit | 5fe634b3f2899ec519ee6261a2a506133b84d099 (patch) | |
| tree | 5f16abc727b8ac5b2b1f31eaeb028c4c9688c1a1 /src/lib/j2k_encoder.cc | |
| parent | 2a466391f79f3cab480f83ac0228049f050a54c6 (diff) | |
Rename CPU J2K -> OpenJPEG J2K so we can differentiate from Kakadu.
Diffstat (limited to 'src/lib/j2k_encoder.cc')
| -rw-r--r-- | src/lib/j2k_encoder.cc | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/src/lib/j2k_encoder.cc b/src/lib/j2k_encoder.cc index bc4030531..e3e3c881b 100644 --- a/src/lib/j2k_encoder.cc +++ b/src/lib/j2k_encoder.cc @@ -31,11 +31,11 @@ #include "encode_server_description.h" #include "encode_server_finder.h" #include "film.h" -#include "cpu_j2k_encoder_thread.h" #ifdef DCPOMATIC_GROK #include "grok/context.h" #include "grok_j2k_encoder_thread.h" #endif +#include "openjpeg_j2k_encoder_thread.h" #include "remote_j2k_encoder_thread.h" #include "j2k_encoder.h" #include "log.h" @@ -140,11 +140,11 @@ J2KEncoder::servers_list_changed() auto const grok_enable = false; #endif - auto const cpu = (grok_enable || config->only_servers_encode()) ? 0 : config->master_encoding_threads(); + auto const openjpeg = (grok_enable || config->only_servers_encode()) ? 0 : config->master_encoding_threads(); auto const gpu = grok_enable ? config->master_encoding_threads() : 0; LOG_GENERAL("Thread counts from: grok={}, only_servers={}, master={}", grok_enable ? "yes" : "no", config->only_servers_encode() ? "yes" : "no", config->master_encoding_threads()); - remake_threads(cpu, gpu, EncodeServerFinder::instance()->servers()); + remake_threads(openjpeg, gpu, EncodeServerFinder::instance()->servers()); } @@ -362,14 +362,14 @@ J2KEncoder::terminate_threads() void -J2KEncoder::remake_threads(int cpu, int gpu, list<EncodeServerDescription> servers) +J2KEncoder::remake_threads(int openjpeg, int gpu, list<EncodeServerDescription> servers) { - LOG_GENERAL("Making threads: CPU={}, GPU={}, Remote={}", cpu, gpu, servers.size()); - if ((cpu + gpu + servers.size()) == 0) { + LOG_GENERAL("Making threads: OpenJPEG={}, GPU={}, Remote={}", openjpeg, gpu, servers.size()); + if ((openjpeg + gpu + servers.size()) == 0) { /* Make at least one thread, even if all else fails. Maybe we are configured * for "only servers encode" but no servers have been registered yet. */ - ++cpu; + ++openjpeg; } boost::mutex::scoped_lock lm(_threads_mutex); @@ -388,21 +388,21 @@ J2KEncoder::remake_threads(int cpu, int gpu, list<EncodeServerDescription> serve }; - /* CPU */ + /* OpenJPEG (on CPU) */ - auto const is_cpu_thread = [](shared_ptr<J2KEncoderThread> thread) { - return static_cast<bool>(dynamic_pointer_cast<CPUJ2KEncoderThread>(thread)); + auto const is_openjpeg_thread = [](shared_ptr<J2KEncoderThread> thread) { + return static_cast<bool>(dynamic_pointer_cast<OpenJPEGJ2KEncoderThread>(thread)); }; - auto const current_cpu_threads = std::count_if(_threads.begin(), _threads.end(), is_cpu_thread); + auto const current_openjpeg_threads = std::count_if(_threads.begin(), _threads.end(), is_openjpeg_thread); - for (auto i = current_cpu_threads; i < cpu; ++i) { - auto thread = make_shared<CPUJ2KEncoderThread>(*this); + for (auto i = current_openjpeg_threads; i < openjpeg; ++i) { + auto thread = make_shared<OpenJPEGJ2KEncoderThread>(*this); thread->start(); _threads.push_back(thread); } - remove_threads(cpu, current_cpu_threads, is_cpu_thread); + remove_threads(openjpeg, current_openjpeg_threads, is_openjpeg_thread); #ifdef DCPOMATIC_GROK /* GPU */ |
