Rewrite the entire internal signal handling/wakeup.

[cubemap] / serverpool.cpp

diff --git a/serverpool.cpp b/serverpool.cpp
index fb1668239a366b004313db3ab4b0efb2fd63ec00..e309ab99cecdae61b27faa77c55b5184ba473f4a 100644 (file)
--- a/serverpool.cpp
+++ b/serverpool.cpp
@@ -92,15 +92,7 @@ void ServerPool::add_stream_from_serialized(const StreamProto &stream, const vec
 
        // Close and delete any leftovers, if the number of servers was reduced.
        for (size_t i = num_servers; i < data_fds.size(); ++i) {
-               int ret;
-               do {
-                       ret = close(data_fds[i]);  // Implicitly deletes the file.
-               } while (ret == -1 && errno == EINTR);
-
-               if (ret == -1) {
-                       log_perror("close");
-                       // Can still continue.
-               }
+               safe_close(data_fds[i]);  // Implicitly deletes the file.
        }
 }