diff options
-rw-r--r-- | include/filelogger.h | 12 | ||||
-rw-r--r-- | include/inspircd.h | 4 | ||||
-rw-r--r-- | include/logger.h | 5 | ||||
-rw-r--r-- | src/filelogger.cpp | 35 | ||||
-rw-r--r-- | src/helperfuncs.cpp | 45 | ||||
-rw-r--r-- | src/inspircd.cpp | 7 | ||||
-rw-r--r-- | src/logger.cpp | 24 |
7 files changed, 80 insertions, 52 deletions
diff --git a/include/filelogger.h b/include/filelogger.h index 77ca6f886..8395f1c96 100644 --- a/include/filelogger.h +++ b/include/filelogger.h @@ -88,5 +88,17 @@ class CoreExport FileLogger : public EventHandler virtual ~FileLogger(); }; +class CoreExport FileLogStream : public LogStream +{ + private: + FileLogger *f; + public: + FileLogStream(InspIRCd *Instance, FILE *f, const std::string &type) : LogStream(Instance, type) + { + this->f = new FileLogger(Instance, f); + } + + virtual void OnLog(int loglevel, const std::string &msg); +}; #endif diff --git a/include/inspircd.h b/include/inspircd.h index e8d5c9b8e..5f57619d5 100644 --- a/include/inspircd.h +++ b/include/inspircd.h @@ -304,10 +304,6 @@ class CoreExport InspIRCd : public classbase */ socklen_t length; - /** Nonblocking file writer - */ - FileLogger* Logger; - /** Time offset in seconds * This offset is added to all calls to Time(). Use SetTimeDelta() to update */ diff --git a/include/logger.h b/include/logger.h index 1e043f4f1..d32c3d184 100644 --- a/include/logger.h +++ b/include/logger.h @@ -16,7 +16,7 @@ class CoreExport LogStream : public classbase { - private: + protected: InspIRCd *ServerInstance; std::string type; public: @@ -26,7 +26,7 @@ class CoreExport LogStream : public classbase this->type = type; } - virtual void OnLog(int loglevel, const std::string &msg); + virtual void OnLog(int loglevel, const std::string &msg) { } }; class CoreExport LogManager : public classbase @@ -34,6 +34,7 @@ class CoreExport LogManager : public classbase private: InspIRCd *ServerInstance; std::map<std::string, std::vector<LogStream *> > LogStreams; + std::vector<LogStream *> GlobalLogStreams; //holds all logstreams with a type of * public: LogManager(InspIRCd *Instance) { diff --git a/src/filelogger.cpp b/src/filelogger.cpp index e22b4fdf4..0e50f628e 100644 --- a/src/filelogger.cpp +++ b/src/filelogger.cpp @@ -101,3 +101,38 @@ FileLogger::~FileLogger() this->Close(); } + +void FileLogStream::OnLog(int loglevel, const std::string &text) +{ + static char TIMESTR[26]; + static time_t LAST = 0; + + /* sanity check, just in case */ + if (!ServerInstance->Config) + return; + + /* If we were given -debug we output all messages, regardless of configured loglevel */ + if ((loglevel < ServerInstance->Config->LogLevel) && !ServerInstance->Config->forcedebug) + return; + + if (ServerInstance->Time() != LAST) + { + time_t local = ServerInstance->Time(); + struct tm *timeinfo = localtime(&local); + + strlcpy(TIMESTR,asctime(timeinfo),26); + TIMESTR[24] = ':'; + LAST = ServerInstance->Time(); + } + + if (ServerInstance->Config->log_file && ServerInstance->Config->writelog) + { + std::string out = std::string(TIMESTR) + " " + text.c_str() + "\n"; + this->f->WriteLogLine(out); + } + + if (ServerInstance->Config->nofork) + { + printf("%s %s\n", TIMESTR, text.c_str()); + } +} diff --git a/src/helperfuncs.cpp b/src/helperfuncs.cpp index 3f60cac80..d274dd244 100644 --- a/src/helperfuncs.cpp +++ b/src/helperfuncs.cpp @@ -18,23 +18,12 @@ #include "xline.h" #include "exitcodes.h" -static char TIMESTR[26]; -static time_t LAST = 0; - /** Log() * Write a line of text `text' to the logfile (and stdout, if in nofork) if the level `level' * is greater than the configured loglevel. */ void InspIRCd::Log(int level, const char* text, ...) { - /* sanity check, just in case */ - if (!this->Config || !this->Logger) - return; - - /* Do this check again here so that we save pointless vsnprintf calls */ - if ((level < Config->LogLevel) && !Config->forcedebug) - return; - va_list argsPtr; char textbuffer[65536]; @@ -47,34 +36,8 @@ void InspIRCd::Log(int level, const char* text, ...) void InspIRCd::Log(int level, const std::string &text) { - /* sanity check, just in case */ - if (!this->Config || !this->Logger) - return; - - /* If we were given -debug we output all messages, regardless of configured loglevel */ - if ((level < Config->LogLevel) && !Config->forcedebug) - return; - - if (Time() != LAST) - { - time_t local = Time(); - struct tm *timeinfo = localtime(&local); - - strlcpy(TIMESTR,asctime(timeinfo),26); - TIMESTR[24] = ':'; - LAST = Time(); - } - - if (Config->log_file && Config->writelog) - { - std::string out = std::string(TIMESTR) + " " + text.c_str() + "\n"; - this->Logger->WriteLogLine(out); - } - - if (Config->nofork) - { - printf("%s %s\n", TIMESTR, text.c_str()); - } + this->Logs->Log("WARNING", DEFAULT, "Deprecated call to InspIRCd::Log()! - log message follows"); + this->Logs->Log("DEPRECATED", level, text); } std::string InspIRCd::GetServerDescription(const char* servername) @@ -358,11 +321,11 @@ bool InspIRCd::OpenLog(char**, int) if (!Config->log_file) { - this->Logger = NULL; return false; } - this->Logger = new FileLogger(this, Config->log_file); + FileLogStream *f = new FileLogStream(this, Config->log_file, "*"); + this->Logs->AddLogType("*", f); return true; } diff --git a/src/inspircd.cpp b/src/inspircd.cpp index 29457ec97..ef656cca9 100644 --- a/src/inspircd.cpp +++ b/src/inspircd.cpp @@ -103,9 +103,7 @@ void InspIRCd::Cleanup() } /* Close logging */ - if (this->Logger) - this->Logger->Close(); - + // XXX we need to add a method to terminate all logstreams. /* Cleanup Server Names */ for(servernamelist::iterator itr = servernames.begin(); itr != servernames.end(); ++itr) @@ -182,8 +180,7 @@ void InspIRCd::RehashUsersAndChans() void InspIRCd::CloseLog() { - if (this->Logger) - this->Logger->Close(); + // XXX add a method to terminate all logstreams. } void InspIRCd::SetSignals() diff --git a/src/logger.cpp b/src/logger.cpp index 458dcf5e0..83a657216 100644 --- a/src/logger.cpp +++ b/src/logger.cpp @@ -55,12 +55,25 @@ bool LogManager::AddLogType(const std::string &type, LogStream *l) LogStreams[type] = v; } + if (type == "*") + GlobalLogStreams.push_back(l); + return true; } bool LogManager::DelLogType(const std::string &type, LogStream *l) { std::map<std::string, std::vector<LogStream *> >::iterator i = LogStreams.find(type); + std::vector<LogStream *>::iterator gi = GlobalLogStreams.begin(); + + while (gi != GlobalLogStreams.end()) + { + if ((*gi) == l) + { + GlobalLogStreams.erase(gi); + break; + } + } if (i != LogStreams.end()) { @@ -80,6 +93,8 @@ bool LogManager::DelLogType(const std::string &type, LogStream *l) delete l; return true; } + + it++; } } @@ -97,11 +112,20 @@ void LogManager::Log(const std::string &type, int loglevel, const std::string &m while (it != i->second.end()) { (*it)->OnLog(loglevel, msg); + it++; } return; } + std::vector<LogStream *>::iterator gi = GlobalLogStreams.begin(); + + while (gi != GlobalLogStreams.end()) + { + (*gi)->OnLog(loglevel, msg); + gi++; + } + // blurp, no handler for this type return; } |