Apache

.gitignore

@@ -44,3 +44,9 @@ go.work.sum
 /debian/libgomesi/
 /debian/libgomesi-dev/
 /servers/frankenphp/frankenphp
+/servers/apache/.libs/
+/servers/apache/mod_mesi.la
+/servers/apache/mod_mesi.lo
+/servers/apache/mod_mesi.slo
+/servers/apache/minimal.conf
+/servers/apache/apache2.pid

servers/apache/Makefile

@@ -0,0 +1,8 @@
+build:
+	 apxs -c -I ../../libgomesi/ mod_mesi.c -lgomesi
+ clean:
+	rm -rf .libs
+	rm -f mod_mesi.la mod_mesi.lo mod_mesi.slo
+run: build
+	MY_DOC_ROOT=$$(realpath "$$(pwd)/../../examples") envsubst < apache.conf.dist > minimal.conf
+	apache2 -f $$(pwd)/minimal.conf -DFOREGROUND

servers/apache/apache.conf.dist

@@ -0,0 +1,28 @@
+ServerRoot "."
+PidFile ./apache2.pid
+
+LoadModule mod_mesi_module "./.libs/mod_mesi.so"
+LoadModule mpm_worker_module "/usr/lib/apache2/modules/mod_mpm_worker.so"
+LoadModule authz_core_module "/usr/lib/apache2/modules/mod_authz_core.so"
+LoadModule authz_host_module "/usr/lib/apache2/modules/mod_authz_host.so"
+LoadModule dir_module /usr/lib/apache2/modules/mod_dir.so
+LoadModule headers_module /usr/lib/apache2/modules/mod_headers.so
+LoadModule mime_module /usr/lib/apache2/modules/mod_mime.so
+Listen 8080
+ServerName localhost
+
+<VirtualHost 127.0.0.1:8080>
+DefaultType text/html
+    EnableMesi On
+    DocumentRoot "${MY_DOC_ROOT}"
+    <Directory "${MY_DOC_ROOT}">
+
+        DirectoryIndex index.html
+        AllowOverride None
+        Require all granted
+    </Directory>
+
+</VirtualHost>
+
+ErrorLog /dev/stderr
+

servers/apache/mime.types

@@ -0,0 +1 @@
+text/html					html htm

servers/apache/mod_mesi.c

