- scoped_array<char> buffer (new char[length]);
- socket->read (reinterpret_cast<uint8_t*> (buffer.get()), length);
-
- string s (buffer.get());
- shared_ptr<cxml::Document> xml (new cxml::Document ("ServerAvailable"));
- xml->read_string (s);
-
- string const ip = socket->socket().remote_endpoint().address().to_string ();
- optional<list<EncodeServerDescription>::iterator> 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));
- if (sd.link_version() == SERVER_LINK_VERSION) {
- boost::mutex::scoped_lock lm (_servers_mutex);
- _good_servers.push_back (sd);
- } else {
- boost::mutex::scoped_lock lm (_servers_mutex);
- _bad_servers.push_back (sd);
- }
- emit (boost::bind (boost::ref (ServersListChanged)));
+ try {
+ uint32_t length;
+ _accept_socket->read (reinterpret_cast<uint8_t*>(&length), sizeof(uint32_t));
+ length = ntohl (length);
+
+ scoped_array<char> buffer(new char[length]);
+ _accept_socket->read (reinterpret_cast<uint8_t*>(buffer.get()), length);
+ server_available = buffer.get();
+ } catch (NetworkError&) {
+ /* Maybe the server went away; let's just try again */
+ start_accept();
+ return;