Commit 3a47b6c4 authored by Doug MacEachern's avatar Doug MacEachern
Browse files

adjust to ap_get_brigade() / input filter api changes


git-svn-id: https://svn.apache.org/repos/asf/httpd/httpd/trunk@88925 13f79535-47bb-0310-9956-ffa450edef68
parent c92fc17e
Loading
Loading
Loading
Loading
+4 −3
Original line number Diff line number Diff line
@@ -1362,6 +1362,7 @@ static int pass_request(request_rec *r)
                                                 &mpm_perchild_module);
    char *foo;
    apr_size_t len;
    apr_size_t readbytes = 0;

    apr_pool_userdata_get((void **)&foo, "PERCHILD_BUFFER", r->connection->pool);
    len = strlen(foo);
@@ -1397,7 +1398,7 @@ static int pass_request(request_rec *r)

    write(sconf->sd2, foo, len);
   
    while (ap_get_brigade(r->input_filters, bb, AP_MODE_NONBLOCKING) == APR_SUCCESS) {
    while (ap_get_brigade(r->input_filters, bb, AP_MODE_NONBLOCKING, &readbytes) == APR_SUCCESS) {
        apr_bucket *e;
        APR_BRIGADE_FOREACH(e, bb) {
            const char *str;
@@ -1491,7 +1492,7 @@ static int perchild_post_read(request_rec *r)
    return OK;
}

static apr_status_t perchild_buffer(ap_filter_t *f, apr_bucket_brigade *b, ap_input_mode_t mode)
static apr_status_t perchild_buffer(ap_filter_t *f, apr_bucket_brigade *b, ap_input_mode_t mode, apr_size_t *readbytes)
{
    apr_bucket *e;
    apr_status_t rv;
@@ -1499,7 +1500,7 @@ static apr_status_t perchild_buffer(ap_filter_t *f, apr_bucket_brigade *b, ap_in
    const char *str;
    apr_size_t len;

    if ((rv = ap_get_brigade(f->next, b, mode)) != APR_SUCCESS) {
    if ((rv = ap_get_brigade(f->next, b, mode, readbytes)) != APR_SUCCESS) {
        return rv;
    }

+4 −3
Original line number Diff line number Diff line
@@ -1362,6 +1362,7 @@ static int pass_request(request_rec *r)
                                                 &mpm_perchild_module);
    char *foo;
    apr_size_t len;
    apr_size_t readbytes = 0;

    apr_pool_userdata_get((void **)&foo, "PERCHILD_BUFFER", r->connection->pool);
    len = strlen(foo);
@@ -1397,7 +1398,7 @@ static int pass_request(request_rec *r)

    write(sconf->sd2, foo, len);
   
    while (ap_get_brigade(r->input_filters, bb, AP_MODE_NONBLOCKING) == APR_SUCCESS) {
    while (ap_get_brigade(r->input_filters, bb, AP_MODE_NONBLOCKING, &readbytes) == APR_SUCCESS) {
        apr_bucket *e;
        APR_BRIGADE_FOREACH(e, bb) {
            const char *str;
@@ -1491,7 +1492,7 @@ static int perchild_post_read(request_rec *r)
    return OK;
}

static apr_status_t perchild_buffer(ap_filter_t *f, apr_bucket_brigade *b, ap_input_mode_t mode)
static apr_status_t perchild_buffer(ap_filter_t *f, apr_bucket_brigade *b, ap_input_mode_t mode, apr_size_t *readbytes)
{
    apr_bucket *e;
    apr_status_t rv;
@@ -1499,7 +1500,7 @@ static apr_status_t perchild_buffer(ap_filter_t *f, apr_bucket_brigade *b, ap_in
    const char *str;
    apr_size_t len;

    if ((rv = ap_get_brigade(f->next, b, mode)) != APR_SUCCESS) {
    if ((rv = ap_get_brigade(f->next, b, mode, readbytes)) != APR_SUCCESS) {
        return rv;
    }