blob: a0bc69919d6edd26d643ac01c82e37089732ce17 (
plain) (
blame)
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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
//
// SplitterChannel.cpp
//
// Library: Foundation
// Package: Logging
// Module: SplitterChannel
//
// Copyright (c) 2004-2006, Applied Informatics Software Engineering GmbH.
// and Contributors.
//
// SPDX-License-Identifier: BSL-1.0
//
#include "Poco/SplitterChannel.h"
#include "Poco/LoggingRegistry.h"
#include "Poco/StringTokenizer.h"
namespace Poco {
SplitterChannel::SplitterChannel()
{
}
SplitterChannel::~SplitterChannel()
{
try
{
close();
}
catch (...)
{
poco_unexpected();
}
}
void SplitterChannel::addChannel(Channel* pChannel)
{
poco_check_ptr (pChannel);
FastMutex::ScopedLock lock(_mutex);
pChannel->duplicate();
_channels.push_back(pChannel);
}
void SplitterChannel::removeChannel(Channel* pChannel)
{
FastMutex::ScopedLock lock(_mutex);
for (ChannelVec::iterator it = _channels.begin(); it != _channels.end(); ++it)
{
if (*it == pChannel)
{
pChannel->release();
_channels.erase(it);
break;
}
}
}
void SplitterChannel::setProperty(const std::string& name, const std::string& value)
{
if (name.compare(0, 7, "channel") == 0)
{
StringTokenizer tokenizer(value, ",;", StringTokenizer::TOK_IGNORE_EMPTY | StringTokenizer::TOK_TRIM);
for (StringTokenizer::Iterator it = tokenizer.begin(); it != tokenizer.end(); ++it)
{
addChannel(LoggingRegistry::defaultRegistry().channelForName(*it));
}
}
else Channel::setProperty(name, value);
}
void SplitterChannel::log(const Message& msg)
{
FastMutex::ScopedLock lock(_mutex);
for (ChannelVec::iterator it = _channels.begin(); it != _channels.end(); ++it)
{
(*it)->log(msg);
}
}
void SplitterChannel::close()
{
FastMutex::ScopedLock lock(_mutex);
for (ChannelVec::iterator it = _channels.begin(); it != _channels.end(); ++it)
{
(*it)->release();
}
_channels.clear();
}
int SplitterChannel::count() const
{
FastMutex::ScopedLock lock(_mutex);
return (int) _channels.size();
}
} // namespace Poco
|
