mod_manager.c

/*
 * Copyright The mod_cluster Project Authors
 * SPDX-License-Identifier: Apache-2.0
 */

/*
 * @author Jean-Frederic Clere
 */

#include "domain.h"
#include "common.h"

#include "apr_lib.h"
#include "apr_uuid.h"

#define CORE_PRIVATE
#include "httpd.h"
#include "scoreboard.h"
#include "sessionid.h"


#define DEFMAXCONTEXT          100
#define DEFMAXNODE             20
#define DEFMAXHOST             20
#define DEFMAXSESSIONID        0 /* it has performance/security impact */
#define MAXMESSSIZE            1024

/* Warning messages */
#define SBALBAD                "Balancer name contained an upper case character. We will use \"%s\" instead."

/* Error messages */
#define TYPESYNTAX             1
#define SMESPAR                "SYNTAX: Can't parse MCMP message. It might have contained illegal symbols or unknown elements."
#define SBALBIG                "SYNTAX: Balancer field too big"
#define SBAFBIG                "SYNTAX: A field is too big"
#define SROUBIG                "SYNTAX: JVMRoute field too big"
#define SROUBAD                "SYNTAX: JVMRoute can't be empty"
#define SDOMBIG                "SYNTAX: LBGroup field too big"
#define SHOSBIG                "SYNTAX: Host field too big"
#define SPORBIG                "SYNTAX: Port field too big"
#define STYPBIG                "SYNTAX: Type field too big"
#define SALIBIG                "SYNTAX: Alias field too big"
#define SCONBIG                "SYNTAX: Context field too big"
#define SFLUBAD                "SYNTAX: Flushwait field has bad value"
#define SPNGBAD                "SYNTAX: Ping field has bad value"
#define STTLBAD                "SYNTAX: TTL field has bad value"
#define STIMBAD                "SYNTAX: Timeout field has bad value"
#define SALIBAD                "SYNTAX: Alias without Context"
#define SCONBAD                "SYNTAX: Context without Alias"
#define NOCONAL                "SYNTAX: No Context and Alias in APP command"
#define SBADFLD                "SYNTAX: Invalid field \"%s\" in message"
#define SMISFLD                "SYNTAX: Mandatory field(s) missing in message"
#define SCMDUNS                "SYNTAX: Command is not supported"
#define SMULALB                "SYNTAX: Only one Alias in APP command"
#define SMULCTB                "SYNTAX: Only one Context in APP command"
#define SREADER                "SYNTAX: %s can't read POST data"

#define TYPEMEM                2
#define MNODEUI                "MEM: Can't update or insert node with \"%s\" JVMRoute"
#define MNODERM                "MEM: Old node with \"%s\" JVMRoute still exists"
#define MBALAUI                "MEM: Can't update or insert balancer for node with \"%s\" JVMRoute"
#define MNODERD                "MEM: Can't read node with \"%s\" JVMRoute"
#define MHOSTRD                "MEM: Can't read host alias for node with \"%s\" JVMRoute"
#define MHOSTUI                "MEM: Can't update or insert host alias for node with \"%s\" JVMRoute"
#define MCONTUI                "MEM: Can't update or insert context for node with \"%s\" JVMRoute"
#define MNODEET                "MEM: Another for the same worker already exist"

/* Protocol version supported */
#define VERSION_PROTOCOL       "0.2.1"

/* Internal substitution for node commands */
#define NODE_COMMAND           "/NODE_COMMAND"

/* range of the commands */
#define RANGECONTEXT           0
#define RANGENODE              1
#define RANGEDOMAIN            2

/* define content-type */
#define TEXT_PLAIN             1
#define TEXT_XML               2

#define PLAINTEXT_CONTENT_TYPE "text/plain"
#define XML_CONTENT_TYPE       "text/xml"

/* Data structure for shared memory block */
typedef struct version_data
{
    apr_uint64_t counter;
} version_data;

/* mutex and lock for tables/slotmen */
static apr_global_mutex_t *node_mutex;
static apr_global_mutex_t *context_mutex;
static const char *node_mutex_type = "node-shm";
static const char *context_mutex_type = "context-shm";

/* counter for the version (nodes) */
static ap_slotmem_instance_t *version_node_mem = NULL;

/* shared memory */
static mem_t *contextstatsmem = NULL;
static mem_t *nodestatsmem = NULL;
static mem_t *hoststatsmem = NULL;
static mem_t *balancerstatsmem = NULL;
static mem_t *sessionidstatsmem = NULL;
static mem_t *domainstatsmem = NULL;
/* Used for HCExpr templates with lbmethod_cluster */
static apr_table_t *proxyhctemplate = NULL;

static void set_proxyhctemplate(apr_pool_t *p, apr_table_t *t)
{
    proxyhctemplate = apr_table_overlay(p, t, proxyhctemplate);
}

static slotmem_storage_method *storage = NULL;
static balancer_method *balancerhandler = NULL;
static void (*advertise_info)(request_rec *) = NULL;

static APR_OPTIONAL_FN_TYPE(balancer_manage) *balancer_manage = NULL;

module AP_MODULE_DECLARE_DATA manager_module;

static char balancer_nonce[APR_UUID_FORMATTED_LENGTH + 1];

typedef struct mod_manager_config
{
    /* base name for the shared memory */
    char *basefilename;
    /* max number of context supported */
    unsigned maxcontext;
    /* max number of node supported */
    unsigned maxnode;
    /* max number of host supported */
    unsigned maxhost;
    /* max number of session supported */
    unsigned maxsessionid;

    /* version, the version is increased each time the node update logic is called */
    unsigned tableversion;

    /* Should be the slotmem persisted (1) or not (0) */
    int persistent;

    /* check for nonce in the command logic */
    int nonce;

    /* default name for balancer */
    char *balancername;

    /* allow aditional display */
    int allow_display;
    /* allow command logic */
    int allow_cmd;
    /* don't context in first status page */
    int reduce_display;
    /* maximum message size */
    int maxmesssize;
    /* Enable MCMP receiver */
    int enable_mcmp_receive;
    /* Enable WebSocket Proxy */
    int enable_ws_tunnel;
    /* WebSocket upgrade header */
    char *ws_upgrade_header;
    /* AJP secret */
    char *ajp_secret;
    /* size of the proxy response field buffer */
    long response_field_size;

} mod_manager_config;

/* routines for the node_storage_method */
static apr_status_t loc_read_node(int ids, nodeinfo_t **node)
{
    return get_node(nodestatsmem, node, ids);
}

static int loc_get_ids_used_node(int *ids)
{
    return get_ids_used_node(nodestatsmem, ids);
}

static int loc_get_max_size_node(void)
{
    return nodestatsmem ? get_max_size_node(nodestatsmem) : 0;
}

static apr_status_t loc_remove_node(int id)
{
    return remove_node(nodestatsmem, id);
}

static apr_status_t loc_find_node(nodeinfo_t **node, const char *route)
{
    return find_node(nodestatsmem, node, route);
}

/**
 * Increase the version of the nodes table
 */
static void inc_version_node(void)
{
    version_data *base;
    if (storage->dptr(version_node_mem, 0, (void **)&base) == APR_SUCCESS) {
        base->counter++;
    }
}
static apr_uint64_t get_version_node(void)
{
    version_data *base;
    if (storage->dptr(version_node_mem, 0, (void **)&base) == APR_SUCCESS) {
        return base->counter;
    }
    return 0;
}
static void set_version_node(apr_uint64_t val)
{
    version_data *base;
    if (storage->dptr(version_node_mem, 0, (void **)&base) == APR_SUCCESS) {
        base->counter = val;
    }
}

/**
 * Check is the nodes (in shared memory) were modified since last
 * call to worker_nodes_are_updated().
 *
 * @param data server_rec
 * @param pool unused argument
 * @return 0 (no update) or X (the version has changed, the local table needs to be updated)
 */
static unsigned loc_worker_nodes_need_update(void *data, apr_pool_t *pool)
{
    int size;
    server_rec *s = (server_rec *)data;
    unsigned last = 0;
    mod_manager_config *mconf = ap_get_module_config(s->module_config, &manager_module);
    (void)pool;

    size = loc_get_max_size_node();
    if (size == 0) {
        return 0; /* broken */
    }

    last = get_version_node();

    if (last != mconf->tableversion) {
        return last;
    }
    return 0;
}

/**
 * Store the last version update in the proccess config
 */
static int loc_worker_nodes_are_updated(void *data, unsigned last)
{
    server_rec *s = (server_rec *)data;
    mod_manager_config *mconf = ap_get_module_config(s->module_config, &manager_module);
    mconf->tableversion = last;
    return 0;
}

static apr_status_t loc_lock_nodes(void)
{
    return apr_global_mutex_lock(node_mutex);
}

static apr_status_t loc_unlock_nodes(void)
{
    return apr_global_mutex_unlock(node_mutex);
}

static int loc_get_max_size_context(void)
{
    return contextstatsmem ? get_max_size_context(contextstatsmem) : 0;
}

static int loc_get_max_size_host(void)
{
    return hoststatsmem ? get_max_size_host(hoststatsmem) : 0;
}

/**
 * Remove the virtual hosts and contexts corresponding the node
 */
static void loc_remove_host_context(int node, apr_pool_t *pool)
{
    /* for read the hosts */
    int i;
    int size = loc_get_max_size_host();
    int *id;
    int sizecontext = loc_get_max_size_context();
    int *idcontext;

    if (size == 0) {
        return;
    }
    id = apr_palloc(pool, sizeof(int) * size);
    idcontext = apr_palloc(pool, sizeof(int) * sizecontext);
    size = get_ids_used_host(hoststatsmem, id);
    for (i = 0; i < size; i++) {
        hostinfo_t *ou;

        if (get_host(hoststatsmem, &ou, id[i]) != APR_SUCCESS) {
            continue;
        }
        if (ou->node == node) {
            remove_host(hoststatsmem, ou->id);
        }
    }

    sizecontext = get_ids_used_context(contextstatsmem, idcontext);
    for (i = 0; i < sizecontext; i++) {
        contextinfo_t *context;
        if (get_context(contextstatsmem, &context, idcontext[i]) != APR_SUCCESS) {
            continue;
        }
        if (context->node == node) {
            remove_context(contextstatsmem, context->id);
        }
    }
}

static const struct node_storage_method node_storage = {
    loc_read_node,
    loc_get_ids_used_node,
    loc_get_max_size_node,
    loc_worker_nodes_need_update,
    loc_worker_nodes_are_updated,
    loc_remove_node,
    loc_find_node,
    loc_remove_host_context,
    loc_lock_nodes,
    loc_unlock_nodes,
};

/*
 * routines for the context_storage_method
 */
static apr_status_t loc_read_context(int ids, contextinfo_t **context)
{
    return get_context(contextstatsmem, context, ids);
}

static int loc_get_ids_used_context(int *ids)
{
    return get_ids_used_context(contextstatsmem, ids);
}

static apr_status_t loc_lock_contexts(void)
{
    return apr_global_mutex_lock(context_mutex);
}

static apr_status_t loc_unlock_contexts(void)
{
    return apr_global_mutex_unlock(context_mutex);
}

/* clang-format off */
static const struct context_storage_method context_storage = {
    loc_read_context,
    loc_get_ids_used_context,
    loc_get_max_size_context,
    loc_lock_contexts,
    loc_unlock_contexts
};
/* clang-format on */

/*
 * routines for the host_storage_method
 */
static apr_status_t loc_read_host(int ids, hostinfo_t **host)
{
    return get_host(hoststatsmem, host, ids);
}

static int loc_get_ids_used_host(int *ids)
{
    return get_ids_used_host(hoststatsmem, ids);
}

static const struct host_storage_method host_storage = {
    loc_read_host,
    loc_get_ids_used_host,
    loc_get_max_size_host,
};

/*
 * routines for the balancer_storage_method
 */
static apr_status_t loc_read_balancer(int ids, balancerinfo_t **balancer)
{
    return get_balancer(balancerstatsmem, balancer, ids);
}

static int loc_get_ids_used_balancer(int *ids)
{
    return get_ids_used_balancer(balancerstatsmem, ids);
}

static int loc_get_max_size_balancer(void)
{
    return balancerstatsmem ? get_max_size_balancer(balancerstatsmem) : 0;
}

static const struct balancer_storage_method balancer_storage = {
    loc_read_balancer,
    loc_get_ids_used_balancer,
    loc_get_max_size_balancer,
};

/*
 * routines for the sessionid_storage_method
 */
static apr_status_t loc_read_sessionid(int ids, sessionidinfo_t **sessionid)
{
    return get_sessionid(sessionidstatsmem, sessionid, ids);
}

static int loc_get_ids_used_sessionid(int *ids)
{
    return get_ids_used_sessionid(sessionidstatsmem, ids);
}

static int loc_get_max_size_sessionid(void)
{
    return sessionidstatsmem ? get_max_size_sessionid(sessionidstatsmem) : 0;
}

static apr_status_t loc_remove_sessionid(sessionidinfo_t *sessionid)
{
    return remove_sessionid(sessionidstatsmem, sessionid);
}

static apr_status_t loc_insert_update_sessionid(sessionidinfo_t *sessionid)
{
    return insert_update_sessionid(sessionidstatsmem, sessionid);
}

static const struct sessionid_storage_method sessionid_storage = {
    loc_read_sessionid,   loc_get_ids_used_sessionid,  loc_get_max_size_sessionid,
    loc_remove_sessionid, loc_insert_update_sessionid,
};

/*
 * routines for the domain_storage_method
 */
static apr_status_t loc_read_domain(int ids, domaininfo_t **domain)
{
    return get_domain(domainstatsmem, domain, ids);
}

static int loc_get_ids_used_domain(int *ids)
{
    return get_ids_used_domain(domainstatsmem, ids);
}

static int loc_get_max_size_domain(void)
{
    return domainstatsmem ? get_max_size_domain(domainstatsmem) : 0;
}

static apr_status_t loc_remove_domain(domaininfo_t *domain)
{
    return remove_domain(domainstatsmem, domain);
}

static apr_status_t loc_insert_update_domain(domaininfo_t *domain)
{
    return insert_update_domain(domainstatsmem, domain);
}

static apr_status_t loc_find_domain(domaininfo_t **domain, const char *route, const char *balancer)
{
    return find_domain(domainstatsmem, domain, route, balancer);
}

/* clang-format off */
static const struct domain_storage_method domain_storage = {
    loc_read_domain,
    loc_get_ids_used_domain,
    loc_get_max_size_domain,
    loc_remove_domain,
    loc_insert_update_domain,
    loc_find_domain,
};
/* clang-format on */

/*
 * cleanup logic
 */
static apr_status_t cleanup_manager(void *param)
{
    /* shared memory */
    contextstatsmem = NULL;
    nodestatsmem = NULL;
    hoststatsmem = NULL;
    balancerstatsmem = NULL;
    sessionidstatsmem = NULL;
    domainstatsmem = NULL;
    version_node_mem = NULL;
    (void)param;
    return APR_SUCCESS;
}

static void mc_initialize_cleanup(apr_pool_t *p)
{
    apr_pool_cleanup_register(p, NULL, cleanup_manager, apr_pool_cleanup_null);
}

static void normalize_balancer_name(char *balancer_name, const server_rec *s)
{
    int upper_case_char_found = 0;
    char *balancer_name_start = balancer_name;
    for (; *balancer_name; ++balancer_name) {
        if (!upper_case_char_found) {
            upper_case_char_found = apr_isupper(*balancer_name);
        }
        *balancer_name = apr_tolower(*balancer_name);
    }
    balancer_name = balancer_name_start;
    if (upper_case_char_found) {
        ap_log_error(APLOG_MARK, APLOG_NOTICE, 0, s, SBALBAD, balancer_name);
    }
}

/*
 * This routine is called in the parent; we must register our
 * mutex type before the config is processed so that users can
 * adjust the mutex settings using the Mutex directive.
 */
static int manager_pre_config(apr_pool_t *pconf, apr_pool_t *plog, apr_pool_t *ptemp)
{
    (void)plog;
    (void)ptemp;
    ap_mutex_register(pconf, node_mutex_type, NULL, APR_LOCK_DEFAULT, 0);
    ap_mutex_register(pconf, context_mutex_type, NULL, APR_LOCK_DEFAULT, 0);
    proxyhctemplate = apr_table_make(plog, 1);
    return OK;
}

/*
 * Call after parser the configuration.
 * Creates the shared memory.
 */
