Changes in uspace/lib/http/src/receive-buffer.c [9a09212:408424e] in mainline

File:

• uspace/lib/http/src/receive-buffer.c (modified) (8 diffs)

uspace/lib/http/src/receive-buffer.c

@@ -61 +61 @@
 }
 
-static int dummy_receive(void *unused, void *buf, size_t buf_size,
-    size_t *nrecv)
-{
-        *nrecv = 0;
-        return EOK;
+static ssize_t dummy_receive(void *unused, void *buf, size_t buf_size)
+{
+        return 0;
 }
 
@@ -169 +167 @@
                 }
                 
-                size_t nrecv;
-                int rc = rb->receive(rb->client_data, rb->buffer + rb->in, free, &nrecv);
-                if (rc != EOK)
-                        return rc;
-                
-                rb->in = nrecv;
+                ssize_t rc = rb->receive(rb->client_data, rb->buffer + rb->in, free);
+                if (rc <= 0)
+                        return rc;
+                
+                rb->in = rc;
         }
         
@@ -183 +180 @@
 }
 
-int recv_buffer(receive_buffer_t *rb, char *buf, size_t buf_size,
-    size_t *nrecv)
-{
-        /* Flush any buffered data */
+ssize_t recv_buffer(receive_buffer_t *rb, char *buf, size_t buf_size)
+{
+        /* Flush any buffered data*/
         if (rb->out != rb->in) {
                 size_t size = min(rb->in - rb->out, buf_size);
                 memcpy(buf, rb->buffer + rb->out, size);
                 rb->out += size;
-                *nrecv = size;
-                return EOK;
-        }
-        
-        return rb->receive(rb->client_data, buf, buf_size, nrecv);
+                return size;
+        }
+        
+        return rb->receive(rb->client_data, buf, buf_size);
 }
 
 /** Receive a character and if it is c, discard it from input buffer
- * @param ndisc Place to store number of characters discarded
- * @return EOK or error code
- */
-int recv_discard(receive_buffer_t *rb, char discard, size_t *ndisc)
+ * @return number of characters discarded (0 or 1) or negative error code
+ */
+ssize_t recv_discard(receive_buffer_t *rb, char discard)
 {
         char c = 0;
@@ -208 +202 @@
         if (rc != EOK)
                 return rc;
-        if (c != discard) {
-                *ndisc = 0;
-                return EOK;
-        }
+        if (c != discard)
+                return 0;
         rc = recv_char(rb, &c, true);
         if (rc != EOK)
                 return rc;
-        *ndisc = 1;
-        return EOK;
+        return 1;
 }
 
 /** Receive a prefix of constant string discard and return number of bytes read
- * @param ndisc Place to store number of characters discarded
- * @return EOK or error code
- */
-int recv_discard_str(receive_buffer_t *rb, const char *discard, size_t *ndisc)
+ * @return number of characters discarded or negative error code
+ */
+ssize_t recv_discard_str(receive_buffer_t *rb, const char *discard)
 {
         size_t discarded = 0;
         while (*discard) {
-                size_t nd;
-                int rc = recv_discard(rb, *discard, &nd);
-                if (rc != EOK)
-                        return rc;
-                if (nd == 0)
+                ssize_t rc = recv_discard(rb, *discard);
+                if (rc < 0)
+                        return rc;
+                if (rc == 0)
                         break;
-                discarded += nd;
+                discarded++;
                 discard++;
         }
-
-        *ndisc = discarded;
-        return EOK;
-}
-
-int recv_while(receive_buffer_t *rb, char_class_func_t class)
-{
+        return discarded;
+}
+
+ssize_t recv_while(receive_buffer_t *rb, char_class_func_t class)
+{
+        size_t received = 0;
+        
         while (true) {
                 char c = 0;
@@ -255 +244 @@
                 if (rc != EOK)
                         return rc;
-        }
-        
-        return EOK;
+                
+                received++;
+        }
+        
+        return received;
 }
 
 /** Receive an end of line, either CR, LF, CRLF or LFCR
  *
- * @param nrecv Place to store number of bytes received (zero if
- *              no newline is present in the stream)
- * @return EOK on success or error code
- */
-int recv_eol(receive_buffer_t *rb, size_t *nrecv)
+ * @return number of bytes read (0 if no newline is present in the stream)
+ *         or negative error code
+ */
+ssize_t recv_eol(receive_buffer_t *rb)
 {
         char c = 0;
@@ -273 +263 @@
                 return rc;
         
-        if (c != '\r' && c != '\n') {
-                *nrecv = 0;
-                return EOK;
-        }
+        if (c != '\r' && c != '\n')
+                return 0;
         
         rc = recv_char(rb, &c, true);
@@ -282 +270 @@
                 return rc;
         
-        size_t nr;
-        rc = recv_discard(rb, (c == '\r' ? '\n' : '\r'), &nr);
-        if (rc != EOK)
-                return rc;
-        
-        *nrecv = 1 + nr;
-        return EOK;
+        ssize_t rc2 = recv_discard(rb, (c == '\r' ? '\n' : '\r'));
+        if (rc2 < 0)
+                return rc2;
+        
+        return 1 + rc2;
 }
 
 /* Receive a single line */
-int recv_line(receive_buffer_t *rb, char *line, size_t size, size_t *nrecv)
+ssize_t recv_line(receive_buffer_t *rb, char *line, size_t size)
 {
         size_t written = 0;
-        size_t nr;
         
         while (written < size) {
@@ -303 +288 @@
                         return rc;
                 if (c == '\n') {
-                        rc = recv_discard(rb, '\r', &nr);
-                        if (rc != EOK)
-                                return rc;
-
+                        recv_discard(rb, '\r');
                         line[written++] = 0;
-                        *nrecv = written;
-                        return EOK;
+                        return written;
                 }
                 else if (c == '\r') {
-                        rc = recv_discard(rb, '\n', &nr);
-                        if (rc != EOK)
-                                return rc;
+                        recv_discard(rb, '\n');
                         line[written++] = 0;
-                        *nrecv = written;
-                        return EOK;
+                        return written;
                 }
                 line[written++] = c;