]> git.pld-linux.org Git - packages/apache1.git/blame - apache1-mod_ssl-eapi.patch
- s/httpd/apache/ s/apxs/apxs1/
[packages/apache1.git] / apache1-mod_ssl-eapi.patch
CommitLineData
5fa7631d 1## _____ _ ____ ___
2## | ____| / \ | _ \_ _|
3## | _| / _ \ | |_) | |
4## | |__ / ___ \| __/| |
5## |____/_/ \_\_| |___| Extended API for Apache
6## ____________________________________________________________________________
7##
8## Annotated patch file: eapi.patch
9## Copyright (c) 1998-2001 Ralf S. Engelschall, All Rights Reserved.
d5724db6 10## Created on: 01-Nov-2003
5fa7631d 11##
12## This file assembles changes to existing Apache source files
13## between the original Apache and the patched variant. It can be
14## automatically applied to a vanilla Apache source tree with the
15## 'patch' tool to upgrade those files. Each patch snippet is
16## annotated with a short description.
17##
18## This file contains all patches to the Apache source
19## tree which add the Extended API (EAPI) support.
20##
21
22+---------------------------------------------------------------------------
23| Add the EAPI and EAPI_MM configuration entries which triggers the EAPI
24| patches and configured the shared memory support via the MM library.
25+---------------------------------------------------------------------------
26Index: src/Configuration.tmpl
695b0fd7
JB
27--- src/Configuration.tmpl 28 Jan 2002 19:21:21 -0000 1.1.1.7
28+++ src/Configuration.tmpl 28 Jan 2002 19:40:56 -0000 1.23
5fa7631d 29@@ -68,6 +105,24 @@
30 #TARGET=
31
32 ################################################################
33+# Extended API (EAPI) support:
34+#
35+# EAPI:
36+# The EAPI rule enables more module hooks, a generic low-level hook
37+# mechanism, a generic context mechanism and shared memory based pools.
38+#
39+# EAPI_MM:
40+# Set the EAPI_MM variable to either the directory of a MM Shared Memory
41+# Library source tree or the installation tree of MM. Alternatively you can
42+# also use the value 'SYSTEM' which then indicates that MM is installed
43+# under various system locations. When the MM library files cannot be found
44+# the EAPI still can be built, but without shared memory pool support, of
45+# course.
46+
47+Rule EAPI=no
48+#EAPI_MM=SYSTEM
49+
50+################################################################
51 # Dynamic Shared Object (DSO) support
52 #
53 # There is experimental support for compiling the Apache core and
54
55+---------------------------------------------------------------------------
56| Patch in implementation of the EAPI rule.
57+---------------------------------------------------------------------------
58Index: src/Configure
d5724db6
JB
59--- src/Configure 29 Oct 2003 18:57:30 -0000 1.1.1.22
60+++ src/Configure 29 Oct 2003 18:59:05 -0000 1.25
7802c33e 61@@ -1892,6 +1892,72 @@
5fa7631d 62 fi
63
64 ####################################################################
65+## Extended API (EAPI) support:
66+##
67+if [ "x$RULE_EAPI" = "x" ]; then
68+ RULE_EAPI=`./helpers/CutRule EAPI $file`
69+fi
70+if [ "x$RULE_EAPI" = "xyes" ]; then
71+ echo " + enabling Extended API (EAPI)"
72+ CFLAGS="$CFLAGS -DEAPI"
73+ # some vendor compilers are too restrictive
74+ # for our ap_hook and ap_ctx sources.
75+ case "$OS:$CC" in
76+ *IRIX-32*:*/cc|*IRIX-32*:cc )
77+ CFLAGS="$CFLAGS -woff 1048,1110,1164"
78+ ;;
79+ esac
80+ # MM Shared Memory Library support for EAPI
81+ if [ "x$EAPI_MM" = "x" ]; then
695b0fd7 82+ EAPI_MM=`egrep '^EAPI_MM=' $file | sed -n -e '$p' | awk -F= '{print $2}'`
5fa7631d 83+ fi
84+ if [ "x$EAPI_MM" != "x" ]; then
85+ case $EAPI_MM in
86+ SYSTEM|/* ) ;;
87+ * ) for p in . .. ../..; do
88+ if [ -d "$p/$EAPI_MM" ]; then
89+ EAPI_MM="`echo $p/$EAPI_MM | sed -e 's;/\./;/;g'`"
90+ break
91+ fi
92+ done
93+ ;;
94+ esac
95+ if [ "x$EAPI_MM" = "xSYSTEM" ]; then
96+ echo " using MM library for EAPI: (system-wide)"
97+ CFLAGS="$CFLAGS -DEAPI_MM"
98+ __INCLUDES="`mm-config --cflags`"
99+ if [ "x$__INCLUDES" != "x-I/usr/include" ]; then
100+ INCLUDES="$INCLUDES $__INCLUDES"
101+ fi
102+ LDFLAGS="$LDFLAGS `mm-config --ldflags`"
103+ LIBS="$LIBS `mm-config --libs`"
104+ else
105+ if [ -f "$EAPI_MM/.libs/libmm.a" -a -f "$EAPI_MM/mm.h" ]; then
106+ echo " using MM library: $EAPI_MM (source-tree only)"
107+ case $EAPI_MM in
108+ /* ) ;;
109+ * ) EAPI_MM="\$(SRCDIR)/$EAPI_MM" ;;
110+ esac
111+ CFLAGS="$CFLAGS -DEAPI_MM"
112+ INCLUDES="$INCLUDES -I$EAPI_MM"
113+ LDFLAGS="$LDFLAGS -L$EAPI_MM/.libs"
114+ LIBS="$LIBS -lmm"
115+ elif [ -f "$EAPI_MM/bin/mm-config" ]; then
116+ echo " using MM library: $EAPI_MM (installed)"
117+ CFLAGS="$CFLAGS -DEAPI_MM"
118+ INCLUDES="$INCLUDES `$EAPI_MM/bin/mm-config --cflags`"
119+ LDFLAGS="$LDFLAGS `$EAPI_MM/bin/mm-config --ldflags`"
120+ LIBS="$LIBS `$EAPI_MM/bin/mm-config --libs`"
121+ else
122+ echo "Configure:Error: Cannot find MM library under $EAPI_MM" 1>&2
123+ exit 1
124+ fi
125+ fi
126+ fi
127+fi
128+
129+
130+####################################################################
131 ## Add in the Expat library if needed/wanted.
132 ##
b5bf29fd 133
5fa7631d 134
135+---------------------------------------------------------------------------
136| Add the build support for the ap_hook.c and ap_ctx.c sources (Unix)
137+---------------------------------------------------------------------------
138Index: src/ap/Makefile.tmpl
77cf3173
JB
139--- src/ap/Makefile.tmpl 19 Jun 2002 07:20:22 -0000 1.1.1.8
140+++ src/ap/Makefile.tmpl 19 Jun 2002 07:29:08 -0000 1.8
141@@ -7,7 +7,7 @@
5fa7631d 142
143 OBJS=ap_cpystrn.o ap_execve.o ap_fnmatch.o ap_getpass.o ap_md5c.o ap_signal.o \
695b0fd7
JB
144 ap_slack.o ap_snprintf.o ap_sha1.o ap_checkpass.o ap_base64.o ap_ebcdic.o \
145- ap_strtol.o
146+ ap_strtol.o ap_hook.o ap_ctx.o ap_mm.o
5fa7631d 147
148 .c.o:
149 $(CC) -c $(INCLUDES) $(CFLAGS) $<
150
151+---------------------------------------------------------------------------
152| Add the build support for the ap_hook.c and ap_ctx.c sources (Win32)
153+---------------------------------------------------------------------------
154Index: src/ap/ap.mak
7802c33e
JB
155--- src/ap/ap.mak 18 Jul 2003 15:44:30 -0000 1.1.1.10
156+++ src/ap/ap.mak 18 Jul 2003 15:56:58 -0000 1.10
157@@ -44,6 +44,9 @@
5fa7631d 158 -@erase "$(INTDIR)\ap_cpystrn.obj"
159 -@erase "$(INTDIR)\ap_fnmatch.obj"
160 -@erase "$(INTDIR)\ap_md5c.obj"
161+ -@erase "$(INTDIR)\ap_hook.obj"
162+ -@erase "$(INTDIR)\ap_ctx.obj"
163+ -@erase "$(INTDIR)\ap_mm.obj"
164 -@erase "$(INTDIR)\ap_sha1.obj"
165 -@erase "$(INTDIR)\ap_signal.obj"
166 -@erase "$(INTDIR)\ap_slack.obj"
7802c33e 167@@ -99,6 +102,9 @@
5fa7631d 168 "$(INTDIR)\ap_cpystrn.obj" \
169 "$(INTDIR)\ap_fnmatch.obj" \
170 "$(INTDIR)\ap_md5c.obj" \
171+ "$(INTDIR)\ap_hook.obj" \
172+ "$(INTDIR)\ap_ctx.obj" \
173+ "$(INTDIR)\ap_mm.obj" \
174 "$(INTDIR)\ap_sha1.obj" \
175 "$(INTDIR)\ap_signal.obj" \
176 "$(INTDIR)\ap_slack.obj" \
7802c33e 177@@ -128,6 +134,9 @@
5fa7631d 178 -@erase "$(INTDIR)\ap_cpystrn.obj"
179 -@erase "$(INTDIR)\ap_fnmatch.obj"
180 -@erase "$(INTDIR)\ap_md5c.obj"
181+ -@erase "$(INTDIR)\ap_hook.obj"
182+ -@erase "$(INTDIR)\ap_ctx.obj"
183+ -@erase "$(INTDIR)\ap_mm.obj"
184 -@erase "$(INTDIR)\ap_sha1.obj"
185 -@erase "$(INTDIR)\ap_signal.obj"
186 -@erase "$(INTDIR)\ap_slack.obj"
7802c33e 187@@ -183,6 +192,9 @@
5fa7631d 188 "$(INTDIR)\ap_cpystrn.obj" \
189 "$(INTDIR)\ap_fnmatch.obj" \
190 "$(INTDIR)\ap_md5c.obj" \
191+ "$(INTDIR)\ap_hook.obj" \
192+ "$(INTDIR)\ap_ctx.obj" \
193+ "$(INTDIR)\ap_mm.obj" \
194 "$(INTDIR)\ap_sha1.obj" \
195 "$(INTDIR)\ap_signal.obj" \
196 "$(INTDIR)\ap_slack.obj" \
197
198+---------------------------------------------------------------------------
199| Replace the MODULE_MAGIC_COOKIE to allow us to distinguish between
200| EAPI-aware modules and standard modules.
201+---------------------------------------------------------------------------
202Index: src/include/ap_mmn.h
7802c33e
JB
203--- src/include/ap_mmn.h 18 Jul 2003 15:44:32 -0000 1.1.1.12
204+++ src/include/ap_mmn.h 18 Jul 2003 15:56:58 -0000 1.12
205@@ -245,7 +245,23 @@
206 * 19990320.15 - ap_is_recursion_limit_exceeded()
5fa7631d 207 */
208
209+/*
210+ * Under Extended API situations we replace the magic cookie "AP13" with
211+ * "EAPI" to let us distinguish between the EAPI module structure (which
212+ * contain additional pointers at the end) and standard module structures
213+ * (which lack at least NULL's for the pointers at the end). This is
214+ * important because standard ("AP13") modules would dump core when we
215+ * dispatch over the additional hooks because NULL's are missing at the end of
216+ * the module structure. See also the code in mod_so for details on loading
217+ * (we accept both "AP13" and "EAPI").
218+ */
219+#ifdef EAPI
220+#define MODULE_MAGIC_COOKIE_AP13 0x41503133UL /* "AP13" */
221+#define MODULE_MAGIC_COOKIE_EAPI 0x45415049UL /* "EAPI" */
222+#define MODULE_MAGIC_COOKIE MODULE_MAGIC_COOKIE_EAPI
223+#else
224 #define MODULE_MAGIC_COOKIE 0x41503133UL /* "AP13" */
225+#endif
226
227 #ifndef MODULE_MAGIC_NUMBER_MAJOR
228 #define MODULE_MAGIC_NUMBER_MAJOR 19990320
229
230+---------------------------------------------------------------------------
231| Add the additional prototypes and defines for the
232| shared memory pools.
233+---------------------------------------------------------------------------
234Index: src/include/ap_alloc.h
7802c33e
JB
235--- src/include/ap_alloc.h 18 Jul 2003 15:44:31 -0000 1.1.1.6
236+++ src/include/ap_alloc.h 18 Jul 2003 15:56:58 -0000 1.7
5fa7631d 237@@ -95,6 +95,15 @@
a6148d70 238 API_EXPORT(pool *) ap_init_alloc(void); /* Set up everything */
5fa7631d 239 void ap_cleanup_alloc(void);
240 API_EXPORT(pool *) ap_make_sub_pool(pool *); /* All pools are subpools of permanent_pool */
241+#if defined(EAPI)
242+typedef enum { AP_POOL_RD, AP_POOL_RW } ap_pool_lock_mode;
243+int ap_shared_pool_possible(void);
244+void ap_init_alloc_shared(int);
245+void ap_kill_alloc_shared(void);
246+API_EXPORT(pool *) ap_make_shared_sub_pool(pool *);
247+API_EXPORT(int) ap_acquire_pool(pool *, ap_pool_lock_mode);
248+API_EXPORT(int) ap_release_pool(pool *);
249+#endif
250 API_EXPORT(void) ap_destroy_pool(pool *);
251
252 /* pools have nested lifetimes -- sub_pools are destroyed when the
253
254+---------------------------------------------------------------------------
255| Add the additional context variable `ctx' for BUFF structures.
256+---------------------------------------------------------------------------
257Index: src/include/buff.h
7802c33e
JB
258--- src/include/buff.h 18 Jul 2003 15:44:32 -0000 1.1.1.7
259+++ src/include/buff.h 18 Jul 2003 15:56:58 -0000 1.11
5fa7631d 260@@ -125,6 +125,10 @@
261 /* transport handle, for RPC binding handle or some such */
262 void *t_handle;
263
264+#ifdef EAPI
265+ ap_ctx *ctx;
266+#endif /* EAPI */
267+
268 #ifdef B_SFIO
269 Sfio_t *sf_in;
270 Sfio_t *sf_out;
d5724db6 271@@ -181,6 +185,10 @@
5fa7631d 272 API_EXPORT(int) ap_bflsbuf(int c, BUFF *fb);
273 API_EXPORT(int) ap_bfilbuf(BUFF *fb);
d5724db6 274
5fa7631d 275+#ifdef EAPI
276+#define ap_bpeekc(fb) ( ((fb)->incnt == 0) ? EOF : *((fb)->inptr) )
277+#endif
d5724db6 278+
5fa7631d 279 #ifndef CHARSET_EBCDIC
280
d5724db6 281 #define ap_bgetc(fb) ( ((fb)->incnt == 0) ? ap_bfilbuf(fb) : \
5fa7631d 282
283+---------------------------------------------------------------------------
284| Add the four additional Apache API module hooks.
285+---------------------------------------------------------------------------
286Index: src/include/http_config.h
7802c33e
JB
287--- src/include/http_config.h 18 Jul 2003 15:44:32 -0000 1.1.1.11
288+++ src/include/http_config.h 18 Jul 2003 15:56:58 -0000 1.13
5fa7631d 289@@ -276,6 +276,65 @@
290 void (*child_exit) (server_rec *, pool *);
291 #endif
292 int (*post_read_request) (request_rec *);
293+
294+#ifdef EAPI
295+ /*
296+ * ANSI C guarantees us that we can at least _extend_ the module structure
297+ * with additional hooks without the need to change all existing modules.
298+ * Because: ``If there are fewer initializers in the list than members of
299+ * the structure, the trailing members are initialized with 0.'' (The C
300+ * Programming Language, 2nd Ed., A8.7 Initialization). So we just
301+ * have to put our additional hooks here:
302+ *
303+ * add_module:
304+ * Called from within ap_add_module() right after the module structure
305+ * was linked into the Apache internal module list. It is mainly
306+ * intended to be used to define configuration defines (<IfDefine>)
307+ * which have to be available directly after a LoadModule/AddModule.
308+ * Actually this is the earliest possible hook a module can use.
309+ *
310+ * remove_module:
311+ * Called from within ap_remove_module() right before the module
312+ * structure is kicked out from the Apache internal module list.
313+ * Actually this is last possible hook a module can use and exists for
314+ * consistency with the add_module hook.
315+ *
316+ * rewrite_command:
317+ * Called right after a configuration directive line was read and
318+ * before it is processed. It is mainly intended to be used for
319+ * rewriting directives in order to provide backward compatibility to
320+ * old directive variants.
321+ *
322+ * new_connection:
323+ * Called from within the internal new_connection() function, right
324+ * after the conn_rec structure for the new established connection was
325+ * created and before Apache starts processing the request with
326+ * ap_read_request(). It is mainly intended to be used to setup/run
327+ * connection dependent things like sending start headers for
328+ * on-the-fly compression, etc.
329+ *
330+ * close_connection:
331+ * Called from within the Apache dispatching loop just before any
332+ * ap_bclose() is performed on the socket connection, but a long time
333+ * before any pool cleanups are done for the connection (which can be
334+ * too late for some applications). It is mainly intended to be used
335+ * to close/finalize connection dependent things like sending end
336+ * headers for on-the-fly compression, etc.
337+ */
338+#ifdef ULTRIX_BRAIN_DEATH
339+ void (*add_module) ();
340+ void (*remove_module) ();
341+ char *(*rewrite_command) ();
342+ void (*new_connection) ();
343+ void (*close_connection) ();
344+#else
345+ void (*add_module) (struct module_struct *);
346+ void (*remove_module) (struct module_struct *);
347+ char *(*rewrite_command) (cmd_parms *, void *config, const char *);
348+ void (*new_connection) (conn_rec *);
349+ void (*close_connection) (conn_rec *);
350+#endif
351+#endif /* EAPI */
352 } module;
353
354 /* Initializer for the first few module slots, which are only
355
356+---------------------------------------------------------------------------
357| Add the additional variable `ap_global_ctx' for holding
358| global module context.
359+---------------------------------------------------------------------------
360Index: src/include/http_conf_globals.h
7802c33e
JB
361--- src/include/http_conf_globals.h 18 Jul 2003 15:44:32 -0000 1.1.1.13
362+++ src/include/http_conf_globals.h 18 Jul 2003 15:56:58 -0000 1.14
b5bf29fd
MK
363@@ -95,6 +95,9 @@
364 #endif
5fa7631d 365 extern int ap_dump_settings;
366 extern API_VAR_EXPORT int ap_extended_status;
367+#ifdef EAPI
368+extern API_VAR_EXPORT ap_ctx *ap_global_ctx;
369+#endif /* EAPI */
370
371 extern API_VAR_EXPORT char *ap_pid_fname;
372 extern API_VAR_EXPORT char *ap_scoreboard_fname;
373
5fa7631d 374+---------------------------------------------------------------------------
375| First add support for the HTTPS protocol scheme via hooks,
376| second add the additional context variable `ctx' for the
377| conn_rec, server_rec and request_rec structures. And third
378| add a prototype for the additional ap_add_config_define()
379| function.
380+---------------------------------------------------------------------------
7802c33e 381Index: src/include/httpd.h
d5724db6
JB
382--- src/include/httpd.h 29 Oct 2003 18:57:32 -0000 1.1.1.22
383+++ src/include/httpd.h 29 Oct 2003 18:59:05 -0000 1.32
7802c33e
JB
384@@ -70,7 +70,19 @@
385 /* Headers in which EVERYONE has an interest... */
5fa7631d 386
7802c33e 387 #include "ap_config.h"
5fa7631d 388+#ifdef EAPI
7802c33e
JB
389+#include "ap_mm.h"
390+#endif
391 #include "ap_alloc.h"
392+/*
393+ * Include the Extended API headers.
394+ * Don't move the position. It has to be after ap_alloc.h because it uses the
395+ * pool stuff but before buff.h because the buffer stuff uses the EAPI, too.
396+ */
015adaf5 397+#ifdef EAPI
7802c33e
JB
398+#include "ap_hook.h"
399+#include "ap_ctx.h"
015adaf5 400+#endif /* EAPI */
7802c33e
JB
401 #include "buff.h"
402 #include "ap.h"
403
404@@ -145,8 +157,13 @@
405 #define ap_http_method(r) ap_os_http_method((void*)r)
406 #define ap_default_port(r) ap_os_default_port((void*)r)
015adaf5 407 #else
015adaf5 408+#ifdef EAPI
7802c33e
JB
409+#define ap_http_method(r) (((r)->ctx != NULL && ap_ctx_get((r)->ctx, "ap::http::method") != NULL) ? ((char *)ap_ctx_get((r)->ctx, "ap::http::method")) : "http")
410+#define ap_default_port(r) (((r)->ctx != NULL && ap_ctx_get((r)->ctx, "ap::default::port") != NULL) ? atoi((char *)ap_ctx_get((r)->ctx, "ap::default::port")) : DEFAULT_HTTP_PORT)
411+#else /* EAPI */
412 #define ap_http_method(r) "http"
413 #define ap_default_port(r) DEFAULT_HTTP_PORT
5fa7631d 414+#endif /* EAPI */
7802c33e 415 #endif
5fa7631d 416
7802c33e 417 /* --------- Default user name and group name running standalone ---------- */
d5724db6 418@@ -355,6 +372,19 @@
7802c33e
JB
419 #define SCOREBOARD_MAINTENANCE_INTERVAL 1000000
420 #endif
5fa7631d 421
7802c33e
JB
422+/*
423+ * Unix only:
424+ * Path to Shared Memory Files
425+ */
5fa7631d 426+#ifdef EAPI
7802c33e
JB
427+#ifndef EAPI_MM_CORE_PATH
428+#define EAPI_MM_CORE_PATH "logs/mm"
429+#endif
430+#ifndef EAPI_MM_CORE_MAXSIZE
431+#define EAPI_MM_CORE_MAXSIZE 1024*1024*1 /* max. 1MB */
432+#endif
433+#endif
5fa7631d 434+
7802c33e
JB
435 /* Number of requests to try to handle in a single process. If <= 0,
436 * the children don't die off. That's the default here, since I'm still
437 * interested in finding and stanching leaks.
d5724db6 438@@ -447,6 +477,9 @@
7802c33e
JB
439 API_EXPORT(const char *) ap_get_server_version(void);
440 API_EXPORT(void) ap_add_version_component(const char *component);
441 API_EXPORT(const char *) ap_get_server_built(void);
5fa7631d 442+#ifdef EAPI
7802c33e 443+API_EXPORT(void) ap_add_config_define(const char *define);
5fa7631d 444+#endif /* EAPI */
015adaf5 445
7802c33e
JB
446 /* Numeric release version identifier: MMNNFFRBB: major minor fix final beta
447 * Always increases along the same track as the source branch.
d5724db6 448@@ -850,6 +883,10 @@
7802c33e
JB
449 * record to improve 64bit alignment the next time we need to break
450 * binary compatibility for some other reason.
451 */
5fa7631d 452+
453+#ifdef EAPI
7802c33e 454+ ap_ctx *ctx;
5fa7631d 455+#endif /* EAPI */
7802c33e 456 };
5fa7631d 457
458
d5724db6 459@@ -898,6 +935,9 @@
7802c33e
JB
460 char *local_host; /* used for ap_get_server_name when
461 * UseCanonicalName is set to DNS
462 * (ignores setting of HostnameLookups) */
5fa7631d 463+#ifdef EAPI
7802c33e 464+ ap_ctx *ctx;
5fa7631d 465+#endif /* EAPI */
7802c33e 466 };
015adaf5 467
7802c33e 468 /* Per-vhost config... */
d5724db6 469@@ -970,6 +1010,10 @@
7802c33e
JB
470 int limit_req_line; /* limit on size of the HTTP request line */
471 int limit_req_fieldsize; /* limit on size of any request header field */
472 int limit_req_fields; /* limit on number of request header fields */
5fa7631d 473+
474+#ifdef EAPI
7802c33e 475+ ap_ctx *ctx;
5fa7631d 476+#endif /* EAPI */
7802c33e 477 };
5fa7631d 478
7802c33e 479 /* These are more like real hosts than virtual hosts */
5fa7631d 480
481+---------------------------------------------------------------------------
7802c33e 482| Patch the shared memory pool support into the Apache pool facility.
5fa7631d 483+---------------------------------------------------------------------------
7802c33e 484Index: src/main/alloc.c
d5724db6
JB
485--- src/main/alloc.c 29 Oct 2003 18:57:34 -0000 1.1.1.15
486+++ src/main/alloc.c 31 Oct 2003 21:23:12 -0000 1.24
7802c33e
JB
487@@ -64,6 +64,10 @@
488 */
5fa7631d 489
7802c33e 490 #include "httpd.h"
5fa7631d 491+#ifdef EAPI
7802c33e
JB
492+#include "http_config.h"
493+#include "http_conf_globals.h"
494+#endif
495 #include "multithread.h"
496 #include "http_log.h"
5fa7631d 497
7802c33e
JB
498@@ -138,6 +142,10 @@
499 #define BLOCK_MINALLOC 0
500 #endif
5fa7631d 501
7802c33e
JB
502+#if defined(EAPI) && defined(EAPI_MM)
503+static AP_MM *mm = NULL;
504+#endif
015adaf5 505+
7802c33e
JB
506 /*****************************************************************
507 *
508 * Managing free storage blocks...
509@@ -166,6 +174,9 @@
510 char *endp;
511 union block_hdr *next;
512 char *first_avail;
513+#if defined(EAPI) && defined(EAPI_MM)
514+ int is_shm;
515+#endif
516 #ifdef POOL_DEBUG
517 union block_hdr *global_next;
518 struct pool *owning_pool;
519@@ -216,7 +227,11 @@
520 /* Get a completely new block from the system pool. Note that we rely on
521 malloc() to provide aligned memory. */
5fa7631d 522
7802c33e
JB
523+#if defined(EAPI) && defined(EAPI_MM)
524+static union block_hdr *malloc_block(int size, int is_shm)
525+#else
526 static union block_hdr *malloc_block(int size)
527+#endif
528 {
529 union block_hdr *blok;
530 int request_size;
531@@ -232,6 +247,11 @@
532 num_malloc_bytes += size + sizeof(union block_hdr);
533 #endif
534 request_size = size + sizeof(union block_hdr);
535+#if defined(EAPI) && defined(EAPI_MM)
536+ if (is_shm)
537+ blok = (union block_hdr *)ap_mm_malloc(mm, request_size);
538+ else
539+#endif
540 blok = (union block_hdr *) malloc(request_size);
541 if (blok == NULL) {
542 fprintf(stderr, "Ouch! malloc(%d) failed in malloc_block()\n",
543@@ -239,6 +259,9 @@
544 exit(1);
5fa7631d 545 }
7802c33e
JB
546 debug_fill(blok, size + sizeof(union block_hdr));
547+#if defined(EAPI) && defined(EAPI_MM)
548+ blok->h.is_shm = is_shm;
549+#endif
550 blok->h.next = NULL;
551 blok->h.first_avail = (char *) (blok + 1);
552 blok->h.endp = size + blok->h.first_avail;
553@@ -299,6 +322,10 @@
554 if (blok == NULL)
555 return; /* Sanity check --- freeing empty pool? */
5fa7631d 556
7802c33e
JB
557+#if defined(EAPI) && defined(EAPI_MM)
558+ if (blok->h.is_shm)
559+ (void)ap_mm_lock(mm, AP_MM_LOCK_RW);
560+#endif
561 (void) ap_acquire_mutex(alloc_mutex);
562 old_free_list = block_freelist;
563 block_freelist = blok;
564@@ -345,6 +372,10 @@
5fa7631d 565 #endif
7802c33e
JB
566
567 (void) ap_release_mutex(alloc_mutex);
568+#if defined(EAPI) && defined(EAPI_MM)
569+ if (blok->h.is_shm)
570+ (void)ap_mm_unlock(mm);
5fa7631d 571+#endif
7802c33e 572 #endif
5fa7631d 573 }
574
7802c33e
JB
575@@ -353,7 +384,11 @@
576 * if necessary. Must be called with alarms blocked.
577 */
5fa7631d 578
7802c33e
JB
579+#if defined(EAPI) && defined(EAPI_MM)
580+static union block_hdr *new_block(int min_size, int is_shm)
581+#else
582 static union block_hdr *new_block(int min_size)
5fa7631d 583+#endif
7802c33e
JB
584 {
585 union block_hdr **lastptr = &block_freelist;
586 union block_hdr *blok = block_freelist;
587@@ -363,7 +398,12 @@
588 */
589
590 while (blok != NULL) {
591+#if defined(EAPI) && defined(EAPI_MM)
592+ if (blok->h.is_shm == is_shm &&
593+ min_size + BLOCK_MINFREE <= blok->h.endp - blok->h.first_avail) {
594+#else
595 if (min_size + BLOCK_MINFREE <= blok->h.endp - blok->h.first_avail) {
5fa7631d 596+#endif
7802c33e
JB
597 *lastptr = blok->h.next;
598 blok->h.next = NULL;
599 debug_verify_filled(blok->h.first_avail, blok->h.endp,
600@@ -379,7 +419,11 @@
601 /* Nope. */
602
603 min_size += BLOCK_MINFREE;
604+#if defined(EAPI) && defined(EAPI_MM)
605+ blok = malloc_block((min_size > BLOCK_MINALLOC) ? min_size : BLOCK_MINALLOC, is_shm);
606+#else
607 blok = malloc_block((min_size > BLOCK_MINALLOC) ? min_size : BLOCK_MINALLOC);
5fa7631d 608+#endif
7802c33e 609 return blok;
5fa7631d 610 }
611
7802c33e
JB
612@@ -429,6 +473,9 @@
613 #ifdef POOL_DEBUG
614 struct pool *joined;
615 #endif
616+#if defined(EAPI) && defined(EAPI_MM)
617+ int is_shm;
618+#endif
619 };
5fa7631d 620
7802c33e
JB
621 static pool *permanent_pool;
622@@ -443,16 +490,28 @@
623 #define POOL_HDR_CLICKS (1 + ((sizeof(struct pool) - 1) / CLICK_SZ))
624 #define POOL_HDR_BYTES (POOL_HDR_CLICKS * CLICK_SZ)
5fa7631d 625
7802c33e
JB
626+#if defined(EAPI) && defined(EAPI_MM)
627+static struct pool *make_sub_pool_internal(struct pool *p, int is_shm)
628+#else
629 API_EXPORT(struct pool *) ap_make_sub_pool(struct pool *p)
5fa7631d 630+#endif
7802c33e
JB
631 {
632 union block_hdr *blok;
633 pool *new_pool;
5fa7631d 634
7802c33e 635 ap_block_alarms();
5fa7631d 636
7802c33e
JB
637+#if defined(EAPI) && defined(EAPI_MM)
638+ if (is_shm)
639+ (void)ap_mm_lock(mm, AP_MM_LOCK_RW);
5fa7631d 640+#endif
7802c33e
JB
641 (void) ap_acquire_mutex(alloc_mutex);
642
643+#if defined(EAPI) && defined(EAPI_MM)
644+ blok = new_block(POOL_HDR_BYTES, is_shm);
5fa7631d 645+#else
7802c33e 646 blok = new_block(POOL_HDR_BYTES);
5fa7631d 647+#endif
7802c33e
JB
648 new_pool = (pool *) blok->h.first_avail;
649 blok->h.first_avail += POOL_HDR_BYTES;
650 #ifdef POOL_DEBUG
651@@ -471,12 +530,38 @@
652 p->sub_pools = new_pool;
015adaf5 653 }
5fa7631d 654
7802c33e
JB
655+#if defined(EAPI) && defined(EAPI_MM)
656+ new_pool->is_shm = is_shm;
657+#endif
5fa7631d 658+
7802c33e
JB
659 (void) ap_release_mutex(alloc_mutex);
660+#if defined(EAPI) && defined(EAPI_MM)
661+ if (is_shm)
662+ (void)ap_mm_unlock(mm);
663+#endif
664 ap_unblock_alarms();
5fa7631d 665
7802c33e
JB
666 return new_pool;
667 }
5fa7631d 668
7802c33e
JB
669+#if defined(EAPI)
670+#if defined(EAPI_MM)
671+API_EXPORT(struct pool *) ap_make_sub_pool(struct pool *p)
672+{
673+ return make_sub_pool_internal(p, 0);
674+}
675+API_EXPORT(struct pool *) ap_make_shared_sub_pool(struct pool *p)
676+{
677+ return make_sub_pool_internal(p, 1);
678+}
679+#else
680+API_EXPORT(struct pool *) ap_make_shared_sub_pool(struct pool *p)
681+{
682+ return NULL;
683+}
5fa7631d 684+#endif
5fa7631d 685+#endif
7802c33e
JB
686+
687 #ifdef POOL_DEBUG
688 static void stack_var_init(char *s)
689 {
690@@ -491,6 +576,13 @@
691 }
015adaf5 692 #endif
5fa7631d 693
7802c33e
JB
694+#if defined(EAPI)
695+int ap_shared_pool_possible(void)
696+{
697+ return ap_mm_useable();
698+}
699+#endif
5fa7631d 700+
7802c33e
JB
701 #ifdef ALLOC_STATS
702 static void dump_stats(void)
703 {
704@@ -523,6 +615,58 @@
705 return permanent_pool;
706 }
5fa7631d 707
7802c33e
JB
708+#if defined(EAPI)
709+void ap_init_alloc_shared(int early)
710+{
711+#if defined(EAPI_MM)
712+ int mm_size;
713+ char *mm_path;
714+ char *err1, *err2;
015adaf5 715+
7802c33e
JB
716+ if (early) {
717+ /* process very early on startup */
718+ mm_size = ap_mm_maxsize();
719+ if (mm_size > EAPI_MM_CORE_MAXSIZE)
720+ mm_size = EAPI_MM_CORE_MAXSIZE;
721+ mm_path = ap_server_root_relative(permanent_pool,
722+ ap_psprintf(permanent_pool, "%s.%ld",
723+ EAPI_MM_CORE_PATH, (long)getpid()));
724+ if ((mm = ap_mm_create(mm_size, mm_path)) == NULL) {
725+ fprintf(stderr, "Ouch! ap_mm_create(%d, \"%s\") failed\n", mm_size, mm_path);
726+ err1 = ap_mm_error();
727+ if (err1 == NULL)
728+ err1 = "-unknown-";
729+ err2 = strerror(errno);
730+ if (err2 == NULL)
731+ err2 = "-unknown-";
732+ fprintf(stderr, "Error: MM: %s: OS: %s\n", err1, err2);
733+ exit(1);
734+ }
735+ }
736+ else {
737+ /* process a lot later on startup */
738+#ifdef WIN32
739+ ap_mm_permission(mm, (_S_IREAD|_S_IWRITE), ap_user_id, -1);
740+#else
741+ ap_mm_permission(mm, (S_IRUSR|S_IWUSR), ap_user_id, -1);
742+#endif
743+ }
744+#endif /* EAPI_MM */
745+ return;
746+}
747+
748+void ap_kill_alloc_shared(void)
749+{
750+#if defined(EAPI_MM)
751+ if (mm != NULL) {
752+ ap_mm_destroy(mm);
753+ mm = NULL;
754+ }
755+#endif /* EAPI_MM */
756+ return;
757+}
015adaf5 758+#endif /* EAPI */
759+
7802c33e
JB
760 void ap_cleanup_alloc(void)
761 {
762 ap_destroy_mutex(alloc_mutex);
763@@ -533,10 +677,18 @@
764 {
765 ap_block_alarms();
5fa7631d 766
7802c33e
JB
767+#if defined(EAPI) && defined(EAPI_MM)
768+ if (a->is_shm)
769+ (void)ap_mm_lock(mm, AP_MM_LOCK_RW);
5fa7631d 770+#endif
7802c33e
JB
771 (void) ap_acquire_mutex(alloc_mutex);
772 while (a->sub_pools)
773 ap_destroy_pool(a->sub_pools);
774 (void) ap_release_mutex(alloc_mutex);
775+#if defined(EAPI) && defined(EAPI_MM)
776+ if (a->is_shm)
777+ (void)ap_mm_unlock(mm);
a4bf41f2 778+#endif
7802c33e
JB
779 /* Don't hold the mutex during cleanups. */
780 run_cleanups(a->cleanups);
781 a->cleanups = NULL;
782@@ -570,6 +722,10 @@
783 ap_block_alarms();
784 ap_clear_pool(a);
a4bf41f2 785
7802c33e
JB
786+#if defined(EAPI) && defined(EAPI_MM)
787+ if (a->is_shm)
788+ (void)ap_mm_lock(mm, AP_MM_LOCK_RW);
015adaf5 789+#endif
7802c33e
JB
790 (void) ap_acquire_mutex(alloc_mutex);
791 if (a->parent) {
792 if (a->parent->sub_pools == a)
793@@ -580,6 +736,10 @@
794 a->sub_next->sub_prev = a->sub_prev;
5fa7631d 795 }
7802c33e
JB
796 (void) ap_release_mutex(alloc_mutex);
797+#if defined(EAPI) && defined(EAPI_MM)
798+ if (a->is_shm)
799+ (void)ap_mm_unlock(mm);
800+#endif
015adaf5 801
7802c33e
JB
802 free_blocks(a->first);
803 ap_unblock_alarms();
804@@ -594,6 +754,30 @@
805 return bytes_in_block_list(block_freelist);
806 }
5fa7631d 807
7802c33e
JB
808+#if defined(EAPI)
809+API_EXPORT(int) ap_acquire_pool(pool *p, ap_pool_lock_mode mode)
810+{
811+#if defined(EAPI_MM)
812+ if (!p->is_shm)
813+ return 1;
814+ return ap_mm_lock(mm, mode == AP_POOL_RD ? AP_MM_LOCK_RD : AP_MM_LOCK_RW);
815+#else
816+ return 1;
817+#endif
818+}
819+
820+API_EXPORT(int) ap_release_pool(pool *p)
821+{
822+#if defined(EAPI_MM)
823+ if (!p->is_shm)
824+ return 1;
825+ return ap_mm_unlock(mm);
826+#else
827+ return 1;
828+#endif
829+}
5fa7631d 830+#endif /* EAPI */
831+
7802c33e
JB
832 /*****************************************************************
833 * POOL_DEBUG support
834 */
835@@ -759,16 +943,31 @@
5fa7631d 836
7802c33e 837 ap_block_alarms();
015adaf5 838
7802c33e
JB
839+#if defined(EAPI) && defined(EAPI_MM)
840+ if (a->is_shm)
841+ (void)ap_mm_lock(mm, AP_MM_LOCK_RW);
842+#endif
843 (void) ap_acquire_mutex(alloc_mutex);
015adaf5 844
7802c33e
JB
845+#if defined(EAPI) && defined(EAPI_MM)
846+ blok = new_block(size, a->is_shm);
847+#else
848 blok = new_block(size);
849+#endif
850 a->last->h.next = blok;
851 a->last = blok;
852 #ifdef POOL_DEBUG
853 blok->h.owning_pool = a;
854 #endif
855+#if defined(EAPI) && defined(EAPI_MM)
856+ blok->h.is_shm = a->is_shm;
015adaf5 857+#endif
5fa7631d 858
7802c33e
JB
859 (void) ap_release_mutex(alloc_mutex);
860+#if defined(EAPI) && defined(EAPI_MM)
861+ if (a->is_shm)
862+ (void)ap_mm_unlock(mm);
863+#endif
5fa7631d 864
7802c33e
JB
865 ap_unblock_alarms();
866
867@@ -885,6 +1084,11 @@
868 size = cur_len << 1;
869 if (size < AP_PSPRINTF_MIN_SIZE)
870 size = AP_PSPRINTF_MIN_SIZE;
871+#if defined(EAPI) && defined(EAPI_MM)
872+ if (ps->block->h.is_shm)
873+ ptr = ap_mm_realloc(ps->base, size);
015adaf5 874+ else
875+#endif
7802c33e
JB
876 ptr = realloc(ps->base, size);
877 if (ptr == NULL) {
878 fputs("Ouch! Out of memory!\n", stderr);
879@@ -908,9 +1112,21 @@
880 size = AP_PSPRINTF_MIN_SIZE;
5fa7631d 881
7802c33e
JB
882 /* must try another blok */
883+#if defined(EAPI) && defined(EAPI_MM)
884+ if (blok->h.is_shm)
885+ (void)ap_mm_lock(mm, AP_MM_LOCK_RW);
886+#endif
887 (void) ap_acquire_mutex(alloc_mutex);
888+#if defined(EAPI) && defined(EAPI_MM)
889+ nblok = new_block(size, blok->h.is_shm);
890+#else
891 nblok = new_block(size);
892+#endif
893 (void) ap_release_mutex(alloc_mutex);
894+#if defined(EAPI) && defined(EAPI_MM)
895+ if (blok->h.is_shm)
896+ (void)ap_mm_unlock(mm);
897+#endif
898 memcpy(nblok->h.first_avail, blok->h.first_avail, cur_len);
899 ps->vbuff.curpos = nblok->h.first_avail + cur_len;
900 /* save a byte for the NUL terminator */
901@@ -919,10 +1135,18 @@
902 /* did we allocate the current blok? if so free it up */
903 if (ps->got_a_new_block) {
904 debug_fill(blok->h.first_avail, blok->h.endp - blok->h.first_avail);
905+#if defined(EAPI) && defined(EAPI_MM)
906+ if (blok->h.is_shm)
907+ (void)ap_mm_lock(mm, AP_MM_LOCK_RW);
908+#endif
909 (void) ap_acquire_mutex(alloc_mutex);
910 blok->h.next = block_freelist;
911 block_freelist = blok;
912 (void) ap_release_mutex(alloc_mutex);
913+#if defined(EAPI) && defined(EAPI_MM)
914+ if (blok->h.is_shm)
915+ (void)ap_mm_unlock(mm);
015adaf5 916+#endif
015adaf5 917 }
7802c33e
JB
918 ps->blok = nblok;
919 ps->got_a_new_block = 1;
920@@ -941,6 +1165,11 @@
921 void *ptr;
922
923 ap_block_alarms();
924+#if defined(EAPI) && defined(EAPI_MM)
925+ if (p->is_shm)
926+ ps.base = ap_mm_malloc(mm, 512);
927+ else
928+#endif
929 ps.base = malloc(512);
930 if (ps.base == NULL) {
931 fputs("Ouch! Out of memory!\n", stderr);
932@@ -953,6 +1182,11 @@
933 *ps.vbuff.curpos++ = '\0';
934 ptr = ps.base;
935 /* shrink */
936+#if defined(EAPI) && defined(EAPI_MM)
937+ if (p->is_shm)
938+ ptr = ap_mm_realloc(ptr, (char *)ps.vbuff.curpos - (char *)ptr);
939+ else
940+#endif
941 ptr = realloc(ptr, (char *)ps.vbuff.curpos - (char *)ptr);
942 if (ptr == NULL) {
943 fputs("Ouch! Out of memory!\n", stderr);
5fa7631d 944
945+---------------------------------------------------------------------------
7802c33e
JB
946| Patch the low-level buffer routines to additionally allow
947| modules to intercept the I/O processing via hooks.
5fa7631d 948+---------------------------------------------------------------------------
7802c33e 949Index: src/main/buff.c
d5724db6
JB
950--- src/main/buff.c 29 Oct 2003 18:57:34 -0000 1.1.1.14
951+++ src/main/buff.c 29 Oct 2003 18:59:05 -0000 1.22
7802c33e
JB
952@@ -293,6 +293,9 @@
953 }
954 else
955 #endif
5fa7631d 956+#ifdef EAPI
7802c33e 957+ if (!ap_hook_call("ap::buff::read", &rv, fb, buf, nbyte))
5fa7631d 958+#endif /* EAPI */
7802c33e
JB
959 rv = read(fb->fd_in, buf, nbyte);
960
961 return rv;
962@@ -304,6 +307,9 @@
5fa7631d 963
7802c33e
JB
964 #if defined (WIN32) || defined(NETWARE) || defined(CYGWIN_WINSOCK)
965 if (fb->flags & B_SOCKET) {
015adaf5 966+#ifdef EAPI
7802c33e 967+ if (!ap_hook_call("ap::buff::recvwithtimeout", &rv, fb, buf, nbyte))
015adaf5 968+#endif /* EAPI */
7802c33e
JB
969 rv = ap_recvwithtimeout(fb->fd_in, buf, nbyte, 0);
970 if (rv == SOCKET_ERROR)
971 errno = WSAGetLastError();
972@@ -351,6 +357,9 @@
973 }
974 else
975 #endif
5fa7631d 976+#ifdef EAPI
7802c33e 977+ if (!ap_hook_call("ap::buff::write", &rv, fb, buf, nbyte))
5fa7631d 978+#endif /* EAPI */
7802c33e
JB
979 #if defined (B_SFIO)
980 rv = sfwrite(fb->sf_out, buf, nbyte);
981 #else
982@@ -381,6 +390,9 @@
983
984 #if defined(WIN32) || defined(NETWARE)
985 if (fb->flags & B_SOCKET) {
5fa7631d 986+#ifdef EAPI
7802c33e 987+ if (!ap_hook_call("ap::buff::sendwithtimeout", &rv, fb, buf, nbyte))
5fa7631d 988+#endif /* EAPI */
7802c33e
JB
989 rv = ap_sendwithtimeout(fb->fd, buf, nbyte, 0);
990 if (rv == SOCKET_ERROR)
991 errno = WSAGetLastError();
992@@ -464,6 +476,10 @@
993 fb->callback_data = NULL;
994 fb->filter_callback = NULL;
995
5fa7631d 996+#ifdef EAPI
7802c33e 997+ fb->ctx = ap_ctx_new(p);
5fa7631d 998+#endif /* EAPI */
7802c33e
JB
999+
1000 return fb;
1001 }
5fa7631d 1002
7802c33e
JB
1003@@ -1116,6 +1132,9 @@
1004 i = 0;
1005 while (i < nvec) {
1006 do
5fa7631d 1007+#ifdef EAPI
7802c33e 1008+ if (!ap_hook_call("ap::buff::writev", &rv, fb, &vec[i], nvec -i))
5fa7631d 1009+#endif /* EAPI */
7802c33e
JB
1010 rv = writev(fb->fd, &vec[i], nvec - i);
1011 while (rv == -1 && (errno == EINTR || errno == EAGAIN)
1012 && !(fb->flags & B_EOUT));
015adaf5 1013
1014+---------------------------------------------------------------------------
7802c33e
JB
1015| Add the implementation of the additional `add_module' and
1016| `rewrite_command' module hooks. Additionally the `ctx'
1017| variables are initialized.
015adaf5 1018+---------------------------------------------------------------------------
7802c33e
JB
1019Index: src/main/http_config.c
1020--- src/main/http_config.c 18 Jul 2003 15:44:34 -0000 1.1.1.16
1021+++ src/main/http_config.c 18 Jul 2003 15:56:58 -0000 1.19
1022@@ -600,6 +600,20 @@
1023 m->name = tmp;
5fa7631d 1024 }
7802c33e
JB
1025 #endif /*_OSD_POSIX*/
1026+
5fa7631d 1027+#ifdef EAPI
7802c33e
JB
1028+ /*
1029+ * Invoke the `add_module' hook inside the now existing set
1030+ * of modules to let them all now that this module was added.
1031+ */
1032+ {
1033+ module *m2;
1034+ for (m2 = top_module; m2 != NULL; m2 = m2->next)
1035+ if (m2->magic == MODULE_MAGIC_COOKIE_EAPI)
1036+ if (m2->add_module != NULL)
1037+ (*m2->add_module)(m);
1038+ }
1039+#endif /* EAPI */
1040 }
5fa7631d 1041
7802c33e
JB
1042 /*
1043@@ -614,6 +628,21 @@
1044 {
1045 module *modp;
5fa7631d 1046
5fa7631d 1047+#ifdef EAPI
7802c33e
JB
1048+ /*
1049+ * Invoke the `remove_module' hook inside the now existing
1050+ * set of modules to let them all now that this module is
1051+ * beeing removed.
1052+ */
015adaf5 1053+ {
7802c33e
JB
1054+ module *m2;
1055+ for (m2 = top_module; m2 != NULL; m2 = m2->next)
1056+ if (m2->magic == MODULE_MAGIC_COOKIE_EAPI)
1057+ if (m2->remove_module != NULL)
1058+ (*m2->remove_module)(m);
015adaf5 1059+ }
5fa7631d 1060+#endif /* EAPI */
b7715870 1061+
7802c33e
JB
1062 modp = top_module;
1063 if (modp == m) {
1064 /* We are the top module, special case */
1065@@ -1007,6 +1036,27 @@
1066 const command_rec *cmd;
1067 module *mod = top_module;
1068
5fa7631d 1069+#ifdef EAPI
7802c33e
JB
1070+ /*
1071+ * Invoke the `rewrite_command' of modules to allow
1072+ * they to rewrite the directive line before we
1073+ * process it.
1074+ */
015adaf5 1075+ {
7802c33e
JB
1076+ module *m;
1077+ char *cp;
1078+ for (m = top_module; m != NULL; m = m->next) {
1079+ if (m->magic == MODULE_MAGIC_COOKIE_EAPI) {
1080+ if (m->rewrite_command != NULL) {
1081+ cp = (m->rewrite_command)(parms, config, l);
1082+ if (cp != NULL)
1083+ l = cp;
1084+ }
1085+ }
015adaf5 1086+ }
1087+ }
015adaf5 1088+#endif /* EAPI */
015adaf5 1089+
7802c33e
JB
1090 if ((l[0] == '#') || (!l[0]))
1091 return NULL;
5fa7631d 1092
7802c33e
JB
1093@@ -1467,6 +1517,10 @@
1094 s->limit_req_fieldsize = main_server->limit_req_fieldsize;
1095 s->limit_req_fields = main_server->limit_req_fields;
5fa7631d 1096
5fa7631d 1097+#ifdef EAPI
7802c33e 1098+ s->ctx = ap_ctx_new(p);
5fa7631d 1099+#endif /* EAPI */
7802c33e
JB
1100+
1101 *ps = s;
5fa7631d 1102
7802c33e 1103 return ap_parse_vhost_addrs(p, hostname, s);
d5724db6 1104@@ -1578,6 +1632,10 @@
7802c33e
JB
1105 s->module_config = create_server_config(p, s);
1106 s->lookup_defaults = create_default_per_dir_config(p);
d5724db6 1107
5fa7631d 1108+#ifdef EAPI
7802c33e 1109+ s->ctx = ap_ctx_new(p);
5fa7631d 1110+#endif /* EAPI */
d5724db6 1111+
7802c33e
JB
1112 return s;
1113 }
d5724db6 1114
7802c33e
JB
1115
1116+---------------------------------------------------------------------------
1117| Add the ap_global_ctx variable and the new
1118| ap_add_config_define() function. Additionally the
1119| implementation of the additional `new_connection' module hook
1120| is added plus the initialization of one more `ctx' variable.
1121+---------------------------------------------------------------------------
1122Index: src/main/http_main.c
d5724db6
JB
1123--- src/main/http_main.c 29 Oct 2003 18:57:36 -0000 1.1.1.21
1124+++ src/main/http_main.c 29 Oct 2003 18:59:05 -0000 1.43
7802c33e
JB
1125@@ -279,6 +279,9 @@
1126
1127 int ap_dump_settings = 0;
1128 API_VAR_EXPORT int ap_extended_status = 0;
5fa7631d 1129+#ifdef EAPI
7802c33e 1130+API_VAR_EXPORT ap_ctx *ap_global_ctx;
5fa7631d 1131+#endif /* EAPI */
1132
7802c33e
JB
1133 /*
1134 * The max child slot ever assigned, preserved across restarts. Necessary
1135@@ -471,6 +474,30 @@
1136 }
1137 }
5fa7631d 1138
1139+#ifdef EAPI
7802c33e
JB
1140+API_EXPORT(void) ap_add_config_define(const char *define)
1141+{
1142+ char **var;
1143+ var = (char **)ap_push_array(ap_server_config_defines);
1144+ *var = ap_pstrdup(pcommands, define);
1145+ return;
1146+}
1147+
1148+/*
1149+ * Invoke the `close_connection' hook of modules to let them do
1150+ * some connection dependent actions before we close it.
1151+ */
1152+static void ap_call_close_connection_hook(conn_rec *c)
1153+{
1154+ module *m;
1155+ for (m = top_module; m != NULL; m = m->next)
1156+ if (m->magic == MODULE_MAGIC_COOKIE_EAPI)
1157+ if (m->close_connection != NULL)
1158+ (*m->close_connection)(c);
1159+ return;
1160+}
5fa7631d 1161+#endif /* EAPI */
7802c33e
JB
1162+
1163 #ifndef NETWARE
1164 static APACHE_TLS int volatile exit_after_unblock = 0;
1165 #endif
1166@@ -1577,6 +1604,10 @@
1167 ap_log_transaction(log_req);
1168 }
5fa7631d 1169
7802c33e
JB
1170+#ifdef EAPI
1171+ ap_call_close_connection_hook(save_req->connection);
1172+#endif /* EAPI */
015adaf5 1173+
7802c33e
JB
1174 ap_bsetflag(save_req->connection->client, B_EOUT, 1);
1175 ap_bclose(save_req->connection->client);
1176
1177@@ -1585,6 +1616,9 @@
1178 ap_longjmp(jmpbuffer, 1);
1179 }
1180 else { /* abort the connection */
5fa7631d 1181+#ifdef EAPI
7802c33e 1182+ ap_call_close_connection_hook(current_conn);
5fa7631d 1183+#endif /* EAPI */
7802c33e
JB
1184 ap_bsetflag(current_conn->client, B_EOUT, 1);
1185 ap_bclose(current_conn->client);
1186 current_conn->aborted = 1;
1187@@ -1887,10 +1921,16 @@
1188 /* Send any leftover data to the client, but never try to again */
015adaf5 1189
7802c33e 1190 if (ap_bflush(r->connection->client) == -1) {
5fa7631d 1191+#ifdef EAPI
7802c33e
JB
1192+ ap_call_close_connection_hook(r->connection);
1193+#endif /* EAPI */
1194 ap_kill_timeout(r);
1195 ap_bclose(r->connection->client);
1196 return;
1197 }
1198+#ifdef EAPI
1199+ ap_call_close_connection_hook(r->connection);
1200+#endif /* EAPI */
1201 ap_bsetflag(r->connection->client, B_EOUT, 1);
5fa7631d 1202
7802c33e
JB
1203 /* Close our half of the connection --- send the client a FIN */
1204@@ -2589,6 +2629,9 @@
1205 /* Clear the pool - including any registered cleanups */
1206 ap_destroy_pool(pglobal);
015adaf5 1207 #endif
7802c33e
JB
1208+#ifdef EAPI
1209+ ap_kill_alloc_shared();
5fa7631d 1210+#endif
7802c33e
JB
1211 exit(code);
1212 }
1213
1214@@ -3608,6 +3651,24 @@
1215 conn->remote_addr = *remaddr;
1216 conn->remote_ip = ap_pstrdup(conn->pool,
1217 inet_ntoa(conn->remote_addr.sin_addr));
1218+#ifdef EAPI
1219+ conn->ctx = ap_ctx_new(conn->pool);
1220+#endif /* EAPI */
015adaf5 1221+
7802c33e
JB
1222+#ifdef EAPI
1223+ /*
1224+ * Invoke the `new_connection' hook of modules to let them do
1225+ * some connection dependent actions before we go on with
1226+ * processing the request on this connection.
1227+ */
1228+ {
1229+ module *m;
1230+ for (m = top_module; m != NULL; m = m->next)
1231+ if (m->magic == MODULE_MAGIC_COOKIE_EAPI)
1232+ if (m->new_connection != NULL)
1233+ (*m->new_connection)(conn);
1234+ }
1235+#endif /* EAPI */
5fa7631d 1236
7802c33e
JB
1237 return conn;
1238 }
d5724db6 1239@@ -4023,6 +4084,15 @@
7802c33e
JB
1240 printf("Server's Module Magic Number: %u:%u\n",
1241 MODULE_MAGIC_NUMBER_MAJOR, MODULE_MAGIC_NUMBER_MINOR);
1242 printf("Server compiled with....\n");
1243+#ifdef EAPI
1244+ printf(" -D EAPI\n");
015adaf5 1245+#endif
7802c33e
JB
1246+#ifdef EAPI_MM
1247+ printf(" -D EAPI_MM\n");
1248+#ifdef EAPI_MM_CORE_PATH
1249+ printf(" -D EAPI_MM_CORE_PATH=\"" EAPI_MM_CORE_PATH "\"\n");
015adaf5 1250+#endif
5fa7631d 1251+#endif
7802c33e
JB
1252 #ifdef TPF
1253 show_os_specific_compile_settings();
015adaf5 1254 #endif
d5724db6 1255@@ -4194,6 +4264,22 @@
7802c33e
JB
1256 ap_server_pre_read_config = ap_make_array(pcommands, 1, sizeof(char *));
1257 ap_server_post_read_config = ap_make_array(pcommands, 1, sizeof(char *));
1258 ap_server_config_defines = ap_make_array(pcommands, 1, sizeof(char *));
1259+
1260+#ifdef EAPI
1261+ ap_hook_init();
1262+ ap_hook_configure("ap::buff::read",
1263+ AP_HOOK_SIG4(int,ptr,ptr,int), AP_HOOK_TOPMOST);
1264+ ap_hook_configure("ap::buff::write",
1265+ AP_HOOK_SIG4(int,ptr,ptr,int), AP_HOOK_TOPMOST);
1266+ ap_hook_configure("ap::buff::writev",
1267+ AP_HOOK_SIG4(int,ptr,ptr,int), AP_HOOK_TOPMOST);
1268+ ap_hook_configure("ap::buff::sendwithtimeout",
1269+ AP_HOOK_SIG4(int,ptr,ptr,int), AP_HOOK_TOPMOST);
1270+ ap_hook_configure("ap::buff::recvwithtimeout",
1271+ AP_HOOK_SIG4(int,ptr,ptr,int), AP_HOOK_TOPMOST);
1272+
1273+ ap_global_ctx = ap_ctx_new(NULL);
1274+#endif /* EAPI */
015adaf5 1275 }
5fa7631d 1276
7802c33e 1277 #ifndef MULTITHREAD
d5724db6 1278@@ -4655,6 +4741,9 @@
5fa7631d 1279
7802c33e
JB
1280 ap_sync_scoreboard_image();
1281 if (ap_scoreboard_image->global.running_generation != ap_my_generation) {
1282+#ifdef EAPI
1283+ ap_call_close_connection_hook(current_conn);
1284+#endif /* EAPI */
1285 ap_bclose(conn_io);
1286 clean_child_exit(0);
1287 }
d5724db6 1288@@ -4683,6 +4772,9 @@
7802c33e
JB
1289 */
1290
1291 #ifdef NO_LINGCLOSE
1292+#ifdef EAPI
1293+ ap_call_close_connection_hook(current_conn);
1294+#endif /* EAPI */
1295 ap_bclose(conn_io); /* just close it */
1296 #else
1297 if (r && r->connection
d5724db6 1298@@ -4693,6 +4785,9 @@
7802c33e
JB
1299 lingering_close(r);
1300 }
1301 else {
1302+#ifdef EAPI
1303+ ap_call_close_connection_hook(current_conn);
1304+#endif /* EAPI */
1305 ap_bsetflag(conn_io, B_EOUT, 1);
1306 ap_bclose(conn_io);
1307 }
d5724db6 1308@@ -5463,16 +5558,31 @@
7802c33e
JB
1309 usage(argv[0]);
1310 }
1311 }
1312+#ifdef EAPI
1313+ ap_init_alloc_shared(TRUE);
015adaf5 1314+#endif
5fa7631d 1315
7802c33e
JB
1316 ap_suexec_enabled = init_suexec();
1317 server_conf = ap_read_config(pconf, ptrans, ap_server_confname);
1318
1319+#ifdef EAPI
1320+ ap_init_alloc_shared(FALSE);
1321+#endif
1322+
1323 if (ap_configtestonly) {
1324 fprintf(stderr, "Syntax OK\n");
1325+#ifdef EAPI
1326+ clean_parent_exit(0);
015adaf5 1327+#else
7802c33e 1328 exit(0);
015adaf5 1329+#endif
7802c33e
JB
1330 }
1331 if (ap_dump_settings) {
1332+#ifdef EAPI
1333+ clean_parent_exit(0);
015adaf5 1334+#else
7802c33e 1335 exit(0);
015adaf5 1336+#endif
7802c33e 1337 }
015adaf5 1338
7802c33e 1339 child_timeouts = !ap_standalone || one_process;
d5724db6 1340@@ -5620,6 +5730,10 @@
7802c33e
JB
1341 ap_destroy_pool(r->pool);
1342 }
015adaf5 1343
7802c33e
JB
1344+#ifdef EAPI
1345+ ap_call_close_connection_hook(conn);
1346+#endif /* EAPI */
1347+
1348 ap_bclose(cio);
1349 }
1350 exit(0);
d5724db6 1351@@ -5996,6 +6110,9 @@
7802c33e 1352 ap_kill_cleanups_for_socket(ptrans, csd);
015adaf5 1353
7802c33e
JB
1354 #ifdef NO_LINGCLOSE
1355+#ifdef EAPI
1356+ ap_call_close_connection_hook(current_conn);
1357+#endif /* EAPI */
1358 ap_bclose(conn_io); /* just close it */
1359 #else
1360 if (r && r->connection
d5724db6 1361@@ -6006,6 +6123,9 @@
7802c33e
JB
1362 lingering_close(r);
1363 }
1364 else {
1365+#ifdef EAPI
1366+ ap_call_close_connection_hook(current_conn);
1367+#endif /* EAPI */
1368 ap_bsetflag(conn_io, B_EOUT, 1);
1369 ap_bclose(conn_io);
1370 }
d5724db6 1371@@ -7574,6 +7694,10 @@
7802c33e
JB
1372 if (!conf_specified)
1373 ap_cpystrn(ap_server_confname, SERVER_CONFIG_FILE, sizeof(ap_server_confname));
015adaf5 1374
7802c33e
JB
1375+#ifdef EAPI
1376+ ap_init_alloc_shared(TRUE);
015adaf5 1377+#endif
7802c33e
JB
1378+
1379 if (!ap_os_is_path_absolute(ap_server_confname))
1380 ap_cpystrn(ap_server_confname,
1381 ap_server_root_relative(pcommands, ap_server_confname),
d5724db6 1382@@ -7614,6 +7738,9 @@
7802c33e
JB
1383 #else /* ndef WIN32 */
1384 server_conf = ap_read_config(pconf, ptrans, ap_server_confname);
d5724db6 1385 #endif
7802c33e
JB
1386+#ifdef EAPI
1387+ ap_init_alloc_shared(FALSE);
d5724db6 1388+#endif
7802c33e
JB
1389
1390 if (ap_configtestonly) {
d5724db6 1391 fprintf(stderr, "%s: Syntax OK\n", ap_server_root_relative(pcommands, ap_server_confname));
7802c33e
JB
1392
1393+---------------------------------------------------------------------------
1394| Just add the initialization of the `ctx' variable for
1395| conn_rec structures.
1396+---------------------------------------------------------------------------
1397Index: src/main/http_request.c
d5724db6
JB
1398--- src/main/http_request.c 29 Oct 2003 18:57:37 -0000 1.1.1.17
1399+++ src/main/http_request.c 29 Oct 2003 18:59:05 -0000 1.17
1400@@ -1406,6 +1406,10 @@
7802c33e
JB
1401
1402 new->method = r->method;
1403 new->method_number = r->method_number;
1404+#ifdef EAPI
1405+ /* initialize context _BEFORE_ ap_parse_uri() call */
1406+ new->ctx = r->ctx;
1407+#endif /* EAPI */
1408 ap_parse_uri(new, new_uri);
1409 new->request_config = ap_create_request_config(r->pool);
1410 new->per_dir_config = r->server->lookup_defaults;
1411
1412+---------------------------------------------------------------------------
1413| Just add the initialization of the `ctx' variable for
1414| request_rec structures.
1415+---------------------------------------------------------------------------
1416Index: src/main/http_protocol.c
1417--- src/main/http_protocol.c 18 Jul 2003 15:44:35 -0000 1.1.1.19
1418+++ src/main/http_protocol.c 18 Jul 2003 15:56:58 -0000 1.19
1419@@ -1202,6 +1202,10 @@
1420 r->status = HTTP_REQUEST_TIME_OUT; /* Until we get a request */
1421 r->the_request = NULL;
1422
1423+#ifdef EAPI
1424+ r->ctx = ap_ctx_new(r->pool);
1425+#endif /* EAPI */
015adaf5 1426+
7802c33e
JB
1427 #ifdef CHARSET_EBCDIC
1428 ap_bsetflag(r->connection->client, B_ASCII2EBCDIC, r->ebcdic.conv_in = 1);
1429 ap_bsetflag(r->connection->client, B_EBCDIC2ASCII, r->ebcdic.conv_out = 1);
1430@@ -1358,6 +1362,11 @@
1431 rnew->read_body = REQUEST_NO_BODY;
015adaf5 1432
7802c33e
JB
1433 rnew->main = (request_rec *) r;
1434+
1435+#ifdef EAPI
1436+ rnew->ctx = r->ctx;
1437+#endif /* EAPI */
1438+
5fa7631d 1439 }
5fa7631d 1440
7802c33e
JB
1441 API_EXPORT(void) ap_finalize_sub_req_protocol(request_rec *sub)
1442
1443+---------------------------------------------------------------------------
1444| Add support for loading both EAPI and AP13 modules.
1445+---------------------------------------------------------------------------
1446Index: src/modules/standard/mod_so.c
1447--- src/modules/standard/mod_so.c 18 Jul 2003 15:44:39 -0000 1.1.1.10
1448+++ src/modules/standard/mod_so.c 18 Jul 2003 15:56:59 -0000 1.11
1449@@ -269,11 +269,24 @@
1450 * Make sure the found module structure is really a module structure
1451 *
1452 */
1453+#ifdef EAPI
1454+ if ( modp->magic != MODULE_MAGIC_COOKIE_AP13
1455+ && modp->magic != MODULE_MAGIC_COOKIE_EAPI) {
015adaf5 1456+#else
7802c33e 1457 if (modp->magic != MODULE_MAGIC_COOKIE) {
015adaf5 1458+#endif
7802c33e
JB
1459 return ap_pstrcat(cmd->pool, "API module structure `", modname,
1460 "' in file ", szModuleFile, " is garbled -"
1461 " perhaps this is not an Apache module DSO?", NULL);
1462 }
1463+#ifdef EAPI
1464+ if (modp->magic == MODULE_MAGIC_COOKIE_AP13) {
1465+ ap_log_error(APLOG_MARK, APLOG_WARNING|APLOG_NOERRNO, NULL,
1466+ "Loaded DSO %s uses plain Apache 1.3 API, "
1467+ "this module might crash under EAPI! "
1468+ "(please recompile it with -DEAPI)", filename);
1469+ }
015adaf5 1470+#endif
015adaf5 1471
7802c33e
JB
1472 /*
1473 * Add this module to the Apache core structures
1474
1475+---------------------------------------------------------------------------
1476| Add additional logging functions to the CustomLog directive
1477| which can be used by other modules to create additional
1478| logfile tags. Actually we add two types of hooks: One hook
1479| for intercepting the new and generic %x (eXtension) tag and
1480| one hook for creating new %x tags at all.
1481+---------------------------------------------------------------------------
1482Index: src/modules/standard/mod_log_config.c
1483--- src/modules/standard/mod_log_config.c 18 Jul 2003 15:44:39 -0000 1.1.1.14
1484+++ src/modules/standard/mod_log_config.c 18 Jul 2003 15:56:59 -0000 1.27
1485@@ -262,6 +262,9 @@
1486 typedef const char *(*item_key_func) (request_rec *, char *);
1487
1488 typedef struct {
1489+#ifdef EAPI
1490+ char ch;
015adaf5 1491+#endif
7802c33e
JB
1492 item_key_func func;
1493 char *arg;
1494 int condition_sense;
1495@@ -580,15 +583,36 @@
1496 }
1497 };
1498
1499+#ifdef EAPI
1500+static struct log_item_list *find_log_func(pool *p, char k)
1501+#else /* EAPI */
1502 static struct log_item_list *find_log_func(char k)
1503+#endif /* EAPI */
015adaf5 1504 {
7802c33e
JB
1505 int i;
1506+#ifdef EAPI
1507+ struct log_item_list *lil;
1508+#endif /* EAPI */
1509
1510 for (i = 0; log_item_keys[i].ch; ++i)
1511 if (k == log_item_keys[i].ch) {
1512 return &log_item_keys[i];
1513 }
1514
1515+#ifdef EAPI
1516+ if (ap_hook_status(ap_psprintf(p, "ap::mod_log_config::log_%c", k))
1517+ != AP_HOOK_STATE_NOTEXISTANT) {
1518+ lil = (struct log_item_list *)
1519+ ap_pcalloc(p, sizeof(struct log_item_list));
1520+ if (lil == NULL)
1521+ return NULL;
1522+ lil->ch = k;
1523+ lil->func = NULL;
1524+ lil->want_orig_default = 0;
1525+ return lil;
1526+ }
1527+#endif /* EAPI */
1528+
1529 return NULL;
015adaf5 1530 }
1531
7802c33e
JB
1532@@ -714,7 +738,11 @@
1533 break;
1534
1535 default:
1536+#ifdef EAPI
1537+ l = find_log_func(p, *s++);
1538+#else /* EAPI */
1539 l = find_log_func(*s++);
5fa7631d 1540+#endif /* EAPI */
7802c33e
JB
1541 if (!l) {
1542 char dummy[2];
5fa7631d 1543
7802c33e
JB
1544@@ -723,6 +751,9 @@
1545 return ap_pstrcat(p, "Unrecognized LogFormat directive %",
1546 dummy, NULL);
1547 }
1548+#ifdef EAPI
1549+ it->ch = s[-1];
015adaf5 1550+#endif
7802c33e
JB
1551 it->func = l->func;
1552 if (it->want_orig == -1) {
1553 it->want_orig = l->want_orig_default;
1554@@ -784,6 +815,15 @@
5fa7631d 1555
7802c33e
JB
1556 /* We do. Do it... */
1557
1558+#ifdef EAPI
1559+ if (item->func == NULL) {
1560+ cp = NULL;
1561+ ap_hook_use(ap_psprintf(r->pool, "ap::mod_log_config::log_%c", item->ch),
1562+ AP_HOOK_SIG3(ptr,ptr,ptr), AP_HOOK_DECLINE(NULL),
1563+ &cp, r, item->arg);
1564+ }
1565+ else
5fa7631d 1566+#endif
7802c33e
JB
1567 cp = (*item->func) (item->want_orig ? orig : r, item->arg);
1568 return cp ? cp : "-";
1569 }
1570
1571+---------------------------------------------------------------------------
1572| Allow RewriteCond and RewriteRule directives to lookup
1573| variables from other modules.
1574+---------------------------------------------------------------------------
1575Index: src/modules/standard/mod_rewrite.c
d5724db6
JB
1576--- src/modules/standard/mod_rewrite.c 29 Oct 2003 18:57:38 -0000 1.1.1.18
1577+++ src/modules/standard/mod_rewrite.c 29 Oct 2003 18:59:05 -0000 1.16
1578@@ -3882,6 +3882,15 @@
015adaf5 1579 }
7802c33e
JB
1580 #endif /* ndef WIN32 && NETWARE*/
1581
1582+#ifdef EAPI
1583+ else {
1584+ ap_hook_use("ap::mod_rewrite::lookup_variable",
1585+ AP_HOOK_SIG3(ptr,ptr,ptr),
1586+ AP_HOOK_DECLINE(NULL),
1587+ &result, r, var);
1588+ }
5fa7631d 1589+#endif
7802c33e
JB
1590+
1591 if (result == NULL) {
1592 return ap_pstrdup(r->pool, "");
1593 }
1594
1595+---------------------------------------------------------------------------
1596| Add an EAPI hook to allow other modules to add content to
1597| the status HTML page.
1598+---------------------------------------------------------------------------
1599Index: src/modules/standard/mod_status.c
1600--- src/modules/standard/mod_status.c 18 Jul 2003 15:44:39 -0000 1.1.1.15
1601+++ src/modules/standard/mod_status.c 18 Jul 2003 15:56:59 -0000 1.12
1602@@ -694,12 +720,23 @@
1603 ap_rprintf(r,
1604 "<td>?<td nowrap>?<td nowrap>..reading.. </tr>\n\n");
1605 else
1606+#ifndef NO_PRETTYPRINT
1607+ ap_rprintf(r,
1608+ "<td nowrap><font face=\"Arial,Helvetica\" size=\"-1\">%s</font>"
1609+ "<td nowrap><font face=\"Arial,Helvetica\" size=\"-1\">%s</font>"
1610+ "<td nowrap><font face=\"Arial,Helvetica\" size=\"-1\">%s</font>"
1611+ "</tr>\n\n",
1612+ score_record.client,
1613+ vhost ? vhost->server_hostname : "(unavailable)",
1614+ ap_escape_html(r->pool, score_record.request));
1615+#else
1616 ap_rprintf(r,
1617 "<td>%s<td nowrap>%s<td nowrap>%s</tr>\n\n",
1618 ap_escape_html(r->pool, score_record.client),
1619 vhost ? ap_escape_html(r->pool,
1620 vhost->server_hostname) : "(unavailable)",
1621 ap_escape_html(r->pool, score_record.request));
1622+#endif
1623 } /* no_table_report */
1624 } /* !short_report */
1625 } /* if (<active child>) */
1626
1627+---------------------------------------------------------------------------
1628| Add hooks to the scheme processing to allow other modules to
1629| recognize more schemes by intercepting this processing.
1630+---------------------------------------------------------------------------
1631Index: src/modules/proxy/mod_proxy.c
1632--- src/modules/proxy/mod_proxy.c 18 Jul 2003 15:44:36 -0000 1.1.1.13
1633+++ src/modules/proxy/mod_proxy.c 18 Jul 2003 15:56:58 -0000 1.20
1634@@ -218,6 +218,9 @@
1635 static int proxy_fixup(request_rec *r)
1636 {
1637 char *url, *p;
1638+#ifdef EAPI
1639+ int rc;
1640+#endif /* EAPI */
5fa7631d 1641
7802c33e
JB
1642 if (r->proxyreq == NOT_PROXY || strncmp(r->filename, "proxy:", 6) != 0)
1643 return DECLINED;
1644@@ -225,6 +228,14 @@
1645 url = &r->filename[6];
1646
1647 /* canonicalise each specific scheme */
1648+#ifdef EAPI
1649+ if (ap_hook_use("ap::mod_proxy::canon",
1650+ AP_HOOK_SIG3(int,ptr,ptr),
1651+ AP_HOOK_DECLINE(DECLINED),
1652+ &rc, r, url) && rc != DECLINED)
1653+ return rc;
1654+ else
1655+#endif /* EAPI */
1656 if (strncasecmp(url, "http:", 5) == 0)
1657 return ap_proxy_http_canon(r, url + 5, "http", DEFAULT_HTTP_PORT);
1658 else if (strncasecmp(url, "ftp:", 4) == 0)
1659@@ -240,9 +251,44 @@
1660 static void proxy_init(server_rec *r, pool *p)
1661 {
1662 ap_proxy_garbage_init(r, p);
1663+#ifdef EAPI
1664+ ap_hook_use("ap::mod_proxy::init",
1665+ AP_HOOK_SIG3(void,ptr,ptr), AP_HOOK_ALL, r, p);
1666+#endif
015adaf5 1667 }
1668
7802c33e
JB
1669-
1670+#ifdef EAPI
1671+static void proxy_addmod(module *m)
015adaf5 1672+{
7802c33e
JB
1673+ /* export: ap_proxy_http_canon() as `ap::mod_proxy::http::canon' */
1674+ ap_hook_configure("ap::mod_proxy::http::canon",
1675+ AP_HOOK_SIG5(int,ptr,ptr,ptr,int), AP_HOOK_TOPMOST);
1676+ ap_hook_register("ap::mod_proxy::http::canon",
1677+ ap_proxy_http_canon, AP_HOOK_NOCTX);
1678+
1679+ /* export: ap_proxy_http_handler() as `ap::mod_proxy::http::handler' */
1680+ ap_hook_configure("ap::mod_proxy::http::handler",
1681+ AP_HOOK_SIG6(int,ptr,ptr,ptr,ptr,int), AP_HOOK_TOPMOST);
1682+ ap_hook_register("ap::mod_proxy::http::handler",
1683+ ap_proxy_http_handler, AP_HOOK_NOCTX);
1684+
1685+ /* export: ap_proxyerror() as `ap::mod_proxy::error' */
1686+ ap_hook_configure("ap::mod_proxy::error",
1687+ AP_HOOK_SIG3(int,ptr,ptr), AP_HOOK_TOPMOST);
1688+ ap_hook_register("ap::mod_proxy::error",
1689+ ap_proxyerror, AP_HOOK_NOCTX);
1690+ return;
015adaf5 1691+}
1692+
7802c33e 1693+static void proxy_remmod(module *m)
015adaf5 1694+{
7802c33e
JB
1695+ /* remove the hook references */
1696+ ap_hook_unregister("ap::mod_proxy::http::canon", ap_proxy_http_canon);
1697+ ap_hook_unregister("ap::mod_proxy::http::handler", ap_proxy_http_handler);
1698+ ap_hook_unregister("ap::mod_proxy::error", ap_proxyerror);
1699+ return;
015adaf5 1700+}
5fa7631d 1701+#endif /* EAPI */
5fa7631d 1702
7802c33e
JB
1703 /* Send a redirection if the request contains a hostname which is not */
1704 /* fully qualified, i.e. doesn't have a domain name appended. Some proxy */
1705@@ -374,6 +420,14 @@
1706 * CONNECT is a special method that bypasses the normal proxy
1707 * code.
1708 */
1709+#ifdef EAPI
1710+ if (!ap_hook_use("ap::mod_proxy::handler",
1711+ AP_HOOK_SIG7(int,ptr,ptr,ptr,ptr,int,ptr),
1712+ AP_HOOK_DECLINE(DECLINED),
1713+ &rc, r, cr, url,
1714+ ents[i].hostname, ents[i].port,
1715+ ents[i].protocol) || rc == DECLINED) {
1716+#endif /* EAPI */
1717 if (r->method_number == M_CONNECT)
1718 rc = ap_proxy_connect_handler(r, cr, url, ents[i].hostname,
1719 ents[i].port);
1720@@ -383,6 +437,9 @@
1721 ents[i].port);
1722 else
1723 rc = DECLINED;
1724+#ifdef EAPI
1725+ }
1726+#endif /* EAPI */
5fa7631d 1727
7802c33e
JB
1728 /* an error or success */
1729 if (rc != DECLINED && rc != HTTP_BAD_GATEWAY)
1730@@ -397,6 +454,14 @@
1731 */
5fa7631d 1732
7802c33e
JB
1733 /* handle the scheme */
1734+#ifdef EAPI
1735+ if (ap_hook_use("ap::mod_proxy::handler",
1736+ AP_HOOK_SIG7(int,ptr,ptr,ptr,ptr,int,ptr),
1737+ AP_HOOK_DECLINE(DECLINED),
1738+ &rc, r, cr, url,
1739+ NULL, 0, scheme) && rc != DECLINED)
1740+ return rc;
1741+#endif /* EAPI */
1742 if (r->method_number == M_CONNECT) {
1743 return ap_proxy_connect_handler(r, cr, url, NULL, 0);
1744 }
1745@@ -994,4 +1059,10 @@
1746 NULL, /* child_init */
1747 NULL, /* child_exit */
1748 proxy_detect /* post read-request */
1749+#ifdef EAPI
1750+ ,proxy_addmod, /* EAPI: add_module */
1751+ proxy_remmod, /* EAPI: remove_module */
1752+ NULL, /* EAPI: rewrite_command */
1753+ NULL /* EAPI: new_connection */
015adaf5 1754+#endif
7802c33e
JB
1755 };
1756
1757+---------------------------------------------------------------------------
1758| Add hooks to the HTTP processing to allow other modules
1759| to enhance it by intercepting this processing.
1760+---------------------------------------------------------------------------
1761Index: src/modules/proxy/proxy_http.c
1762--- src/modules/proxy/proxy_http.c 18 Jul 2003 15:44:37 -0000 1.1.1.16
1763+++ src/modules/proxy/proxy_http.c 18 Jul 2003 15:56:58 -0000 1.24
1764@@ -170,6 +170,9 @@
1765 const char *datestr, *urlstr;
1766 int result, major, minor;
1767 const char *content_length;
1768+#ifdef EAPI
1769+ char *peer;
015adaf5 1770+#endif
7802c33e
JB
1771
1772 void *sconf = r->server->module_config;
1773 proxy_server_conf *conf =
1774@@ -191,6 +194,12 @@
1775 return HTTP_BAD_REQUEST;
1776 urlptr += 3;
1777 destport = DEFAULT_HTTP_PORT;
1778+#ifdef EAPI
1779+ ap_hook_use("ap::mod_proxy::http::handler::set_destport",
1780+ AP_HOOK_SIG2(int,ptr),
1781+ AP_HOOK_TOPMOST,
1782+ &destport, r);
1783+#endif /* EAPI */
1784 strp = strchr(urlptr, '/');
1785 if (strp == NULL) {
1786 desthost = ap_pstrdup(p, urlptr);
1787@@ -228,12 +237,18 @@
1788 err = ap_proxy_host2addr(proxyhost, &server_hp);
1789 if (err != NULL)
1790 return DECLINED; /* try another */
1791+#ifdef EAPI
1792+ peer = ap_psprintf(p, "%s:%u", proxyhost, proxyport);
015adaf5 1793+#endif
7802c33e
JB
1794 }
1795 else {
1796 server.sin_port = htons((unsigned short)destport);
1797 err = ap_proxy_host2addr(desthost, &server_hp);
1798 if (err != NULL)
1799 return ap_proxyerror(r, HTTP_INTERNAL_SERVER_ERROR, err);
1800+#ifdef EAPI
1801+ peer = ap_psprintf(p, "%s:%u", desthost, destport);
015adaf5 1802+#endif
1803 }
015adaf5 1804
7802c33e
JB
1805
1806@@ -308,14 +323,42 @@
1807 f = ap_bcreate(p, B_RDWR | B_SOCKET);
1808 ap_bpushfd(f, sock, sock);
1809
5fa7631d 1810+#ifdef EAPI
7802c33e
JB
1811+ {
1812+ char *errmsg = NULL;
1813+ ap_hook_use("ap::mod_proxy::http::handler::new_connection",
1814+ AP_HOOK_SIG4(ptr,ptr,ptr,ptr),
1815+ AP_HOOK_DECLINE(NULL),
1816+ &errmsg, r, f, peer);
1817+ if (errmsg != NULL)
1818+ return ap_proxyerror(r, HTTP_BAD_GATEWAY, errmsg);
1819+ }
1820+#endif /* EAPI */
1821+
1822 ap_hard_timeout("proxy send", r);
1823 ap_bvputs(f, r->method, " ", proxyhost ? url : urlptr, " HTTP/1.1" CRLF,
1824 NULL);
1825+#ifdef EAPI
1826+ {
1827+ int rc = DECLINED;
1828+ ap_hook_use("ap::mod_proxy::http::handler::write_host_header",
1829+ AP_HOOK_SIG6(int,ptr,ptr,ptr,int,ptr),
1830+ AP_HOOK_DECLINE(DECLINED),
1831+ &rc, r, f, desthost, destport, destportstr);
1832+ if (rc == DECLINED) {
1833+ if (destportstr != NULL && destport != DEFAULT_HTTP_PORT)
1834+ ap_bvputs(f, "Host: ", desthost, ":", destportstr, CRLF, NULL);
1835+ else
1836+ ap_bvputs(f, "Host: ", desthost, CRLF, NULL);
1837+ }
1838+ }
1839+#else /* EAPI */
1840 /* Send Host: now, adding it to req_hdrs wouldn't be much better */
1841 if (destportstr != NULL && destport != DEFAULT_HTTP_PORT)
1842 ap_bvputs(f, "Host: ", desthost, ":", destportstr, CRLF, NULL);
1843 else
1844 ap_bvputs(f, "Host: ", desthost, CRLF, NULL);
1845+#endif /* EAPI */
1846
1847 if (conf->viaopt == via_block) {
1848 /* Block all outgoing Via: headers */
1849
1850+---------------------------------------------------------------------------
1851| Add EAPI hooks in module structure for APXS generated samples.
1852+---------------------------------------------------------------------------
1853Index: src/support/apxs.pl
1854--- src/support/apxs.pl 18 Jul 2003 15:44:46 -0000 1.1.1.13
1855+++ src/support/apxs.pl 18 Jul 2003 15:56:59 -0000 1.13
1856@@ -796,5 +796,11 @@
1857 NULL, /* child_init */
1858 NULL, /* child_exit */
1859 NULL /* [#0] post read-request */
1860+#ifdef EAPI
1861+ ,NULL, /* EAPI: add_module */
1862+ NULL, /* EAPI: remove_module */
1863+ NULL, /* EAPI: rewrite_command */
1864+ NULL /* EAPI: new_connection */
5fa7631d 1865+#endif
7802c33e 1866 };
5fa7631d 1867
7802c33e
JB
1868
1869+---------------------------------------------------------------------------
1870| Add the EAPI functions, so the stuff can be built under AIX
1871| and similar braindead platforms as DSO.
1872+---------------------------------------------------------------------------
1873Index: src/support/httpd.exp
1874--- src/support/httpd.exp 18 Jul 2003 15:44:47 -0000 1.1.1.12
1875+++ src/support/httpd.exp 18 Jul 2003 15:56:59 -0000 1.14
1876@@ -429,3 +429,59 @@
1877 XML_SetUnparsedEntityDeclHandler
1878 XML_SetUserData
1879 XML_UseParserAsHandlerArg
1880+ap_add_config_define
1881+ap_make_shared_sub_pool
1882+ap_global_ctx
1883+ap_ctx_new
1884+ap_ctx_get
1885+ap_ctx_set
1886+ap_hook_init
1887+ap_hook_kill
1888+ap_hook_configure
1889+ap_hook_register_I
1890+ap_hook_unregister_I
1891+ap_hook_status
1892+ap_hook_use
1893+ap_hook_call
1894+ap_mm_useable
1895+ap_MM_create
1896+ap_MM_permission
1897+ap_MM_destroy
1898+ap_MM_lock
1899+ap_MM_unlock
1900+ap_MM_malloc
1901+ap_MM_realloc
1902+ap_MM_free
1903+ap_MM_calloc
1904+ap_MM_strdup
1905+ap_MM_sizeof
1906+ap_MM_maxsize
1907+ap_MM_available
1908+ap_MM_error
1909+ap_mm_create
1910+ap_mm_permission
1911+ap_mm_destroy
1912+ap_mm_lock
1913+ap_mm_unlock
1914+ap_mm_malloc
1915+ap_mm_realloc
1916+ap_mm_free
1917+ap_mm_calloc
1918+ap_mm_strdup
1919+ap_mm_sizeof
1920+ap_mm_maxsize
1921+ap_mm_available
1922+ap_mm_error
1923+ap_mm_display_info
1924+ap_mm_core_create
1925+ap_mm_core_permission
1926+ap_mm_core_delete
1927+ap_mm_core_size
1928+ap_mm_core_lock
1929+ap_mm_core_unlock
1930+ap_mm_core_maxsegsize
1931+ap_mm_core_align2page
1932+ap_mm_core_align2word
1933+ap_mm_lib_error_set
1934+ap_mm_lib_error_get
1935+ap_mm_lib_version
1936
1937+---------------------------------------------------------------------------
1938| Add the EAPI functions, so the stuff can be built under
1939| Windows 95 and similar braindead platforms as DDL.
1940+---------------------------------------------------------------------------
1941Index: src/ApacheCore.def
1942--- src/ApacheCore.def 19 Jun 2002 07:20:21 -0000 1.1.1.10
1943+++ src/ApacheCore.def 19 Jun 2002 07:29:08 -0000 1.14
1944@@ -447,3 +447,67 @@
1945 ap_getline @439
1946 ap_get_chunk_size @440
1947 ap_escape_logitem @441
1948+
1949+ ; EAPI extended symbols
1950+ ; note; no ID's, so these all bind by name rather than ordinal since
1951+ ; their ordinals would change with symbol changes in the distribution
1952+ ap_add_config_define
1953+ ap_global_ctx DATA
1954+ ap_ctx_new
1955+ ap_ctx_get
1956+ ap_ctx_overlay
1957+ ap_ctx_set
1958+ ap_hook_init
1959+ ap_hook_kill
1960+ ap_hook_configure
1961+ ap_hook_register_I
1962+ ap_hook_unregister_I
1963+ ap_hook_status
1964+ ap_hook_use
1965+ ap_hook_call
1966+ ap_set_callback_and_alarm
1967+ ap_acquire_pool
1968+ ap_make_shared_sub_pool
1969+ ap_release_pool
1970+ ap_mm_useable
1971+ ap_MM_create
1972+ ap_MM_permission
1973+ ap_MM_destroy
1974+ ap_MM_lock
1975+ ap_MM_unlock
1976+ ap_MM_malloc
1977+ ap_MM_realloc
1978+ ap_MM_free
1979+ ap_MM_calloc
1980+ ap_MM_strdup
1981+ ap_MM_sizeof
1982+ ap_MM_maxsize
1983+ ap_MM_available
1984+ ap_MM_error
1985+ ap_mm_create
1986+ ap_mm_permission
1987+ ap_mm_destroy
1988+ ap_mm_lock
1989+ ap_mm_unlock
1990+ ap_mm_malloc
1991+ ap_mm_realloc
1992+ ap_mm_free
1993+ ap_mm_calloc
1994+ ap_mm_strdup
1995+ ap_mm_sizeof
1996+ ap_mm_maxsize
1997+ ap_mm_available
1998+ ap_mm_error
1999+ ap_mm_display_info
2000+ ap_mm_core_create
2001+ ap_mm_core_permission
2002+ ap_mm_core_delete
2003+ ap_mm_core_size
2004+ ap_mm_core_lock
2005+ ap_mm_core_unlock
2006+ ap_mm_core_align2page
2007+ ap_mm_core_align2word
2008+ ap_mm_lib_error_set
2009+ ap_mm_lib_error_get
2010+ ap_mm_lib_version
2011+
This page took 1.124147 seconds and 4 git commands to generate.