needless enum Status removed.
This commit is contained in:
@@ -66,8 +66,8 @@ int calcLevel(const std::string level)
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
LogMessage::LogMessage(const int area, const int level, const std::string text, const Status status)
|
LogMessage::LogMessage(const int area, const int level, const std::string text, const bool run)
|
||||||
: m_area(area), m_level(level), m_text(text), m_status(status)
|
: m_area(area), m_level(level), m_text(text), m_run(run)
|
||||||
{
|
{
|
||||||
char time[24];
|
char time[24];
|
||||||
struct timeval tv;
|
struct timeval tv;
|
||||||
@@ -96,7 +96,7 @@ void* LogSink::run()
|
|||||||
{
|
{
|
||||||
while (1) {
|
while (1) {
|
||||||
LogMessage* message = m_queue.remove();
|
LogMessage* message = m_queue.remove();
|
||||||
if (message->getStatus() == LogMessage::End) {
|
if (message->isRunning() == false) {
|
||||||
delete message;
|
delete message;
|
||||||
while (m_queue.size() == true) {
|
while (m_queue.size() == true) {
|
||||||
LogMessage* message = m_queue.remove();
|
LogMessage* message = m_queue.remove();
|
||||||
@@ -190,7 +190,7 @@ void LogInstance::log(const int area, const int level, const std::string& data,
|
|||||||
|
|
||||||
if (vasprintf(&tmp, data.c_str(), ap) != -1) {
|
if (vasprintf(&tmp, data.c_str(), ap) != -1) {
|
||||||
std::string buffer(tmp);
|
std::string buffer(tmp);
|
||||||
m_messages.add(new LogMessage(LogMessage(area, level, buffer, LogMessage::Run)));
|
m_messages.add(new LogMessage(LogMessage(area, level, buffer)));
|
||||||
}
|
}
|
||||||
|
|
||||||
va_end(ap);
|
va_end(ap);
|
||||||
@@ -213,9 +213,9 @@ void* LogInstance::run()
|
|||||||
|
|
||||||
if (((*iter)->getAreas() & message->getArea()
|
if (((*iter)->getAreas() & message->getArea()
|
||||||
&& (*iter)->getLevel() >= message->getLevel())
|
&& (*iter)->getLevel() >= message->getLevel())
|
||||||
&& message->getStatus() == LogMessage::Run) {
|
&& message->isRunning() == true) {
|
||||||
(*iter)->addMessage(*message);
|
(*iter)->addMessage(*message);
|
||||||
} else if (message->getStatus() == LogMessage::End) {
|
} else if (message->isRunning() == false) {
|
||||||
(*iter)->addMessage(*message);
|
(*iter)->addMessage(*message);
|
||||||
m_running = false;
|
m_running = false;
|
||||||
}
|
}
|
||||||
@@ -231,6 +231,6 @@ void* LogInstance::run()
|
|||||||
|
|
||||||
void LogInstance::stop()
|
void LogInstance::stop()
|
||||||
{
|
{
|
||||||
m_messages.add(new LogMessage(LogMessage(bas, error, "", LogMessage::End)));
|
m_messages.add(new LogMessage(LogMessage(bas, error, "", false)));
|
||||||
usleep(100000);
|
usleep(100000);
|
||||||
}
|
}
|
||||||
|
|||||||
+5
-15
@@ -39,31 +39,27 @@ class LogMessage
|
|||||||
{
|
{
|
||||||
|
|
||||||
public:
|
public:
|
||||||
enum Status { Run, End };
|
LogMessage(const int area, const int level, const std::string text, const bool run=true);
|
||||||
|
|
||||||
LogMessage(const int area, const int level, const std::string text, const Status status);
|
|
||||||
|
|
||||||
~LogMessage() {}
|
|
||||||
|
|
||||||
LogMessage(const LogMessage& src)
|
LogMessage(const LogMessage& src)
|
||||||
: m_area(src.m_area), m_level(src.m_level), m_text(src.m_text),
|
: m_area(src.m_area), m_level(src.m_level), m_text(src.m_text),
|
||||||
m_status(src.m_status), m_time(src.m_time) {}
|
m_run(src.m_run), m_time(src.m_time) {}
|
||||||
|
|
||||||
void operator= (const LogMessage& src)
|
void operator= (const LogMessage& src)
|
||||||
{ m_area = src.m_area; m_level = src.m_level; m_text = src.m_text;
|
{ m_area = src.m_area; m_level = src.m_level; m_text = src.m_text;
|
||||||
m_status = src.m_status; m_time = src.m_time; }
|
m_run = src.m_run; m_time = src.m_time; }
|
||||||
|
|
||||||
int getArea() const { return (m_area); }
|
int getArea() const { return (m_area); }
|
||||||
int getLevel() const { return(m_level); }
|
int getLevel() const { return(m_level); }
|
||||||
std::string getText() const { return (m_text.c_str()); }
|
std::string getText() const { return (m_text.c_str()); }
|
||||||
Status getStatus() const { return (m_status); }
|
bool isRunning() const { return (m_run); }
|
||||||
std::string getTime() const { return (m_time.c_str()); }
|
std::string getTime() const { return (m_time.c_str()); }
|
||||||
|
|
||||||
private:
|
private:
|
||||||
int m_area;
|
int m_area;
|
||||||
int m_level;
|
int m_level;
|
||||||
std::string m_text;
|
std::string m_text;
|
||||||
Status m_status;
|
bool m_run;
|
||||||
std::string m_time;
|
std::string m_time;
|
||||||
|
|
||||||
};
|
};
|
||||||
@@ -77,8 +73,6 @@ public:
|
|||||||
LogSink(const int areas, const int level, const Type type, const char* name)
|
LogSink(const int areas, const int level, const Type type, const char* name)
|
||||||
: m_areas(areas), m_level(level), m_type(type), m_name(name) {}
|
: m_areas(areas), m_level(level), m_type(type), m_name(name) {}
|
||||||
|
|
||||||
virtual ~LogSink() {}
|
|
||||||
|
|
||||||
void addMessage(const LogMessage& message);
|
void addMessage(const LogMessage& message);
|
||||||
|
|
||||||
void* run();
|
void* run();
|
||||||
@@ -113,8 +107,6 @@ public:
|
|||||||
: LogSink(areas, level, Console, name), m_instance(++m_numInstance)
|
: LogSink(areas, level, Console, name), m_instance(++m_numInstance)
|
||||||
{ this->start(name); }
|
{ this->start(name); }
|
||||||
|
|
||||||
~LogConsole() {}
|
|
||||||
|
|
||||||
private:
|
private:
|
||||||
const int m_instance;
|
const int m_instance;
|
||||||
static int m_numInstance;
|
static int m_numInstance;
|
||||||
@@ -131,8 +123,6 @@ public:
|
|||||||
: LogSink(areas, level, Logfile, name), m_filename(filename), m_instance(++m_numInstance)
|
: LogSink(areas, level, Logfile, name), m_filename(filename), m_instance(++m_numInstance)
|
||||||
{ this->start(name); }
|
{ this->start(name); }
|
||||||
|
|
||||||
~LogFile() {}
|
|
||||||
|
|
||||||
private:
|
private:
|
||||||
std::string m_filename;
|
std::string m_filename;
|
||||||
const int m_instance;
|
const int m_instance;
|
||||||
|
|||||||
Reference in New Issue
Block a user