Rewrite some read/write loops for readability 15/193915/2
authorIgor Kotrasinski <i.kotrasinsk@partner.samsung.com>
Tue, 27 Nov 2018 10:28:28 +0000 (11:28 +0100)
committerIgor Kotrasinski <i.kotrasinsk@partner.samsung.com>
Tue, 27 Nov 2018 11:18:54 +0000 (12:18 +0100)
Change-Id: I2f26120a82c51f0a285f96cb16b0f9f2499c2c77
Signed-off-by: Igor Kotrasinski <i.kotrasinsk@partner.samsung.com>
TEECLib/src/teec_connection.c
ssflib/src/ssf_client.cpp

index da805d3bcfd3e95041f722c2e31840036e2d5afe..7ae18ccebeec158360e543dd4fbf4c6854425c87 100644 (file)
@@ -130,12 +130,14 @@ static uint32_t sendCommandtoDaemon(int32_t sockfd, char *fdata, size_t size)
 
        if (sockfd >= 0) {
                // send size number of bytes to Simulator Daemon
-               do {
+               while (nbytes < size) {
                        nwrite = send(sockfd, fdata + nbytes, size - nbytes, 0);
-               } while ((nwrite == -1 && errno == EINTR) || (nwrite > 0 && ((nbytes +=
-
-                                        nwrite) < size)));
-
+                       if (nwrite == -1 && errno == EINTR)
+                               continue;
+                       if (nwrite <= 0)
+                               break;
+                       nbytes += nwrite;
+               }
                return (size != nbytes) ? errno : 0;
        }
 
@@ -163,12 +165,14 @@ static uint32_t receiveResponse(int32_t sockfd, char *fdata, size_t size)
 
        if (sockfd >= 0) {
                // receive size number of bytes to Simulator Daemon
-               do {
+               while (nbytes < size) {
                        nread = recv(sockfd, fdata + nbytes, size - nbytes, 0);
-               } while ((nread == -1 && errno == EINTR)
-
-                                || (nread > 0 && ((nbytes += nread) < size)));
-
+                       if (nread == -1 && errno == EINTR)
+                               continue;
+                       if (nread <= 0)
+                               break;
+                       nbytes += nread;
+               }
                return (size != nbytes) ? errno : 0;
        }
 
index e0cec5d1ca91d15c3887fab90a46a4e5735e163d..7164f3859474f8d3019988334e47d949aa131b23 100644 (file)
@@ -100,10 +100,14 @@ static uint32_t sendCommandtoDaemon(int32_t sockfd, char* fdata, size_t size) {
        ssize_t nwrite = 0;
        size_t nbytes = 0;
        if (sockfd >= 0) {
-               do {
+               while (nbytes < size) {
                        nwrite = send(sockfd, fdata + nbytes, size - nbytes, 0);
-               } while ((nwrite == -1 && errno == EINTR) || (nwrite > 0 && ((nbytes +=
-                   nwrite) < size)));
+                       if (nwrite == -1 && errno == EINTR)
+                               continue;
+                       if (nwrite <= 0)
+                               break;
+                       nbytes += nwrite;
+               }
                return (size != nbytes) ? errno : 0;
        }
        LOGE(MODULE_SSF_LIB, "failed");
@@ -123,10 +127,14 @@ static uint32_t receiveResponse(int32_t sockfd, char* fdata, size_t size) {
        ssize_t nread = 0;
        size_t nbytes = 0;
        if (sockfd >= 0) {
-               do {
+               while (nbytes < size) {
                        nread = recv(sockfd, fdata + nbytes, size - nbytes, 0);
-               } while ((nread == -1 && errno == EINTR)
-                   || (nread > 0 && ((nbytes += nread) < size)));
+                       if (nread == -1 && errno == EINTR)
+                               continue;
+                       if (nread <= 0)
+                               break;
+                       nbytes += nread;
+               }
                return (size != nbytes) ? errno : 0;
        }
        LOGE(MODULE_SSF_LIB, "failed");