Replace read/write with send/recv

New implementation does not require to mask SIGPILE singal in client.

Change-Id: I88338d10547f3ec521f12a83bfdb6d8391ef6bec

diff --git a/src/common/connection.cpp b/src/common/connection.cpp
index e5ab101eb2aab2d8de1e6cbb842437602f524390..32e98f72a84c7eb1c6ca546103d27a5d8f506075 100644 (file)
--- a/src/common/connection.cpp
+++ b/src/common/connection.cpp
@@ -182,7 +182,10 @@ int sendToServer(char const * const interface, const RawBuffer &send, MessageBuf
             LogError("Error in poll(POLLOUT)");
             return SECURITY_MANAGER_ERROR_SOCKET;
         }
-        ssize_t temp = TEMP_FAILURE_RETRY(write(sock.Get(), &send[done], send.size() - done));
+        ssize_t temp = TEMP_FAILURE_RETRY(::send(sock.Get(),
+                                                 &send[done],
+                                                 send.size() - done,
+                                                 MSG_NOSIGNAL));
         if (-1 == temp) {
             int err = errno;
             LogError("Error in write: " << GetErrnoString(err));
@@ -196,7 +199,10 @@ int sendToServer(char const * const interface, const RawBuffer &send, MessageBuf
             LogError("Error in poll(POLLIN)");
             return SECURITY_MANAGER_ERROR_SOCKET;
         }
-        ssize_t temp = TEMP_FAILURE_RETRY(read(sock.Get(), buffer, 2048));
+        ssize_t temp = TEMP_FAILURE_RETRY(::recv(sock.Get(),
+                                                 buffer,
+                                                 2048,
+                                                 0));
         if (-1 == temp) {
             int err = errno;
             LogError("Error in read: " << GetErrnoString(err));