Searched refs:reactable (Results 1 – 4 of 4) sorted by relevance
128 auto* reactable = static_cast<Reactor::Reactable*>(event.data.ptr); in Run() local132 …if (std::find(invalidation_list_.begin(), invalidation_list_.end(), reactable) != invalidation_lis… in Run()137 std::lock_guard<std::mutex> reactable_lock(reactable->mutex_); in Run()139 reactable->is_executing_ = true; in Run()141 …if (event.events & (EPOLLIN | EPOLLHUP | EPOLLRDHUP | EPOLLERR) && !reactable->on_read_ready_.is_n… in Run()142 reactable->on_read_ready_.Run(); in Run()144 if (event.events & EPOLLOUT && !reactable->on_write_ready_.is_null()) { in Run()145 reactable->on_write_ready_.Run(); in Run()148 std::unique_lock<std::mutex> reactable_lock(reactable->mutex_); in Run()149 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()
63 void Unregister(Reactable* reactable);72 …void ModifyRegistration(Reactable* reactable, common::Closure on_read_ready, common::Closure on_wr…