18 /* init the plugin data */
19 INIT_FUNC(mod_cml_init
) {
22 p
= calloc(1, sizeof(*p
));
24 p
->basedir
= buffer_init();
25 p
->baseurl
= buffer_init();
26 p
->trigger_handler
= buffer_init();
31 /* detroy the plugin data */
32 FREE_FUNC(mod_cml_free
) {
37 if (!p
) return HANDLER_GO_ON
;
39 if (p
->config_storage
) {
41 for (i
= 0; i
< srv
->config_context
->used
; i
++) {
42 plugin_config
*s
= p
->config_storage
[i
];
44 if (NULL
== s
) continue;
48 buffer_free(s
->mc_namespace
);
49 buffer_free(s
->power_magnet
);
50 array_free(s
->mc_hosts
);
52 #if defined(USE_MEMCACHED)
53 if (s
->memc
) memcached_free(s
->memc
);
58 free(p
->config_storage
);
61 buffer_free(p
->trigger_handler
);
62 buffer_free(p
->basedir
);
63 buffer_free(p
->baseurl
);
70 /* handle plugin config and check values */
72 SETDEFAULTS_FUNC(mod_cml_set_defaults
) {
76 config_values_t cv
[] = {
77 { "cml.extension", NULL
, T_CONFIG_STRING
, T_CONFIG_SCOPE_CONNECTION
}, /* 0 */
78 { "cml.memcache-hosts", NULL
, T_CONFIG_ARRAY
, T_CONFIG_SCOPE_CONNECTION
}, /* 1 */
79 { "cml.memcache-namespace", NULL
, T_CONFIG_STRING
, T_CONFIG_SCOPE_CONNECTION
}, /* 2 */
80 { "cml.power-magnet", NULL
, T_CONFIG_STRING
, T_CONFIG_SCOPE_CONNECTION
}, /* 3 */
81 { NULL
, NULL
, T_CONFIG_UNSET
, T_CONFIG_SCOPE_UNSET
}
84 if (!p
) return HANDLER_ERROR
;
86 p
->config_storage
= calloc(1, srv
->config_context
->used
* sizeof(plugin_config
*));
88 for (i
= 0; i
< srv
->config_context
->used
; i
++) {
89 data_config
const* config
= (data_config
const*)srv
->config_context
->data
[i
];
92 s
= calloc(1, sizeof(plugin_config
));
93 s
->ext
= buffer_init();
94 s
->mc_hosts
= array_init();
95 s
->mc_namespace
= buffer_init();
96 s
->power_magnet
= buffer_init();
97 #if defined(USE_MEMCACHED)
101 cv
[0].destination
= s
->ext
;
102 cv
[1].destination
= s
->mc_hosts
;
103 cv
[2].destination
= s
->mc_namespace
;
104 cv
[3].destination
= s
->power_magnet
;
106 p
->config_storage
[i
] = s
;
108 if (0 != config_insert_values_global(srv
, config
->value
, cv
, i
== 0 ? T_CONFIG_SCOPE_SERVER
: T_CONFIG_SCOPE_CONNECTION
)) {
109 return HANDLER_ERROR
;
112 if (!array_is_vlist(s
->mc_hosts
)) {
113 log_error_write(srv
, __FILE__
, __LINE__
, "s",
114 "unexpected value for cml.memcache-hosts; expected list of \"host\"");
115 return HANDLER_ERROR
;
118 if (s
->mc_hosts
->used
) {
119 #if defined(USE_MEMCACHED)
120 buffer
*option_string
= buffer_init();
124 data_string
*ds
= (data_string
*)s
->mc_hosts
->data
[0];
126 buffer_append_string_len(option_string
, CONST_STR_LEN("--SERVER="));
127 buffer_append_string_buffer(option_string
, ds
->value
);
130 for (k
= 1; k
< s
->mc_hosts
->used
; k
++) {
131 data_string
*ds
= (data_string
*)s
->mc_hosts
->data
[k
];
133 buffer_append_string_len(option_string
, CONST_STR_LEN(" --SERVER="));
134 buffer_append_string_buffer(option_string
, ds
->value
);
137 s
->memc
= memcached(CONST_BUF_LEN(option_string
));
139 if (NULL
== s
->memc
) {
140 log_error_write(srv
, __FILE__
, __LINE__
, "sb",
141 "configuring memcached failed for option string:",
144 buffer_free(option_string
);
146 if (NULL
== s
->memc
) return HANDLER_ERROR
;
148 log_error_write(srv
, __FILE__
, __LINE__
, "s",
149 "memcache support is not compiled in but cml.memcache-hosts is set, aborting");
150 return HANDLER_ERROR
;
155 return HANDLER_GO_ON
;
160 static int mod_cml_patch_connection(server
*srv
, connection
*con
, plugin_data
*p
) {
162 plugin_config
*s
= p
->config_storage
[0];
165 #if defined(USE_MEMCACHED)
171 /* skip the first, the global context */
172 for (i
= 1; i
< srv
->config_context
->used
; i
++) {
173 data_config
*dc
= (data_config
*)srv
->config_context
->data
[i
];
174 s
= p
->config_storage
[i
];
176 /* condition didn't match */
177 if (!config_check_cond(srv
, con
, dc
)) continue;
180 for (j
= 0; j
< dc
->value
->used
; j
++) {
181 data_unset
*du
= dc
->value
->data
[j
];
183 if (buffer_is_equal_string(du
->key
, CONST_STR_LEN("cml.extension"))) {
185 } else if (buffer_is_equal_string(du
->key
, CONST_STR_LEN("cml.memcache-hosts"))) {
186 #if defined(USE_MEMCACHED)
189 } else if (buffer_is_equal_string(du
->key
, CONST_STR_LEN("cml.memcache-namespace"))) {
191 } else if (buffer_is_equal_string(du
->key
, CONST_STR_LEN("cml.power-magnet"))) {
201 static int cache_call_lua(server
*srv
, connection
*con
, plugin_data
*p
, buffer
*cml_file
) {
205 /* cleanup basedir */
207 buffer_copy_buffer(b
, con
->uri
.path
);
208 for (c
= b
->ptr
+ buffer_string_length(b
); c
> b
->ptr
&& *c
!= '/'; c
--);
211 buffer_string_set_length(b
, c
- b
->ptr
+ 1);
215 buffer_copy_buffer(b
, con
->physical
.path
);
216 for (c
= b
->ptr
+ buffer_string_length(b
); c
> b
->ptr
&& *c
!= '/'; c
--);
219 buffer_string_set_length(b
, c
- b
->ptr
+ 1);
227 return cache_parse_lua(srv
, con
, p
, cml_file
);
230 URIHANDLER_FUNC(mod_cml_power_magnet
) {
231 plugin_data
*p
= p_d
;
233 mod_cml_patch_connection(srv
, con
, p
);
235 buffer_reset(p
->basedir
);
236 buffer_reset(p
->baseurl
);
237 buffer_reset(p
->trigger_handler
);
239 if (buffer_string_is_empty(p
->conf
.power_magnet
)) return HANDLER_GO_ON
;
243 * cml.power-magnet = server.docroot + "/rewrite.cml"
245 * is called on EACH request, take the original REQUEST_URI and modifies the
246 * request header as neccesary.
249 * if file_exists("/maintainance.html") {
250 * output_include = ( "/maintainance.html" )
254 * as we only want to rewrite HTML like requests we should cover it in a conditional
258 switch(cache_call_lua(srv
, con
, p
, p
->conf
.power_magnet
)) {
261 if (con
->conf
.log_request_handling
) {
262 log_error_write(srv
, __FILE__
, __LINE__
, "s", "cache-error");
264 con
->http_status
= 500;
265 return HANDLER_COMEBACK
;
267 if (con
->conf
.log_request_handling
) {
268 log_error_write(srv
, __FILE__
, __LINE__
, "s", "cache-hit");
271 buffer_reset(con
->physical
.path
);
272 return HANDLER_FINISHED
;
275 return HANDLER_GO_ON
;
277 con
->http_status
= 500;
278 return HANDLER_COMEBACK
;
282 URIHANDLER_FUNC(mod_cml_is_handled
) {
283 plugin_data
*p
= p_d
;
285 if (buffer_string_is_empty(con
->physical
.path
)) return HANDLER_ERROR
;
287 mod_cml_patch_connection(srv
, con
, p
);
289 buffer_reset(p
->basedir
);
290 buffer_reset(p
->baseurl
);
291 buffer_reset(p
->trigger_handler
);
293 if (buffer_string_is_empty(p
->conf
.ext
)) return HANDLER_GO_ON
;
295 if (!buffer_is_equal_right_len(con
->physical
.path
, p
->conf
.ext
, buffer_string_length(p
->conf
.ext
))) {
296 return HANDLER_GO_ON
;
299 switch(cache_call_lua(srv
, con
, p
, con
->physical
.path
)) {
302 if (con
->conf
.log_request_handling
) {
303 log_error_write(srv
, __FILE__
, __LINE__
, "s", "cache-error");
305 con
->http_status
= 500;
306 return HANDLER_COMEBACK
;
308 if (con
->conf
.log_request_handling
) {
309 log_error_write(srv
, __FILE__
, __LINE__
, "s", "cache-hit");
312 buffer_reset(con
->physical
.path
);
313 return HANDLER_FINISHED
;
315 if (con
->conf
.log_request_handling
) {
316 log_error_write(srv
, __FILE__
, __LINE__
, "s", "cache-miss");
319 return HANDLER_COMEBACK
;
321 con
->http_status
= 500;
322 return HANDLER_COMEBACK
;
326 int mod_cml_plugin_init(plugin
*p
);
327 int mod_cml_plugin_init(plugin
*p
) {
328 p
->version
= LIGHTTPD_VERSION_ID
;
329 p
->name
= buffer_init_string("cache");
331 p
->init
= mod_cml_init
;
332 p
->cleanup
= mod_cml_free
;
333 p
->set_defaults
= mod_cml_set_defaults
;
335 p
->handle_subrequest_start
= mod_cml_is_handled
;
336 p
->handle_physical
= mod_cml_power_magnet
;