Searched refs:observers (Results 1 – 3 of 3) sorted by relevance
318 std::map<ConnectionId, const std::shared_ptr<IObserver>> observers; in handleInvalidateAck() local323 mBufferPool.mInvalidation.onHandleAck(&observers, &invalidationId); in handleInvalidateAck()327 for (auto it = observers.begin(); it != observers.end(); ++it) { in handleInvalidateAck()
118 std::map<ConnectionId, const std::shared_ptr<IObserver>> *observers,
146 std::map<ConnectionId, const std::shared_ptr<IObserver>> *observers, in onHandleAck() argument155 observers->emplace(it->first, observer); in onHandleAck()