Searched refs:listeners_ (Results 1 – 6 of 6) sorted by relevance
50 RTNLHandler::GetInstance()->listeners_.clear(); in SetUp()60 EXPECT_EQ(1, RTNLHandler::GetInstance()->listeners_.size()); in TEST_F()65 EXPECT_EQ(0, RTNLHandler::GetInstance()->listeners_.size()); in TEST_F()73 EXPECT_EQ(1, RTNLHandler::GetInstance()->listeners_.size()); in TEST_F()78 EXPECT_EQ(0, RTNLHandler::GetInstance()->listeners_.size()); in TEST_F()
134 for (const auto& listener : listeners_) { in AddListener()138 listeners_.push_back(to_add); in AddListener()143 for (auto it = listeners_.begin(); it != listeners_.end(); ++it) { in RemoveListener()145 listeners_.erase(it); in RemoveListener()216 for (const auto& listener : listeners_) { in DispatchEvent()
188 std::vector<RTNLListener*> listeners_;
315 while (!listeners_.empty()) { in ExpireListeners()316 const ListenerEntryPtr& last_listener = listeners_.back(); in ExpireListeners()318 listeners_.size() <= kMaxListenerEntries) { in ExpireListeners()324 listeners_.pop_back(); in ExpireListeners()333 for (it = listeners_.begin(); it != listeners_.end(); ++it) { in FindListener()348 for (it = listeners_.begin(); it != listeners_.end(); ++it) { in FindDestination()378 deque<ListenerEntryPtr>::iterator entry_ptr = listeners_.end(); in IsIncomingPacketAllowed()386 if (entry_ptr == listeners_.end()) { in IsIncomingPacketAllowed()427 if (entry_it != listeners_.end()) { in LogOutgoingPacket()428 if (entry_it != listeners_.begin()) { in LogOutgoingPacket()[all …]
48 return processor_.listeners_; in GetListeners()51 return *processor_.listeners_[index]; in GetListener()
200 std::deque<ListenerEntryPtr> listeners_; variable