hcq/MaxScale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixed for typo in modutil.h

Browse Source 
Addition of timestamps to the query log produced by the QLA filter
This commit is contained in:
Mark Riddoch
2014-06-04 23:30:54 +01:00
parent 46ca0676c0
commit ea177b481f
2 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/include/modutil.h
View File

@ -33,5 +33,5 @@
extern int modutil_is_SQL(GWBUF *); extern int modutil_is_SQL(GWBUF *);
extern int modutil_extract_SQL(GWBUF *, char **, int *); extern int modutil_extract_SQL(GWBUF *, char **, int *);
extern GWBUF *modutil_repalce_SQL(GWBUF *, char *); extern GWBUF *modutil_replace_SQL(GWBUF *, char *);
#endif #endif

14
server/modules/filter/qlafilter.c
View File

@ -34,6 +34,8 @@
#include <modinfo.h> #include <modinfo.h>
#include <modutil.h> #include <modutil.h>
#include <string.h> #include <string.h>
#include <time.h>
#include <sys/time.h>
MODULE_INFO info = { MODULE_INFO info = {
MODULE_API_FILTER, MODULE_API_FILTER,
@ -247,11 +249,19 @@ static int
routeQuery(FILTER *instance, void *session, GWBUF *queue) routeQuery(FILTER *instance, void *session, GWBUF *queue)
{ {
QLA_SESSION *my_session = (QLA_SESSION *)session; QLA_SESSION *my_session = (QLA_SESSION *)session;
char *ptr; char *ptr, t_buf[40];
int length; int length;
struct tm t;
struct timeval tv;
if (modutil_extract_SQL(queue, &ptr, &length)) if (modutil_extract_SQL(queue, &ptr, &length))
{ {
gettimeofday(&tv, NULL);
localtime_r(&tv.tv_sec, &t);
sprintf(t_buf, "%02d:%02d:%02d.%-3d %d/%02d/%d, ",
t.tm_hour, t.tm_min, t.tm_sec, tv.tv_usec / 1000,
t.tm_mday, t.tm_mon + 1, 1900 + t.tm_year);
write(my_session->fd, t_buf, strlen(t_buf));
write(my_session->fd, ptr, length); write(my_session->fd, ptr, length);
write(my_session->fd, "\n", 1); write(my_session->fd, "\n", 1);
} }