1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
/* $Id: mod_log_sql_ssl.c 140 2004-05-14 03:50:47Z urkle@drip.ws $ */
#if defined(WITH_APACHE20)
# include "apache20.h"
#else
# error Unsupported Apache version
#endif
#ifdef HAVE_CONFIG_H
/* Undefine these to prevent conflicts between Apache ap_config_auto.h and
* my config.h. Only really needed for Apache < 2.0.48, but it can't hurt.
*/
#undef PACKAGE_BUGREPORT
#undef PACKAGE_NAME
#undef PACKAGE_STRING
#undef PACKAGE_TARNAME
#undef PACKAGE_VERSION
#include "config.h"
#endif
#include "mod_log_sql.h"
module AP_MODULE_DECLARE_DATA log_sql_logio_module;
// From apachge 2.2's mod_logio.c to provide logging ACTUAL incoming and outgoing bytes
static const char logio_filter_name[] = "LOG_SQL_INPUT_OUTPUT";
typedef struct {
apr_off_t bytes_in;
apr_off_t bytes_out;
} logio_config_t;
static void ap_logio_add_bytes_out(conn_rec *c, apr_off_t bytes){
logio_config_t *cf = ap_get_module_config(c->conn_config, &log_sql_logio_module);
cf->bytes_out += bytes;
}
static const char *log_bytes_in(request_rec *r, char *a)
{
logio_config_t *cf = ap_get_module_config(r->connection->conn_config,
&log_sql_logio_module);
return apr_off_t_toa(r->pool, cf->bytes_in);
}
static const char *log_bytes_out(request_rec *r, char *a)
{
logio_config_t *cf = ap_get_module_config(r->connection->conn_config,
&log_sql_logio_module);
return apr_off_t_toa(r->pool, cf->bytes_out);
}
static int logio_transaction(request_rec *r)
{
logio_config_t *cf = ap_get_module_config(r->connection->conn_config,
&log_sql_logio_module);
cf->bytes_in = cf->bytes_out = 0;
return OK;
}
static apr_status_t logio_in_filter(ap_filter_t *f,
apr_bucket_brigade *bb,
ap_input_mode_t mode,
apr_read_type_e block,
apr_off_t readbytes) {
apr_off_t length;
apr_status_t status;
logio_config_t *cf = ap_get_module_config(f->c->conn_config, &log_sql_logio_module);
status = ap_get_brigade(f->next, bb, mode, block, readbytes);
apr_brigade_length (bb, 0, &length);
if (length > 0)
cf->bytes_in += length;
return status;
}
static apr_status_t logio_out_filter(ap_filter_t *f,
apr_bucket_brigade *bb) {
apr_bucket *b = APR_BRIGADE_LAST(bb);
/* End of data, make sure we flush */
if (APR_BUCKET_IS_EOS(b)) {
APR_BUCKET_INSERT_BEFORE(b,
apr_bucket_flush_create(f->c->bucket_alloc));
}
return ap_pass_brigade(f->next, bb);
}
static int logio_pre_conn(conn_rec *c, void *csd) {
logio_config_t *cf = apr_pcalloc(c->pool, sizeof(*cf));
ap_set_module_config(c->conn_config, &log_sql_logio_module, cf);
ap_add_input_filter(logio_filter_name, NULL, NULL, c);
ap_add_output_filter(logio_filter_name, NULL, NULL, c);
return OK;
}
static int post_config(apr_pool_t *p, apr_pool_t *plog, apr_pool_t *ptemp, server_rec *s)
{
log_sql_register_item(s,p,'i', log_bytes_in, "bytes_in", 0, 0);
log_sql_register_item(s,p,'o', log_bytes_out, "bytes_out", 0, 0);
return OK;
}
static void register_hooks(apr_pool_t *p) {
static const char *pre[] = { "mod_log_sql.c", NULL };
ap_hook_pre_connection(logio_pre_conn, NULL, NULL, APR_HOOK_MIDDLE);
ap_hook_log_transaction(logio_transaction, pre, NULL, APR_HOOK_MIDDLE);
ap_hook_post_config(post_config, NULL, NULL, APR_HOOK_REALLY_FIRST);
ap_register_input_filter(logio_filter_name, logio_in_filter, NULL,
AP_FTYPE_NETWORK - 1);
ap_register_output_filter(logio_filter_name, logio_out_filter, NULL,
AP_FTYPE_NETWORK - 1);
APR_REGISTER_OPTIONAL_FN(ap_logio_add_bytes_out);
}
module AP_MODULE_DECLARE_DATA log_sql_logio_module = {
STANDARD20_MODULE_STUFF,
NULL, NULL, NULL, NULL, NULL, register_hooks
};
|
