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

Method addObserver

base/poco/Net/src/SocketNotifier.cpp:35–46  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

33
34
35void SocketNotifier::addObserver(SocketReactor* pReactor, const Poco::AbstractObserver& observer)
36{
37 _nc.addObserver(observer);
38 if (observer.accepts(pReactor->_pReadableNotification))
39 _events.insert(pReactor->_pReadableNotification.get());
40 else if (observer.accepts(pReactor->_pWritableNotification))
41 _events.insert(pReactor->_pWritableNotification.get());
42 else if (observer.accepts(pReactor->_pErrorNotification))
43 _events.insert(pReactor->_pErrorNotification.get());
44 else if (observer.accepts(pReactor->_pTimeoutNotification))
45 _events.insert(pReactor->_pTimeoutNotification.get());
46}
47
48
49void SocketNotifier::removeObserver(SocketReactor* pReactor, const Poco::AbstractObserver& observer)

Callers 1

addEventHandlerMethod · 0.45

Calls 3

acceptsMethod · 0.45
insertMethod · 0.45
getMethod · 0.45

Tested by

no test coverage detected