static int manager_init(apr_pool_t *p, apr_pool_t *plog, apr_pool_t *ptemp, server_rec *s)
{
    char *node;
    char *context;
    char *host;
    char *balancer;
    char *sessionid;
    char *domain;
    char *version;
    apr_uuid_t uuid;
    mod_manager_config *mconf = ap_get_module_config(s->module_config, &manager_module);
    apr_status_t rv;
    (void)plog; /* unused variable */

    if (ap_state_query(AP_SQ_MAIN_STATE) == AP_SQ_MS_CREATE_PRE_CONFIG) {
        return OK;
    }

    if (mconf->basefilename) {
        node = apr_pstrcat(ptemp, mconf->basefilename, "/manager.node", NULL);
        context = apr_pstrcat(ptemp, mconf->basefilename, "/manager.context", NULL);
        host = apr_pstrcat(ptemp, mconf->basefilename, "/manager.host", NULL);
        balancer = apr_pstrcat(ptemp, mconf->basefilename, "/manager.balancer", NULL);
        sessionid = apr_pstrcat(ptemp, mconf->basefilename, "/manager.sessionid", NULL);
        domain = apr_pstrcat(ptemp, mconf->basefilename, "/manager.domain", NULL);
        version = apr_pstrcat(ptemp, mconf->basefilename, "/manager.version", NULL);
    } else {
        node = ap_server_root_relative(ptemp, "logs/manager.node");
        context = ap_server_root_relative(ptemp, "logs/manager.context");
        host = ap_server_root_relative(ptemp, "logs/manager.host");
        balancer = ap_server_root_relative(ptemp, "logs/manager.balancer");
        sessionid = ap_server_root_relative(ptemp, "logs/manager.sessionid");
        domain = ap_server_root_relative(ptemp, "logs/manager.domain");
        version = ap_server_root_relative(ptemp, "logs/manager.version");
    }

    /* Do some sanity checks */
    if (mconf->maxhost < mconf->maxnode) {
        ap_log_error(APLOG_MARK, APLOG_NOTICE, 0, s, "manager_init: Maxhost value increased to Maxnode (%d)",
                     mconf->maxnode);
        mconf->maxhost = mconf->maxnode;
    }
    if (mconf->maxcontext < mconf->maxhost) {
        ap_log_error(APLOG_MARK, APLOG_NOTICE, 0, s, "manager_init: Maxcontext value increased to Maxhost (%d)",
                     mconf->maxhost);
        mconf->maxcontext = mconf->maxhost;
    }

    /* Get a provider to handle the shared memory */
    storage = ap_lookup_provider(AP_SLOTMEM_PROVIDER_GROUP, "shm", AP_SLOTMEM_PROVIDER_VERSION);
    if (storage == NULL) {
        ap_log_error(APLOG_MARK, APLOG_EMERG, 0, s, "manager_init: ap_lookup_provider %s failed",
                     AP_SLOTMEM_PROVIDER_GROUP);
        return !OK;
    }
    nodestatsmem = create_mem_node(node, &mconf->maxnode, mconf->persistent + AP_SLOTMEM_TYPE_PREGRAB, p, storage);
    if (nodestatsmem == NULL) {
        ap_log_error(APLOG_MARK, APLOG_EMERG, 0, s, "manager_init: create_mem_node %s failed", node);
        return !OK;
    }
    if (get_last_mem_error(nodestatsmem) != APR_SUCCESS) {
        char buf[120];
        ap_log_error(APLOG_MARK, APLOG_EMERG, 0, s, "manager_init: create_mem_node %s failed: %s", node,
                     apr_strerror(get_last_mem_error(nodestatsmem), buf, sizeof(buf)));
        return !OK;
    }

    contextstatsmem =
        create_mem_context(context, &mconf->maxcontext, mconf->persistent + AP_SLOTMEM_TYPE_PREGRAB, p, storage);
    if (contextstatsmem == NULL) {
        ap_log_error(APLOG_MARK, APLOG_EMERG, 0, s, "manager_init: create_mem_context failed");
        return !OK;
    }

    hoststatsmem = create_mem_host(host, &mconf->maxhost, mconf->persistent + AP_SLOTMEM_TYPE_PREGRAB, p, storage);
    if (hoststatsmem == NULL) {
        ap_log_error(APLOG_MARK, APLOG_EMERG, 0, s, "manager_init: create_mem_host failed");
        return !OK;
    }

    balancerstatsmem =
        create_mem_balancer(balancer, &mconf->maxhost, mconf->persistent + AP_SLOTMEM_TYPE_PREGRAB, p, storage);
    if (balancerstatsmem == NULL) {
        ap_log_error(APLOG_MARK, APLOG_EMERG, 0, s, "manager_init: create_mem_balancer failed");
        return !OK;
    }

    if (mconf->maxsessionid) {
        /* Only create sessionid stuff if required */
        sessionidstatsmem = create_mem_sessionid(sessionid, &mconf->maxsessionid,
                                                 mconf->persistent + AP_SLOTMEM_TYPE_PREGRAB, p, storage);
        if (sessionidstatsmem == NULL) {
            ap_log_error(APLOG_MARK, APLOG_EMERG, 0, s, "manager_init: create_mem_sessionid failed");
            return !OK;
        }
    }

    domainstatsmem =
        create_mem_domain(domain, &mconf->maxnode, mconf->persistent + AP_SLOTMEM_TYPE_PREGRAB, p, storage);
    if (domainstatsmem == NULL) {
        ap_log_error(APLOG_MARK, APLOG_EMERG, 0, s, "manager_init: create_mem_domain failed");
        return !OK;
    }

    /* For the version node we just need a apr_uint64_t in shared memory */
    rv = storage->create(&version_node_mem, version, sizeof(apr_uint64_t), 1, AP_SLOTMEM_TYPE_PREGRAB, p);
    if (rv != APR_SUCCESS) {
        ap_log_error(APLOG_MARK, APLOG_EMERG, rv, s, "manager_init: create_share_version failed");
        return !OK;
    }
    set_version_node(0);

    /* Get a provider to ping/pong logics */
    balancerhandler = ap_lookup_provider("proxy_cluster", "balancer", "0");
    if (balancerhandler == NULL) {
        ap_log_error(APLOG_MARK, APLOG_WARNING, 0, s, "manager_init: can't find a ping/pong logic");
    }

    advertise_info = ap_lookup_provider("advertise", "info", "0");
    balancer_manage = APR_RETRIEVE_OPTIONAL_FN(balancer_manage);

    /* Retrieve a UUID and store the nonce. */
    apr_uuid_get(&uuid);
    apr_uuid_format(balancer_nonce, &uuid);

    /* Clean up to prevent backgroup thread (proxy_cluster_watchdog_func) to crash */
    mc_initialize_cleanup(p);

    /* Create global mutex */
    if (ap_global_mutex_create(&node_mutex, NULL, node_mutex_type, NULL, s, p, 0) != APR_SUCCESS) {
        ap_log_error(APLOG_MARK, APLOG_EMERG, 0, s, "manager_init: ap_global_mutex_create %s failed", node_mutex_type);
        return !OK;
    }
    if (ap_global_mutex_create(&context_mutex, NULL, context_mutex_type, NULL, s, p, 0) != APR_SUCCESS) {
        ap_log_error(APLOG_MARK, APLOG_EMERG, 0, s, "manager_init: ap_global_mutex_create %s failed", node_mutex_type);
        return !OK;
    }

    return OK;
}

static apr_status_t decodeenc(char **ptr);
static char **process_buff(request_rec *r, char *buff)
{
    int i = 0;
    char *s = buff;
    char **ptr = NULL;
    for (; *s != '\0'; s++) {
        if (*s == '&' || *s == '=') {
            i++;
        }
    }
    ptr = apr_palloc(r->pool, sizeof(char *) * (i + 2));
    if (ptr == NULL) {
        return NULL;
    }

    s = buff;
    ptr[0] = s;
    ptr[i + 1] = NULL;
    i = 1;
    for (; *s != '\0'; s++) {
        /* our separators */
        if (*s == '&' || *s == '=') {
            *s = '\0';
            ptr[i] = s + 1;
            i++;
        }
    }

    if (decodeenc(ptr) != APR_SUCCESS) {
        return NULL;
    }

    return ptr;
}

static apr_status_t insert_update_host_helper(server_rec *s, mem_t *mem, hostinfo_t *info, char *alias)
{
    (void)s;
    strncpy(info->host, alias, HOSTALIASZ);
    info->host[HOSTALIASZ] = '\0';
    return insert_update_host(mem, info);
}

/**
 * Insert the hosts from Alias information
 */
static apr_status_t insert_update_hosts(server_rec *s, mem_t *mem, char *str, int node, int vhost)
{
    hostinfo_t info;
    apr_status_t status;
    char *ptr = str;
    char *previous = str;

    char empty[] = {'\0'};
    if (str == NULL) {
        ptr = empty;
        previous = empty;
    }

    info.node = node;
    info.vhost = vhost;

    while (*ptr) {
        if (*ptr == ',') {
            *ptr = '\0';
            status = insert_update_host_helper(s, mem, &info, previous);
            if (status != APR_SUCCESS) {
                return status;
            }
            previous = ptr + 1;
        }
        ptr++;
    }

    return insert_update_host_helper(s, mem, &info, previous);
}

/**
 * Remove the context using the contextinfo_t information
 * we read it first then remove it
 */
static void read_remove_context(mem_t *mem, contextinfo_t *context)
{
    contextinfo_t *info;
    info = read_context(mem, context);
    if (info != NULL) {
        remove_context(mem, info->id);
    }
}

static apr_status_t insert_update_context_helper(server_rec *s, mem_t *mem, contextinfo_t *info, char *context,
                                                 int status)
{
    (void)s;
    info->id = 0;
    strncpy(info->context, context, CONTEXTSZ);
    info->context[CONTEXTSZ] = '\0';
    if (status == REMOVE) {
        read_remove_context(mem, info);
        return APR_SUCCESS;
    }

    return insert_update_context(mem, info);
}

/**
 * Insert the context from Context information
 * Note:
 *     1 - if status is REMOVE remove_context will be called
 *     2 - return codes of REMOVE are ignored (always success)
 */
static apr_status_t insert_update_contexts(server_rec *s, mem_t *mem, char *str, int node, int vhost, int status)
{
    char *ptr = str;
    char *previous = str;
    apr_status_t ret = APR_SUCCESS;
    contextinfo_t info;

    char root[] = "/";
    if (ptr == NULL) {
        ptr = root;
        previous = root;
    }

    info.node = node;
    info.vhost = vhost;
    info.status = status;

    while (*ptr) {
        if (*ptr == ',') {
            *ptr = '\0';
            ret = insert_update_context_helper(s, mem, &info, previous, status);
            if (ret != APR_SUCCESS) {
                return ret;
            }

            previous = ptr + 1;
        }
        ptr++;
    }

    return insert_update_context_helper(s, mem, &info, previous, status);
}

/**
 * Check that the node could be handle as is there were the same
 */
static int is_same_node(const nodeinfo_t *nodeinfo, const nodeinfo_t *node)
{
    if (strcmp(nodeinfo->mess.balancer, node->mess.balancer)) {
        return 0;
    }
    if (strcmp(nodeinfo->mess.Host, node->mess.Host)) {
        return 0;
    }
    if (strcmp(nodeinfo->mess.Port, node->mess.Port)) {
        return 0;
    }
    if (strcmp(nodeinfo->mess.Type, node->mess.Type)) {
        return 0;
    }
    if (nodeinfo->mess.reversed != node->mess.reversed) {
        return 0;
    }

    /* Those means the reslist has to be changed */
    if (nodeinfo->mess.smax != node->mess.smax) {
        return 0;
    }
    if (nodeinfo->mess.ttl != node->mess.ttl) {
        return 0;
    }

    /* All other fields can be modified without causing problems */
    return 1;
}

/**
 * Check if another node has the same worker
 */
static int is_same_worker_existing(const request_rec *r, const nodeinfo_t *node)
{
    int size, i;
    int *id;
    size = loc_get_max_size_node();
    if (size == 0) {
        return 0;
    }
    id = apr_palloc(r->pool, sizeof(int) * size);
    size = get_ids_used_node(nodestatsmem, id);
    for (i = 0; i < size; i++) {
        nodeinfo_t *ou;
        if (get_node(nodestatsmem, &ou, id[i]) != APR_SUCCESS) {
            continue;
        }
        if (is_same_node(ou, node)) {
            /* we have a node that corresponds to the same worker */
            if (!strcmp(ou->mess.JVMRoute, node->mess.JVMRoute)) {
                return 0; /* well it is the same */
            }
            if (ou->mess.remove) {
                if (strcmp(ou->mess.JVMRoute, "REMOVED") == 0) {
                    /* Look in remove_removed_node, only "REMOVED" have cleaned the contexts/hosts */
                    return 0; /* well it marked removed */
                }
            }
            ap_log_error(APLOG_MARK, APLOG_WARNING, 0, r->server,
                         "process_config: nodes %s and %s correspond to the same worker", node->mess.JVMRoute,
                         ou->mess.JVMRoute);
            return 1;
        }
    }
    return 0;
}

/**
 * Builds the parameter for mod_balancer
 */
static apr_status_t mod_manager_manage_worker(request_rec *r, const nodeinfo_t *node, const balancerinfo_t *bal)
{
    apr_table_t *params;
    apr_status_t rv;
    int i;
    const apr_array_header_t *h;
    const apr_table_entry_t *entries;

    params = apr_table_make(r->pool, 10);
    /* balancer */
    apr_table_set(params, "b", node->mess.balancer);
    apr_table_set(params, "b_lbm", "cluster");
    apr_table_set(params, "b_tmo", apr_psprintf(r->pool, "%d", bal->Timeout));
    apr_table_set(params, "b_max", apr_psprintf(r->pool, "%d", bal->Maxattempts));
    apr_table_set(params, "b_ss", apr_pstrcat(r->pool, bal->StickySessionCookie, "|", bal->StickySessionPath, NULL));

    /* and new worker */
    apr_table_set(params, "b_wyes", "1");
    apr_table_set(params, "b_nwrkr",
                  apr_pstrcat(r->pool, node->mess.Type, "://", node->mess.Host, ":", node->mess.Port, NULL));
    rv = balancer_manage(r, params);
    if (rv != APR_SUCCESS) {
        return rv;
    }
    apr_table_clear(params);

    /* now process the worker */
    apr_table_set(params, "b", node->mess.balancer);
    apr_table_set(params, "w",
                  apr_pstrcat(r->pool, node->mess.Type, "://", node->mess.Host, ":", node->mess.Port, NULL));
    apr_table_set(params, "w_wr", node->mess.JVMRoute);
    apr_table_set(params, "w_status_D", "0"); /* Not Dissabled */

    /* set the health check (requires mod_proxy_hcheck) */
    /* CPING for AJP and OPTIONS for HTTP/1.1 */
    apr_table_set(params, "w_hm", strcmp(node->mess.Type, "ajp") ? "OPTIONS" : "CPING");

    /* Use 10 sec for the moment, the idea is to adjust it with the STATUS frequency */
    apr_table_set(params, "w_hi", "10000");

    h = apr_table_elts(proxyhctemplate);
    entries = (const apr_table_entry_t *)h->elts;

    for (i = 0; i < h->nelts; i++) {
        const char *key = translate_balancer_params(entries[i].key);
        if (key != NULL) {
            apr_table_set(params, key, entries[i].val);
        }
    }

    return balancer_manage(r, params);
}

/**
 * Check if the proxy balancer module already has a worker and return the id
 */
static proxy_worker *proxy_node_getid(request_rec *r, const nodeinfo_t *nodeinfo, int *id,
                                      const proxy_server_conf **the_conf)
{
    if (balancerhandler != NULL) {
        return balancerhandler->proxy_node_getid(r, nodeinfo->mess.balancer, nodeinfo->mess.Type, nodeinfo->mess.Host,
                                                 nodeinfo->mess.Port, id, the_conf);
    }
    return NULL;
}

static void reenable_proxy_worker(request_rec *r, nodeinfo_t *node, proxy_worker *worker, nodeinfo_t *nodeinfo,
                                  const proxy_server_conf *the_conf)
{
    if (balancerhandler != NULL) {
        balancerhandler->reenable_proxy_worker(r->server, node, worker, nodeinfo, the_conf);
    }
}

static int proxy_node_get_free_id(request_rec *r, int node_table_size)
{
    if (balancerhandler != NULL) {
        return balancerhandler->proxy_node_get_free_id(r, node_table_size);
    }
    return -1;
}

/*
 * Parse boolean parameter where Yes/On are true and No/Off are false.
 * @return true iff an input was recognized, false otherwise
 */
static int process_boolean_parameter(const char *val, int *parameter)
{
    if (strcasecmp(val, "yes") == 0 || strcasecmp(val, "on") == 0) {
        *parameter = 1;
        return 1;
    } else if (strcasecmp(val, "no") == 0 || strcasecmp(val, "off") == 0) {
        *parameter = 0;
        return 1;
    }

    return 0;
}

static void process_config_balancer_defaults(request_rec *r, balancerinfo_t *balancerinfo, mod_manager_config *mconf)
{
    memset(balancerinfo, '\0', sizeof(*balancerinfo));
    if (mconf->balancername != NULL) {
        normalize_balancer_name(mconf->balancername, r->server);
        strncpy(balancerinfo->balancer, mconf->balancername, sizeof(balancerinfo->balancer));
        balancerinfo->balancer[sizeof(balancerinfo->balancer) - 1] = '\0';
    } else {
        strcpy(balancerinfo->balancer, "mycluster");
    }
    balancerinfo->StickySession = 1;
    balancerinfo->StickySessionForce = 1;
    balancerinfo->StickySessionRemove = 0;
    strcpy(balancerinfo->StickySessionCookie, "JSESSIONID");
    strcpy(balancerinfo->StickySessionPath, "jsessionid");
    balancerinfo->Maxattempts = 1;
    balancerinfo->Timeout = 0;
}

static void process_config_node_defaults(request_rec *r, nodeinfo_t *nodeinfo, mod_manager_config *mconf)
{
    memset(&nodeinfo->mess, '\0', sizeof(nodeinfo->mess));
    if (mconf->balancername != NULL) {
        normalize_balancer_name(mconf->balancername, r->server);
        strncpy(nodeinfo->mess.balancer, mconf->balancername, sizeof(nodeinfo->mess.balancer));
        nodeinfo->mess.balancer[sizeof(nodeinfo->mess.balancer) - 1] = '\0';
    } else {
        strcpy(nodeinfo->mess.balancer, "mycluster");
    }
    strcpy(nodeinfo->mess.Host, "localhost");
    strcpy(nodeinfo->mess.Port, "8009");
    strcpy(nodeinfo->mess.Type, "ajp");
    nodeinfo->mess.Upgrade[0] = '\0';
    nodeinfo->mess.AJPSecret[0] = '\0';
    nodeinfo->mess.reversed = 0;
    nodeinfo->mess.remove = 0;               /* not marked as removed */
    nodeinfo->mess.flushpackets = flush_off; /* FLUSH_OFF; See enum flush_packets in proxy.h flush_off */
    nodeinfo->mess.flushwait = PROXY_FLUSH_WAIT;
    nodeinfo->mess.ping = apr_time_from_sec(10);
    nodeinfo->mess.smax = -1; /* let mod_proxy logic get the right one */
    nodeinfo->mess.ttl = apr_time_from_sec(60);
    nodeinfo->mess.timeout = 0;
    nodeinfo->mess.id = -1;
    nodeinfo->mess.lastcleantry = 0;
    nodeinfo->mess.has_workers = 0;
}

static char *process_config_balancer(const request_rec *r, const char *key, char *val, balancerinfo_t *balancerinfo,
                                     nodeinfo_t *nodeinfo, int *errtype)
{
    if (strcasecmp(key, "Balancer") == 0) {
        if (strlen(val) >= sizeof(nodeinfo->mess.balancer)) {
            *errtype = TYPESYNTAX;
            return SBALBIG;
        }
        normalize_balancer_name(val, r->server);
        strncpy(nodeinfo->mess.balancer, val, sizeof(nodeinfo->mess.balancer));
        nodeinfo->mess.balancer[sizeof(nodeinfo->mess.balancer) - 1] = '\0';
        strncpy(balancerinfo->balancer, val, sizeof(balancerinfo->balancer));
        balancerinfo->balancer[sizeof(balancerinfo->balancer) - 1] = '\0';
    }
    if (strcasecmp(key, "StickySession") == 0) {
        process_boolean_parameter(val, &balancerinfo->StickySession);
    }
    if (strcasecmp(key, "StickySessionCookie") == 0) {
        if (strlen(val) >= sizeof(balancerinfo->StickySessionCookie)) {
            *errtype = TYPESYNTAX;
            return SBAFBIG;
        }
        strcpy(balancerinfo->StickySessionCookie, val);
    }
    if (strcasecmp(key, "StickySessionPath") == 0) {
        if (strlen(val) >= sizeof(balancerinfo->StickySessionPath)) {
            *errtype = TYPESYNTAX;
            return SBAFBIG;
        }
        strcpy(balancerinfo->StickySessionPath, val);
    }
    if (strcasecmp(key, "StickySessionRemove") == 0) {
        process_boolean_parameter(val, &balancerinfo->StickySessionRemove);
    }
    /* The java part assumes default = yes and sents only StickySessionForce=No */
    if (strcasecmp(key, "StickySessionForce") == 0) {
        process_boolean_parameter(val, &balancerinfo->StickySessionForce);
    }
    /* Note that it is workerTimeout (set/getWorkerTimeout in java code) */
    if (strcasecmp(key, "WaitWorker") == 0) {
        balancerinfo->Timeout = apr_time_from_sec(atoi(val));
    }
    if (strcasecmp(key, "Maxattempts") == 0) {
        balancerinfo->Maxattempts = atoi(val);
    }

    return NULL;
}

