Changeset b4a875b in mod_gnutls

Timestamp:

Jul 8, 2011, 4:55:17 PM (12 years ago)

Author:

Dash Shendy <admin@…>

Branches:

asyncio, debian/master, debian/stretch-backports, jessie-backports, master, msva, proxy-ticket, upstream

Children:

60cf11c

Parents:

b59327c

Message:

EOC Bucket Infinite Loop Bugfix

Signed-off-by: Dash Shendy <neuromancer@…>

File:

• src/gnutls_io.c (modified) (6 diffs)

src/gnutls_io.c

@@ -542 +542 @@
 {
         apr_size_t ret;
-        apr_bucket *e;
         mgs_handle_t *ctxt = (mgs_handle_t *) f->ctx;
         apr_status_t status = APR_SUCCESS;
@@ -563 +562 @@
                 apr_bucket *bucket = APR_BRIGADE_FIRST(bb);
 
-                if (AP_BUCKET_IS_EOC(bucket)) {
-                        if (ctxt->session != NULL) {
-                                do {
-                                        ret =
-                                            gnutls_bye(ctxt->session,
-                                                       GNUTLS_SHUT_WR);
-                                } while (ret == GNUTLS_E_INTERRUPTED
-                                         || ret == GNUTLS_E_AGAIN);
-                        }
-
-                        apr_bucket_copy(bucket, &e);
-                        APR_BRIGADE_INSERT_TAIL(ctxt->output_bb, e);
-
-                        if ((status =
-                             ap_pass_brigade(f->next,
-                                             ctxt->output_bb)) !=
-                            APR_SUCCESS) {
-                                apr_brigade_cleanup(ctxt->output_bb);
-                                return status;
-                        }
-
-                        apr_brigade_cleanup(ctxt->output_bb);
-                        if (ctxt->session) {
-                                gnutls_deinit(ctxt->session);
-                                ctxt->session = NULL;
-                        }
-                        continue;
-                } else if (APR_BUCKET_IS_FLUSH(bucket)
-                           || APR_BUCKET_IS_EOS(bucket)) {
-
-                        apr_bucket_copy(bucket, &e);
-                        APR_BRIGADE_INSERT_TAIL(ctxt->output_bb, e);
-                        if ((status =
-                             ap_pass_brigade(f->next,
-                                             bb)) != APR_SUCCESS) {
-                                apr_brigade_cleanup(ctxt->output_bb);
-                                return status;
-                        }
-
-                        apr_brigade_cleanup(ctxt->output_bb);
-                        continue;
-                } else {
+                if (AP_BUCKET_IS_EOS(bucket)) {
+                        return ap_pass_brigade(f->next, bb);
+                } else if (APR_BUCKET_IS_FLUSH(bucket)) {
+                /* Try Flush */
+                        if( write_flush(ctxt) < 0) {
+                        /* Flush Error */
+                                return ctxt->output_rc;
+                        }
+                        /* cleanup! */
+                        apr_bucket_delete(bucket);
+                } else if (AP_BUCKET_IS_EOC(bucket)) {
+                /* End Of Connection */
+                        if (ctxt->session != NULL) {
+                        /* Try A Clean Shutdown */
+                                do {
+                                         ret = gnutls_bye( ctxt->session, 
+                                                 GNUTLS_SHUT_WR);
+                                } while(ret == GNUTLS_E_INTERRUPTED || 
+                                        ret == GNUTLS_E_AGAIN);
+                        /* De-Initialize Session */
+                                gnutls_deinit(ctxt->session);
+                                ctxt->session = NULL;
+                        }
+                        /* Pass next brigade! */
+                        return ap_pass_brigade(f->next, bb);
+                } else {
                         /* filter output */
                         const char *data;
@@ -613 +596 @@
 
                         if (APR_STATUS_IS_EAGAIN(status)) {
-                                rblock = APR_BLOCK_READ;
-                                continue;       /* and try again with a blocking read. */
+                        /* No data available so Flush! */
+                                if (write_flush(ctxt) < 0) {
+                                        return ctxt->output_rc;
+                                }
+                        /* Try again with a blocking read. */
+                                rblock = APR_BLOCK_READ;
+                                continue;       
                         }
 
@@ -621 +609 @@
                         if (!APR_STATUS_IS_EOF(status)
                             && (status != APR_SUCCESS)) {
-                                break;
+                                return status;
                         }
 
@@ -652 +640 @@
                                                 ctxt->output_rc =
                                                     APR_EGENERAL;
+                                                return ctxt->output_rc;
                                         }
                                 } else if (ret != len) {
@@ -661 +650 @@
 
                         apr_bucket_delete(bucket);
-
-                        if (ctxt->output_rc != APR_SUCCESS) {
-                                break;
-                        }
                 }
         }