Searched refs:dispatchers_ (Results 1 – 11 of 11) sorted by relevance
141 iter(&dispatchers_); !iter.IsAtEnd(); iter.Advance()) { in ~FileSystemDispatcher()146 dispatchers_.Remove(request_id); in ~FileSystemDispatcher()172 int request_id = dispatchers_.Add( in OpenFileSystem()182 int request_id = dispatchers_.Add( in ResolveURL()191 int request_id = dispatchers_.Add(CallbackDispatcher::Create(callback)); in DeleteFileSystem()200 int request_id = dispatchers_.Add(CallbackDispatcher::Create(callback)); in Move()209 int request_id = dispatchers_.Add(CallbackDispatcher::Create(callback)); in Copy()218 int request_id = dispatchers_.Add(CallbackDispatcher::Create(callback)); in Remove()227 int request_id = dispatchers_.Add( in ReadMetadata()237 int request_id = dispatchers_.Add(CallbackDispatcher::Create(callback)); in CreateFile()[all …]
150 IDMap<CallbackDispatcher, IDMapOwnPointer> dispatchers_; variable
130 if (dispatchers_) { in ~MessageInTransit()131 for (size_t i = 0; i < dispatchers_->size(); i++) { in ~MessageInTransit()132 if (!(*dispatchers_)[i].get()) in ~MessageInTransit()135 DCHECK((*dispatchers_)[i]->HasOneRef()); in ~MessageInTransit()136 (*dispatchers_)[i]->Close(); in ~MessageInTransit()165 DCHECK(!dispatchers_); in SetDispatchers()168 dispatchers_ = dispatchers.Pass(); in SetDispatchers()170 for (size_t i = 0; i < dispatchers_->size(); i++) in SetDispatchers()171 DCHECK(!(*dispatchers_)[i].get() || (*dispatchers_)[i]->HasOneRef()); in SetDispatchers()179 DCHECK(!dispatchers_); in SetTransportData()[all …]
208 DispatcherVector* dispatchers() { return dispatchers_.get(); } in dispatchers()212 return dispatchers_ && !dispatchers_->empty(); in has_dispatchers()259 scoped_ptr<DispatcherVector> dispatchers_; variable
36 dispatchers_.AddObserver(dispatcher); in AddPlatformEventDispatcher()42 dispatchers_.RemoveObserver(dispatcher); in RemovePlatformEventDispatcher()75 dispatchers_.might_have_observers()) { in DispatchEvent()76 ObserverList<PlatformEventDispatcher>::Iterator iter(dispatchers_); in DispatchEvent()
88 PlatformEventDispatcherList dispatchers_; variable
16 while (!dispatchers_.empty()) { in ~EventHandler()17 EventDispatcher* dispatcher = dispatchers_.top(); in ~EventHandler()18 dispatchers_.pop(); in ~EventHandler()
162 (*it)->dispatchers_.push(this); in DispatchEventToEventHandlers()173 CHECK(handler->dispatchers_.top() == this); in DispatchEventToEventHandlers()174 handler->dispatchers_.pop(); in DispatchEventToEventHandlers()
57 std::stack<EventDispatcher*> dispatchers_; variable
1205 ASSERT(dispatchers_.empty()); in ~PhysicalSocketServer()1253 DispatcherList::iterator pos = std::find(dispatchers_.begin(), in Add()1254 dispatchers_.end(), in Add()1256 if (pos != dispatchers_.end()) in Add()1258 dispatchers_.push_back(pdispatcher); in Add()1263 DispatcherList::iterator pos = std::find(dispatchers_.begin(), in Remove()1264 dispatchers_.end(), in Remove()1269 if (pos == dispatchers_.end()) { in Remove()1274 size_t index = pos - dispatchers_.begin(); in Remove()1275 dispatchers_.erase(pos); in Remove()[all …]
108 DispatcherList dispatchers_; variable