added the 'is_closed' flag to signal that there won't be any input into this chunkqueue anymore

git-svn-id: svn://svn.lighttpd.net/lighttpd/branches/lighttpd-merge-1.4.x@1237 152afb58-edef-0310-8abb-c4023f1b3aa9

2 files changed, 3 insertions, 0 deletions

diff --git a/src/chunk.c b/src/chunk.c
index a47a5448..95ff1ff3 100644
--- a/src/chunk.c
+++ b/src/chunk.c
@@ -159,6 +159,7 @@ void chunkqueue_reset(chunkqueue *cq) {
 	chunkqueue_remove_finished_chunks(cq);
 	cq->bytes_in = 0;
 	cq->bytes_out = 0;
+	cq->is_closed = 0;
 }
 
 int chunkqueue_append_file(chunkqueue *cq, buffer *fn, off_t offset, off_t len) {
diff --git a/src/chunk.h b/src/chunk.h
index 779b761c..f42b58cb 100644
--- a/src/chunk.h
+++ b/src/chunk.h
@@ -43,6 +43,8 @@ typedef struct {
 
 	array *tempdirs;
 
+	int is_closed;   /* the input to this CQ is closed */
+
 	off_t  bytes_in, bytes_out;
 } chunkqueue;