| 254 | } |
| 255 | |
| 256 | void Stream::checkForSessionTimeout() { |
| 257 | base::MutexLock lock(_mutex); |
| 258 | |
| 259 | for (std::size_t i = 0; i < MAX_CLIENTS; ++i) { |
| 260 | if (_client[i].sessionTimeout() || !_enabled) { |
| 261 | if (_enabled) { |
| 262 | SI_LOG_INFO("Stream: %d, Watchdog kicked in for StreamClient[%d] with SessionID %s", |
| 263 | _streamID, i, _client[i].getSessionID().c_str()); |
| 264 | } else { |
| 265 | SI_LOG_INFO("Stream: %d, Reclaiming StreamClient[%d] with SessionID %s", |
| 266 | _streamID, i, _client[i].getSessionID().c_str()); |
| 267 | } |
| 268 | teardown(i); |
| 269 | close(i); |
| 270 | } |
| 271 | } |
| 272 | } |
| 273 | |
| 274 | bool Stream::update(int clientID, bool start) { |
| 275 | base::MutexLock lock(_mutex); |
no test coverage detected