* Reorganize structure of source files

* Adopt build system for new structure

--HG--
rename : cfg_file.h => src/cfg_file.h
rename : cfg_file.l => src/cfg_file.l
rename : cfg_file.y => src/cfg_file.y
rename : cfg_utils.c => src/cfg_utils.c
rename : controller.c => src/controller.c
rename : filter.c => src/filter.c
rename : filter.h => src/filter.h
rename : fstring.c => src/fstring.c
rename : fstring.h => src/fstring.h
rename : main.c => src/main.c
rename : main.h => src/main.h
rename : mem_pool.c => src/mem_pool.c
rename : mem_pool.h => src/mem_pool.h
rename : memcached-test.c => src/memcached-test.c
rename : memcached.c => src/memcached.c
rename : memcached.h => src/memcached.h
rename : perl.c => src/perl.c
rename : perl.h => src/perl.h
rename : plugins/regexp.c => src/plugins/regexp.c
rename : plugins/surbl.c => src/plugins/surbl.c
rename : protocol.c => src/protocol.c
rename : protocol.h => src/protocol.h
rename : upstream.c => src/upstream.c
rename : upstream.h => src/upstream.h
rename : url.c => src/url.c
rename : url.h => src/url.h
rename : util.c => src/util.c
rename : util.h => src/util.h
rename : worker.c => src/worker.c

1 files changed, 190 insertions, 0 deletions

diff --git a/src/perl.c b/src/perl.c
new file mode 100644
index 000000000..870283835
--- /dev/null
+++ b/src/perl.c
@@ -0,0 +1,190 @@
+#include <sys/types.h>
+#include <unistd.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <syslog.h>
+
+#include <glib.h>
+
+#include <EXTERN.h>               /* from the Perl distribution     */
+#include <perl.h>                 /* from the Perl distribution     */
+
+#include "url.h"
+#include "main.h"
+#include "perl.h"
+
+extern PerlInterpreter *my_perl;
+
+int
+perl_call_header_filter (const char *function, struct worker_task *task)
+{
+	int result;
+	dSP;
+
+	ENTER;
+	SAVETMPS;
+
+	PUSHMARK (SP);
+	XPUSHs (sv_2mortal (newSViv (PTR2IV (task))));
+	PUTBACK;
+	
+	call_pv (function, G_SCALAR);
+
+	SPAGAIN;
+
+	result = POPi;
+	msg_debug ("header_filter: call of %s with returned mark %d\n", function, result);
+
+	PUTBACK;
+	FREETMPS;
+	LEAVE;
+
+	return result;
+}
+
+int
+perl_call_mime_filter (const char *function, struct worker_task *task)
+{
+	int result;
+	dSP;
+
+	ENTER;
+	SAVETMPS;
+
+	PUSHMARK (SP);
+	XPUSHs (sv_2mortal (newSViv (PTR2IV (task))));
+	PUTBACK;
+	
+	call_pv (function, G_SCALAR);
+
+	SPAGAIN;
+
+	result = POPi;
+	msg_debug ("mime_filter: call of %s returned mark %d\n", function, result);
+
+	PUTBACK;
+	FREETMPS;
+	LEAVE;
+
+	return result;
+}
+
+int
+perl_call_message_filter (const char *function, struct worker_task *task)
+{
+	int result;
+	dSP;
+
+	ENTER;
+	SAVETMPS;
+
+	PUSHMARK (SP);
+	XPUSHs (sv_2mortal (newSViv (PTR2IV (task))));
+	PUTBACK;
+	
+	call_pv (function, G_SCALAR);
+
+	SPAGAIN;
+
+	result = POPi;
+	msg_debug ("message_filter: call of %s returned mark %d\n", function, result);
+
+	PUTBACK;
+	FREETMPS;
+	LEAVE;
+
+	return result;
+}
+
+int
+perl_call_url_filter (const char *function, struct worker_task *task)
+{
+	int result;
+	dSP;
+
+	ENTER;
+	SAVETMPS;
+	
+	PUSHMARK (SP);
+	XPUSHs (sv_2mortal (newSViv (PTR2IV (task))));
+	PUTBACK;
+	
+	call_pv (function, G_SCALAR);
+
+	SPAGAIN;
+
+	result = POPi;
+	msg_debug ("url_filter: call of %s for url returned mark %d\n", function, result);
+
+	PUTBACK;
+	FREETMPS;
+	LEAVE;
+
+	return result;
+}
+
+int
+perl_call_chain_filter (const char *function, struct worker_task *task, int *marks, unsigned int number)
+{
+	int result, i;
+	AV *av;
+
+	dSP;
+	
+	ENTER;
+	SAVETMPS;
+	av = newAV();
+	av_extend (av, number);
+	for (i = 0; i < number; i ++) {
+		av_push (av, sv_2mortal (newSViv (marks[i])));
+	}
+	PUSHMARK (SP);
+	XPUSHs (sv_2mortal (newSViv (PTR2IV (task))));
+	XPUSHs (sv_2mortal ((SV *)AvARRAY (av)));
+	PUTBACK;
+	
+	call_pv (function, G_SCALAR);
+
+	SPAGAIN;
+
+	result = POPi;
+	msg_debug ("chain_filter: call of %s returned mark %d\n", function, result);
+
+	PUTBACK;
+	FREETMPS;
+	av_undef (av);
+	LEAVE;
+
+
+	return result;
+}
+
+void perl_call_memcached_callback (memcached_ctx_t *ctx, memc_error_t error, void *data)
+{
+	struct {
+        SV *callback;
+        struct worker_task *task;
+    } *callback_data = data;
+	
+	dSP;
+
+	ENTER;
+	SAVETMPS;
+	PUSHMARK (SP);
+	XPUSHs (sv_2mortal (newSViv (PTR2IV (callback_data->task))));
+	XPUSHs (sv_2mortal (newSViv (error)));
+	XPUSHs (sv_2mortal (newSVpv (ctx->param->buf, ctx->param->bufsize)));
+	PUTBACK;
+
+	call_sv (callback_data->callback, G_SCALAR);
+	
+    /* Set save point */
+    callback_data->task->save.saved = 0;
+	process_filters (callback_data->task);
+
+	SPAGAIN;
+	FREETMPS;
+	LEAVE;
+
+}