summaryrefslogtreecommitdiff
path: root/src/lib/j2k_encoder.cc
diff options
context:
space:
mode:
authorCarl Hetherington <cth@carlh.net>2018-04-13 01:09:10 +0100
committerCarl Hetherington <cth@carlh.net>2018-04-13 01:09:10 +0100
commit9106e6ed551b13e1b7c7ee2088d54ce0ae430bcf (patch)
treeb147172aa469005bdd7c80095abcd4493e9c92e1 /src/lib/j2k_encoder.cc
parent6dd6676700f830547e9e7c38781f09de5f2a1a00 (diff)
Tidy up to use one list of servers.
Diffstat (limited to 'src/lib/j2k_encoder.cc')
-rw-r--r--src/lib/j2k_encoder.cc6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/lib/j2k_encoder.cc b/src/lib/j2k_encoder.cc
index bbd602dd0..e62e708cc 100644
--- a/src/lib/j2k_encoder.cc
+++ b/src/lib/j2k_encoder.cc
@@ -412,7 +412,11 @@ J2KEncoder::servers_list_changed ()
}
}
- BOOST_FOREACH (EncodeServerDescription i, EncodeServerFinder::instance()->good_servers ()) {
+ BOOST_FOREACH (EncodeServerDescription i, EncodeServerFinder::instance()->servers()) {
+ if (!i.current_link_version()) {
+ continue;
+ }
+
LOG_GENERAL (N_("Adding %1 worker threads for remote %2"), i.threads(), i.host_name ());
for (int j = 0; j < i.threads(); ++j) {
_threads.push_back (new boost::thread (boost::bind (&J2KEncoder::encoder_thread, this, i)));