- scoped_array<char> buffer(new char[length]);
- _accept_socket->read (reinterpret_cast<uint8_t*>(buffer.get()), length);
+ 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;
+ }