static char *process_config_node(const char *key, char *val, nodeinfo_t *nodeinfo, int *errtype)
{
    apr_interval_time_t time;

    if (strcasecmp(key, "JVMRoute") == 0) {
        if (strlen(val) >= sizeof(nodeinfo->mess.JVMRoute)) {
            *errtype = TYPESYNTAX;
            return SROUBIG;
        }
        strcpy(nodeinfo->mess.JVMRoute, val);
    }
    /* We renamed it LBGroup */
    if (strcasecmp(key, "Domain") == 0) {
        if (strlen(val) >= sizeof(nodeinfo->mess.Domain)) {
            *errtype = TYPESYNTAX;
            return SDOMBIG;
        }
        strcpy(nodeinfo->mess.Domain, val);
    }
    if (strcasecmp(key, "Host") == 0) {
        char *p_read = val, *p_write = val;
        int flag = 0;
        if (strlen(val) >= sizeof(nodeinfo->mess.Host)) {
            *errtype = TYPESYNTAX;
            return SHOSBIG;
        }
        /* Removes %zone from an address */
        if (*p_read == '[') {
            while (*p_read) {
                *p_write = *p_read++;
                if ((*p_write == '%' || flag) && *p_write != ']') {
                    flag = 1;
                } else {
                    p_write++;
                }
            }
            *p_write = '\0';
        }
        strcpy(nodeinfo->mess.Host, val);
    }
    if (strcasecmp(key, "Port") == 0) {
        if (strlen(val) >= sizeof(nodeinfo->mess.Port)) {
            *errtype = TYPESYNTAX;
            return SPORBIG;
        }
        strcpy(nodeinfo->mess.Port, val);
    }
    if (strcasecmp(key, "Type") == 0) {
        if (strlen(val) >= sizeof(nodeinfo->mess.Type)) {
            *errtype = TYPESYNTAX;
            return STYPBIG;
        }
        strcpy(nodeinfo->mess.Type, val);
    }
    if (strcasecmp(key, "Reversed") == 0) {
        process_boolean_parameter(val, &nodeinfo->mess.reversed);
    }
    if (strcasecmp(key, "flushpackets") == 0) {
        if (!process_boolean_parameter(val, (int *)&nodeinfo->mess.flushpackets)) {
            if (strcasecmp(val, "auto") == 0) {
                nodeinfo->mess.flushpackets = flush_auto;
            }
        }
    }
    if (strcasecmp(key, "flushwait") == 0) {
        if (ap_timeout_parameter_parse(val, &time, "ms") != APR_SUCCESS) {
            *errtype = TYPESYNTAX;
            return SFLUBAD;
        } else {
            nodeinfo->mess.flushwait = time;
        }
    }
    if (strcasecmp(key, "ping") == 0) {
        if (ap_timeout_parameter_parse(val, &time, "s") != APR_SUCCESS) {
            *errtype = TYPESYNTAX;
            return SPNGBAD;
        } else {
            nodeinfo->mess.ping = time;
        }
    }
    if (strcasecmp(key, "smax") == 0) {
        nodeinfo->mess.smax = atoi(val);
    }
    if (strcasecmp(key, "ttl") == 0) {
        if (ap_timeout_parameter_parse(val, &time, "s") != APR_SUCCESS) {
            *errtype = TYPESYNTAX;
            return STTLBAD;
        } else {
            nodeinfo->mess.ttl = time;
        }
    }
    if (strcasecmp(key, "Timeout") == 0) {
        if (ap_timeout_parameter_parse(val, &time, "s") != APR_SUCCESS) {
            *errtype = TYPESYNTAX;
            return STIMBAD;
        } else {
            nodeinfo->mess.timeout = time;
        }
    }

    return NULL;
}

static nodeinfo_t *read_node_by_id(mem_t *mem, int id)
{
    nodeinfo_t workernodeinfo;
    workernodeinfo.mess.id = id;
    (void)mem;
    return read_node(nodestatsmem, &workernodeinfo);
}

static void mark_node_removed(nodeinfo_t *node)
{
    if (node) {
        strcpy(node->mess.JVMRoute, "REMOVED");
        node->mess.remove = 1;
        node->updatetime = apr_time_now();
        node->mess.num_remove_check = 0;
    }
}
static const proxy_worker_shared *read_shared_by_node(request_rec *r, nodeinfo_t *node)
{
    void *sconf = r->server->module_config;
    int i, port;
    char *name = apr_pstrcat(r->pool, BALANCER_PREFIX, node->mess.balancer, NULL);
    proxy_server_conf *conf = (proxy_server_conf *)ap_get_module_config(sconf, &proxy_module);
    proxy_balancer *balancer = (proxy_balancer *)conf->balancers->elts;
    if (sscanf(node->mess.Port, "%u", &port) != 1) {
        return NULL; /* something is wrong */
    }
    for (i = 0; i < conf->balancers->nelts; i++, balancer++) {
        int j;
        proxy_worker **workers;
        if (strcmp(balancer->s->name, name)) {
            continue;
        }
        /* Sync the shared memory for balancer */
        ap_proxy_sync_balancer(balancer, r->server, conf);

        workers = (proxy_worker **)balancer->workers->elts;
        for (j = 0; j < balancer->workers->nelts; j++, workers++) {
            proxy_worker *worker = *workers;
            ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                         "read_shared_by_node: Balancer %s worker (%d) %s, %s, %d", balancer->s->name, worker->s->index,
                         worker->s->route, worker->s->hostname, worker->s->port);
            if (worker->s->port == port && strcmp(worker->s->hostname, node->mess.Host) == 0 &&
                strcmp(worker->s->route, node->mess.JVMRoute) == 0) {
                return worker->s;
            }
        }
    }

    return NULL;
}

/* 0 if limit is OK (not exceeded), 1 otherwise */
static int check_context_alias_length(const char *str, int limit)
{
    int i = 0, len = 0;
    while (str[i]) {
        if (str[i] == ',') {
            len = 0;
        }
        if (len >= limit) {
            return 1;
        }
        len++;
        i++;
    }

    return 0;
}

/**
 * Process Alias and Context if present.
 * We process both in two different context:
 *     1) during CONFIG command
 *     2) during APP command
 * to differenciate between the two use the last argument (true -> CONFIG, false -> APP)
 */
static char *process_context_alias(char *key, char *val, apr_pool_t *p, char **contexts, char **aliases, int *errtype,
                                   int in_config)
{
    if (strcasecmp(key, "Alias") == 0) {
        char *tmp;

        if (*aliases && !in_config) {
            *errtype = TYPESYNTAX;
            return in_config ? SALIBAD : SMULALB;
        }
        if (check_context_alias_length(val, HOSTALIASZ)) {
            *errtype = TYPESYNTAX;
            return SALIBIG;
        }

        /* Aliases to lower case for further case-insensitive treatment, IETF RFC 1035 Section 2.3.3. */
        tmp = val;
        while (*tmp) {
            *tmp = apr_tolower(*tmp);
            tmp++;
        }

        if (*aliases) {
            *aliases = apr_pstrcat(p, *aliases, ",", val, NULL);
        } else {
            *aliases = val;
        }
    }

    if (strcasecmp(key, "Context") == 0) {
        if (*contexts && !in_config) {
            *errtype = TYPESYNTAX;
            return SMULCTB;
        }
        if (check_context_alias_length(val, CONTEXTSZ)) {
            *errtype = TYPESYNTAX;
            return SCONBIG;
        }

        if (*contexts) {
            *contexts = apr_pstrcat(p, *contexts, ",", val, NULL);
        } else {
            *contexts = val;
        }
    }

    return NULL;
}

/*
 * Process a CONFIG message
 * Balancer: <Balancer name>
 * <balancer configuration>
 * StickySession	StickySessionCookie	StickySessionPath	StickySessionRemove
 * StickySessionForce	Timeout	Maxattempts
 * JvmRoute?: <JvmRoute>
 * Domain: <Domain>
 * <Host: <Node IP>
 * Port: <Connector Port>
 * Type: <Type of the connector>
 * Reserved: <Use connection pool initiated by Tomcat *.>
 * <node conf>
 * flushpackets	flushwait	ping	smax	ttl
 * Virtual hosts in JBossAS
 * Alias: <vhost list>
 * Context corresponding to the applications.
 * Context: <context list>
 */
static char *process_config(request_rec *r, char **ptr, int *errtype)
{
    /* Process the node/balancer description */
    nodeinfo_t nodeinfo;
    nodeinfo_t *node;
    balancerinfo_t balancerinfo;

    char *contexts = NULL;
    char *aliases = NULL;

    int i = 0;
    int id = -1;
    int vid = 1; /* zero and "" is empty */
    int removed = -1;
    void *sconf = r->server->module_config;
    mod_manager_config *mconf = ap_get_module_config(sconf, &manager_module);
    int clean = 1;
    proxy_worker *worker;
    const proxy_server_conf *the_conf = NULL;
    apr_status_t rv;

    /* Fill default node values */
    process_config_node_defaults(r, &nodeinfo, mconf);
    ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "process_config: Start");

    /* Fill default balancer values */
    process_config_balancer_defaults(r, &balancerinfo, mconf);

    while (ptr[i]) {
        char *err_msg = NULL;
        if (!ptr[i + 1] || *ptr[i + 1] == '\0') {
            *errtype = TYPESYNTAX;
            return SMESPAR;
        }

        /* Balancer part */
        err_msg = process_config_balancer(r, ptr[i], ptr[i + 1], &balancerinfo, &nodeinfo, errtype);
        if (err_msg != NULL) {
            return err_msg;
        }
        /* Node part */
        err_msg = process_config_node(ptr[i], ptr[i + 1], &nodeinfo, errtype);
        if (err_msg != NULL) {
            return err_msg;
        }
        /* Optional parameters */
        err_msg = process_context_alias(ptr[i], ptr[i + 1], r->pool, &contexts, &aliases, errtype, 1);
        if (err_msg != NULL) {
            return err_msg;
        }

        i += 2;
    }

    /* Check for JVMRoute */
    if (nodeinfo.mess.JVMRoute[0] == '\0') {
        *errtype = TYPESYNTAX;
        return SROUBAD;
    }

    if (mconf->enable_ws_tunnel && strcmp(nodeinfo.mess.Type, "ajp")) {
        if (!strcmp(nodeinfo.mess.Type, "http")) {
            strcpy(nodeinfo.mess.Type, "ws");
        }
        if (!strcmp(nodeinfo.mess.Type, "https")) {
            strcpy(nodeinfo.mess.Type, "wss");
        }
        if (mconf->ws_upgrade_header) {
            strncpy(nodeinfo.mess.Upgrade, mconf->ws_upgrade_header, sizeof(nodeinfo.mess.Upgrade));
            nodeinfo.mess.Upgrade[sizeof(nodeinfo.mess.Upgrade) - 1] = '\0';
        } else {
            strcpy(nodeinfo.mess.Upgrade, "websocket");
        }
    }

    if (strcmp(nodeinfo.mess.Type, "ajp") == 0) {
        if (mconf->ajp_secret) {
            strncpy(nodeinfo.mess.AJPSecret, mconf->ajp_secret, sizeof(nodeinfo.mess.AJPSecret));
            nodeinfo.mess.AJPSecret[sizeof(nodeinfo.mess.AJPSecret) - 1] = '\0';
        }
    }

    if (mconf->response_field_size && strcmp(nodeinfo.mess.Type, "ajp")) {
        nodeinfo.mess.ResponseFieldSize = mconf->response_field_size;
    }
    /* Insert or update balancer description */
    rv = loc_lock_nodes();
    ap_assert(rv == APR_SUCCESS);
    if (insert_update_balancer(balancerstatsmem, &balancerinfo) != APR_SUCCESS) {
        loc_unlock_nodes();
        *errtype = TYPEMEM;
        return apr_psprintf(r->pool, MBALAUI, nodeinfo.mess.JVMRoute);
    }

    /* check for removed node */
    node = read_node(nodestatsmem, &nodeinfo);
    if (node != NULL) {
        /* If the node is removed (or kill and restarted) and recreated unchanged that is ok: network problems */
        if (!is_same_node(node, &nodeinfo)) {
            /* Here we can't update it because the old one is still in */
            char *mess = apr_psprintf(r->pool, MNODERM, node->mess.JVMRoute);
            ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server,
                         "process_config: node %s %d %s : %s  %s already exists, removing...", node->mess.JVMRoute,
                         node->mess.id, node->mess.Port, nodeinfo.mess.JVMRoute, nodeinfo.mess.Port);
            mark_node_removed(node);
            loc_remove_host_context(node->mess.id, r->pool);
            inc_version_node();
            loc_unlock_nodes();
            *errtype = TYPEMEM;
            return mess;
        }
    }
    /* check if a node corresponding to the same worker already exists */
    if (is_same_worker_existing(r, &nodeinfo)) {
        loc_unlock_nodes();
        *errtype = TYPEMEM;
        return MNODEET;
    }

    /* Check for corresponding proxy_worker */
    worker = proxy_node_getid(r, &nodeinfo, &id, &the_conf);
    if (id != -1) {
        /* Same node should be OK, different nodes will bring problems */
        if (node != NULL && node->mess.id == id) {
            ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                         "process_config: worker %d (%s) exists and should be OK", id, nodeinfo.mess.JVMRoute);
        } else {
            /* Here that is the tricky part, we will insert_update the whole node including proxy_worker_shared */
            char *pptr;

            ap_log_error(APLOG_MARK, APLOG_WARNING, 0, r->server,
                         "process_config: worker %d (%s) exists and IS NOT OK!!!", id, nodeinfo.mess.JVMRoute);
            if (node == NULL) {
                /* try to read the node */
                nodeinfo_t *workernode = read_node_by_id(nodestatsmem, id);
                if (workernode != NULL) {
                    if (strcmp(workernode->mess.JVMRoute, "REMOVED") == 0) {
                        /* We are in the remove process */
                        /* Something to clean ? */
                        strcpy(workernode->mess.JVMRoute, nodeinfo.mess.JVMRoute);
                        /* if the workernode->mess is zeroed we are going to reinsert it */
                    } else if ((workernode->mess.JVMRoute[0] != '\0') &&
                               (strcmp(workernode->mess.JVMRoute, nodeinfo.mess.JVMRoute) != 0)) {
                        ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server,
                                     "process_config: worker %d (%s) exists and does NOT correspond to %s", id,
                                     workernode->mess.JVMRoute, nodeinfo.mess.JVMRoute);
                        loc_unlock_nodes();
                        *errtype = TYPEMEM;
                        return MNODEET;
                    }
                    removed = id; /* we save the id of the worknode in case insert/update fails */
                }
            }
            clean = 0;
            ap_assert(worker->s->port != 0);
            /* XXX: really needed? offset logic OK here, we save the worker information (see mod_proxy_cluster) */
            pptr = (char *)&nodeinfo;
            pptr = pptr + NODEOFFSET;
            memcpy(pptr, worker->s, sizeof(proxy_worker_shared)); /* restore the information we are going to reuse */
            ap_assert(the_conf);
        }
    } else {
        nodeinfo_t *workernode;
        rv = find_node_byhostport(nodestatsmem, &workernode, nodeinfo.mess.Host, nodeinfo.mess.Port);
        if (rv == APR_SUCCESS) {
            /* Normally the node is just being removed, so no host/context but some other child might have a worker */
            ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "process_config: NOT NEW (%d %s) %s %s (%s)",
                         workernode->mess.id, workernode->mess.JVMRoute, workernode->mess.Host, workernode->mess.Port,
                         nodeinfo.mess.JVMRoute);

            id = workernode->mess.id;
            if (strcmp(workernode->mess.JVMRoute, "REMOVED") == 0) {
                strcpy(workernode->mess.JVMRoute, nodeinfo.mess.JVMRoute);
                workernode->mess.remove = 0;
                workernode->mess.num_remove_check = 0;
            }
        } else {
            ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "process_config: NEW (%s) %s", nodeinfo.mess.JVMRoute,
                         nodeinfo.mess.Port);
        }
    }
    if (id == -1) {
        /* make sure we insert in a "free" node according to the worker logic */
        id = proxy_node_get_free_id(r, node_storage.get_max_size_node());
        if (id == -1 && balancerhandler != NULL) {
            ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                         "process_config: NEW (%s) %s %s will not be added (Maxnode reached)", nodeinfo.mess.JVMRoute,
                         nodeinfo.mess.Host, nodeinfo.mess.Port);
        } else if (id != -1) {
            ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "process_config: NEW (%s) %s %s in %d",
                         nodeinfo.mess.JVMRoute, nodeinfo.mess.Host, nodeinfo.mess.Port, id);
        }
    }

    /* Insert or update node description */
    if (insert_update_node(nodestatsmem, &nodeinfo, &id, clean) != APR_SUCCESS) {
        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                     "process_config: insert_update_node failed for %s clean: %d", nodeinfo.mess.JVMRoute, clean);
        if (removed != -1) {
            nodeinfo_t *workernode = read_node_by_id(nodestatsmem, removed);
            mark_node_removed(workernode);
        }
        loc_unlock_nodes();
        *errtype = TYPEMEM;
        return apr_psprintf(r->pool, MNODEUI, nodeinfo.mess.JVMRoute);
    }

    if (clean == 0) {
        /* need to read the node */
        nodeinfo_t *workernode = read_node_by_id(nodestatsmem, id);
        ap_assert(workernode != NULL);
        ap_assert(the_conf);
        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "process_config: worker %d (%s) inserted", id,
                     nodeinfo.mess.JVMRoute);
        /* make sure we can use it */
        ap_assert(worker->context != NULL);
        ap_assert(workernode->mess.id == id);
        ap_assert(the_conf);

        /* so the scheme, hostname and port correspond to worker which was removed and readded */
        reenable_proxy_worker(r, workernode, worker, &nodeinfo, the_conf);
        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                     "process_config: reenable_proxy_worker... scheme %s hostname %s port %d route %s name %s id: %d",
                     worker->s->scheme, worker->s->hostname_ex, worker->s->port, worker->s->route,
#ifdef PROXY_WORKER_EXT_NAME_SIZE
                     worker->s->name_ex,
#else
                     worker->s->name,
#endif
                     worker->s->index);
    } else {
        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "process_config: (%s) %s inserted/updated in worker %d",
                     nodeinfo.mess.JVMRoute, nodeinfo.mess.Port, id);
    }
    inc_version_node();

    /* Insert the Alias and corresponding Context */
    if (aliases == NULL && contexts == NULL) {
        /* if using mod_balancer create or update the worker */
        if (balancer_manage) {
            apr_status_t rv = mod_manager_manage_worker(r, &nodeinfo, &balancerinfo);
            ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "process_config: balancer-manager returned %d", rv);
        } else {
            ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "process_config: NO balancer-manager");
        }
        loc_unlock_nodes();
        return NULL; /* Alias and Context missing */
    }


    if (insert_update_hosts(r->server, hoststatsmem, aliases, id, vid) != APR_SUCCESS) {
        loc_unlock_nodes();
        return apr_psprintf(r->pool, MHOSTUI, nodeinfo.mess.JVMRoute);
    }

    if (insert_update_contexts(r->server, contextstatsmem, contexts, id, vid, STOPPED) != APR_SUCCESS) {
        loc_unlock_nodes();
        return apr_psprintf(r->pool, MCONTUI, nodeinfo.mess.JVMRoute);
    }

    vid++;

    /* if using mod_balancer create or update the worker */
    if (balancer_manage) {
        apr_status_t rv = mod_manager_manage_worker(r, &nodeinfo, &balancerinfo);
        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "process_config: balancer-manager returned %d", rv);
    } else {
        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "process_config: NO balancer-manager");
    }
    loc_unlock_nodes();

    ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "process_config: Done");

    return NULL;
}

