Lines Matching refs:pdispatcher
1192 void PhysicalSocketServer::Add(Dispatcher *pdispatcher) { in Add() argument
1197 pdispatcher); in Add()
1200 dispatchers_.push_back(pdispatcher); in Add()
1203 void PhysicalSocketServer::Remove(Dispatcher *pdispatcher) { in Remove() argument
1207 pdispatcher); in Remove()
1272 Dispatcher *pdispatcher = dispatchers_[i]; in Wait() local
1273 ASSERT(pdispatcher); in Wait()
1274 if (!process_io && (pdispatcher != signal_wakeup_)) in Wait()
1276 int fd = pdispatcher->GetDescriptor(); in Wait()
1280 uint32_t ff = pdispatcher->GetRequestedEvents(); in Wait()
1311 Dispatcher *pdispatcher = dispatchers_[i]; in Wait() local
1312 int fd = pdispatcher->GetDescriptor(); in Wait()
1329 if (pdispatcher->GetRequestedEvents() & DE_ACCEPT) { in Wait()
1331 } else if (errcode || pdispatcher->IsDescriptorClosed()) { in Wait()
1342 if (pdispatcher->GetRequestedEvents() & DE_CONNECT) { in Wait()
1355 pdispatcher->OnPreEvent(ff); in Wait()
1356 pdispatcher->OnEvent(ff, errcode); in Wait()