clearlinux/uwsgi
2
0
Fork 0
mirror of https://github.com/clearlinux/uwsgi.git synced 2026-09-06 21:51:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixed rack.input with buffered arg

Browse Source
This commit is contained in:
roberto@quantal64
2012-09-28 16:21:37 +02:00
parent 973e508af7
commit dafe3bb12c
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/rack/rack_plugin.c
+2 -6
View File
@@ -158,7 +158,7 @@ VALUE rb_uwsgi_io_read(VALUE obj, VALUE args) {
}
else {
chunk_size = NUM2LONG(RARRAY_PTR(args)[0]);
// hack to bypass broken middlewares
// hack to tolerate broken middlewares
if (chunk_size <= 0) {
chunk_size = wsgi_req->post_cl;
}
@@ -173,8 +173,6 @@ VALUE rb_uwsgi_io_read(VALUE obj, VALUE args) {
// push in the specified buffer
if (RARRAY_LEN(args) > 1) {
rb_str_cat(RARRAY_PTR(args)[1], tmp_chunk, rlen);
free(tmp_chunk);
return RARRAY_PTR(args)[1];
}
// return a new string
chunk = rb_str_new(tmp_chunk, rlen);
@@ -210,7 +208,7 @@ VALUE rb_uwsgi_io_read(VALUE obj, VALUE args) {
}
else {
chunk_size = NUM2LONG(RARRAY_PTR(args)[0]);
// hack to respect broken middlewares
// hack to tolerate broken middlewares
if (chunk_size <= 0) {
chunk_size = wsgi_req->post_cl;
}
@@ -220,8 +218,6 @@ VALUE rb_uwsgi_io_read(VALUE obj, VALUE args) {
}
if (RARRAY_LEN(args) > 1) {
rb_str_cat(RARRAY_PTR(args)[1], wsgi_req->post_buffering_buf+wsgi_req->buf_pos, chunk_size);
wsgi_req->buf_pos+=chunk_size;
return RARRAY_PTR(args)[1];
}
chunk = rb_str_new(wsgi_req->post_buffering_buf+wsgi_req->buf_pos, chunk_size);
wsgi_req->buf_pos+=chunk_size;