/*
 * Hepler function to convert status to string. The individual statuses are macros defined in context.h; if
 * there is an unknown status (integer value other than 1-4, it will be interpreted as REMOVE -> "REMOVED").
 */
static char *context_status_to_string(int status)
{
    switch (status) {
    case ENABLED:
        return "ENABLED";
    case DISABLED:
        return "DISABLED";
    case STOPPED:
        return "STOPPED";
    default:
        return "REMOVED";
    }
}

/**
 * Process a DUMP command.
 */
static char *process_dump(request_rec *r, int *errtype)
{
    int size, i;
    int *id;
    unsigned char type;
    const char *accept_header = apr_table_get(r->headers_in, "Accept");
    (void)errtype;

    if (accept_header && strstr((char *)accept_header, XML_CONTENT_TYPE) != NULL) {
        ap_set_content_type(r, XML_CONTENT_TYPE);
        type = TEXT_XML;
        ap_rprintf(r, "<?xml version=\"1.0\" standalone=\"yes\" ?>\n");
    } else {
        ap_set_content_type(r, PLAINTEXT_CONTENT_TYPE);
        type = TEXT_PLAIN;
    }

    size = loc_get_max_size_balancer();
    if (size == 0) {
        return NULL;
    }

    if (type == TEXT_XML) {
        ap_rprintf(r, "<Dump><Balancers>");
    }

    id = apr_palloc(r->pool, sizeof(int) * size);
    size = get_ids_used_balancer(balancerstatsmem, id);
    for (i = 0; i < size; i++) {
        balancerinfo_t *ou;
        if (get_balancer(balancerstatsmem, &ou, id[i]) != APR_SUCCESS) {
            continue;
        }

        switch (type) {
        case TEXT_XML:
            ap_rprintf(r,
                       "<Balancer id=\"%d\" name=\"%.*s\">"
                       "<StickySession>"
                       "<Enabled>%d</Enabled>"
                       "<Cookie>%.*s</Cookie>"
                       "<Path>%.*s</Path>"
                       "<Remove>%d</Remove>"
                       "<Force>%d</Force>"
                       "</StickySession>"
                       "<Timeout>%d</Timeout>"
                       "<MaxAttempts>%d</MaxAttempts>"
                       "</Balancer>",
                       id[i], (int)sizeof(ou->balancer), ou->balancer, ou->StickySession,
                       (int)sizeof(ou->StickySessionCookie), ou->StickySessionCookie,
                       (int)sizeof(ou->StickySessionPath), ou->StickySessionPath, ou->StickySessionRemove,
                       ou->StickySessionForce, (int)apr_time_sec(ou->Timeout), ou->Maxattempts);
            break;
        case TEXT_PLAIN:
        default:
            ap_rprintf(
                r,
                "balancer: [%d] Name: %.*s Sticky: %d [%.*s]/[%.*s] remove: %d force: %d Timeout: %d maxAttempts: %d\n",
                id[i], (int)sizeof(ou->balancer), ou->balancer, ou->StickySession, (int)sizeof(ou->StickySessionCookie),
                ou->StickySessionCookie, (int)sizeof(ou->StickySessionPath), ou->StickySessionPath,
                ou->StickySessionRemove, ou->StickySessionForce, (int)apr_time_sec(ou->Timeout), ou->Maxattempts);
            break;
        }
    }
    if (type == TEXT_XML) {
        ap_rprintf(r, "</Balancers>");
    }

    size = loc_get_max_size_node();
    id = apr_palloc(r->pool, sizeof(int) * size);
    size = get_ids_used_node(nodestatsmem, id);

    if (type == TEXT_XML) {
        ap_rprintf(r, "<Nodes>");
    }
    for (i = 0; i < size; i++) {
        nodeinfo_t *ou;
        if (get_node(nodestatsmem, &ou, id[i]) != APR_SUCCESS) {
            continue;
        }

        switch (type) {
        case TEXT_XML:
            ap_rprintf(r,
                       "<Node id=\"%d\">"
                       "<Balancer>%.*s</Balancer>"
                       "<JVMRoute>%.*s</JVMRoute>"
                       "<LBGroup>%.*s</LBGroup>"
                       "<Host>%.*s</Host>"
                       "<Port>%.*s</Port>"
                       "<Type>%.*s</Type>"
                       "<FlushPackets>%d</FlushPackets>"
                       "<FlushWait>%d</FlushWait>"
                       "<Ping>%d</Ping>"
                       "<Smax>%d</Smax>"
                       "<Ttl>%d</Ttl>"
                       "<Timeout>%d</Timeout>"
                       "</Node>",
                       ou->mess.id, (int)sizeof(ou->mess.balancer), ou->mess.balancer, (int)sizeof(ou->mess.JVMRoute),
                       ou->mess.JVMRoute, (int)sizeof(ou->mess.Domain), ou->mess.Domain, (int)sizeof(ou->mess.Host),
                       ou->mess.Host, (int)sizeof(ou->mess.Port), ou->mess.Port, (int)sizeof(ou->mess.Type),
                       ou->mess.Type, ou->mess.flushpackets, ou->mess.flushwait / 1000,
                       (int)apr_time_sec(ou->mess.ping), ou->mess.smax, (int)apr_time_sec(ou->mess.ttl),
                       (int)apr_time_sec(ou->mess.timeout));
            break;
        case TEXT_PLAIN:
        default:
            ap_rprintf(r,
                       "node: [%d:%d],Balancer: %.*s,JVMRoute: %.*s,LBGroup: [%.*s],Host: %.*s,Port: %.*s,"
                       "Type: %.*s,flushpackets: %d,flushwait: %d,ping: %d,smax: %d,ttl: %d,timeout: %d\n",
                       id[i], ou->mess.id, (int)sizeof(ou->mess.balancer), ou->mess.balancer,
                       (int)sizeof(ou->mess.JVMRoute), ou->mess.JVMRoute, (int)sizeof(ou->mess.Domain), ou->mess.Domain,
                       (int)sizeof(ou->mess.Host), ou->mess.Host, (int)sizeof(ou->mess.Port), ou->mess.Port,
                       (int)sizeof(ou->mess.Type), ou->mess.Type, ou->mess.flushpackets, ou->mess.flushwait / 1000,
                       (int)apr_time_sec(ou->mess.ping), ou->mess.smax, (int)apr_time_sec(ou->mess.ttl),
                       (int)apr_time_sec(ou->mess.timeout));
            break;
        }
    }

    if (type == TEXT_XML) {
        ap_rprintf(r, "</Nodes><Hosts>");
    }

    size = loc_get_max_size_host();
    id = apr_palloc(r->pool, sizeof(int) * size);
    size = get_ids_used_host(hoststatsmem, id);
    for (i = 0; i < size; i++) {
        hostinfo_t *ou;
        if (get_host(hoststatsmem, &ou, id[i]) != APR_SUCCESS) {
            continue;
        }

        switch (type) {
        case TEXT_XML:
            ap_rprintf(r, "<Host id=\"%d\" alias=\"%.*s\">\
                               <Vhost>%d</Vhost>\
                               <Node>%d</Node>\
                           </Host>",
                       id[i], (int)sizeof(ou->host), ou->host, ou->vhost, ou->node);
            break;
        case TEXT_PLAIN:
        default:
            ap_rprintf(r, "host: %d [%.*s] vhost: %d node: %d\n", id[i], (int)sizeof(ou->host), ou->host, ou->vhost,
                       ou->node);
            break;
        }
    }
    if (type == TEXT_XML) {
        ap_rprintf(r, "</Hosts><Contexts>");
    }

    size = loc_get_max_size_context();
    id = apr_palloc(r->pool, sizeof(int) * size);
    size = get_ids_used_context(contextstatsmem, id);
    for (i = 0; i < size; i++) {
        contextinfo_t *ou;
        if (get_context(contextstatsmem, &ou, id[i]) != APR_SUCCESS) {
            continue;
        }

        switch (type) {
        case TEXT_XML:
            ap_rprintf(r,
                       "<Context id=\"%d\" path=\"%.*s\">"
                       "<Vhost>%d</Vhost>"
                       "<Node>%d</Node>"
                       "<Status id=\"%d\">%s</Status>"
                       "</Context>",
                       id[i], (int)sizeof(ou->context), ou->context, ou->vhost, ou->node, ou->status,
                       context_status_to_string(ou->status));
            break;
        case TEXT_PLAIN:
        default:
            ap_rprintf(r, "context: %d [%.*s] vhost: %d node: %d status: %d\n", id[i], (int)sizeof(ou->context),
                       ou->context, ou->vhost, ou->node, ou->status);
            break;
        }
    }

    if (type == TEXT_XML) {
        ap_rprintf(r, "</Contexts></Dump>");
    }
    return NULL;
}

static char *flush_to_str(int flush)
{
    switch (flush) {
    case flush_on:
        return "On";
    case flush_auto:
        return "Auto";
    case flush_off:
    default:
        return "Off";
    }
}

/*
 * Process a INFO command.
 * Statics informations ;-)
 */
static char *process_info(request_rec *r, int *errtype)
{
    int size, i;
    int *id;
    unsigned char type;
    const char *accept_header = apr_table_get(r->headers_in, "Accept");
    (void)errtype;

    if (accept_header && strstr((char *)accept_header, XML_CONTENT_TYPE) != NULL) {
        ap_set_content_type(r, XML_CONTENT_TYPE);
        type = TEXT_XML;
        ap_rprintf(r, "<?xml version=\"1.0\" standalone=\"yes\" ?>\n");
    } else {
        ap_set_content_type(r, PLAINTEXT_CONTENT_TYPE);
        type = TEXT_PLAIN;
    }

    size = loc_get_max_size_node();
    if (size == 0) {
        return NULL;
    }
    id = apr_palloc(r->pool, sizeof(int) * size);
    size = get_ids_used_node(nodestatsmem, id);

    if (type == TEXT_XML) {
        ap_rprintf(r, "<Info><Nodes>");
    }

    for (i = 0; i < size; i++) {
        nodeinfo_t *ou;
        const proxy_worker_shared *proxystat;
        char *flushpackets;
        if (get_node(nodestatsmem, &ou, id[i]) != APR_SUCCESS) {
            continue;
        }

        switch (type) {
        case TEXT_XML:
            ap_rprintf(r,
                       "<Node id=\"%d\" name=\"%.*s\">"
                       "<Balancer>%.*s</Balancer>"
                       "<LBGroup>%.*s</LBGroup>"
                       "<Host>%.*s</Host>"
                       "<Port>%.*s</Port>"
                       "<Type>%.*s</Type>",
                       id[i], (int)sizeof(ou->mess.JVMRoute), ou->mess.JVMRoute, (int)sizeof(ou->mess.balancer),
                       ou->mess.balancer, (int)sizeof(ou->mess.Domain), ou->mess.Domain, (int)sizeof(ou->mess.Host),
                       ou->mess.Host, (int)sizeof(ou->mess.Port), ou->mess.Port, (int)sizeof(ou->mess.Type),
                       ou->mess.Type);
            break;
        case TEXT_PLAIN:
        default:
            ap_rprintf(r, "Node: [%d],Name: %.*s,Balancer: %.*s,LBGroup: %.*s,Host: %.*s,Port: %.*s,Type: %.*s", id[i],
                       (int)sizeof(ou->mess.JVMRoute), ou->mess.JVMRoute, (int)sizeof(ou->mess.balancer),
                       ou->mess.balancer, (int)sizeof(ou->mess.Domain), ou->mess.Domain, (int)sizeof(ou->mess.Host),
                       ou->mess.Host, (int)sizeof(ou->mess.Port), ou->mess.Port, (int)sizeof(ou->mess.Type),
                       ou->mess.Type);
            break;
        }

        flushpackets = flush_to_str(ou->mess.flushpackets);

        switch (type) {
        case TEXT_XML:
            ap_rprintf(r,
                       "<Flushpackets>%s</Flushpackets>"
                       "<Flushwait>%d</Flushwait>"
                       "<Ping>%d</Ping>"
                       "<Smax>%d</Smax>"
                       "<Ttl>%d</Ttl>",
                       flushpackets, ou->mess.flushwait / 1000, (int)apr_time_sec(ou->mess.ping), ou->mess.smax,
                       (int)apr_time_sec(ou->mess.ttl));
            break;
        case TEXT_PLAIN:
        default:
            ap_rprintf(r, ",Flushpackets: %s,Flushwait: %d,Ping: %d,Smax: %d,Ttl: %d", flushpackets,
                       ou->mess.flushwait / 1000, (int)apr_time_sec(ou->mess.ping), ou->mess.smax,
                       (int)apr_time_sec(ou->mess.ttl));
            break;
        }

        proxystat = read_shared_by_node(r, ou);
        if (!proxystat) {
            ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "process_config: No proxystat, assume zeros");
            proxystat = apr_pcalloc(r->pool, sizeof(proxy_worker_shared));
        }

        switch (type) {
        case TEXT_XML:
            ap_rprintf(r,
                       "<Elected>%d</Elected>"
                       "<Read>%d</Read>"
                       "<Transfered>%d</Transfered>"
                       "<Connected>%d</Connected>"
                       "<Load>%d</Load>"
                       "</Node>",
                       (int)proxystat->elected, (int)proxystat->read, (int)proxystat->transferred, (int)proxystat->busy,
                       proxystat->lbfactor);
            break;
        case TEXT_PLAIN:
        default:
            ap_rprintf(r, ",Elected: %d,Read: %d,Transfered: %d,Connected: %d,Load: %d\n", (int)proxystat->elected,
                       (int)proxystat->read, (int)proxystat->transferred, (int)proxystat->busy, proxystat->lbfactor);
            break;
        }
    }

    if (type == TEXT_XML) {
        ap_rprintf(r, "</Nodes>");
    }

    /* Process the Vhosts */
    size = loc_get_max_size_host();
    id = apr_palloc(r->pool, sizeof(int) * size);
    size = get_ids_used_host(hoststatsmem, id);
    if (type == TEXT_XML) {
        ap_rprintf(r, "<Vhosts>");
    }
    for (i = 0; i < size; i++) {
        hostinfo_t *ou;
        if (get_host(hoststatsmem, &ou, id[i]) != APR_SUCCESS) {
            continue;
        }

        switch (type) {
        case TEXT_XML:
            ap_rprintf(r,
                       "<Vhost id=\"%d\" alias=\"%.*s\">"
                       "<Node id=\"%d\"/>"
                       "</Vhost>",
                       ou->vhost, (int)sizeof(ou->host), ou->host, ou->node);
            break;
        case TEXT_PLAIN:
        default:
            ap_rprintf(r, "Vhost: [%d:%d:%d], Alias: %.*s\n", ou->node, ou->vhost, id[i], (int)sizeof(ou->host),
                       ou->host);
            break;
        }
    }

    if (type == TEXT_XML) {
        ap_rprintf(r, "</Vhosts>");
    }

    /* Process the Contexts */
    size = loc_get_max_size_context();
    id = apr_palloc(r->pool, sizeof(int) * size);
    size = get_ids_used_context(contextstatsmem, id);

    if (type == TEXT_XML) {
        ap_rprintf(r, "<Contexts>");
    }

    for (i = 0; i < size; i++) {
        contextinfo_t *ou;
        if (get_context(contextstatsmem, &ou, id[i]) != APR_SUCCESS) {
            continue;
        }

        switch (type) {
        case TEXT_XML:
            ap_rprintf(r,
                       "<Context id=\"%d\">"
                       "<Status id=\"%d\">%s</Status>"
                       "<Context>%.*s</Context>"
                       "<Node id=\"%d\"/>"
                       "<Vhost id=\"%d\"/>"
                       "</Context>",
                       id[i], ou->status, context_status_to_string(ou->status), (int)sizeof(ou->context), ou->context,
                       ou->node, ou->vhost);
            break;
        case TEXT_PLAIN:
        default:
            ap_rprintf(r, "Context: [%d:%d:%d], Context: %.*s, Status: %s\n", ou->node, ou->vhost, id[i],
                       (int)sizeof(ou->context), ou->context, context_status_to_string(ou->status));
            break;
        }
    }

    if (type == TEXT_XML) {
        ap_rprintf(r, "</Contexts></Info>");
    }
    return NULL;
}

/**
 * Process a *-APP command that applies to the node NOTE: the node is locked
 */
static char *process_node_cmd(request_rec *r, int status, int *errtype, nodeinfo_t *node)
{
    /* for read the hosts */
    int i, j;
    int size = loc_get_max_size_host();
    int *id;
    (void)errtype;

    ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "process_node_cmd: status %s processing node: %d",
                 context_status_to_string(status), node->mess.id);
    if (size == 0) {
        return NULL;
    }
    id = apr_palloc(r->pool, sizeof(int) * size);
    size = get_ids_used_host(hoststatsmem, id);
    for (i = 0; i < size; i++) {
        hostinfo_t *ou;
        int sizecontext;
        int *idcontext;

        if (get_host(hoststatsmem, &ou, id[i]) != APR_SUCCESS) {
            continue;
        }
        if (ou->node != node->mess.id) {
            continue;
        }
        /* If the host corresponds to a node process all contextes */
        sizecontext = get_max_size_context(contextstatsmem);
        idcontext = apr_palloc(r->pool, sizeof(int) * sizecontext);
        sizecontext = get_ids_used_context(contextstatsmem, idcontext);
        for (j = 0; j < sizecontext; j++) {
            contextinfo_t *context;
            if (get_context(contextstatsmem, &context, idcontext[j]) != APR_SUCCESS) {
                continue;
            }
            if (context->vhost == ou->vhost && context->node == ou->node) {
                /* Process the context */
                if (status != REMOVE) {
                    context->status = status;
                    insert_update_context(contextstatsmem, context);
                } else {
                    remove_context(contextstatsmem, context->id);
                }
            }
        }
        if (status == REMOVE) {
            remove_host(hoststatsmem, ou->id);
        }
    }

    /* The REMOVE-APP * removes the node (well mark it removed) */
    if (status == REMOVE) {
        int id;
        node->mess.remove = 1;
        insert_update_node(nodestatsmem, node, &id, 0);
    }
    return NULL;
}


/**
 * Process an enable/disable/stop/remove application message
 */
