Handle EINTR safely in client read path

Agent-Logs-Url: https://github.com/WEBcodeX1/http-1.2/sessions/52de29c4-0332-4c1e-9fd4-e87a34608c1f

Co-authored-by: clauspruefer <17313789+clauspruefer@users.noreply.github.com>

Author: Copilot

src/Client.cpp

@@ -1,5 +1,7 @@
 #include "Client.hpp"
 
+#include <cerrno>
+
 using namespace std;
 
 Client::Client(Filedescriptor_t ClientFD, char* BufferAddress) :
@@ -20,7 +22,11 @@ Client::~Client()
 
 ssize_t Client::receiveData()
 {
-    ssize_t RcvBytes = read(_ClientFD, _ReceiveBuffer, SOCKET_RECEIVE_BUFFER_SIZE);
+    ssize_t RcvBytes;
+    do {
+        RcvBytes = read(_ClientFD, _ReceiveBuffer, SOCKET_RECEIVE_BUFFER_SIZE);
+    } while (RcvBytes == -1 && errno == EINTR);
+
     DBG(220, "RcvBytes:" << RcvBytes << " ClientFD:" << _ClientFD);
 
     if (RcvBytes > 0) {

src/ClientHandler.cpp

@@ -1,5 +1,6 @@
 #include "ClientHandler.hpp"
 
+#include <cerrno>
 #include <memory>
 
 using namespace std;
@@ -83,9 +84,18 @@ void ClientHandler::readClientData(const uint16_t FDCount)
 
         if (Clients.contains(ReadFD)) {
             const auto RecvStatus = Clients[ReadFD]->receiveData();
+            const int RecvErrno = errno;
             if (RecvStatus == 0) {
                 Clients.erase(ReadFD);
                 close(ReadFD);
+            } else if (
+                RecvStatus < 0 &&
+                RecvErrno != EAGAIN &&
+                RecvErrno != EWOULDBLOCK &&
+                RecvErrno != EINTR
+            ) {
+                Clients.erase(ReadFD);
+                close(ReadFD);
             }
         }
     }