tyler.durden/loganalyzer
1
0
Fork 0
mirror of https://github.com/rsyslog/loganalyzer.git synced 2025-09-26 03:09:21 +02:00
Code Issues Packages Projects Releases Wiki Activity

Added MsgParser into database logstream classes as well

Browse Source
This commit is contained in:
Andre Lorbach 2008-09-02 14:54:13 +02:00
parent c5b7ff8e3a
commit f545c7f38a
2 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/classes/logstreamdb.class.php
View File

@ -257,6 +257,10 @@ class LogStreamDB extends LogStream {
$arrProperitesOut[$property] = '';
}
// Run optional Message Parsers now
if ( isset($arrProperitesOut[SYSLOG_MESSAGE]) )
$this->_logStreamConfigObj->ProcessMsgParsers($arrProperitesOut[SYSLOG_MESSAGE], $arrProperitesOut);
// Set uID to the PropertiesOut! //DEBUG -> $this->_currentRecordNum;
$uID = $arrProperitesOut[SYSLOG_UID] = $this->bufferedRecords[$this->_currentRecordNum][$dbmapping[$szTableType][SYSLOG_UID]];
@ -727,7 +731,7 @@ class LogStreamDB extends LogStream {
// Append LIMIT clause
$szSql .= " LIMIT " . $this->_currentRecordStart . ", " . $this->_logStreamConfigObj->RecordsPerQuery;
echo $szSql . "<br>";
//echo $szSql . "<br>";
// Perform Database Query
$myquery = mysql_query($szSql, $this->_dbhandle);

4
src/classes/logstreampdo.class.php
View File

@ -292,6 +292,10 @@ class LogStreamPDO extends LogStream {
$arrProperitesOut[$property] = '';
}
// Run optional Message Parsers now
if ( isset($arrProperitesOut[SYSLOG_MESSAGE]) )
$this->_logStreamConfigObj->ProcessMsgParsers($arrProperitesOut[SYSLOG_MESSAGE], $arrProperitesOut);
// Set uID to the PropertiesOut! //DEBUG -> $this->_currentRecordNum;
$uID = $arrProperitesOut[SYSLOG_UID] = $this->bufferedRecords[$this->_currentRecordNum][$dbmapping[$szTableType][SYSLOG_UID]];