static char *process_appl_cmd(request_rec *r, char **ptr, int status, int *errtype, int global, int fromnode)
{
    nodeinfo_t nodeinfo;
    nodeinfo_t *node;

    char *contexts = NULL;
    char *aliases = NULL;

    int i = 0;
    hostinfo_t hostinfo;
    hostinfo_t *host = NULL;
    char *err_msg;

    memset(&nodeinfo.mess, '\0', sizeof(nodeinfo.mess));

    while (ptr[i]) {
        if (strcasecmp(ptr[i], "JVMRoute") == 0) {
            if (strlen(ptr[i + 1]) >= sizeof(nodeinfo.mess.JVMRoute)) {
                *errtype = TYPESYNTAX;
                return SROUBIG;
            }
            strcpy(nodeinfo.mess.JVMRoute, ptr[i + 1]);
            nodeinfo.mess.id = -1;
        }
        err_msg = process_context_alias(ptr[i], ptr[i + 1], r->pool, &contexts, &aliases, errtype, 0);
        if (err_msg) {
            return err_msg;
        }

        i += 2;
    }

    /* Check for JVMRoute, Alias and Context */
    if (nodeinfo.mess.JVMRoute[0] == '\0') {
        *errtype = TYPESYNTAX;
        return SROUBAD;
    }

    /* Note: This applies only for non-wildcarded requests for which Alias and Context are required */
    if (contexts == NULL && aliases == NULL && strcmp(r->uri, "/*") != 0) {
        *errtype = TYPESYNTAX;
        return NOCONAL;
    }

    if (contexts == NULL && aliases != NULL) {
        *errtype = TYPESYNTAX;
        return SALIBAD;
    }
    if (aliases == NULL && contexts != NULL) {
        *errtype = TYPESYNTAX;
        return SCONBAD;
    }

    /* Read the node */
    loc_lock_nodes();
    node = read_node(nodestatsmem, &nodeinfo);
    if (node == NULL) {
        loc_unlock_nodes();
        if (status == REMOVE) {
            return NULL; /* Already done */
        }
        *errtype = TYPEMEM;
        return apr_psprintf(r->pool, MNODERD, nodeinfo.mess.JVMRoute);
    }

    /* If the node is marked removed check what to do */
    if (node->mess.remove) {
        loc_unlock_nodes();
        if (status == REMOVE) {
            return NULL; /* Already done */
        }
        /* Act has if the node wasn't found */
        *errtype = TYPEMEM;
        return apr_psprintf(r->pool, MNODERD, node->mess.JVMRoute);
    }

    inc_version_node();

    /* Process the * APP commands */
    if (global) {
        char *ret;
        ret = process_node_cmd(r, status, errtype, node);
        loc_unlock_nodes();
        return ret;
    }

    /* Go through the provided Aliases, the first Alias that matches an existing host gets used
     * otherwise, a new host will be created
     */
    hostinfo.node = node->mess.id;
    hostinfo.id = 0;
    if (aliases != NULL) {
        int start = 0;
        i = 0;
        while (host == NULL && (unsigned)(i + start) < strlen(aliases)) {
            while (aliases[start + i] != ',' && aliases[start + i] != '\0') {
                i++;
            }

            strncpy(hostinfo.host, aliases + start, i);
            hostinfo.host[i] = '\0';
            host = read_host(hoststatsmem, &hostinfo);
            start = start + i + 1;
            i = 0;
        }
    } else {
        hostinfo.host[0] = '\0';
    }

    if (host == NULL) {
        int vid, size, *id;

        /* If REMOVE ignores it */
        if (status == REMOVE) {
            loc_unlock_nodes();
            return NULL;
        }

        /* Find the first available vhost id */
        vid = 0;
        size = loc_get_max_size_host();
        id = apr_palloc(r->pool, sizeof(int) * size);
        size = get_ids_used_host(hoststatsmem, id);
        for (i = 0; i < size; i++) {
            hostinfo_t *ou;
            if (get_host(hoststatsmem, &ou, id[i]) != APR_SUCCESS) {
                continue;
            }
            if (ou->node == node->mess.id && ou->vhost > vid) {
                vid = ou->vhost;
            }
        }
        vid++; /* Use next one. */
        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "process_appl_cmd: adding vhost: %d node: %d route: %s",
                     vid, node->mess.id, nodeinfo.mess.JVMRoute);
        /* If the Host doesn't exist yet create it */
        if (insert_update_hosts(r->server, hoststatsmem, aliases, node->mess.id, vid) != APR_SUCCESS) {
            loc_unlock_nodes();
            *errtype = TYPEMEM;
            return apr_psprintf(r->pool, MHOSTUI, nodeinfo.mess.JVMRoute);
        }
        hostinfo.id = 0;
        hostinfo.node = node->mess.id;
        hostinfo.host[0] = '\0';
        if (aliases != NULL) {
            strncpy(hostinfo.host, aliases, sizeof(hostinfo.host));
            hostinfo.host[sizeof(hostinfo.host) - 1] = '\0';
        }

        host = read_host(hoststatsmem, &hostinfo);
        if (host == NULL) {
            loc_unlock_nodes();
            *errtype = TYPEMEM;
            return apr_psprintf(r->pool, MHOSTRD, node->mess.JVMRoute);
        }
    }

    if (status == ENABLED) {
        /* There is no load balancing between balancers */
        int size = loc_get_max_size_context();
        int *id = apr_palloc(r->pool, sizeof(int) * size);
        size = get_ids_used_context(contextstatsmem, id);
        for (i = 0; i < size; i++) {
            contextinfo_t *ou;
            if (get_context(contextstatsmem, &ou, id[i]) != APR_SUCCESS) {
                continue;
            }
            if (strcmp(ou->context, contexts) == 0) {
                /* There is the same context somewhere else */
                nodeinfo_t *hisnode;
                if (get_node(nodestatsmem, &hisnode, ou->node) != APR_SUCCESS) {
                    continue;
                }
                if (strcmp(hisnode->mess.balancer, node->mess.balancer)) {
                    /* the same context would be on 2 different balancer */
                    ap_log_error(APLOG_MARK, APLOG_WARNING, 0, r->server,
                                 "process_appl_cmd: ENABLE: context %s is in balancer %s and %s", contexts,
                                 node->mess.balancer, hisnode->mess.balancer);
                }
            }
        }
    }

    /* Now update each context from Context: part */
    if (insert_update_contexts(r->server, contextstatsmem, contexts, node->mess.id, host->vhost, status) !=
        APR_SUCCESS) {
        loc_unlock_nodes();
        *errtype = TYPEMEM;
        return apr_psprintf(r->pool, MCONTUI, node->mess.JVMRoute);
    }

    if (insert_update_hosts(r->server, hoststatsmem, aliases, node->mess.id, host->vhost) != APR_SUCCESS) {
        loc_unlock_nodes();
        *errtype = TYPEMEM;
        return apr_psprintf(r->pool, MHOSTUI, node->mess.JVMRoute);
    }

    /* Remove the host if all the contextes have been removed */
    if (status == REMOVE) {
        int size = loc_get_max_size_context();
        int *id = apr_palloc(r->pool, sizeof(int) * size);
        size = get_ids_used_context(contextstatsmem, id);
        for (i = 0; i < size; i++) {
            contextinfo_t *ou;
            if (get_context(contextstatsmem, &ou, id[i]) != APR_SUCCESS) {
                continue;
            }
            if (ou->vhost == host->vhost && ou->node == node->mess.id) {
                break;
            }
        }
        if (i == size) {
            int size = loc_get_max_size_host();
            int *id = apr_palloc(r->pool, sizeof(int) * size);
            size = get_ids_used_host(hoststatsmem, id);
            for (i = 0; i < size; i++) {
                hostinfo_t *ou;

                if (get_host(hoststatsmem, &ou, id[i]) != APR_SUCCESS) {
                    continue;
                }
                if (ou->vhost == host->vhost && ou->node == node->mess.id) {
                    remove_host(hoststatsmem, ou->id);
                }
            }
        }
    } else if (status == STOPPED) {
        /* insert_update_contexts in fact makes that contexts corresponds only to the first context... */
        contextinfo_t in;
        contextinfo_t *ou;
        in.id = 0;
        strncpy(in.context, contexts, CONTEXTSZ);
        in.context[CONTEXTSZ] = '\0';
        in.vhost = host->vhost;
        in.node = node->mess.id;
        ou = read_context(contextstatsmem, &in);
        if (ou != NULL) {
            ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "process_appl_cmd: STOP-APP nbrequests %d",
                         ou->nbrequests);
            if (fromnode) {
                ap_set_content_type(r, PLAINTEXT_CONTENT_TYPE);
                ap_rprintf(r, "Type=STOP-APP-RSP&JvmRoute=%.*s&Alias=%.*s&Context=%.*s&Requests=%d",
                           (int)sizeof(nodeinfo.mess.JVMRoute), nodeinfo.mess.JVMRoute, (int)sizeof(aliases), aliases,
                           (int)sizeof(contexts), contexts, ou->nbrequests);
                ap_rprintf(r, "\n");
            }
        } else {
            ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "process_appl_cmd: STOP-APP can't read_context");
        }
    }
    loc_unlock_nodes();
    return NULL;
}

static char *process_enable(request_rec *r, char **ptr, int *errtype, int global)
{
    return process_appl_cmd(r, ptr, ENABLED, errtype, global, 0);
}

static char *process_disable(request_rec *r, char **ptr, int *errtype, int global)
{
    return process_appl_cmd(r, ptr, DISABLED, errtype, global, 0);
}

static char *process_stop(request_rec *r, char **ptr, int *errtype, int global, int fromnode)
{
    return process_appl_cmd(r, ptr, STOPPED, errtype, global, fromnode);
}

static char *process_remove(request_rec *r, char **ptr, int *errtype, int global)
{
    return process_appl_cmd(r, ptr, REMOVE, errtype, global, 0);
}

/*
 * Call the ping/pong logic
 * Do a ping/png request to the node and set the load factor.
 */
static int isnode_up(request_rec *r, int id, int Load)
{
    return balancerhandler != NULL ? balancerhandler->proxy_node_isup(r, id, Load) : OK;
}

/*
 * Call the ping/pong logic using scheme://host:port
 * Do a ping/png request to the node and set the load factor.
 */
static int ishost_up(request_rec *r, char *scheme, char *host, char *port)
{
    return balancerhandler != NULL ? balancerhandler->proxy_host_isup(r, scheme, host, port) : OK;
}

/*
 * Process the STATUS command
 * Load -1 : Broken
 * Load 0  : Standby.
 * Load 1-100 : Load factor.
 */
static char *process_status(request_rec *r, const char *const *ptr, int *errtype)
{
    int Load = -1;
    nodeinfo_t nodeinfo;
    nodeinfo_t *node;

    int i = 0;

    ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "Processing STATUS");
    while (ptr[i]) {
        if (strcasecmp(ptr[i], "JVMRoute") == 0) {
            if (strlen(ptr[i + 1]) >= sizeof(nodeinfo.mess.JVMRoute)) {
                *errtype = TYPESYNTAX;
                return SROUBIG;
            }
            strcpy(nodeinfo.mess.JVMRoute, ptr[i + 1]);
            nodeinfo.mess.id = -1;
        } else if (strcasecmp(ptr[i], "Load") == 0) {
            Load = atoi(ptr[i + 1]);
        } else {
            *errtype = TYPESYNTAX;
            return apr_psprintf(r->pool, SBADFLD, ptr[i]);
        }
        i++;
        i++;
    }

    /* Read the node */
    loc_lock_nodes();
    node = read_node(nodestatsmem, &nodeinfo);
    loc_unlock_nodes();
    if (node == NULL) {
        *errtype = TYPEMEM;
        return apr_psprintf(r->pool, MNODERD, nodeinfo.mess.JVMRoute);
    }

    /*
     * If the node is usualable do a ping/pong to prevent Split-Brain Syndrome
     * and update the worker status and load factor acccording to the test result.
     */
    ap_set_content_type(r, PLAINTEXT_CONTENT_TYPE);
    ap_rprintf(r, "Type=STATUS-RSP&JVMRoute=%.*s", (int)sizeof(nodeinfo.mess.JVMRoute), nodeinfo.mess.JVMRoute);

    ap_rprintf(r, isnode_up(r, node->mess.id, Load) != OK ? "&State=NOTOK" : "&State=OK");

    ap_rprintf(r, "&id=%ld", ap_scoreboard_image->global->restart_time);

    ap_rprintf(r, "\n");
    return NULL;
}

/*
 * Process the VERSION command
 */
static char *process_version(request_rec *r, const char *const *const ptr, int *errtype)
{
    const char *accept_header = apr_table_get(r->headers_in, "Accept");
    (void)ptr;
    (void)errtype;

    if (accept_header && strstr((char *)accept_header, XML_CONTENT_TYPE) != NULL) {
        ap_set_content_type(r, XML_CONTENT_TYPE);
        ap_rprintf(r, "<?xml version=\"1.0\" standalone=\"yes\" ?>\n");
        ap_rprintf(r, "<version><release>%s</release><protocol>%s</protocol></version>", MOD_CLUSTER_EXPOSED_VERSION,
                   VERSION_PROTOCOL);
    } else {
        ap_set_content_type(r, PLAINTEXT_CONTENT_TYPE);
        ap_rprintf(r, "release: %s, protocol: %s", MOD_CLUSTER_EXPOSED_VERSION, VERSION_PROTOCOL);
    }
    ap_rprintf(r, "\n");
    return NULL;
}

/*
 * Process the PING command
 * With a JVMRoute does a cping/cpong in the node.
 * Without just answers ok.
 * NOTE: It is hard to cping/cpong a host + port but CONFIG + PING + REMOVE_APP *
 *       would do the same.
 */
static char *process_ping(request_rec *r, const char *const *ptr, int *errtype)
{
    nodeinfo_t nodeinfo;
    nodeinfo_t *node;
    char *scheme = NULL;
    char *host = NULL;
    char *port = NULL;

    int i = 0;

    ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "Processing PING");
    nodeinfo.mess.id = -2;
    while (ptr[i] && ptr[i][0] != '\0') {
        if (strcasecmp(ptr[i], "JVMRoute") == 0) {
            if (strlen(ptr[i + 1]) >= sizeof(nodeinfo.mess.JVMRoute)) {
                *errtype = TYPESYNTAX;
                return SROUBIG;
            }
            strcpy(nodeinfo.mess.JVMRoute, ptr[i + 1]);
            nodeinfo.mess.id = -1;
        } else if (strcasecmp(ptr[i], "Scheme") == 0) {
            scheme = apr_pstrdup(r->pool, ptr[i + 1]);
        } else if (strcasecmp(ptr[i], "Host") == 0) {
            host = apr_pstrdup(r->pool, ptr[i + 1]);
        } else if (strcasecmp(ptr[i], "Port") == 0) {
            port = apr_pstrdup(r->pool, ptr[i + 1]);
        } else {
            *errtype = TYPESYNTAX;
            return apr_psprintf(r->pool, SBADFLD, ptr[i]);
        }
        i++;
        i++;
    }
    if (nodeinfo.mess.id == -2) {
        /* PING scheme, host, port or just httpd */
        if (scheme == NULL && host == NULL && port == NULL) {
            ap_set_content_type(r, PLAINTEXT_CONTENT_TYPE);
            ap_rprintf(r, "Type=PING-RSP&State=OK");
        } else {
            if (scheme == NULL || host == NULL || port == NULL) {
                *errtype = TYPESYNTAX;
                return apr_psprintf(r->pool, SMISFLD);
            }
            ap_set_content_type(r, PLAINTEXT_CONTENT_TYPE);
            ap_rprintf(r, "Type=PING-RSP");
            ap_rprintf(r, ishost_up(r, scheme, host, port) != OK ? "&State=NOTOK" : "&State=OK");
        }
    } else {

        /* Read the node */
        loc_lock_nodes();
        node = read_node(nodestatsmem, &nodeinfo);
        loc_unlock_nodes();
        if (node == NULL) {
            *errtype = TYPEMEM;
            return apr_psprintf(r->pool, MNODERD, nodeinfo.mess.JVMRoute);
        }

        /*
         * If the node is usualable do a ping/pong to prevent Split-Brain Syndrome
         * and update the worker status and load factor acccording to the test result.
         */
        ap_set_content_type(r, PLAINTEXT_CONTENT_TYPE);
        ap_rprintf(r, "Type=PING-RSP&JVMRoute=%.*s", (int)sizeof(nodeinfo.mess.JVMRoute), nodeinfo.mess.JVMRoute);

        ap_rprintf(r, isnode_up(r, node->mess.id, -2) != OK ? "&State=NOTOK" : "&State=OK");
    }
    ap_rprintf(r, "&id=%ld", ap_scoreboard_image->global->restart_time);

    ap_rprintf(r, "\n");
    return NULL;
}

/*
 * Decodes a '%' escaped string, and returns the number of characters
 * (From mod_proxy_ftp.c).
 */

/* already called in the knowledge that the characters are hex digits */
/* Copied from modules/proxy/proxy_util.c */
static int mod_manager_hex2c(const char *x)
{
    int i, ch;

#if !APR_CHARSET_EBCDIC
    ch = x[0];
    if (apr_isdigit(ch)) {
        i = ch - '0';
    } else if (apr_isupper(ch)) {
        i = ch - ('A' - 10);
    } else {
        i = ch - ('a' - 10);
    }
    i <<= 4;

    ch = x[1];
    if (apr_isdigit(ch)) {
        i += ch - '0';
    } else if (apr_isupper(ch)) {
        i += ch - ('A' - 10);
    } else {
        i += ch - ('a' - 10);
    }
    return i;
#else  /*APR_CHARSET_EBCDIC */
    /*
     * we assume that the hex value refers to an ASCII character
     * so convert to EBCDIC so that it makes sense locally;
     *
     * example:
     *
     * client specifies %20 in URL to refer to a space char;
     * at this point we're called with EBCDIC "20"; after turning
     * EBCDIC "20" into binary 0x20, we then need to assume that 0x20
     * represents an ASCII char and convert 0x20 to EBCDIC, yielding
     * 0x40
     */
    char buf[1];

    if (1 == sscanf(x, "%2x", &i)) {
        buf[0] = i & 0xFF;
        ap_xlate_proto_from_ascii(buf, 1);
        return buf[0];
    } else {
        return 0;
    }
#endif /*APR_CHARSET_EBCDIC */
}

/*
 * Processing of decoded characters
 */
static apr_status_t decodeenc(char **ptr)
{
    int val, i, j;
    char ch;
    val = 0;
    while (NULL != ptr[val]) {
        if (ptr[val][0] == '\0') {
            /* special case for no characters */
            val++;
            continue;
        }
        for (i = 0, j = 0; ptr[val][i] != '\0'; i++, j++) {
            /* decode it if not already done */
            ch = ptr[val][i];
            if (ch == '%' && apr_isxdigit(ptr[val][i + 1]) && apr_isxdigit(ptr[val][i + 2])) {
                ch = (char)mod_manager_hex2c(&(ptr[val][i + 1]));
                i += 2;
            }

            /* process decoded, = and & are legit characters */
            /* from apr_escape_entity() */
            if (ch == '<' || ch == '>' || ch == '\"' || ch == '\'') {
                return TYPESYNTAX;
            }
            /* from apr_escape_shell() */
            if (ch == '\r' || ch == '\n') {
                return TYPESYNTAX;
            }

            ptr[val][j] = ch;
        }
        ptr[val][j] = '\0';
        val++;
    }
    return APR_SUCCESS;
}

/*
 * Check that the method is one of ours
 */
