1 files changed, 24 insertions, 25 deletions

diff --git a/src/main/extractor_common.c b/src/main/extractor_common.c
index 866609e..59524b3 100644
--- a/src/main/extractor_common.c
+++ b/src/main/extractor_common.c
@@ -39,27 +39,27 @@
  * @param buf buffer to read from
  * @param size number of bytes to write
  * @return number of bytes written (that is 'size'), or -1 on error
- */ 
+ */
 ssize_t
 EXTRACTOR_write_all_ (int fd,
-                      const void *buf,
-                      size_t size)
+                      const void *buf,
+                      size_t size)
 {
   const char *data = buf;
   size_t off = 0;
   ssize_t ret;
-  
+
   while (off < size)
+  {
+    ret = write (fd, &data[off], size - off);
+    if (ret <= 0)
     {
-      ret = write (fd, &data[off], size - off);
-      if (ret <= 0)
-        {
-          if (-1 == ret)
-            LOG_STRERROR ("write");
-          return -1;
-        }
-      off += ret;
+      if (-1 == ret)
+        LOG_STRERROR ("write");
+      return -1;
     }
+    off += ret;
+  }
   return size;
 }
 
@@ -74,28 +74,27 @@ EXTRACTOR_write_all_ (int fd,
  */
 ssize_t
 EXTRACTOR_read_all_ (int fd,
-                     void *buf,
-                     size_t size)
+                     void *buf,
+                     size_t size)
 {
   char *data = buf;
   size_t off = 0;
   ssize_t ret;
-  
+
   while (off < size)
+  {
+    ret = read (fd, &data[off], size - off);
+    if (ret <= 0)
     {
-      ret = read (fd, &data[off], size - off);
-      if (ret <= 0)
-        {
-          if (-1 == ret)
-            LOG_STRERROR ("write");
-          return -1;
-        }
-      off += ret;
+      if (-1 == ret)
+        LOG_STRERROR ("write");
+      return -1;
     }
+    off += ret;
+  }
   return size;
-  
-}
 
+}
 
 
 /* end of extractor_common.c */