summaryrefslogtreecommitdiff
path: root/src/lib/j2k_encoder.cc
diff options
context:
space:
mode:
authorCarl Hetherington <cth@carlh.net>2026-02-16 01:29:52 +0100
committerCarl Hetherington <cth@carlh.net>2026-02-16 01:29:55 +0100
commit5fe634b3f2899ec519ee6261a2a506133b84d099 (patch)
tree5f16abc727b8ac5b2b1f31eaeb028c4c9688c1a1 /src/lib/j2k_encoder.cc
parent2a466391f79f3cab480f83ac0228049f050a54c6 (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.cc28
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 */