Searched refs:watchers_ (Results 1 – 9 of 9) sorted by relevance
| /external/libchrome/mojo/core/ |
| D | watcher_set.cc | 21 for (const auto& entry : watchers_) in NotifyState()
26 for (const auto& entry : watchers_) in NotifyClosed()
33 auto it = watchers_.find(watcher.get()); in Add()
34 if (it == watchers_.end()) { in Add()
36 watchers_.insert(std::make_pair(watcher.get(), Entry{watcher})); in Add()
56 auto it = watchers_.find(watcher); in Remove()
57 if (it == watchers_.end()) in Remove()
67 watchers_.erase(it); in Remove()
|
| D | message_pipe_dispatcher.cc | 94 watchers_(this) { in MessagePipeDispatcher()
111 watchers_.NotifyClosed(); in Fuse()
119 other->watchers_.NotifyClosed(); in Fuse()
192 watchers_.NotifyState(GetHandleSignalsStateNoLock()); in ReadMessage()
257 return watchers_.Add(watcher, context, GetHandleSignalsStateNoLock()); in AddWatcherRef()
265 return watchers_.Remove(watcher, context); in RemoveWatcherRef()
309 watchers_.NotifyState(GetHandleSignalsStateNoLock()); in CancelTransit()
346 watchers_.NotifyClosed(); in CloseNoLock()
422 watchers_.NotifyState(GetHandleSignalsStateNoLock()); in OnPortStatusChanged()
|
| D | data_pipe_consumer_dispatcher.cc | 123 watchers_.NotifyState(GetHandleSignalsStateNoLock()); in ReadData()
145 watchers_.NotifyState(GetHandleSignalsStateNoLock()); in ReadData()
153 watchers_.NotifyState(GetHandleSignalsStateNoLock()); in ReadData()
188 watchers_.NotifyState(GetHandleSignalsStateNoLock()); in ReadData()
208 watchers_.NotifyState(GetHandleSignalsStateNoLock()); in BeginReadData()
227 watchers_.NotifyState(GetHandleSignalsStateNoLock()); in BeginReadData()
261 watchers_.NotifyState(GetHandleSignalsStateNoLock()); in EndReadData()
277 return watchers_.Add(watcher, context, GetHandleSignalsStateNoLock()); in AddWatcherRef()
286 return watchers_.Remove(watcher, context); in RemoveWatcherRef()
427 watchers_(this), in DataPipeConsumerDispatcher()
[all …]
|
| D | data_pipe_producer_dispatcher.cc | 153 watchers_.NotifyState(GetHandleSignalsStateNoLock()); in WriteData()
220 watchers_.NotifyState(GetHandleSignalsStateNoLock()); in EndWriteData()
236 return watchers_.Add(watcher, context, GetHandleSignalsStateNoLock()); in AddWatcherRef()
245 return watchers_.Remove(watcher, context); in RemoveWatcherRef()
317 watchers_.NotifyState(state); in CancelTransit()
387 watchers_(this), in DataPipeProducerDispatcher()
424 watchers_.NotifyClosed(); in CloseNoLock()
533 watchers_.NotifyState(GetHandleSignalsStateNoLock()); in UpdateSignalsStateNoLock()
|
| D | watcher_set.h | 61 base::flat_map<WatcherDispatcher*, Entry> watchers_; variable
|
| D | message_pipe_dispatcher.h | 106 WatcherSet watchers_; variable
|
| D | data_pipe_producer_dispatcher.h | 98 WatcherSet watchers_; variable
|
| D | data_pipe_consumer_dispatcher.h | 99 WatcherSet watchers_; variable
|
| /external/libchrome/base/files/ |
| D | file_path_watcher_linux.cc | 94 std::unordered_map<Watch, WatcherSet> watchers_; member in base::__anon271f2d060111::InotifyReader
307 watchers_[watch].insert(watcher); in AddWatch()
318 watchers_[watch].erase(watcher); in RemoveWatch()
320 if (watchers_[watch].empty()) { in RemoveWatch()
321 watchers_.erase(watch); in RemoveWatch()
333 for (WatcherSet::iterator watcher = watchers_[event->wd].begin(); in OnInotifyEvent()
334 watcher != watchers_[event->wd].end(); in OnInotifyEvent()
|