static int is_our_method(const request_rec *r)
{
    int ours = 0;
    if (strcasecmp(r->method, "CONFIG") == 0) {
        ours = 1;
    } else if (strcasecmp(r->method, "ENABLE-APP") == 0) {
        ours = 1;
    } else if (strcasecmp(r->method, "DISABLE-APP") == 0) {
        ours = 1;
    } else if (strcasecmp(r->method, "STOP-APP") == 0) {
        ours = 1;
    } else if (strcasecmp(r->method, "REMOVE-APP") == 0) {
        ours = 1;
    } else if (strcasecmp(r->method, "STATUS") == 0) {
        ours = 1;
    } else if (strcasecmp(r->method, "DUMP") == 0) {
        ours = 1;
    } else if (strcasecmp(r->method, "INFO") == 0) {
        ours = 1;
    } else if (strcasecmp(r->method, "PING") == 0) {
        ours = 1;
    } else if (strcasecmp(r->method, "VERSION") == 0) {
        ours = 1;
    }
    return ours;
}

/*
 * This routine is called before mod_proxy translate name.
 * This allows us to make decisions before mod_proxy
 * to be able to fill tables even with ProxyPass / balancer...
 */
static int manager_trans(request_rec *r)
{
    core_dir_config *conf = (core_dir_config *)ap_get_module_config(r->per_dir_config, &core_module);
    mod_manager_config *mconf = ap_get_module_config(r->server->module_config, &manager_module);

    if (conf && conf->handler && r->method_number == M_GET && strcmp(conf->handler, "mod_cluster-manager") == 0) {
        r->handler = "mod_cluster-manager";
        r->filename = apr_pstrdup(r->pool, r->uri);
        return OK;
    }
    if (r->method_number != M_INVALID) {
        return DECLINED;
    }
    if (!mconf->enable_mcmp_receive) {
        return DECLINED; /* Not allowed to receive MCMP */
    }

    if (is_our_method(r)) {
        int i;
        /* The method one of ours */
        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "manager_trans: %s (%s)", r->method, r->uri);
        r->handler = "mod-cluster"; /* that hack doesn't work on httpd-2.4.x */
        i = strlen(r->uri);
        if (strcmp(r->uri, "*") == 0 || (i >= 2 && r->uri[i - 1] == '*' && r->uri[i - 2] == '/')) {
            r->filename = apr_pstrdup(r->pool, NODE_COMMAND);
        } else {
            r->filename = apr_pstrdup(r->pool, r->uri);
        }
        return OK;
    }

    return DECLINED;
}

/*
 * fixup logic to prevent subrequest to our methods
 */
static int manager_map_to_storage(request_rec *r)
{
    mod_manager_config *mconf = ap_get_module_config(r->server->module_config, &manager_module);
    if (r->method_number != M_INVALID) {
        return DECLINED;
    }
    if (!mconf->enable_mcmp_receive) {
        return DECLINED; /* Not allowed to receive MCMP */
    }

    if (is_our_method(r)) {
        /* The method one of ours */
        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "manager_map_to_storage: %s (%s)", r->method, r->uri);
        return OK;
    }

    return DECLINED;
}

/*
 * Create the commands that are possible on the context
 */
static char *context_string(request_rec *r, contextinfo_t *ou, const char *Alias, const char *JVMRoute)
{
    char context[CONTEXTSZ + 1];
    strncpy(context, ou->context, CONTEXTSZ);
    context[CONTEXTSZ] = '\0';
    return apr_pstrcat(r->pool, "JVMRoute=", JVMRoute, "&Alias=", Alias, "&Context=", context, NULL);
}

static char *balancer_nonce_string(request_rec *r)
{
    char *ret = "";
    void *sconf = r->server->module_config;
    mod_manager_config *mconf = ap_get_module_config(sconf, &manager_module);
    if (mconf->nonce) {
        ret = apr_psprintf(r->pool, "nonce=%s&", balancer_nonce);
    }
    return ret;
}

static void print_context_command(request_rec *r, contextinfo_t *ou, const char *Alias, const char *JVMRoute)
{
    if (ou->status == DISABLED) {
        ap_rprintf(r, "<a href=\"%s?%sCmd=ENABLE-APP&Range=CONTEXT&%s\">Enable</a> ", r->uri, balancer_nonce_string(r),
                   context_string(r, ou, Alias, JVMRoute));
        ap_rprintf(r, " <a href=\"%s?%sCmd=STOP-APP&Range=CONTEXT&%s\">Stop</a>", r->uri, balancer_nonce_string(r),
                   context_string(r, ou, Alias, JVMRoute));
    }
    if (ou->status == ENABLED) {
        ap_rprintf(r, "<a href=\"%s?%sCmd=DISABLE-APP&Range=CONTEXT&%s\">Disable</a>", r->uri, balancer_nonce_string(r),
                   context_string(r, ou, Alias, JVMRoute));
        ap_rprintf(r, " <a href=\"%s?%sCmd=STOP-APP&Range=CONTEXT&%s\">Stop</a>", r->uri, balancer_nonce_string(r),
                   context_string(r, ou, Alias, JVMRoute));
    }
    if (ou->status == STOPPED) {
        ap_rprintf(r, "<a href=\"%s?%sCmd=ENABLE-APP&Range=CONTEXT&%s\">Enable</a> ", r->uri, balancer_nonce_string(r),
                   context_string(r, ou, Alias, JVMRoute));
        ap_rprintf(r, "<a href=\"%s?%sCmd=DISABLE-APP&Range=CONTEXT&%s\">Disable</a>", r->uri, balancer_nonce_string(r),
                   context_string(r, ou, Alias, JVMRoute));
    }
}

/*
 * Create the commands that are possible on the node
 */
static char *node_string(request_rec *r, const char *JVMRoute)
{
    return apr_pstrcat(r->pool, "JVMRoute=", JVMRoute, NULL);
}

static void print_node_command(request_rec *r, const char *JVMRoute)
{
    ap_rprintf(r, "<a href=\"%s?%sCmd=ENABLE-APP&Range=NODE&%s\">Enable Contexts</a> ", r->uri,
               balancer_nonce_string(r), node_string(r, JVMRoute));
    ap_rprintf(r, "<a href=\"%s?%sCmd=DISABLE-APP&Range=NODE&%s\">Disable Contexts</a> ", r->uri,
               balancer_nonce_string(r), node_string(r, JVMRoute));
    ap_rprintf(r, "<a href=\"%s?%sCmd=STOP-APP&Range=NODE&%s\">Stop Contexts</a>", r->uri, balancer_nonce_string(r),
               node_string(r, JVMRoute));
}

/*
 * Helper function for html escaping of non-NULL terminated strings.
 */
static char *mc_escape_html(apr_pool_t *pool, const char *str, int len)
{
    char *s = apr_palloc(pool, len + 1);
    memcpy(s, str, len);
    s[len] = '\0';
    return ap_escape_html(pool, s);
}

static void print_domain_command(request_rec *r, const char *Domain)
{
    ap_rprintf(r, "<a href=\"%s?%sCmd=ENABLE-APP&Range=DOMAIN&Domain=%s\">Enable Nodes</a> ", r->uri,
               balancer_nonce_string(r), Domain);
    ap_rprintf(r, "<a href=\"%s?%sCmd=DISABLE-APP&Range=DOMAIN&Domain=%s\">Disable Nodes</a> ", r->uri,
               balancer_nonce_string(r), Domain);
    ap_rprintf(r, "<a href=\"%s?%sCmd=STOP-APP&Range=DOMAIN&Domain=%s\">Stop Nodes</a>", r->uri,
               balancer_nonce_string(r), Domain);
}

/*
 * Process the parameters and display corresponding informations
 */
static void print_contexts(request_rec *r, int reduce_display, int allow_cmd, int node, int host, const char *Alias,
                           const char *JVMRoute)
{
    int size, i;
    int *id;
    /* Process the Contexts */
    if (!reduce_display) {
        ap_rprintf(r, "<h3>Contexts:</h3>");
    }
    ap_rprintf(r, "<pre>");
    size = loc_get_max_size_context();
    if (size == 0) {
        return;
    }
    id = apr_palloc(r->pool, sizeof(int) * size);
    size = get_ids_used_context(contextstatsmem, id);
    for (i = 0; i < size; i++) {
        contextinfo_t *ou;
        if (get_context(contextstatsmem, &ou, id[i]) != APR_SUCCESS) {
            continue;
        }
        if (ou->node != node || ou->vhost != host) {
            continue;
        }
        ap_rprintf(r, "%.*s, Status: %s Request: %d ", CONTEXTSZ, mc_escape_html(r->pool, ou->context, CONTEXTSZ),
                   context_status_to_string(ou->status), ou->nbrequests);
        if (allow_cmd) {
            print_context_command(r, ou, Alias, JVMRoute);
        }
        ap_rprintf(r, "\n");
    }
    ap_rprintf(r, "</pre>");
}

static void print_hosts(request_rec *r, int reduce_display, int allow_cmd, int node, const char *JVMRoute)
{
    int size, i, j;
    int *id, *idChecker;
    int vhost = 0;

    /* Process the Vhosts */
    size = loc_get_max_size_host();
    if (size == 0) {
        return;
    }
    id = apr_palloc(r->pool, sizeof(int) * size);
    size = get_ids_used_host(hoststatsmem, id);
    idChecker = apr_pcalloc(r->pool, sizeof(int) * size);
    for (i = 0; i < size; i++) {
        hostinfo_t *ou;
        if (get_host(hoststatsmem, &ou, id[i]) != APR_SUCCESS) {
            continue;
        }
        if (ou->node != node) {
            continue;
        }
        if (ou->vhost != vhost) {
            /* if we've logged this already, contine */
            if (idChecker[i] == 1) {
                continue;
            }
            if (vhost && !reduce_display) {
                ap_rprintf(r, "</pre>");
            }
            if (!reduce_display) {
                ap_rprintf(r, "<h2> Virtual Host %d:</h2>", ou->vhost);
            }
            print_contexts(r, reduce_display, allow_cmd, ou->node, ou->vhost, ou->host, JVMRoute);
            if (reduce_display) {
                ap_rprintf(r, "Aliases: ");
            } else {
                ap_rprintf(r, "<h3>Aliases:</h3>");
                ap_rprintf(r, "<pre>");
            }
            vhost = ou->vhost;

            ap_rprintf(r, "%.*s", HOSTALIASZ, mc_escape_html(r->pool, ou->host, HOSTALIASZ));
            ap_rprintf(r, reduce_display ? " " : "\n");

            /* Go ahead and check for any other later alias entries for this vhost and print them now */
            for (j = i + 1; j < size; j++) {
                hostinfo_t *pv;
                if (get_host(hoststatsmem, &pv, id[j]) != APR_SUCCESS) {
                    continue;
                }
                if (pv->node != node) {
                    continue;
                }
                if (pv->vhost != vhost) {
                    continue;
                }

                /* mark this entry as logged */
                idChecker[j] = 1;
                /* step the outer loop forward if we can */
                if (i == j - 1) {
                    i++;
                }
                ap_rprintf(r, "%.*s", HOSTALIASZ, mc_escape_html(r->pool, pv->host, HOSTALIASZ));
                ap_rprintf(r, reduce_display ? " " : "\n");
            }
        }
    }
    if (size && !reduce_display) {
        ap_rprintf(r, "</pre>");
    }
}

static void print_sessionid(request_rec *r)
{
    int size, i;
    int *id;

    /* Process the Sessionids */
    size = loc_get_max_size_sessionid();
    if (size == 0) {
        return;
    }
    id = apr_palloc(r->pool, sizeof(int) * size);
    size = get_ids_used_sessionid(sessionidstatsmem, id);
    if (!size) {
        return;
    }
    ap_rprintf(r, "<h1>SessionIDs:</h1>");
    ap_rprintf(r, "<pre>");
    for (i = 0; i < size; i++) {
        sessionidinfo_t *ou;
        if (get_sessionid(sessionidstatsmem, &ou, id[i]) != APR_SUCCESS) {
            continue;
        }
        ap_rprintf(r, "id: %.*s route: %.*s\n", SESSIONIDSZ, ou->sessionid, JVMROUTESZ, ou->JVMRoute);
    }
    ap_rprintf(r, "</pre>");
}

static void print_domain(request_rec *r, int reduce_display)
{
#if HAVE_CLUSTER_EX_DEBUG
    int size, i;
    int *id;

    /* Process the domain information: the removed node belonging to a domain are stored there */
    if (reduce_display) {
        ap_rprintf(r, "<br/>LBGroup:");
    } else {
        ap_rprintf(r, "<h1>LBGroup:</h1>");
    }
    ap_rprintf(r, "<pre>");
    size = loc_get_max_size_domain();
    if (size == 0) {
        return;
    }
    id = apr_palloc(r->pool, sizeof(int) * size);
    size = get_ids_used_domain(domainstatsmem, id);
    for (i = 0; i < size; i++) {
        domaininfo_t *ou;
        if (get_domain(domainstatsmem, &ou, id[i]) != APR_SUCCESS) {
            continue;
        }
        ap_rprintf(r, "dom: %.*s route: %.*s balancer: %.*s\n", DOMAINNDSZ, ou->domain, JVMROUTESZ, ou->JVMRoute,
                   BALANCERSZ, ou->balancer);
    }
    ap_rprintf(r, "</pre>");
#else
    (void)r;
    (void)reduce_display;
#endif
}

static int count_sessionid(request_rec *r, const char *route)
{
    int size, i;
    int *id;
    int count = 0;

    /* Count the sessionid corresponding to the route */
    size = loc_get_max_size_sessionid();
    if (size == 0) {
        return 0;
    }
    id = apr_palloc(r->pool, sizeof(int) * size);
    size = get_ids_used_sessionid(sessionidstatsmem, id);
    for (i = 0; i < size; i++) {
        sessionidinfo_t *ou;
        if (get_sessionid(sessionidstatsmem, &ou, id[i]) != APR_SUCCESS) {
            continue;
        }
        if (strcmp(route, ou->JVMRoute) == 0) {
            count++;
        }
    }
    return count;
}

static void process_error(request_rec *r, char *errstring, int errtype)
{
    r->status_line = apr_psprintf(r->pool, "ERROR");
    apr_table_setn(r->err_headers_out, "Version", VERSION_PROTOCOL);
    switch (errtype) {
    case TYPESYNTAX:
        apr_table_setn(r->err_headers_out, "Type", "SYNTAX");
        break;
    case TYPEMEM:
        apr_table_setn(r->err_headers_out, "Type", "MEM");
        break;
    default:
        apr_table_setn(r->err_headers_out, "Type", "GENERAL");
        break;
    }
    apr_table_setn(r->err_headers_out, "Mess", errstring);
    ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, "manager_handler %s error: %s", r->method, errstring);
}

static int cmp_nodes(const void *n1, const void *n2)
{
    return strcmp(((nodeinfo_t *)n1)->mess.Domain, ((nodeinfo_t *)n2)->mess.Domain);
}

static void sort_nodes(nodeinfo_t *nodes, int nbnodes)
{
    qsort(nodes, nbnodes, sizeof(nodeinfo_t), cmp_nodes);
}

/*
 * Helper function, returns 1 in case of the application command. Otherwise returns 0
 */
static int process_appl(const char *cmd, request_rec *r, char **ptr, int *errtype, int global, char **errstring,
                        int fromnode)
{
    if (strcasecmp(cmd, "ENABLE-APP") == 0) {
        *errstring = process_enable(r, ptr, errtype, global);
    } else if (strcasecmp(cmd, "DISABLE-APP") == 0) {
        *errstring = process_disable(r, ptr, errtype, global);
    } else if (strcasecmp(cmd, "STOP-APP") == 0) {
        *errstring = process_stop(r, ptr, errtype, global, fromnode);
    } else if (strcasecmp(cmd, "REMOVE-APP") == 0) {
        *errstring = process_remove(r, ptr, errtype, global);
    } else {
        return 0;
    }

    return 1;
}

static char *process_domain(request_rec *r, char **ptr, int *errtype, const char *cmd, const char *domain)
{
    int size, i;
    int *id;
    int pos;
    char *errstring = NULL;
    size = loc_get_max_size_node();
    if (size == 0) {
        return NULL;
    }
    id = apr_palloc(r->pool, sizeof(int) * size);
    size = get_ids_used_node(nodestatsmem, id);

    for (pos = 0; ptr[pos] != NULL && ptr[pos + 1] != NULL; pos = pos + 2) {
    }

    ptr[pos] = apr_pstrdup(r->pool, "JVMRoute");
    ptr[pos + 2] = NULL;
    ptr[pos + 3] = NULL;
    ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, "process_domain");
    for (i = 0; i < size; i++) {
        nodeinfo_t *ou;
        if (get_node(nodestatsmem, &ou, id[i]) != APR_SUCCESS) {
            continue;
        }
        if (strcmp(ou->mess.Domain, domain) != 0) {
            continue;
        }
        /* add the JVMRoute */
        ptr[pos + 1] = apr_pstrdup(r->pool, ou->mess.JVMRoute);
        process_appl(cmd, r, ptr, errtype, RANGENODE, &errstring, 0);
    }
    return errstring;
}

/* XXX: move to mod_proxy_cluster as a provider ? */
static void print_proxystat(request_rec *r, int reduce_display, nodeinfo_t *node)
{
    char *status;
    proxy_worker_shared tmp;
    const proxy_worker_shared *proxystat = read_shared_by_node(r, node);
    if (!proxystat) {
        status = "NOTOK";
        proxystat = &tmp;
    } else {
        status = proxystat->status & PROXY_WORKER_NOT_USABLE_BITMAP ? "NOTOK" : "OK";
    }

    if (reduce_display) {
        ap_rprintf(r, " %s ", status);
    } else {
        ap_rprintf(r, ",Status: %s,Elected: %d,Read: %d,Transferred: %d,Connected: %d,Load: %d", status,
                   (int)proxystat->elected, (int)proxystat->read, (int)proxystat->transferred, (int)proxystat->busy,
                   proxystat->lbfactor);
    }
}

/*
 * Display module information
 */
static void modules_info(request_rec *r)
{
    if (ap_find_linked_module("mod_proxy_cluster.c") != NULL) {
        ap_rputs("mod_proxy_cluster.c: OK<br/>", r);
    } else {
        ap_rputs("mod_proxy_cluster.c: missing<br/>", r);
    }

    if (ap_find_linked_module("mod_sharedmem.c") != NULL) {
        ap_rputs("mod_sharedmem.c: OK<br/>", r);
    } else {
        ap_rputs("mod_sharedmem.c: missing<br/>", r);
    }

    ap_rputs("Protocol supported: ", r);
    if (ap_find_linked_module("mod_proxy_http.c") != NULL) {
        ap_rputs("http ", r);
    }
    if (ap_find_linked_module("mod_proxy_ajp.c") != NULL) {
        ap_rputs("AJP ", r);
    }
    if (ap_find_linked_module("mod_ssl.c") != NULL) {
        ap_rputs("https", r);
    }
    ap_rputs("<br/>", r);

    if (ap_find_linked_module("mod_advertise.c") != NULL) {
        ap_rputs("mod_advertise.c: OK<br/>", r);
    } else {
        ap_rputs("mod_advertise.c: not loaded<br/>", r);
    }
}

