File: stream.cpp

package info (click to toggle)
libwibble 1.1-1
  • links: PTS
  • area: main
  • in suites: jessie, jessie-kfreebsd, stretch
  • size: 1,040 kB
  • ctags: 2,721
  • sloc: cpp: 14,542; makefile: 196; perl: 87; sh: 26
file content (71 lines) | stat: -rw-r--r-- 1,214 bytes parent folder | download | duplicates (3)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
#include <wibble/log/stream.h>
#include <ostream>

namespace wibble {
namespace log {

Streambuf::Streambuf() : level(defaultLevel), sender(0) {}

Streambuf::Streambuf(Sender* s) : level(defaultLevel), sender(s) {}

Streambuf::~Streambuf()
{
    send_partial_line();
}

void Streambuf::send_partial_line()
{
	if (!line.empty())
		send();
}

void Streambuf::setSender(Sender* s) { sender = s; }

void Streambuf::send()
{
	// Send the message
	sender->send(level, line);
	// Reset the level
	level = defaultLevel;
	line.clear();
}

void Streambuf::setLevel(const Level& level)
{
	this->level = level;
}

int Streambuf::overflow(int c)
{
	if (c == '\n')
		send();
	else
		line += c;
	return c;	// or EOF
}

std::ostream& operator<<(std::ostream& s, Level lev)
{
	if (Streambuf* ls = dynamic_cast<Streambuf*>(s.rdbuf()))
	{
		ls->setLevel(lev);
		return s;
	} else {
		switch (lev)
		{
			case DEBUG:   s << "DEBUG: "; break;
			case INFO:    s << "INFO: "; break;
			case UNUSUAL: s << "UNUSUAL: "; break;
			case WARN:    s << "WARN: "; break;
			case ERR:     s << "ERR: "; break;
			case CRIT:    s << "CRITICAL: "; break;
			default:      s << "UNKNOWN: "; break;
		}
		return s;
	}
}

}
}

// vim:set ts=4 sw=4: