/*
- Copyright (C) 2012-2014 Carl Hetherington <cth@carlh.net>
+ Copyright (C) 2012-2015 Carl Hetherington <cth@carlh.net>
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
for (int i = 0; i < d.threads(); ++i) {
_threads.push_back (new boost::thread (boost::bind (&Encoder::encoder_thread, this, d)));
}
+
+ _writer->set_encoder_threads (_threads.size ());
}
void
_threads.push_back (new boost::thread (boost::bind (&Encoder::encoder_thread, this, optional<ServerDescription> ())));
}
+ _writer->set_encoder_threads (_threads.size ());
+
if (!ServerFinder::instance()->disabled ()) {
_server_found_connection = ServerFinder::instance()->connect (boost::bind (&Encoder::server_found, this, _1));
}