summaryrefslogtreecommitdiff
path: root/src/lib/encoder.cc
diff options
context:
space:
mode:
authorCarl Hetherington <cth@carlh.net>2015-12-06 19:59:47 +0000
committerCarl Hetherington <cth@carlh.net>2015-12-11 11:56:22 +0000
commit17df947ac256397311a11894062070f8069c7e75 (patch)
treebb84d231ae31cab2e7e4d6546c62fcd88150b4d8 /src/lib/encoder.cc
parentd499ec381ea5fbbae954531be9d66c9cc723c230 (diff)
Rename Server -> EncodeServer, ServerFinder -> EncodeServerFinder, ServerDescription -> EncodeServerDescription.
Diffstat (limited to 'src/lib/encoder.cc')
-rw-r--r--src/lib/encoder.cc15
1 files changed, 7 insertions, 8 deletions
diff --git a/src/lib/encoder.cc b/src/lib/encoder.cc
index bfb96f41b..8ba794a8e 100644
--- a/src/lib/encoder.cc
+++ b/src/lib/encoder.cc
@@ -27,13 +27,12 @@
#include "log.h"
#include "config.h"
#include "dcp_video.h"
-#include "server.h"
#include "cross.h"
#include "writer.h"
-#include "server_finder.h"
+#include "encode_server_finder.h"
#include "player.h"
#include "player_video.h"
-#include "server_description.h"
+#include "encode_server_description.h"
#include "compose.hpp"
#include <libcxml/cxml.h>
#include <boost/foreach.hpp>
@@ -79,8 +78,8 @@ Encoder::~Encoder ()
void
Encoder::begin ()
{
- if (!ServerFinder::instance()->disabled ()) {
- _server_found_connection = ServerFinder::instance()->ServersListChanged.connect (boost::bind (&Encoder::servers_list_changed, this));
+ if (!EncodeServerFinder::instance()->disabled ()) {
+ _server_found_connection = EncodeServerFinder::instance()->ServersListChanged.connect (boost::bind (&Encoder::servers_list_changed, this));
}
}
@@ -277,7 +276,7 @@ Encoder::terminate_threads ()
}
void
-Encoder::encoder_thread (optional<ServerDescription> server)
+Encoder::encoder_thread (optional<EncodeServerDescription> server)
try
{
if (server) {
@@ -384,11 +383,11 @@ Encoder::servers_list_changed ()
if (!Config::instance()->only_servers_encode ()) {
for (int i = 0; i < Config::instance()->num_local_encoding_threads (); ++i) {
- _threads.push_back (new boost::thread (boost::bind (&Encoder::encoder_thread, this, optional<ServerDescription> ())));
+ _threads.push_back (new boost::thread (boost::bind (&Encoder::encoder_thread, this, optional<EncodeServerDescription> ())));
}
}
- BOOST_FOREACH (ServerDescription i, ServerFinder::instance()->servers ()) {
+ BOOST_FOREACH (EncodeServerDescription i, EncodeServerFinder::instance()->servers ()) {
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 (&Encoder::encoder_thread, this, i)));