summaryrefslogtreecommitdiff
path: root/src/lib/encode_server_finder.cc
diff options
context:
space:
mode:
authorCarl Hetherington <cth@carlh.net>2022-02-24 19:47:19 +0100
committerCarl Hetherington <cth@carlh.net>2022-02-25 08:00:51 +0100
commit5ec4efca61906608e2e7a590b3d1c3f2b7078e81 (patch)
treeec5b593686870a321daea0ae02037917fb41a59b /src/lib/encode_server_finder.cc
parent76e2d6390305eeb59e4934ca66013b09b4a44dda (diff)
Fix some dubious thread/locking behaviour.
Previously we had server_found(), which took the lock and found a server, which it returned as an iterator into the list. However, it then released the lock, which I think left the iterator unprotected. This wasn't done in response to any particular bug, I just noticed it on the way past.
Diffstat (limited to 'src/lib/encode_server_finder.cc')
-rw-r--r--src/lib/encode_server_finder.cc41
1 files changed, 17 insertions, 24 deletions
diff --git a/src/lib/encode_server_finder.cc b/src/lib/encode_server_finder.cc
index 6faab0e63..6b288d70d 100644
--- a/src/lib/encode_server_finder.cc
+++ b/src/lib/encode_server_finder.cc
@@ -231,36 +231,29 @@ EncodeServerFinder::handle_accept (boost::system::error_code ec, shared_ptr<Sock
xml->read_string (s);
auto const ip = socket->socket().remote_endpoint().address().to_string();
- auto found = server_found (ip);
- if (found) {
- (*found)->set_seen ();
- } else {
- EncodeServerDescription sd (ip, xml->number_child<int>("Threads"), xml->optional_number_child<int>("Version").get_value_or(0));
- {
- boost::mutex::scoped_lock lm (_servers_mutex);
- _servers.push_back (sd);
- }
- emit (boost::bind(boost::ref (ServersListChanged)));
}
+ bool changed = false;
+ {
+ boost::mutex::scoped_lock lm (_servers_mutex);
+ auto i = _servers.begin();
+ while (i != _servers.end() && i->host_name() != ip) {
+ ++i;
+ }
- start_accept ();
-}
-
-
-optional<list<EncodeServerDescription>::iterator>
-EncodeServerFinder::server_found (string ip)
-{
- boost::mutex::scoped_lock lm (_servers_mutex);
- auto i = _servers.begin();
- while (i != _servers.end() && i->host_name() != ip) {
- ++i;
+ if (i != _servers.end()) {
+ i->set_seen();
+ } else {
+ EncodeServerDescription sd (ip, xml->number_child<int>("Threads"), xml->optional_number_child<int>("Version").get_value_or(0));
+ _servers.push_back (sd);
+ changed = true;
+ }
}
- if (i != _servers.end()) {
- return i;
+ if (changed) {
+ emit (boost::bind(boost::ref (ServersListChanged)));
}
- return {};
+ start_accept ();
}