rsyslog/rsyslog
1
0
Fork 0
mirror of https://github.com/rsyslog/rsyslog.git synced 2026-06-20 07:32:57 +02:00
Code Issues Packages Projects Releases Wiki Activity

mylabmm

Browse Source
This commit is contained in:
Michael Meckelein 2004-11-08 17:12:34 +00:00
parent 0a4c1d7e6d
commit 6dde2fa916
1 changed files with 98 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

103
syslogd.c
View File

@ -573,6 +573,10 @@ static char sccsid[] = "@(#)syslogd.c 5.27 (Berkeley) 10/10/88";
#endif #endif
#include "version.h" #include "version.h"
#ifdef WITH_DB
#include "mysql/mysql.h"
#endif
#if defined(__linux__) #if defined(__linux__)
#include <paths.h> #include <paths.h>
#endif #endif
@ -689,6 +693,10 @@ struct filed {
#endif #endif
short f_type; /* entry type, see below */ short f_type; /* entry type, see below */
short f_file; /* file descriptor */ short f_file; /* file descriptor */
#ifdef WITH_DB
MYSQL f_hmysql; /* handle to MySQL */
char f_dbsrv; /* IP or hostname
#endif
time_t f_time; /* time this was last written */ time_t f_time; /* time this was last written */
u_char f_pmask[LOG_NFACILITIES+1]; /* priority mask */ u_char f_pmask[LOG_NFACILITIES+1]; /* priority mask */
union { union {
@ -738,13 +746,14 @@ int repeatinterval[] = { 30, 60 }; /* # of secs before flush */
#define F_FORW_SUSP 7 /* suspended host forwarding */ #define F_FORW_SUSP 7 /* suspended host forwarding */
#define F_FORW_UNKN 8 /* unknown host forwarding */ #define F_FORW_UNKN 8 /* unknown host forwarding */
#define F_PIPE 9 /* named pipe */ #define F_PIPE 9 /* named pipe */
#define F_MYSQL 10 /* MySQL database */
char *TypeNames[] = { char *TypeNames[] = {
"UNUSED", "FILE", "TTY", "CONSOLE", "UNUSED", "FILE", "TTY", "CONSOLE",
"FORW", "USERS", "WALL", "FORW(SUSPENDED)", "FORW", "USERS", "WALL", "FORW(SUSPENDED)",
"FORW(UNKNOWN)", "PIPE" "FORW(UNKNOWN)", "PIPE", "MYSQL"
}; };
struct filed *Files = (struct filed *) 0; struct filed *Files = NULL;
struct filed consfile; struct filed consfile;
struct code { struct code {
@ -845,11 +854,13 @@ int decode(char *name, struct code *codetab);
static void dprintf(char *, ...); static void dprintf(char *, ...);
static void allocate_log(void); static void allocate_log(void);
void sighup_handler(); void sighup_handler();
#ifdef WITH_DB
void initMySQL(register struct filed *f);
void writeMySQL(register struct filed *f);
void closeMySQL(register struct filed *f);
#endif
#ifdef SYSLOG_UNIXAF #ifdef SYSLOG_UNIXAF
static int create_unix_socket(const char *path);
#endif
#ifdef SYSLOG_INET
static int create_inet_socket(); static int create_inet_socket();
#endif #endif
@ -1657,6 +1668,9 @@ void logmsg(pri, msg, from, flags)
fprintlog(f, (char *)from, flags, msg); fprintlog(f, (char *)from, flags, msg);
(void) close(f->f_file); (void) close(f->f_file);
f->f_file = -1; f->f_file = -1;
/* TODO: Find out what happend here
and add code to close MySQL connection */
} }
#ifndef SYSV #ifndef SYSV
(void) sigsetmask(omask); (void) sigsetmask(omask);
@ -1747,6 +1761,7 @@ void fprintlog(f, from, flags, msg)
struct hostent *hp; struct hostent *hp;
#endif #endif
dprintf("msg: '%s', prevline: '%s'\n", msg, f->f_prevline);
dprintf("Called fprintlog, "); dprintf("Called fprintlog, ");
v->iov_base = f->f_lasttime; v->iov_base = f->f_lasttime;
@ -1941,6 +1956,15 @@ void fprintlog(f, from, flags, msg)
v->iov_len = 2; v->iov_len = 2;
wallmsg(f, iov); wallmsg(f, iov);
break; break;
#ifdef WITH_DB
case F_MYSQL:
f->f_time = now;
dprintf("\n");
dprintf("Line: '%s'\n", msg);
writeMySQL(f);
break;
#endif
} /* switch */ } /* switch */
if (f->f_type != F_FORW_UNKN) if (f->f_type != F_FORW_UNKN)
f->f_prevcount = 0; f->f_prevcount = 0;
@ -2314,6 +2338,11 @@ void init()
case F_CONSOLE: case F_CONSOLE:
(void) close(f->f_file); (void) close(f->f_file);
break; break;
#ifdef WITH_DB
case F_MYSQL:
closeMySQL(f);
break;
#endif
} }
} }
@ -2741,6 +2770,17 @@ void cfline(line, f)
f->f_type = F_WALL; f->f_type = F_WALL;
break; break;
#ifdef WITH_DB
case '>': /* rger 2004-10-28: added support for MySQL
* >server,dbname,userid,password
*/
dprintf ("set f_type to MySQL \n");
f->f_type = F_MYSQL;
initMySQL(f);
/* TODO: Add actual code! */
break;
#endif /* #ifdef WITH_DB */
default: default:
dprintf ("users: %s\n", p); /* ASP */ dprintf ("users: %s\n", p); /* ASP */
for (i = 0; i < MAXUNAMES && *p; i++) { for (i = 0; i < MAXUNAMES && *p; i++) {
@ -2870,6 +2910,58 @@ void sighup_handler()
return; return;
} }
#ifdef WITH_DB
/*
* The following function is responsible for initiatlizing a
* MySQL connection.
* Initially added 2004-10-28
*/
void initMySQL(register struct filed *f)
{
printf("in initMysql()\n");
mysql_init(&f->f_hmysql);
/* Connect to database */
if (!mysql_real_connect(&f->f_hmysql, "localhost", "root", "", "testsyslog", 0, NULL, 0)) {
printf("cant connect to database \n");
exit(0);
}
}
/*
* The following function is responsible for closing a
* MySQL connection.
* Initially added 2004-10-28
*/
void closeMySQL(register struct filed *f)
{
printf("in closeMySQL\n");
mysql_close(&f->f_hmysql);
}
/*
* The following function writes the current log entry
* to an established MySQL session.
* Initially added 2004-10-28
*/
void writeMySQL(register struct filed *f)
{
char sql_command[MAXSVLINE+1048];
dprintf("in writeMySQL()\n");
snprintf(sql_command, sizeof(sql_command), "INSERT INTO myTable VALUES (1,'%s')", f->f_prevline);
/* query */
if(mysql_query(&f->f_hmysql, sql_command)) {
printf("mysql insert failed\n");
exit(0);
}
else {
printf("insert sucessfully\n");
}
}
#endif /* #ifdef WITH_DB */
/* /*
* Local variables: * Local variables:
* c-indent-level: 8 * c-indent-level: 8
@ -2878,3 +2970,4 @@ void sighup_handler()
* End: * End:
*/ */