| 159 | |
| 160 | |
| 161 | void 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 | |
| 180 | bool SocketReactor::hasEventHandler(const Socket& socket, const Poco::AbstractObserver& observer) |
no test coverage detected