Searched refs:reactable (Results 1 – 4 of 4) sorted by relevance
170 auto* reactable = static_cast<Reactor::Reactable*>(event.data.ptr); in Run() local174 …if (std::find(invalidation_list_.begin(), invalidation_list_.end(), reactable) != invalidation_lis… in Run()179 std::lock_guard<std::mutex> reactable_lock(reactable->mutex_); in Run()181 reactable->is_executing_ = true; in Run()183 …if (event.events & (EPOLLIN | EPOLLHUP | EPOLLRDHUP | EPOLLERR) && !reactable->on_read_ready_.is_n… in Run()184 reactable->on_read_ready_.Run(); in Run()186 if (event.events & EPOLLOUT && !reactable->on_write_ready_.is_null()) { in Run()187 reactable->on_write_ready_.Run(); in Run()190 std::unique_lock<std::mutex> reactable_lock(reactable->mutex_); in Run()191 reactable->is_executing_ = false; in Run()[all …]
191 auto* reactable = reactor_->Register( in TEST_F() local194 reactor_->Unregister(reactable); in TEST_F()199 auto* reactable = reactor_->Register( in TEST_F() local209 reactor_->Unregister(reactable); in TEST_F()217 auto* reactable = reactor_->Register( in TEST_F() local225 reactor_->Unregister(reactable); in TEST_F()230 auto* reactable = reactor_->Register( in TEST_F() local238 reactor_->Unregister(reactable); in TEST_F()248 auto* reactable = reactor_->Register( in TEST_F() local256 reactor_->Unregister(reactable); in TEST_F()[all …]
88 auto* reactable = reactor->Register( in TEST_F() local96 reactor->Unregister(reactable); in TEST_F()
65 void Unregister(Reactable* reactable);80 void ModifyRegistration(Reactable* reactable, ReactOn react_on);