Searched refs:reactable (Results 1 – 4 of 4) sorted by relevance
171 auto* reactable = static_cast<Reactor::Reactable*>(event.data.ptr); in Run() local175 …if (std::find(invalidation_list_.begin(), invalidation_list_.end(), reactable) != invalidation_lis… in Run()180 std::lock_guard<std::mutex> reactable_lock(reactable->mutex_); in Run()182 reactable->is_executing_ = true; in Run()184 …if (event.events & (EPOLLIN | EPOLLHUP | EPOLLRDHUP | EPOLLERR) && !reactable->on_read_ready_.is_n… in Run()185 reactable->on_read_ready_.Run(); in Run()187 if (event.events & EPOLLOUT && !reactable->on_write_ready_.is_null()) { in Run()188 reactable->on_write_ready_.Run(); in Run()191 std::unique_lock<std::mutex> reactable_lock(reactable->mutex_); in Run()192 reactable->is_executing_ = false; in Run()[all …]
192 auto* reactable = reactor_->Register( in TEST_F() local195 reactor_->Unregister(reactable); in TEST_F()200 auto* reactable = reactor_->Register( in TEST_F() local210 reactor_->Unregister(reactable); in TEST_F()218 auto* reactable = reactor_->Register( in TEST_F() local226 reactor_->Unregister(reactable); in TEST_F()231 auto* reactable = reactor_->Register( in TEST_F() local239 reactor_->Unregister(reactable); in TEST_F()249 auto* reactable = reactor_->Register( in TEST_F() local257 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);