static void print_node(request_rec *r, nodeinfo_t *ou, const mod_manager_config *mconf, int sizesessionid)
{
    char *domain = "";

    if (mconf->reduce_display) {
        if (strcmp(domain, ou->mess.Domain) != 0) {
            ap_rprintf(r, "<br/><br/>LBGroup %.*s: ", (int)sizeof(ou->mess.Domain), ou->mess.Domain);
            domain = ou->mess.Domain;
            if (mconf->allow_cmd) {
                print_domain_command(r, domain);
            }
        }

        ap_rprintf(r, "<br/><br/>Node %.*s ", (int)sizeof(ou->mess.JVMRoute), ou->mess.JVMRoute);
        print_proxystat(r, mconf->reduce_display, ou);

        if (mconf->allow_cmd) {
            print_node_command(r, ou->mess.JVMRoute);
        }

        ap_rprintf(r, "<br/>\n");
    } else {
        if (strcmp(domain, ou->mess.Domain) != 0) {
            ap_rprintf(r, "<h1> LBGroup %.*s: ", (int)sizeof(ou->mess.Domain), ou->mess.Domain);
            domain = ou->mess.Domain;
            if (mconf->allow_cmd) {
                print_domain_command(r, domain);
            }
            if (!mconf->reduce_display) {
                ap_rprintf(r, "</h1>\n");
            }
        }

        ap_rprintf(r, "<h1> Node %.*s (%.*s://%.*s:%.*s): </h1>\n", (int)sizeof(ou->mess.JVMRoute), ou->mess.JVMRoute,
                   (int)sizeof(ou->mess.Type), ou->mess.Type, (int)sizeof(ou->mess.Host), ou->mess.Host,
                   (int)sizeof(ou->mess.Port), ou->mess.Port);

        if (mconf->allow_cmd) {
            print_node_command(r, ou->mess.JVMRoute);
        }

        ap_rprintf(r, "<br/>\n");
        ap_rprintf(r, "Balancer: %.*s,LBGroup: %.*s", (int)sizeof(ou->mess.balancer), ou->mess.balancer,
                   (int)sizeof(ou->mess.Domain), ou->mess.Domain);

        ap_rprintf(r, ",Flushpackets: %s,Flushwait: %d,Ping: %d,Smax: %d,Ttl: %d", flush_to_str(ou->mess.flushpackets),
                   ou->mess.flushwait, (int)ou->mess.ping, ou->mess.smax, (int)ou->mess.ttl);

        print_proxystat(r, mconf->reduce_display, ou);
    }

    if (sizesessionid) {
        ap_rprintf(r, ",Num sessions: %d", count_sessionid(r, ou->mess.JVMRoute));
    }
    ap_rprintf(r, "\n");
}

/*
 * Helper function for processing parameters. Returns the command it got.
 */
static const char *process_params(request_rec *r, apr_table_t *params, int allow_cmd, char **errstr)
{
    const char *val = apr_table_get(params, "Refresh");
    const char *cmd = apr_table_get(params, "Cmd");
    const char *range = apr_table_get(params, "Range");
    const char *domain = apr_table_get(params, "Domain");
    char *errstring = *errstr;
    /* Process the Refresh parameter */
    int errtype = 0;

    if (val) {
        long t = atol(val);
        apr_table_set(r->headers_out, "Refresh", apr_ltoa(r->pool, t < 1 ? 10 : t));
    }

    if (!cmd) {
        return NULL;
    }

    /* Process INFO and DUMP */
    if (strcasecmp(cmd, "DUMP") == 0) {
        errstring = process_dump(r, &errtype);
        if (!errstring) {
            return cmd;
        }
    } else if (strcasecmp(cmd, "INFO") == 0) {
        errstring = process_info(r, &errtype);
        if (!errstring) {
            return cmd;
        }
    }
    if (errstring) {
        process_error(r, errstring, errtype);
    }
    /* Process other command if any */
    if (range != NULL && allow_cmd && errstring == NULL) {
        int global = RANGECONTEXT;
        int i;
        char **ptr;
        const apr_array_header_t *arr = apr_table_elts(params);
        const apr_table_entry_t *elts = (const apr_table_entry_t *)arr->elts;
        errtype = 0;

        if (strcasecmp(range, "NODE") == 0) {
            global = RANGENODE;
        } else if (strcasecmp(range, "DOMAIN") == 0) {
            global = RANGEDOMAIN;
        }
        if (global == RANGEDOMAIN) {
            ptr = apr_palloc(r->pool, sizeof(char *) * (arr->nelts + 2) * 2);
        } else {
            ptr = apr_palloc(r->pool, sizeof(char *) * (arr->nelts + 1) * 2);
        }

        for (i = 0; i < arr->nelts; i++) {
            ptr[i * 2] = elts[i].key;
            ptr[i * 2 + 1] = elts[i].val;
        }
        ptr[arr->nelts * 2] = NULL;
        ptr[arr->nelts * 2 + 1] = NULL;

        if (global == RANGEDOMAIN) {
            errstring = process_domain(r, ptr, &errtype, cmd, domain);
        } else if (!process_appl(cmd, r, ptr, &errtype, global, errstr, 0)) {
            errstring = SCMDUNS;
            errtype = TYPESYNTAX;
        }

        if (errstring) {
            process_error(r, errstring, errtype);
        }
    }

    return cmd;
}

static void print_fileheader(request_rec *r, const mod_manager_config *mconf, const char *errstring)
{
    ap_set_content_type(r, "text/html; charset=ISO-8859-1");
    ap_rputs(DOCTYPE_HTML_3_2 "<html><head>\n<title>Mod_cluster Status</title>\n</head><body>\n", r);
    ap_rvputs(r, "<h1>", MOD_CLUSTER_EXPOSED_VERSION, "</h1>", NULL);

    if (errstring) {
        ap_rvputs(r, "<h1> Command failed: ", errstring, "</h1>\n", NULL);
        ap_rvputs(r, " <a href=\"", r->uri, "\">Continue</a>\n", NULL);
        ap_rputs("</body></html>\n", r);
        return;
    }

    /* Advertise information */
    if (mconf->allow_display) {
        ap_rputs("start of \"httpd.conf\" configuration<br/>", r);
        modules_info(r);
        if (advertise_info != NULL) {
            advertise_info(r);
        }
        ap_rputs("end of \"httpd.conf\" configuration<br/><br/>", r);
    }

    ap_rvputs(r, "<a href=\"", r->uri, "?", balancer_nonce_string(r), "refresh=10", "\">Auto Refresh</a>", NULL);
    ap_rvputs(r, " <a href=\"", r->uri, "?", balancer_nonce_string(r), "Cmd=DUMP&Range=ALL", "\">show DUMP output</a>",
              NULL);
    ap_rvputs(r, " <a href=\"", r->uri, "?", balancer_nonce_string(r), "Cmd=INFO&Range=ALL", "\">show INFO output</a>",
              NULL);
    ap_rputs("\n", r);
}

static void print_nodes(request_rec *r, const mod_manager_config *mconf, int size, int sizesessionid)
{
    int *ids;
    int i, nbnodes;
    nodeinfo_t *nodes;

    ids = apr_palloc(r->pool, sizeof(int) * size);
    size = get_ids_used_node(nodestatsmem, ids);

    /* Read the node to sort them by domain */
    nodes = apr_palloc(r->pool, sizeof(nodeinfo_t) * size);
    for (i = nbnodes = 0; i < size; i++) {
        nodeinfo_t *ou;
        if (get_node(nodestatsmem, &ou, ids[i]) != APR_SUCCESS) {
            continue;
        }
        memcpy(&nodes[nbnodes], ou, sizeof(nodeinfo_t));
        nbnodes++;
    }
    sort_nodes(nodes, nbnodes);

    /* Print the ordered nodes */
    for (i = 0; i < size; i++) {
        nodeinfo_t *ou = &nodes[i];
        print_node(r, &nodes[i], mconf, sizesessionid);
        /* Process the Vhosts */
        print_hosts(r, mconf->reduce_display, mconf->allow_cmd, ou->mess.id, ou->mess.JVMRoute);
    }
}

/*
 * Process INFO message and mod_cluster_manager pages generation
 */
static int manager_info(request_rec *r)
{
    int size, sizesessionid, access_status;
    apr_table_t *params = apr_table_make(r->pool, 10);
    const char *name;
    char *errstring = NULL;
    mod_manager_config *mconf = ap_get_module_config(r->server->module_config, &manager_module);

    if (r->args) {
        char *args = apr_pstrdup(r->pool, r->args);
        char *tok, *val;
        while (args && *args) {
            val = ap_strchr(args, '=');
            if (!val) {
                return HTTP_BAD_REQUEST;
            }
            *val++ = '\0';
            if ((tok = ap_strchr(val, '&'))) {
                *tok++ = '\0';
            }
            /*
             * Special case: contexts contain path information
             */
            if ((access_status = ap_unescape_url(val)) != OK) {
                if (strcmp(args, "Context") || (access_status != HTTP_NOT_FOUND)) {
                    return access_status;
                }
            }
            apr_table_setn(params, args, val);
            args = tok;
        }
        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "manager_info: request: %s", r->args);
    }

    /*
     * Check that the supplied nonce matches this server's nonce;
     * otherwise ignore all parameters, to prevent a CSRF attack.
     */
    if (mconf->nonce && ((name = apr_table_get(params, "nonce")) == NULL || strcmp(balancer_nonce, name) != 0)) {
        apr_table_clear(params);
    }

    /* Process the parameters */
    if (r->args) {
        const char *cmd = process_params(r, params, mconf->allow_cmd, &errstring);
        if (cmd && (strcasecmp(cmd, "INFO") == 0 || strcasecmp(cmd, "DUMP") == 0)) {
            return OK;
        }
    }

    print_fileheader(r, mconf, errstring);
    if (errstring) {
        return OK;
    }

    size = loc_get_max_size_node();
    if (size == 0) {
        return OK;
    }

    sizesessionid = loc_get_max_size_sessionid();
    /* Display nodes sorted by domain */
    print_nodes(r, mconf, size, sizesessionid);

    /* Display the sessions */
    if (sizesessionid) {
        print_sessionid(r);
    }

    print_domain(r, mconf->reduce_display);

    ap_rputs("</body></html>\n", r);
    return OK;
}

/* Process the requests from the ModClusterService */
static int manager_handler(request_rec *r)
{
    apr_bucket_brigade *input_brigade;
    char *buff, *errstring = NULL;
    int errtype = 0, global = 0;
    apr_size_t bufsiz = 0, maxbufsiz, len;
    apr_status_t status;
    char **ptr;
    mod_manager_config *mconf;

    if (strcmp(r->handler, "mod_cluster-manager") == 0) {
        /* Display the nodes information */
        if (r->method_number != M_GET) {
            return DECLINED;
        }
        return manager_info(r);
    }

    mconf = ap_get_module_config(r->server->module_config, &manager_module);
    if (!mconf->enable_mcmp_receive) {
        return DECLINED; /* Not allowed to receive MCMP */
    }

    if (!is_our_method(r)) {
        return DECLINED;
    }

    /* Use a buffer to read the message */
    if (mconf->maxmesssize) {
        maxbufsiz = mconf->maxmesssize;
    } else {
        /* we calculate it */
        maxbufsiz = 9 + JVMROUTESZ;
        maxbufsiz = maxbufsiz + (mconf->maxhost * HOSTALIASZ) + 7;
        maxbufsiz = maxbufsiz + (mconf->maxcontext * CONTEXTSZ) + 8;
    }
    if (maxbufsiz < MAXMESSSIZE) {
        maxbufsiz = MAXMESSSIZE;
    }
    buff = apr_pcalloc(r->pool, maxbufsiz);
    input_brigade = apr_brigade_create(r->pool, r->connection->bucket_alloc);
    len = maxbufsiz;
    while (APR_SUCCESS ==
           (status = ap_get_brigade(r->input_filters, input_brigade, AP_MODE_READBYTES, APR_BLOCK_READ, len))) {
        apr_brigade_flatten(input_brigade, buff + bufsiz, &len);
        apr_brigade_cleanup(input_brigade);
        bufsiz += len;
        if (bufsiz >= maxbufsiz || len == 0) {
            break;
        }
        len = maxbufsiz - bufsiz;
    }

    if (status != APR_SUCCESS) {
        process_error(r, apr_psprintf(r->pool, SREADER, r->method), TYPESYNTAX);
        return HTTP_INTERNAL_SERVER_ERROR;
    }
    buff[bufsiz] = '\0';

    /* XXX: Size limit it? */
    ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "manager_handler: %s (%s) processing: \"%s\"", r->method,
                 r->filename, buff);

    ptr = process_buff(r, buff);
    if (ptr == NULL) {
        process_error(r, SMESPAR, TYPESYNTAX);
        return HTTP_INTERNAL_SERVER_ERROR;
    }
    if (strstr(r->filename, NODE_COMMAND)) {
        global = 1;
    }

    if (strcasecmp(r->method, "CONFIG") == 0) {
        errstring = process_config(r, ptr, &errtype);
        /* Status handling */
    } else if (strcasecmp(r->method, "STATUS") == 0) {
        errstring = process_status(r, (const char *const *)ptr, &errtype);
    } else if (strcasecmp(r->method, "DUMP") == 0) {
        errstring = process_dump(r, &errtype);
    } else if (strcasecmp(r->method, "INFO") == 0) {
        errstring = process_info(r, &errtype);
    } else if (strcasecmp(r->method, "PING") == 0) {
        errstring = process_ping(r, (const char *const *)ptr, &errtype);
    } else if (strcasecmp(r->method, "VERSION") == 0) {
        errstring = process_version(r, (const char *const *)ptr, &errtype);
        /* Application handling */
    } else if (!process_appl(r->method, r, ptr, &errtype, global, &errstring, 1)) {
        errstring = SCMDUNS;
        errtype = TYPESYNTAX;
    }

    /* Check error string and build the error message */
    if (errstring) {
        process_error(r, errstring, errtype);
        return HTTP_INTERNAL_SERVER_ERROR;
    }

    ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, "manager_handler: %s  OK", r->method);

    ap_rflush(r);
    return OK;
}

/*
 * Attach to the shared memory when the child is created
 */
static void manager_child_init(apr_pool_t *p, server_rec *s)
{
    char *node;
    char *context;
    char *host;
    char *balancer;
    char *sessionid;
    mod_manager_config *mconf = ap_get_module_config(s->module_config, &manager_module);

    if (storage == NULL) {
        /* that happens when doing a gracefull restart for example after additing/changing the storage provider */
        ap_log_error(APLOG_MARK, APLOG_EMERG, 0, s, "Fatal storage provider not initialized");
        return;
    }

    if (apr_global_mutex_child_init(&node_mutex, apr_global_mutex_lockfile(node_mutex), p) != APR_SUCCESS) {
        ap_log_error(APLOG_MARK, APLOG_CRIT, 0, s, APLOGNO(02994) "Failed to reopen mutex %s in child",
                     node_mutex_type);
        exit(EXIT_FAILURE);
    }
    if (apr_global_mutex_child_init(&context_mutex, apr_global_mutex_lockfile(context_mutex), p) != APR_SUCCESS) {
        ap_log_error(APLOG_MARK, APLOG_CRIT, 0, s, APLOGNO(02994) "Failed to reopen mutex %s in child",
                     context_mutex_type);
        exit(EXIT_FAILURE);
    }

    mconf->tableversion = 0;

    if (mconf->basefilename) {
        node = apr_pstrcat(p, mconf->basefilename, "/manager.node", NULL);
        context = apr_pstrcat(p, mconf->basefilename, "/manager.context", NULL);
        host = apr_pstrcat(p, mconf->basefilename, "/manager.host", NULL);
        balancer = apr_pstrcat(p, mconf->basefilename, "/manager.balancer", NULL);
        sessionid = apr_pstrcat(p, mconf->basefilename, "/manager.sessionid", NULL);
    } else {
        node = ap_server_root_relative(p, "logs/manager.node");
        context = ap_server_root_relative(p, "logs/manager.context");
        host = ap_server_root_relative(p, "logs/manager.host");
        balancer = ap_server_root_relative(p, "logs/manager.balancer");
        sessionid = ap_server_root_relative(p, "logs/manager.sessionid");
    }

    nodestatsmem = get_mem_node(node, &mconf->maxnode, p, storage);
    if (nodestatsmem == NULL) {
        ap_log_error(APLOG_MARK, APLOG_EMERG, 0, s, "manager_child_init: get_mem_node %s failed", node);
        return;
    }
    if (get_last_mem_error(nodestatsmem) != APR_SUCCESS) {
        char buf[120];
        ap_log_error(APLOG_MARK, APLOG_EMERG, 0, s, "manager_child_init: get_mem_node %s failed: %s", node,
                     apr_strerror(get_last_mem_error(nodestatsmem), buf, sizeof(buf)));
        return;
    }

    contextstatsmem = get_mem_context(context, &mconf->maxcontext, p, storage);
    if (contextstatsmem == NULL) {
        ap_log_error(APLOG_MARK, APLOG_EMERG, 0, s, "manager_child_init: get_mem_context failed");
        return;
    }

    hoststatsmem = get_mem_host(host, &mconf->maxhost, p, storage);
    if (hoststatsmem == NULL) {
        ap_log_error(APLOG_MARK, APLOG_EMERG, 0, s, "manager_child_init: get_mem_host failed");
        return;
    }

    balancerstatsmem = get_mem_balancer(balancer, &mconf->maxhost, p, storage);
    if (balancerstatsmem == NULL) {
        ap_log_error(APLOG_MARK, APLOG_EMERG, 0, s, "manager_child_init: get_mem_balancer failed");
        return;
    }

    if (mconf->maxsessionid) {
        /*  Try to get sessionid stuff only if required */
        sessionidstatsmem = get_mem_sessionid(sessionid, &mconf->maxsessionid, p, storage);
        if (sessionidstatsmem == NULL) {
            ap_log_error(APLOG_MARK, APLOG_EMERG, 0, s, "manager_child_init: get_mem_sessionid failed");
            return;
        }
    }
}

/*
 * Supported directives
 */
static const char *cmd_manager_maxcontext(cmd_parms *cmd, void *mconfig, const char *word)
{
    mod_manager_config *mconf = ap_get_module_config(cmd->server->module_config, &manager_module);
    const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);
    (void)mconfig;

    if (err != NULL) {
        return err;
    }
    mconf->maxcontext = atoi(word);
    return NULL;
}

static const char *cmd_manager_maxnode(cmd_parms *cmd, void *mconfig, const char *word)
{
    mod_manager_config *mconf = ap_get_module_config(cmd->server->module_config, &manager_module);
    const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);
    (void)mconfig;

    if (err != NULL) {
        return err;
    }
    mconf->maxnode = atoi(word);
    return NULL;
}

static const char *cmd_manager_maxhost(cmd_parms *cmd, void *mconfig, const char *word)
{
    mod_manager_config *mconf = ap_get_module_config(cmd->server->module_config, &manager_module);
    const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);
    (void)mconfig;

    if (err != NULL) {
        return err;
    }
    mconf->maxhost = atoi(word);
    return NULL;
}

