Introducing readline function in libunit.

Ruby and Java modules now use this function instead of own
implementations.

1 files changed, 4 insertions, 24 deletions

diff --git a/src/java/nxt_jni_InputStream.c b/src/java/nxt_jni_InputStream.c
index b96ff742..3b74b0c1 100644
--- a/src/java/nxt_jni_InputStream.c
+++ b/src/java/nxt_jni_InputStream.c
@@ -90,40 +90,20 @@ static jint JNICALL
 nxt_java_InputStream_readLine(JNIEnv *env, jclass cls,
     jlong req_info_ptr, jarray out, jint off, jint len)
 {
-    char                     *p;
-    jint                     size, b_size;
     uint8_t                  *data;
     ssize_t                  res;
-    nxt_unit_buf_t           *b;
     nxt_unit_request_info_t  *req;
 
     req = nxt_jlong2ptr(req_info_ptr);
 
-    size = 0;
-
-    for (b = req->content_buf; b; b = nxt_unit_buf_next(b)) {
-        b_size = b->end - b->free;
-        p = memchr(b->free, '\n', b_size);
-
-        if (p != NULL) {
-            p++;
-            size += p - b->free;
-            break;
-        }
+    data = (*env)->GetPrimitiveArrayCritical(env, out, NULL);
 
-        size += b_size;
+    res = nxt_unit_request_readline_size(req, len);
 
-        if (size >= len) {
-            break;
-        }
+    if (res > 0) {
+        res = nxt_unit_request_read(req, data + off, res);
     }
 
-    len = len < size ? len : size;
-
-    data = (*env)->GetPrimitiveArrayCritical(env, out, NULL);
-
-    res = nxt_unit_request_read(req, data + off, len);
-
     nxt_unit_req_debug(req, "readLine '%.*s'", res, (char *) data + off);
 
     (*env)->ReleasePrimitiveArrayCritical(env, out, data, 0);