@@ -0,0 +1,148 @@
+#include "httpd.h"
+#include "http_config.h"
+#include "http_protocol.h"
+#include "http_request.h"
+#include "http_core.h"
+#include "http_log.h"
+#include "util_filter.h"
+#include "apr_strings.h"
+#include "http_log.h"
+
+#include "libgomesi.h"
+#include "dlfcn.h"
+
+#ifndef LIB_GOMESI_PATH
+#define LIB_GOMESI_PATH "/usr/lib/libgomesi.so"
+#endif
+
+typedef char *(*ParseFunc)(char *, int, char *);
+
+typedef struct {
+    apr_bucket_brigade *bb;
+} response_filter_ctx;
+
+module AP_MODULE_DECLARE_DATA mod_mesi_module;
+
+typedef struct {
+    int enable_mesi;
+} mesi_config;
+
+static void *create_server_config(apr_pool_t *p, server_rec *s) {
+    mesi_config *conf = apr_pcalloc(p, sizeof(*conf));
+    conf->enable_mesi = 0;
+    return conf;
+}
+
+static void *merge_server_config(apr_pool_t *p, void *basev, void *addv) {
+    mesi_config *base = (mesi_config *) basev;
+    mesi_config *add = (mesi_config *) addv;
+    mesi_config *conf = apr_pcalloc(p, sizeof(*conf));
+    conf->enable_mesi = (add->enable_mesi != 0) ? add->enable_mesi : base->enable_mesi;
+    return conf;
+}
+
+static void *create_dir_config(apr_pool_t *p, char *dir) {
+    return NULL;
+}
+
+static void *merge_dir_config(apr_pool_t *p, void *basev, void *addv) {
+    return NULL;
+}
+
+static const char *set_enable_mesi(cmd_parms *cmd, void *cfg, int flag) {
+    mesi_config *conf = (mesi_config *) ap_get_module_config(cmd->server->module_config, &mod_mesi_module);
+    conf->enable_mesi = flag;
+    return NULL;
+}
+
+static int mesi_request_handler(request_rec *r) {
+    mesi_config *conf = (mesi_config *) ap_get_module_config(r->server->module_config, &mod_mesi_module);
+    if (conf->enable_mesi) {
+        apr_table_set(r->headers_in, "Surrogate-Capability", "ESI/1.0");
+        ap_add_output_filter("MESI_RESPONSE", NULL, r, r->connection);
+    }
+    return DECLINED;
+}
+
+static int mesi_response_filter(ap_filter_t *f, apr_bucket_brigade *bb) {
+    mesi_config *conf = (mesi_config *) ap_get_module_config(f->r->server->module_config, &mod_mesi_module);
+    if (!conf->enable_mesi) {
+        return ap_pass_brigade(f->next, bb);
+    }
+
+    if (!f->r->content_type || strncmp(f->r->content_type, "text/html", 9) != 0 || f->r->status > 400) {
+        if (!f->r->content_type) {
+            ap_log_rerror(APLOG_MARK, APLOG_NOTICE, 0, f->r, "No content type, %s", f->r->uri);
+        } else {
+            ap_log_rerror(APLOG_MARK, APLOG_NOTICE, 0, f->r, "Content type: %s", f->r->content_type);
+        }
+
+
+        return ap_pass_brigade(f->next, bb);
+    }
+
+    apr_status_t rv;
+    apr_bucket *b;
+    apr_size_t len;
+    char *html = NULL;
+    response_filter_ctx *ctx;
+
+    ctx = f->ctx;
+    if (!ctx) {
+        ctx = apr_pcalloc(f->r->pool, sizeof(response_filter_ctx));
+        f->ctx = ctx;
+    }
+
+    for (b = APR_BRIGADE_FIRST(bb); b != APR_BRIGADE_SENTINEL(bb); b = APR_BUCKET_NEXT(b)) {
+        const char *data;
+        apr_size_t data_len;
+
+        if (apr_bucket_read(b, &data, &data_len, APR_BLOCK_READ) == APR_SUCCESS) {
+            if (!html) {
+                html = apr_pstrndup(f->r->pool, data, data_len);
+            } else {
+                html = apr_pstrcat(f->r->pool, html, data, NULL);
+            }
+        }
+    }
+
+    void *go_module = dlopen(LIB_GOMESI_PATH, RTLD_NOW);
+
+    if (!go_module) {
+        dlerror();
+        return ap_pass_brigade(f->next, bb);
+    }
+
+    ParseFunc EsiParse = (ParseFunc)dlsym(go_module, "Parse");
+    char *esi = EsiParse(html, 5, "http://127.0.0.1");
+
+    dlclose(go_module);
+
+    apr_brigade_cleanup(bb);
+    b = apr_bucket_pool_create(esi, strlen(esi), f->r->pool, bb->bucket_alloc);
+    APR_BRIGADE_INSERT_TAIL(bb, b);
+    APR_BRIGADE_INSERT_TAIL(bb, apr_bucket_eos_create(bb->bucket_alloc));
+
+    return ap_pass_brigade(f->next, bb);
+}
+
+
+static void register_hooks(apr_pool_t *p) {
+    ap_hook_post_read_request(mesi_request_handler, NULL, NULL, APR_HOOK_MIDDLE);
+    ap_register_output_filter("MESI_RESPONSE", mesi_response_filter, NULL, AP_FTYPE_CONTENT_SET);
+}
+
+static const command_rec mesi_directives[] = {
+    AP_INIT_FLAG("EnableMesi", set_enable_mesi, NULL, RSRC_CONF, "Enable or disable the Mesi module"),
+    {NULL}
+};
+
+module AP_MODULE_DECLARE_DATA mod_mesi_module = {
+    STANDARD20_MODULE_STUFF,
+    create_dir_config,
+    merge_dir_config,
+    create_server_config,
+    merge_server_config,
+    mesi_directives,
+    register_hooks
+};