Add an error-checking in write()

Change-Id: I3297030d5f5c45838cd4090d32e2cd2bdeccf1e6
Signed-off-by: Sunwook Bae <sunwook45.bae@samsung.com>

diff --git a/src/IpcClient.cpp b/src/IpcClient.cpp
index 8f4d34b82f7b5f5a2f55e3cda28d351752b869a4..6d5221f5bb160bd7da03b6fa911142023df29abe 100644 (file)
--- a/src/IpcClient.cpp
+++ b/src/IpcClient.cpp
@@ -479,6 +479,14 @@ IpcClient::SendAsync(IPC::Message* pMessage)
        while (remain > 0)
        {
                written = write(fd, (char*) pData, remain);
+               if (written < 0)
+               {
+                       _LOGE("Failed to send a request: %d, %s", errno, strerror(errno));
+
+                       ReleaseFd(fd);
+                       return MESSAGEPORT_ERROR_IO_ERROR;
+               }
+
                remain -= written;
                pData += written;
        }
@@ -523,6 +531,7 @@ IpcClient::SendSync(IPC::Message* pMessage)
                        ReleaseFd(fd);
                        return MESSAGEPORT_ERROR_IO_ERROR;
                }
+
                remain -= written;
                pData += written;
        }
@@ -552,6 +561,8 @@ IpcClient::SendSync(IPC::Message* pMessage)
                        }
 
                        _LOGE("Failed to poll (%d, %s).", errno, strerror(errno));
+
+                       ReleaseFd(fd);
                        return MESSAGEPORT_ERROR_IO_ERROR;
                }
 
@@ -580,6 +591,8 @@ IpcClient::SendSync(IPC::Message* pMessage)
                        if (pReply == NULL)
                        {
                                _LOGE("The memory is insufficient.");
+
+                               ReleaseFd(fd);
                                return MESSAGEPORT_ERROR_OUT_OF_MEMORY;
                        }