MCPcopy Create free account
hub / github.com/ClickHouse/ClickHouse / addEventHandler

Method addEventHandler

base/poco/Net/src/SocketReactor.cpp:161–177  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

159
160
161void SocketReactor::addEventHandler(const Socket& socket, const Poco::AbstractObserver& observer)
162{
163 NotifierPtr pNotifier;
164 {
165 FastMutex::ScopedLock lock(_mutex);
166
167 EventHandlerMap::iterator it = _handlers.find(socket);
168 if (it == _handlers.end())
169 {
170 pNotifier = new SocketNotifier(socket);
171 _handlers[socket] = pNotifier;
172 }
173 else pNotifier = it->second;
174 }
175 if (!pNotifier->hasObserver(observer))
176 pNotifier->addObserver(this, observer);
177}
178
179
180bool SocketReactor::hasEventHandler(const Socket& socket, const Poco::AbstractObserver& observer)

Callers 5

registerAcceptorMethod · 0.80
SocketAcceptorMethod · 0.80
registerAcceptorMethod · 0.80
registerConnectorMethod · 0.80

Calls 4

findMethod · 0.45
endMethod · 0.45
hasObserverMethod · 0.45
addObserverMethod · 0.45

Tested by

no test coverage detected