Searched refs:reactable (Results 1 – 4 of 4) sorted by relevance
104 auto* reactable = static_cast<Reactor::Reactable*>(event.data.ptr); in Run() local108 …if (std::find(invalidation_list_.begin(), invalidation_list_.end(), reactable) != invalidation_lis… in Run()112 std::lock_guard<std::recursive_mutex> reactable_lock(reactable->lock_); in Run()115 reactable->is_executing_ = true; in Run()116 …if (event.events & (EPOLLIN | EPOLLHUP | EPOLLRDHUP | EPOLLERR) && reactable->on_read_ready_ != nu… in Run()117 reactable->on_read_ready_(); in Run()119 … if (!reactable_removed_ && event.events & EPOLLOUT && reactable->on_write_ready_ != nullptr) { in Run()120 reactable->on_write_ready_(); in Run()122 reactable->is_executing_ = false; in Run()125 delete reactable; in Run()[all …]
144 auto* reactable = in TEST_F() local147 reactor_->Unregister(reactable); in TEST_F()152 auto* reactable = in TEST_F() local162 reactor_->Unregister(reactable); in TEST_F()170 auto* reactable = in TEST_F() local178 reactor_->Unregister(reactable); in TEST_F()183 auto* reactable = in TEST_F() local186 reactor_->Unregister(reactable); in TEST_F()203 auto* reactable = in TEST_F() local211 reactor_->Unregister(reactable); in TEST_F()[all …]
87 auto* reactable = in TEST_F() local93 reactor->Unregister(reactable); in TEST_F()
63 void Unregister(Reactable* reactable);66 void ModifyRegistration(Reactable* reactable, Closure on_read_ready, Closure on_write_ready);