clearlinux/uwsgi
2
0
Fork 0
mirror of https://github.com/clearlinux/uwsgi.git synced 2026-09-05 13:11:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixed fastrouter

Browse Source
This commit is contained in:
Roberto De Ioris
2012-10-20 17:55:04 +02:00
parent 242497102e
commit ef10dc054f
2 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/corerouter/corerouter.c
+3
View File
@@ -804,6 +804,9 @@ void uwsgi_corerouter_loop(int id, void *data) {
// on error, destroy the session
if (event_queue_interesting_fd_has_error(events, i)) {
if (interesting_fd == cr_session->instance_fd) {
cr_session->instance_failed = 1;
}
corerouter_close_session(ucr, cr_session);
continue;
}
plugins/fastrouter/fastrouter.c
+2 -2
View File
@@ -103,7 +103,7 @@ ssize_t fr_write_body(struct corerouter_session * cs) {
fs->post_buf_pos += len;
// the body chunk has been sent, start again reading from client and instance
if (fs->post_buf_pos == fs->post_buf_len) {
if (fs->post_buf_pos == (size_t) fs->post_buf_len) {
uwsgi_cr_hook_instance_write(cs, NULL);
uwsgi_cr_hook_instance_read(cs, fr_instance_read_response);
uwsgi_cr_hook_read(cs, fr_read_body);
@@ -148,7 +148,7 @@ ssize_t fr_write_response(struct corerouter_session * cs) {
cs->buffer_pos += len;
// ok this response chunk is sent, let's wait for another one
if (cs->buffer_pos == cs->buffer_len) {
if (cs->buffer_pos == (size_t) cs->buffer_len) {
uwsgi_cr_hook_write(cs, NULL);
uwsgi_cr_hook_instance_read(cs, fr_instance_read_response);
}