3f097a
# ./pullrev.sh 1847624
3f097a
http://svn.apache.org/viewvc?view=revision&revision=1847624
3f097a
3f097a
https://bugzilla.redhat.com/show_bug.cgi?id=1654200
3f097a
3f097a
--- mod_fcgid-2.3.9/modules/fcgid/fcgid_proc_unix.c
3f097a
+++ mod_fcgid-2.3.9/modules/fcgid/fcgid_proc_unix.c
3f097a
@@ -762,14 +762,18 @@
3f097a
     struct iovec vec[FCGID_VEC_COUNT];
3f097a
     int nvec = 0;
3f097a
     apr_bucket *e;
3f097a
+    apr_bucket_brigade *tmpbb = apr_brigade_create(output_brigade->p,
3f097a
+                                                   output_brigade->bucket_alloc);
3f097a
 
3f097a
-    for (e = APR_BRIGADE_FIRST(output_brigade);
3f097a
-         e != APR_BRIGADE_SENTINEL(output_brigade);
3f097a
-         e = APR_BUCKET_NEXT(e)) {
3f097a
+    while (!APR_BRIGADE_EMPTY(output_brigade))
3f097a
+    {
3f097a
+        e = APR_BRIGADE_FIRST(output_brigade);
3f097a
+
3f097a
         apr_size_t len;
3f097a
         const char* base;
3f097a
 
3f097a
         if (APR_BUCKET_IS_METADATA(e)) {
3f097a
+            apr_bucket_delete(e);
3f097a
             continue;
3f097a
         }
3f097a
 
3f097a
@@ -780,6 +784,9 @@
3f097a
             return rv;
3f097a
         }
3f097a
 
3f097a
+        APR_BUCKET_REMOVE(e);
3f097a
+        APR_BRIGADE_INSERT_TAIL(tmpbb, e);
3f097a
+
3f097a
         vec[nvec].iov_len = len;
3f097a
         vec[nvec].iov_base = (char*) base;
3f097a
         if (nvec == (FCGID_VEC_COUNT - 1)) {
3f097a
@@ -789,6 +796,7 @@
3f097a
                                FCGID_VEC_COUNT)) != APR_SUCCESS)
3f097a
                 return rv;
3f097a
             nvec = 0;
3f097a
+            apr_brigade_cleanup(tmpbb);
3f097a
         }
3f097a
         else
3f097a
             nvec++;
3f097a
@@ -800,6 +808,7 @@
3f097a
             return rv;
3f097a
     }
3f097a
 
3f097a
+    apr_brigade_destroy(tmpbb);
3f097a
     return APR_SUCCESS;
3f097a
 }
3f097a
 
3f097a
--- mod_fcgid-2.3.9/modules/fcgid/fcgid_proc_win.c
3f097a
+++ mod_fcgid-2.3.9/modules/fcgid/fcgid_proc_win.c
3f097a
@@ -380,19 +380,22 @@
3f097a
     apr_bucket *bucket_request;
3f097a
     apr_status_t rv;
3f097a
     DWORD transferred;
3f097a
+    apr_bucket_brigade *tmpbb = apr_brigade_create(birgade_send->p, 
3f097a
+                                                   birgade_send->bucket_alloc);
3f097a
 
3f097a
     handle_info = (fcgid_namedpipe_handle *) ipc_handle->ipc_handle_info;
3f097a
 
3f097a
-    for (bucket_request = APR_BRIGADE_FIRST(birgade_send);
3f097a
-         bucket_request != APR_BRIGADE_SENTINEL(birgade_send);
3f097a
-         bucket_request = APR_BUCKET_NEXT(bucket_request))
3f097a
-    {
3f097a
+    while (!APR_BRIGADE_EMPTY(birgade_send)) {
3f097a
         const char *write_buf;
3f097a
         apr_size_t write_buf_len;
3f097a
         apr_size_t has_write;
3f097a
 
3f097a
-        if (APR_BUCKET_IS_METADATA(bucket_request))
3f097a
+        bucket_request = APR_BRIGADE_FIRST(birgade_send);
3f097a
+
3f097a
+        if (APR_BUCKET_IS_METADATA(bucket_request)) {
3f097a
+            apr_bucket_delete(bucket_request);
3f097a
             continue;
3f097a
+        }
3f097a
 
3f097a
         if ((rv = apr_bucket_read(bucket_request, &write_buf, &write_buf_len,
3f097a
                                   APR_BLOCK_READ)) != APR_SUCCESS) {
3f097a
@@ -401,6 +404,9 @@
3f097a
             return rv;
3f097a
         }
3f097a
 
3f097a
+        APR_BUCKET_REMOVE(bucket_request);
3f097a
+        APR_BRIGADE_INSERT_TAIL(tmpbb, bucket_request);
3f097a
+
3f097a
         /* Write the buffer to fastcgi server */
3f097a
         has_write = 0;
3f097a
         while (has_write < write_buf_len) {
3f097a
@@ -411,6 +417,7 @@
3f097a
                           write_buf_len - has_write,
3f097a
                           &byteswrite, &handle_info->overlap_write)) {
3f097a
                 has_write += byteswrite;
3f097a
+                apr_brigade_cleanup(tmpbb);
3f097a
                 continue;
3f097a
             } else if ((rv = GetLastError()) != ERROR_IO_PENDING) {
3f097a
                 ap_log_rerror(APLOG_MARK, APLOG_WARNING,
3f097a
@@ -437,6 +444,7 @@
3f097a
                         return APR_ESPIPE;
3f097a
                     }
3f097a
                     has_write += transferred;
3f097a
+                    apr_brigade_cleanup(tmpbb);
3f097a
                     continue;
3f097a
                 } else {
3f097a
                     ap_log_rerror(APLOG_MARK, APLOG_WARNING, 0,
3f097a
@@ -448,6 +456,7 @@
3f097a
         }
3f097a
     }
3f097a
 
3f097a
+    apr_brigade_destroy(tmpbb);
3f097a
     return APR_SUCCESS;
3f097a
 }
3f097a