Searched refs:epollMgr_ (Results 1 – 8 of 8) sorted by relevance
103 epollMgr_ = std::make_shared<EpollManager>(); in OnEnable()104 int32_t ret = epollMgr_->Open(); in OnEnable()112 ret = epollMgr_->Add(monitor_); in OnEnable()123 epollMgr_.reset(); in OnEnable()142 CHKPR(epollMgr_, RET_ERR); in OnDisable()143 epollMgr_->Remove(monitor_); in OnDisable()145 epollMgr_.reset(); in OnDisable()289 ev.data.ptr = epollMgr_.get(); in OnEpollDispatch()291 CHKPR(epollMgr_, RET_ERR); in OnEpollDispatch()292 epollMgr_->Dispatch(ev); in OnEpollDispatch()
104 epollMgr_ = std::make_shared<EpollManager>(); in OnEnable()105 int32_t ret = epollMgr_->Open(); in OnEnable()113 ret = epollMgr_->Add(monitor_); in OnEnable()124 epollMgr_.reset(); in OnEnable()143 CHKPR(epollMgr_, RET_ERR); in OnDisable()144 epollMgr_->Remove(monitor_); in OnDisable()146 epollMgr_.reset(); in OnDisable()289 ev.data.ptr = epollMgr_.get(); in OnEpollDispatch()291 CHKPR(epollMgr_, RET_ERR); in OnEpollDispatch()292 epollMgr_->Dispatch(ev); in OnEpollDispatch()
43 return epollMgr_.Open(); in Init()87 if (epollMgr_.Add(*session) != RET_OK) { in AllocSocketFd()143 int32_t cnt = epollMgr_.WaitTimeout(evs, MAX_EPOLL_EVENTS, 0); in DispatchOne()166 epollMgr_.Remove(*session); in ReleaseSession()184 epollMgr_.Remove(*session); in DeleteCollaborationServiceByName()203 epollMgr_.Remove(*session); in ReleaseSessionByPid()
40 return epollMgr_.Open(); in Init()84 if (epollMgr_.Add(*session) != RET_OK) { in AllocSocketFd()139 int32_t cnt = epollMgr_.WaitTimeout(evs, MAX_EPOLL_EVENTS, 0); in DispatchOne()161 epollMgr_.Remove(*session); in ReleaseSession()178 epollMgr_.Remove(*session); in ReleaseSessionByPid()
93 std::shared_ptr<EpollManager> epollMgr_ { nullptr };100 return (epollMgr_ != nullptr ? epollMgr_->GetFd() : -1); in GetFd()
75 EpollManager epollMgr_; variable83 return epollMgr_.GetFd(); in GetFd()
77 EpollManager epollMgr_; variable85 return epollMgr_.GetFd(); in GetFd()