about summary refs log tree commit homepage
path: root/ext
diff options
context:
space:
mode:
authorEric Wong <normalperson@yhbt.net>2011-05-04 17:04:51 -0700
committerEric Wong <normalperson@yhbt.net>2011-05-04 17:04:51 -0700
commit1b0ee5826ef146a3e2647c40f3bc929d51d1b442 (patch)
tree24cc8da08ddba2cada51afdf8bc91964c4ca4c39 /ext
parentf81aa02448b615c4d5fc4f6544c53289dae9d2ec (diff)
downloadunicorn-1b0ee5826ef146a3e2647c40f3bc929d51d1b442.tar.gz
Combines the following sequence:

   http_parser.buf << socket.readpartial(0x4000)
   http_parser.parse

Into:

   http_parser.add_parse(socket.readpartial(0x4000))

It was too damn redundant otherwise...
Diffstat (limited to 'ext')
-rw-r--r--ext/unicorn_http/unicorn_http.rl22
1 files changed, 22 insertions, 0 deletions
diff --git a/ext/unicorn_http/unicorn_http.rl b/ext/unicorn_http/unicorn_http.rl
index 741f8ee..1d2705c 100644
--- a/ext/unicorn_http/unicorn_http.rl
+++ b/ext/unicorn_http/unicorn_http.rl
@@ -711,6 +711,27 @@ static VALUE HttpParser_parse(VALUE self)
 }
 
 /**
+ * Document-method: parse
+ * call-seq:
+ *    parser.add_parse(buffer) => env or nil
+ *
+ * adds the contents of +buffer+ to the internal buffer and attempts to
+ * continue parsing.  Returns the +env+ Hash on success or nil if more
+ * data is needed.
+ *
+ * Raises HttpParserError if there are parsing errors.
+ */
+static VALUE HttpParser_add_parse(VALUE self, VALUE buffer)
+{
+  struct http_parser *hp = data_get(self);
+
+  Check_Type(buffer, T_STRING);
+  rb_str_buf_append(hp->buf, buffer);
+
+  return HttpParser_parse(self);
+}
+
+/**
  * Document-method: trailers
  * call-seq:
  *    parser.trailers(req, data) => req or nil
@@ -908,6 +929,7 @@ void Init_unicorn_http(void)
   rb_define_method(cHttpParser, "clear", HttpParser_clear, 0);
   rb_define_method(cHttpParser, "reset", HttpParser_reset, 0);
   rb_define_method(cHttpParser, "parse", HttpParser_parse, 0);
+  rb_define_method(cHttpParser, "add_parse", HttpParser_add_parse, 1);
   rb_define_method(cHttpParser, "headers", HttpParser_headers, 2);
   rb_define_method(cHttpParser, "trailers", HttpParser_headers, 2);
   rb_define_method(cHttpParser, "filter_body", HttpParser_filter_body, 2);