static const char *cmd_manager_maxsessionid(cmd_parms *cmd, void *mconfig, const char *word)
{
    mod_manager_config *mconf = ap_get_module_config(cmd->server->module_config, &manager_module);
    const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);
    (void)mconfig;

    if (err != NULL) {
        return err;
    }
    mconf->maxsessionid = atoi(word);
    return NULL;
}

static const char *cmd_manager_memmanagerfile(cmd_parms *cmd, void *mconfig, const char *word)
{
    mod_manager_config *mconf = ap_get_module_config(cmd->server->module_config, &manager_module);
    const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);
    (void)mconfig;

    if (err != NULL) {
        return err;
    }
    mconf->basefilename = ap_server_root_relative(cmd->pool, word);
    if (apr_dir_make_recursive(mconf->basefilename, APR_UREAD | APR_UWRITE | APR_UEXECUTE, cmd->pool) != APR_SUCCESS) {
        return "Can't create directory corresponding to MemManagerFile";
    }
    return NULL;
}

static const char *cmd_manager_balancername(cmd_parms *cmd, void *mconfig, const char *word)
{
    mod_manager_config *mconf = ap_get_module_config(cmd->server->module_config, &manager_module);
    mconf->balancername = apr_pstrdup(cmd->pool, word);
    normalize_balancer_name(mconf->balancername, cmd->server);
    (void)mconfig; /* unused variable */
    return NULL;
}

static const char *cmd_manager_pers(cmd_parms *cmd, void *dummy, const char *arg)
{
    mod_manager_config *mconf = ap_get_module_config(cmd->server->module_config, &manager_module);
    const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);
    (void)dummy;

    if (err != NULL) {
        return err;
    }

    if (!process_boolean_parameter(arg, &mconf->persistent)) {
        return "PersistSlots must be one of: off | on";
    }

    return NULL;
}

static const char *cmd_manager_nonce(cmd_parms *cmd, void *dummy, const char *arg)
{
    mod_manager_config *mconf = ap_get_module_config(cmd->server->module_config, &manager_module);
    (void)dummy;

    if (!process_boolean_parameter(arg, &mconf->nonce)) {
        return "CheckNonce must be one of: off | on";
    }

    return NULL;
}

static const char *cmd_manager_allow_display(cmd_parms *cmd, void *dummy, const char *arg)
{
    mod_manager_config *mconf = ap_get_module_config(cmd->server->module_config, &manager_module);
    (void)dummy;

    if (!process_boolean_parameter(arg, &mconf->allow_display)) {
        return "AllowDisplay must be one of: off | on";
    }

    return NULL;
}

static const char *cmd_manager_allow_cmd(cmd_parms *cmd, void *dummy, const char *arg)
{
    mod_manager_config *mconf = ap_get_module_config(cmd->server->module_config, &manager_module);
    (void)dummy;

    if (!process_boolean_parameter(arg, &mconf->allow_cmd)) {
        return "AllowCmd must be one of: off | on";
    }

    return NULL;
}

static const char *cmd_manager_reduce_display(cmd_parms *cmd, void *dummy, const char *arg)
{
    mod_manager_config *mconf = ap_get_module_config(cmd->server->module_config, &manager_module);
    (void)dummy;

    if (!process_boolean_parameter(arg, &mconf->reduce_display)) {
        return "ReduceDisplay must be one of: off | on";
    }

    return NULL;
}

static const char *cmd_manager_maxmesssize(cmd_parms *cmd, void *mconfig, const char *word)
{
    mod_manager_config *mconf = ap_get_module_config(cmd->server->module_config, &manager_module);
    const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);
    (void)mconfig;

    if (err != NULL) {
        return err;
    }
    mconf->maxmesssize = atoi(word);
    if (mconf->maxmesssize < MAXMESSSIZE) {
        return "MaxMCMPMessSize must bigger than 1024";
    }
    return NULL;
}

static const char *cmd_manager_enable_mcmp_receive(cmd_parms *cmd, void *dummy)
{
    mod_manager_config *mconf = ap_get_module_config(cmd->server->module_config, &manager_module);
    ap_directive_t *directive = cmd->directive->parent ? cmd->directive->parent->first_child : cmd->directive;
    (void)dummy;

    if (!cmd->server->is_virtual) {
        return "EnableMCMPReceive must be in a VirtualHost";
    }

    while (directive) {
        if (strcmp(directive->directive, "<Directory") == 0) {
            return "Directory cannot be used with EnableMCMPReceive, use Location instead";
        }
        directive = directive->next;
    }

    mconf->enable_mcmp_receive = 1;
    return NULL;
}

static const char *cmd_manager_enable_mcmp_receive_deprecated(cmd_parms *cmd, void *dummy)
{
    ap_log_error(APLOG_MARK, APLOG_WARNING, 0, NULL,
                 "EnableMCPMReceive is deprecated misspelled version of 'EnableMCMPReceive' configuration option. "
                 "Please update your configuration.");

    return cmd_manager_enable_mcmp_receive(cmd, dummy);
}

static const char *cmd_manager_enable_ws_tunnel(cmd_parms *cmd, void *dummy)
{
    mod_manager_config *mconf = ap_get_module_config(cmd->server->module_config, &manager_module);
    const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);
    (void)dummy;

    if (err != NULL) {
        return err;
    }
    if (ap_find_linked_module("mod_proxy_http.c") != NULL) {
        mconf->enable_ws_tunnel = 1;
        return NULL;
    }

    return "EnableWsTunnel requires mod_proxy_http.c";
}

static const char *cmd_manager_ws_upgrade_header(cmd_parms *cmd, void *mconfig, const char *word)
{
    mod_manager_config *mconf = ap_get_module_config(cmd->server->module_config, &manager_module);
    const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);
    (void)mconfig;

    if (err != NULL) {
        return err;
    }
    if (strlen(word) >= PROXY_WORKER_MAX_SCHEME_SIZE) {
        return apr_psprintf(cmd->temp_pool, "upgrade protocol length must be < %d characters",
                            PROXY_WORKER_MAX_SCHEME_SIZE);
    }
    if (ap_find_linked_module("mod_proxy_http.c") != NULL) {
        mconf->enable_ws_tunnel = 1;
        mconf->ws_upgrade_header = apr_pstrdup(cmd->pool, word);
        return NULL;
    }

    return "WSUpgradeHeader requires mod_proxy_http.c";
}

static const char *cmd_manager_ajp_secret(cmd_parms *cmd, void *mconfig, const char *word)
{
    mod_manager_config *mconf = ap_get_module_config(cmd->server->module_config, &manager_module);
    const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);
    (void)mconfig;

    if (err != NULL) {
        return err;
    }
    if (strlen(word) >= PROXY_WORKER_MAX_SECRET_SIZE) {
        return apr_psprintf(cmd->temp_pool, "AJP secret length must be < %d characters", PROXY_WORKER_MAX_SECRET_SIZE);
    }
    if (ap_find_linked_module("mod_proxy_ajp.c") != NULL) {
        mconf->ajp_secret = apr_pstrdup(cmd->pool, word);
        return NULL;
    }

    return "AJPsecret requires mod_proxy_ajp.c";
}

static const char *cmd_manager_responsefieldsize(cmd_parms *cmd, void *mconfig, const char *word)
{
    mod_manager_config *mconf = ap_get_module_config(cmd->server->module_config, &manager_module);
    const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);
    long s = atol(word);
    (void)mconfig;

    if (err != NULL) {
        return err;
    }
    if (s < 0) {
        return "ResponseFieldSize must be greater than 0 bytes, or 0 for system default.";
    }
    if (ap_find_linked_module("mod_proxy_http.c") != NULL) {
        mconf->response_field_size = (s ? s : HUGE_STRING_LEN);
        return NULL;
    }

    return "ResponseFieldSize requires mod_proxy_http.c";
}

/* clang-format off */
static const command_rec manager_cmds[] = {
    AP_INIT_TAKE1("Maxcontext", cmd_manager_maxcontext, NULL, OR_ALL,
                  "Maxcontext - number max context supported by mod_cluster"),
    AP_INIT_TAKE1("Maxnode", cmd_manager_maxnode, NULL, OR_ALL, "Maxnode - number max node supported by mod_cluster"),
    AP_INIT_TAKE1("Maxhost", cmd_manager_maxhost, NULL, OR_ALL,
                  "Maxhost - number max host (Alias in virtual hosts) supported by mod_cluster"),
    AP_INIT_TAKE1(
        "Maxsessionid", cmd_manager_maxsessionid, NULL, OR_ALL,
        "Maxsessionid - number session (Used to track number of sessions per nodes) supported by mod_cluster"),
    AP_INIT_TAKE1("MemManagerFile", cmd_manager_memmanagerfile, NULL, OR_ALL,
                  "MemManagerFile - base name of the files used to create/attach to shared memory"),
    AP_INIT_TAKE1("ManagerBalancerName", cmd_manager_balancername, NULL, OR_ALL,
                  "ManagerBalancerName - name of a balancer corresponding to the manager"),
    AP_INIT_TAKE1("PersistSlots", cmd_manager_pers, NULL, OR_ALL,
                  "PersistSlots - Persist the slot mem elements on | off (Default: off No persistence)"),
    AP_INIT_TAKE1("CheckNonce", cmd_manager_nonce, NULL, OR_ALL,
                  "CheckNonce - Switch check of nonce when using mod_cluster-manager handler on | off (Default: on "
                  "Nonce checked)"),
    AP_INIT_TAKE1("AllowDisplay", cmd_manager_allow_display, NULL, OR_ALL,
                  "AllowDisplay - Display additional information in the mod_cluster-manager page on | off (Default: "
                  "off Only version displayed)"),
    AP_INIT_TAKE1("AllowCmd", cmd_manager_allow_cmd, NULL, OR_ALL,
                  "AllowCmd - Allow commands using mod_cluster-manager URL on | off (Default: on Commmands allowed)"),
    AP_INIT_TAKE1("ReduceDisplay", cmd_manager_reduce_display, NULL, OR_ALL,
                  "ReduceDisplay - Don't contexts in the main mod_cluster-manager page. on | off (Default: off Context "
                  "displayed)"),
    AP_INIT_TAKE1("MaxMCMPMessSize", cmd_manager_maxmesssize, NULL, OR_ALL,
                  "MaxMCMPMaxMessSize - Maximum size of MCMP messages. (Default: calculated min value: 1024)"),
    AP_INIT_NO_ARGS("EnableMCMPReceive", cmd_manager_enable_mcmp_receive, NULL, OR_ALL,
                    "EnableMCMPReceive - Allow the VirtualHost to receive MCMP."),
    AP_INIT_NO_ARGS("EnableMCPMReceive", cmd_manager_enable_mcmp_receive_deprecated, NULL, OR_ALL,
                    "EnableMCPMReceive - Deprecated misspelled version of 'EnableMCMPReceive' configuration option "
                    "kept in for configuration backwards compatibility."),
    AP_INIT_NO_ARGS(
        "EnableWsTunnel", cmd_manager_enable_ws_tunnel, NULL, OR_ALL,
        "EnableWsTunnel - Use ws or wss instead of http or https when creating nodes (allows WebSocket proxying)."),
    AP_INIT_TAKE1(
        "WSUpgradeHeader", cmd_manager_ws_upgrade_header, NULL, OR_ALL,
        "WSUpgradeHeader - Accept http upgrade headers. Values: WebSocket or * to use any supplied by a client."),
    AP_INIT_TAKE1("AJPSecret", cmd_manager_ajp_secret, NULL, OR_ALL,
                  "AJPSecret - secret for all mod_cluster node, not configued no secret."),
    AP_INIT_TAKE1("ResponseFieldSize", cmd_manager_responsefieldsize, NULL, OR_ALL,
                  "ResponseFieldSize - Adjust the size of the proxy response field buffer."),
    {.name = NULL}
};
/* clang-format on */

/* hooks declaration */

static void manager_hooks(apr_pool_t *p)
{
    static const char *const aszSucc[] = {"mod_proxy.c", NULL};

    /* For the lock */
    ap_hook_pre_config(manager_pre_config, NULL, NULL, APR_HOOK_MIDDLE);

    /* Create the shared tables for mod_proxy_cluster */
    ap_hook_post_config(manager_init, NULL, NULL, APR_HOOK_MIDDLE);

    /* Attach to the shared tables with create the child */
    ap_hook_child_init(manager_child_init, NULL, NULL, APR_HOOK_FIRST);

    /* post read_request handling: to be handle to use ProxyPass / */
    ap_hook_translate_name(manager_trans, NULL, aszSucc, APR_HOOK_FIRST);

    /* Process the request from the ModClusterService */
    ap_hook_handler(manager_handler, NULL, NULL, APR_HOOK_REALLY_FIRST);

    /* prevent subrequest to map our / or what ever is send with our methods. */
    ap_hook_map_to_storage(manager_map_to_storage, NULL, NULL, APR_HOOK_REALLY_FIRST);

    /* Register nodes/hosts/contexts table provider */
    ap_register_provider(p, "manager", "shared", "0", &node_storage);
    ap_register_provider(p, "manager", "shared", "1", &host_storage);
    ap_register_provider(p, "manager", "shared", "2", &context_storage);
    ap_register_provider(p, "manager", "shared", "3", &balancer_storage);
    ap_register_provider(p, "manager", "shared", "4", &sessionid_storage);
    ap_register_provider(p, "manager", "shared", "5", &domain_storage);
    ap_register_provider(p, "manager", "shared", "6", &set_proxyhctemplate);
}

/*
 * Config creation stuff
 */
static void *create_manager_config(apr_pool_t *p)
{
    mod_manager_config *mconf = apr_pcalloc(p, sizeof(*mconf));

    mconf->basefilename = NULL;
    mconf->maxcontext = DEFMAXCONTEXT;
    mconf->maxnode = DEFMAXNODE;
    mconf->maxhost = DEFMAXHOST;
    mconf->maxsessionid = DEFMAXSESSIONID;
    mconf->tableversion = 0;
    mconf->persistent = 0;
    mconf->nonce = -1;
    mconf->balancername = NULL;
    mconf->allow_display = 0;
    mconf->allow_cmd = -1;
    mconf->reduce_display = 0;
    mconf->enable_mcmp_receive = 0;
    mconf->enable_ws_tunnel = 0;
    mconf->ws_upgrade_header = NULL;
    mconf->ajp_secret = NULL;
    mconf->response_field_size = 0;
    return mconf;
}

static void *create_manager_server_config(apr_pool_t *p, server_rec *s)
{
    (void)s;
    return create_manager_config(p);
}

static void *merge_manager_server_config(apr_pool_t *p, void *server1_conf, void *server2_conf)
{
    mod_manager_config *mconf1 = (mod_manager_config *)server1_conf;
    mod_manager_config *mconf2 = (mod_manager_config *)server2_conf;
    mod_manager_config *mconf = (mod_manager_config *)create_manager_config(p);

    if (mconf2->basefilename) {
        mconf->basefilename = apr_pstrdup(p, mconf2->basefilename);
    } else if (mconf1->basefilename) {
        mconf->basefilename = apr_pstrdup(p, mconf1->basefilename);
    }

    if (mconf2->maxcontext != DEFMAXCONTEXT) {
        mconf->maxcontext = mconf2->maxcontext;
    } else if (mconf1->maxcontext != DEFMAXCONTEXT) {
        mconf->maxcontext = mconf1->maxcontext;
    }

    if (mconf2->maxnode != DEFMAXNODE) {
        mconf->maxnode = mconf2->maxnode;
    } else if (mconf1->maxnode != DEFMAXNODE) {
        mconf->maxnode = mconf1->maxnode;
    }

    if (mconf2->maxhost != DEFMAXHOST) {
        mconf->maxhost = mconf2->maxhost;
    } else if (mconf1->maxhost != DEFMAXHOST) {
        mconf->maxhost = mconf1->maxhost;
    }

    if (mconf2->maxsessionid != DEFMAXSESSIONID) {
        mconf->maxsessionid = mconf2->maxsessionid;
    } else if (mconf1->maxsessionid != DEFMAXSESSIONID) {
        mconf->maxsessionid = mconf1->maxsessionid;
    }

    if (mconf2->persistent != 0) {
        mconf->persistent = mconf2->persistent;
    } else if (mconf1->persistent != 0) {
        mconf->persistent = mconf1->persistent;
    }

    if (mconf2->nonce != -1) {
        mconf->nonce = mconf2->nonce;
    } else if (mconf1->nonce != -1) {
        mconf->nonce = mconf1->nonce;
    }

    if (mconf2->balancername) {
        mconf->balancername = apr_pstrdup(p, mconf2->balancername);
    } else if (mconf1->balancername) {
        mconf->balancername = apr_pstrdup(p, mconf1->balancername);
    }

    if (mconf2->allow_display != 0) {
        mconf->allow_display = mconf2->allow_display;
    } else if (mconf1->allow_display != 0) {
        mconf->allow_display = mconf1->allow_display;
    }

    if (mconf2->allow_cmd != -1) {
        mconf->allow_cmd = mconf2->allow_cmd;
    } else if (mconf1->allow_cmd != -1) {
        mconf->allow_cmd = mconf1->allow_cmd;
    }

    if (mconf2->reduce_display != 0) {
        mconf->reduce_display = mconf2->reduce_display;
    } else if (mconf1->reduce_display != 0) {
        mconf->reduce_display = mconf1->reduce_display;
    }

    if (mconf2->enable_mcmp_receive != 0) {
        mconf->enable_mcmp_receive = mconf2->enable_mcmp_receive;
    } else if (mconf1->enable_mcmp_receive != 0) {
        mconf->enable_mcmp_receive = mconf1->enable_mcmp_receive;
    }

    if (mconf2->enable_ws_tunnel != 0) {
        mconf->enable_ws_tunnel = mconf2->enable_ws_tunnel;
    } else if (mconf1->enable_ws_tunnel != 0) {
        mconf->enable_ws_tunnel = mconf1->enable_ws_tunnel;
    }

    if (mconf2->ws_upgrade_header) {
        mconf->ws_upgrade_header = apr_pstrdup(p, mconf2->ws_upgrade_header);
    } else if (mconf1->ws_upgrade_header) {
        mconf->ws_upgrade_header = apr_pstrdup(p, mconf1->ws_upgrade_header);
    }

    if (mconf2->ajp_secret) {
        mconf->ajp_secret = apr_pstrdup(p, mconf2->ajp_secret);
    } else if (mconf1->ajp_secret) {
        mconf->ajp_secret = apr_pstrdup(p, mconf1->ajp_secret);
    }

    if (mconf2->response_field_size) {
        mconf->response_field_size = mconf2->response_field_size;
    } else if (mconf1->response_field_size) {
        mconf->response_field_size = mconf1->response_field_size;
    }

    return mconf;
}

/* Module declaration */

AP_DECLARE_MODULE(manager) = {
    STANDARD20_MODULE_STUFF,
    NULL,
    NULL,
    create_manager_server_config,
    merge_manager_server_config,
    manager_cmds,        /* command table */
    manager_hooks,       /* register hooks */
    AP_MODULE_FLAG_NONE, /* flags */
};