Commit cd85eac9 authored by Stefan Eissing's avatar Stefan Eissing
Browse files

On the trunk: 

mod_http2: disable and give warning when mpm_prefork is encountered. 
     The server will continue to work, but HTTP/2 will no longer be negotiated.



git-svn-id: https://svn.apache.org/repos/asf/httpd/httpd/trunk@1800689 13f79535-47bb-0310-9956-ffa450edef68
parent fce24d2c

CHANGES

+3 −0
Original line number Diff line number Diff line 
                                                         -*- coding: utf-8 -*-

Changes with Apache 2.5.0



  *) mod_http2: disable and give warning when mpm_prefork is encountered. The server will

     continue to work, but HTTP/2 will no longer be negotiated. [Stefan Eissing]

  

  *) htpasswd / htdigest: Do not apply the strict permissions of the temporary

     passwd file to a possibly existing passwd file. PR 61240. [Ruediger Pluem]

docs/log-message-tags/next-number

+1 −1
Original line number Diff line number Diff line 
10034
 
10035

modules/http2/h2_conn.c

+20 −1
Original line number Diff line number Diff line
@@ -47,6 +47,7 @@ static struct h2_workers *workers; 
static h2_mpm_type_t mpm_type = H2_MPM_UNKNOWN;

static module *mpm_module;

static int async_mpm;

static int mpm_supported = 1;

static apr_socket_t *dummy_socket;



static void check_modules(int force)
@@ -76,11 +77,18 @@ static void check_modules(int force) 
            else if (!strcmp("prefork.c", m->name)) {

                mpm_type = H2_MPM_PREFORK;

                mpm_module = m;

                /* While http2 can work really well on prefork, it collides

                 * today's use case for prefork: runnning single-thread app engines

                 * like php. If we restrict h2_workers to 1 per process, php will

                 * work fine, but browser will be limited to 1 active request at a

                 * time. */

                mpm_supported = 0;

                break;

            }

            else if (!strcmp("simple_api.c", m->name)) {

                mpm_type = H2_MPM_SIMPLE;

                mpm_module = m;

                mpm_supported = 0;

                break;

            }

            else if (!strcmp("mpm_winnt.c", m->name)) {
@@ -107,7 +115,6 @@ apr_status_t h2_conn_child_init(apr_pool_t *pool, server_rec *s) 
    int idle_secs = 0;



    check_modules(1);

    

    ap_mpm_query(AP_MPMQ_MAX_THREADS, &max_threads_per_child);

    

    status = ap_mpm_query(AP_MPMQ_IS_ASYNC, &async_mpm);
@@ -157,6 +164,18 @@ h2_mpm_type_t h2_conn_mpm_type(void) 
    return mpm_type;

}



const char *h2_conn_mpm_name(void)

{

    check_modules(0);

    return mpm_module? mpm_module->name : "unknown";

}



int h2_mpm_supported(void)

{

    check_modules(0);

    return mpm_supported;

}



static module *h2_conn_mpm_module(void)

{

    check_modules(0);

modules/http2/h2_conn.h

+2 −1
Original line number Diff line number Diff line
@@ -64,7 +64,8 @@ typedef enum { 


/* Returns the type of MPM module detected */

h2_mpm_type_t h2_conn_mpm_type(void);



const char *h2_conn_mpm_name(void);

int h2_mpm_supported(void);



conn_rec *h2_slave_create(conn_rec *master, int slave_id, apr_pool_t *parent);

void h2_slave_destroy(conn_rec *slave);

modules/http2/h2_mplx.c

+18 −19
Original line number Diff line number Diff line
@@ -480,9 +480,6 @@ void h2_mplx_release_and_join(h2_mplx *m, apr_thread_cond_t *wait) 
    

    H2_MPLX_LEAVE(m);



    /* 5. unregister again, now that our workers are done */

    h2_workers_unregister(m->workers, m);



    ap_log_cerror(APLOG_MARK, APLOG_TRACE1, 0, m->c,

                  "h2_mplx(%ld): released", m->id);

}
@@ -661,7 +658,7 @@ apr_status_t h2_mplx_reprioritize(h2_mplx *m, h2_stream_pri_cmp *cmp, void *ctx) 


static void register_if_needed(h2_mplx *m) 

{

    if (!m->is_registered && !h2_iq_empty(m->q)) {

    if (!m->aborted && !m->is_registered && !h2_iq_empty(m->q)) {

        apr_status_t status = h2_workers_register(m->workers, m); 

        if (status == APR_SUCCESS) {

            m->is_registered = 1;
@@ -754,25 +751,27 @@ static h2_task *next_stream_task(h2_mplx *m) 
    return NULL;

}



h2_task *h2_mplx_pop_task(h2_mplx *m, int *has_more)

apr_status_t h2_mplx_pop_task(h2_mplx *m, h2_task **ptask)

{

    h2_task *task = NULL;

    apr_status_t rv = APR_EOF;

    

    H2_MPLX_ENTER_ALWAYS(m);

    *ptask = NULL;

    if (APR_SUCCESS != (rv = apr_thread_mutex_lock(m->lock))) {

        return rv;

    }

    

    *has_more = 0;

    if (!m->aborted) {

        task = next_stream_task(m);

        if (task != NULL && !h2_iq_empty(m->q)) {

            *has_more = 1;

    if (m->aborted) {

        rv = APR_EOF;

    }

    else {

            m->is_registered = 0; /* h2_workers will discard this mplx */

        *ptask = next_stream_task(m);

        rv = (*ptask != NULL && !h2_iq_empty(m->q))? APR_EAGAIN : APR_SUCCESS;

    }

    if (APR_EAGAIN != rv) {

        m->is_registered = 0; /* h2_workers will discard this mplx */

    }



    H2_MPLX_LEAVE(m);

    return task;

    return rv;

}



static void task_done(h2_mplx *m, h2_task *task, h2_req_engine *ngn)