| /external/webrtc/webrtc/system_wrappers/source/ |
| D | scoped_vector_unittest.cc | 114 LifeCycleWatcher watcher; in TEST() local
115 EXPECT_EQ(LC_INITIAL, watcher.life_cycle_state()); in TEST()
116 LifeCycleObject* object = watcher.NewLifeCycleObject(); in TEST()
117 EXPECT_EQ(LC_CONSTRUCTED, watcher.life_cycle_state()); in TEST()
119 EXPECT_EQ(LC_DESTROYED, watcher.life_cycle_state()); in TEST()
123 LifeCycleWatcher watcher; in TEST() local
124 EXPECT_EQ(LC_INITIAL, watcher.life_cycle_state()); in TEST()
126 scoped_vector.push_back(watcher.NewLifeCycleObject()); in TEST()
127 EXPECT_EQ(LC_CONSTRUCTED, watcher.life_cycle_state()); in TEST()
128 EXPECT_TRUE(watcher.IsWatching(scoped_vector.back())); in TEST()
[all …]
|
| /external/libchrome/base/message_loop/ |
| D | message_loop_io_posix_unittest.cc | 133 MessagePumpForIO::FdWatchController watcher(FROM_HERE); in TEST_F() local
139 write_fd_.get(), true, MessagePumpForIO::WATCH_WRITE, &watcher, in TEST_F()
154 MessagePumpForIO::FdWatchController watcher(FROM_HERE); in TEST_F() local
158 write_fd_.get(), true, MessagePumpForIO::WATCH_WRITE, &watcher, in TEST_F()
160 ASSERT_TRUE(watcher.StopWatchingFileDescriptor()); in TEST_F()
161 ASSERT_TRUE(watcher.StopWatchingFileDescriptor()); in TEST_F()
183 MessagePumpForIO::FdWatchController watcher(FROM_HERE); in TEST_F() local
189 &watcher, &handler)); in TEST_F()
209 MessagePumpForIO::FdWatchController watcher(FROM_HERE); in TEST_F() local
215 &watcher, &handler)); in TEST_F()
[all …]
|
| D | message_pump_libevent.h | 51 void set_watcher(FdWatcher* watcher) { watcher_ = watcher; } in set_watcher() argument
|
| /external/libchrome/base/files/ |
| D | file_path_watcher_unittest.cc | 186 FilePathWatcher* watcher,
220 FilePathWatcher* watcher, in SetupWatch() argument
223 return watcher->Watch( in SetupWatch()
230 FilePathWatcher watcher; in TEST_F() local
232 ASSERT_TRUE(SetupWatch(test_file(), &watcher, delegate.get(), false)); in TEST_F()
242 FilePathWatcher watcher; in TEST_F() local
244 ASSERT_TRUE(SetupWatch(test_file(), &watcher, delegate.get(), false)); in TEST_F()
256 FilePathWatcher watcher; in TEST_F() local
258 ASSERT_TRUE(SetupWatch(test_file(), &watcher, delegate.get(), false)); in TEST_F()
268 FilePathWatcher watcher; in TEST_F() local
[all …]
|
| D | file_path_watcher_linux.cc | 72 Watch AddWatch(const FilePath& path, FilePathWatcherImpl* watcher);
75 void RemoveWatch(Watch watch, FilePathWatcherImpl* watcher);
293 const FilePath& path, FilePathWatcherImpl* watcher) { in AddWatch() argument
307 watchers_[watch].insert(watcher); in AddWatch()
312 void InotifyReader::RemoveWatch(Watch watch, FilePathWatcherImpl* watcher) { in RemoveWatch() argument
318 watchers_[watch].erase(watcher); in RemoveWatch()
333 for (WatcherSet::iterator watcher = watchers_[event->wd].begin(); in OnInotifyEvent() local
334 watcher != watchers_[event->wd].end(); in OnInotifyEvent()
335 ++watcher) { in OnInotifyEvent()
336 (*watcher)->OnFilePathChanged(event->wd, in OnInotifyEvent()
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_unix_events.py | 1064 watcher = asyncio.AbstractChildWatcher()
1066 NotImplementedError, watcher.add_child_handler, f, f)
1068 NotImplementedError, watcher.remove_child_handler, f)
1070 NotImplementedError, watcher.attach_loop, f)
1072 NotImplementedError, watcher.close)
1074 NotImplementedError, watcher.__enter__)
1076 NotImplementedError, watcher.__exit__, f, f, f)
1083 watcher = unix_events.BaseChildWatcher()
1085 NotImplementedError, watcher._do_waitpid, f)
1109 self.watcher = self.create_watcher()
[all …]
|
| /external/libchrome/mojo/public/cpp/bindings/lib/ |
| D | sequence_local_sync_event_watcher.cc | 85 const SequenceLocalSyncEventWatcher* watcher) { in RegisterWatcher() argument
87 watcher, base::MakeRefCounted<WatcherState>()); in RegisterWatcher()
115 void SignalForWatcher(const SequenceLocalSyncEventWatcher* watcher) { in SignalForWatcher() argument
120 ready_watchers_.insert(watcher); in SignalForWatcher()
129 void ResetForWatcher(const SequenceLocalSyncEventWatcher* watcher) { in ResetForWatcher() argument
131 ready_watchers_.erase(watcher); in ResetForWatcher()
139 bool SyncWatch(const SequenceLocalSyncEventWatcher* watcher, in SyncWatch() argument
152 top_watcher_ = watcher; in SyncWatch()
213 for (auto* watcher : ready_watchers) { in OnEventSignaled() local
214 if (top_watcher_ == watcher || watcher->can_wake_up_during_any_watch_) { in OnEventSignaled()
[all …]
|
| /external/chromium-trace/catapult/devil/devil/utils/ |
| D | reraiser_thread.py | 133 def _JoinAll(self, watcher=None, timeout=None): argument
145 if watcher is None:
146 watcher = watchdog_timer.WatchdogTimer(None)
152 if watcher.IsTimedOut():
173 def JoinAll(self, watcher=None, timeout=None, argument
189 self._JoinAll(watcher, timeout)
196 def GetAllReturnValues(self, watcher=None): argument
203 self.JoinAll(watcher)
219 def RunAsync(funcs, watcher=None): argument
231 return thread_group.GetAllReturnValues(watcher=watcher)
|
| /external/libchrome/mojo/core/ |
| D | watcher_set.cc | 30 MojoResult WatcherSet::Add(const scoped_refptr<WatcherDispatcher>& watcher, in Add() argument
33 auto it = watchers_.find(watcher.get()); in Add()
36 watchers_.insert(std::make_pair(watcher.get(), Entry{watcher})); in Add()
50 watcher->NotifyHandleState(owner_, current_state); in Add()
55 MojoResult WatcherSet::Remove(WatcherDispatcher* watcher, uintptr_t context) { in Remove() argument
56 auto it = watchers_.find(watcher); in Remove()
|
| D | watcher_set.h | 36 MojoResult Add(const scoped_refptr<WatcherDispatcher>& watcher,
41 MojoResult Remove(WatcherDispatcher* watcher, uintptr_t context);
|
| D | watch.cc | 13 Watch::Watch(const scoped_refptr<WatcherDispatcher>& watcher, in Watch() argument
18 : watcher_(watcher), in Watch()
|
| D | message_pipe_dispatcher.h | 60 MojoResult AddWatcherRef(const scoped_refptr<WatcherDispatcher>& watcher,
62 MojoResult RemoveWatcherRef(WatcherDispatcher* watcher,
|
| D | message_pipe_dispatcher.cc | 252 const scoped_refptr<WatcherDispatcher>& watcher, in AddWatcherRef() argument
257 return watchers_.Add(watcher, context, GetHandleSignalsStateNoLock()); in AddWatcherRef()
260 MojoResult MessagePipeDispatcher::RemoveWatcherRef(WatcherDispatcher* watcher, in RemoveWatcherRef() argument
265 return watchers_.Remove(watcher, context); in RemoveWatcherRef()
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-policy.rst | 75 Get a child process watcher object.
77 Return a watcher object implementing the
82 .. method:: set_child_watcher(watcher)
84 Set the current child process watcher to *watcher*.
112 A process watcher allows customization of how an event loop monitors
128 The following two functions can be used to customize the child process watcher
133 Return the current child watcher for the current policy.
135 .. function:: set_child_watcher(watcher)
137 Set the current child watcher to *watcher* for the current
138 policy. *watcher* must implement methods defined in the
[all …]
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | ev_poll_posix.cc | 437 static grpc_error* pollset_kick_locked(grpc_fd_watcher* watcher) { argument
438 gpr_mu_lock(&watcher->pollset->mu);
439 GPR_ASSERT(watcher->worker);
440 grpc_error* err = pollset_kick_ext(watcher->pollset, watcher->worker,
442 gpr_mu_unlock(&watcher->pollset->mu);
457 grpc_fd_watcher* watcher; local
458 for (watcher = fd->inactive_watcher_root.next;
459 watcher != &fd->inactive_watcher_root; watcher = watcher->next) {
460 pollset_kick_locked(watcher);
641 uint32_t write_mask, grpc_fd_watcher* watcher) { argument
[all …]
|
| /external/iptables/iptables/ |
| D | xtables-eb.c | 626 struct xtables_target *watcher; in ebt_load_watcher() local
629 watcher = xtables_find_target(name, XTF_LOAD_MUST_SUCCEED); in ebt_load_watcher()
630 if (!watcher) in ebt_load_watcher()
634 size = XT_ALIGN(sizeof(struct xt_entry_target)) + watcher->size; in ebt_load_watcher()
636 watcher->t = xtables_calloc(1, size); in ebt_load_watcher()
637 watcher->t->u.target_size = size; in ebt_load_watcher()
638 strncpy(watcher->t->u.user.name, name, in ebt_load_watcher()
639 sizeof(watcher->t->u.user.name)); in ebt_load_watcher()
640 watcher->t->u.user.name[sizeof(watcher->t->u.user.name)-1] = '\0'; in ebt_load_watcher()
641 watcher->t->u.user.revision = watcher->revision; in ebt_load_watcher()
[all …]
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowTextView.java | 108 protected void addTextChangedListener(TextWatcher watcher) { in addTextChangedListener() argument
109 this.watchers.add(watcher); in addTextChangedListener()
110 directlyOn(realTextView, TextView.class).addTextChangedListener(watcher); in addTextChangedListener()
114 protected void removeTextChangedListener(TextWatcher watcher) { in removeTextChangedListener() argument
115 this.watchers.remove(watcher); in removeTextChangedListener()
116 directlyOn(realTextView, TextView.class).removeTextChangedListener(watcher); in removeTextChangedListener()
|
| /external/owasp/sanitizer/src/tests/org/owasp/html/ |
| D | CssFuzzerTest.java | 87 Watcher watcher = new Watcher(); in testUnderStress() local
106 synchronized (watcher) { in testUnderStress()
107 watcher.input = randomCss; in testUnderStress()
108 watcher.started = System.nanoTime(); in testUnderStress()
111 watcherThread = new Thread(watcher); in testUnderStress()
168 synchronized (watcher) { in testUnderStress()
169 watcher.input = null; in testUnderStress()
170 watcher.notifyAll(); in testUnderStress()
|
| /external/python/cpython2/Lib/plat-mac/ |
| D | pimp.py | 124 watcher=None): argument
127 self._watcher = watcher
189 watcher=None): argument
195 self._watcher = watcher
295 self.watcher = None
297 def setWatcher(self, watcher): argument
298 self.watcher = watcher
683 watcher=self._db.preferences.watcher)
715 watcher=self._db.preferences.watcher)
1011 def _run(mode, verbose, force, args, prefargs, watcher): argument
[all …]
|
| /external/syzkaller/vendor/google.golang.org/grpc/resolver/dns/ |
| D | dns_resolver.go | 94 go i.watcher()
113 go d.watcher()
144 func (i *ipResolver) watcher() { func
191 func (d *dnsResolver) watcher() { func
|
| /external/libchrome/mojo/public/cpp/system/ |
| D | handle_signal_tracker.cc | 43 SimpleWatcher& watcher = arm_low_watcher ? low_watcher_ : high_watcher_; in Arm() local
44 MojoResult result = watcher.Arm(&ready_result, &last_known_state_); in Arm()
|
| /external/libchrome/mojo/public/cpp/system/tests/ |
| D | scope_to_message_pipe_unittest.cc | 54 SimpleWatcher watcher(FROM_HERE, SimpleWatcher::ArmingPolicy::AUTOMATIC); in TEST_F() local
55 watcher.Watch(pipe.handle1.get(), MOJO_HANDLE_SIGNAL_READABLE, in TEST_F()
|
| /external/webrtc/talk/media/devices/ |
| D | devicemanager.h | 189 void set_watcher(DeviceWatcher* watcher) { watcher_.reset(watcher); } in set_watcher() argument
190 DeviceWatcher* watcher() { return watcher_.get(); } in watcher() function
|
| /external/libchrome/mojo/public/java/system/ |
| D | watcher_impl.cc | 87 auto* watcher = reinterpret_cast<WatcherImpl*>(watcher_ptr); in JNI_WatcherImpl_Start() local
88 return watcher->Start(env, jcaller, mojo_handle, signals); in JNI_WatcherImpl_Start()
|
| /external/apache-http/src/org/apache/http/conn/ |
| D | EofSensorInputStream.java | 109 final EofSensorWatcher watcher) { in EofSensorInputStream() argument
117 eofWatcher = watcher; in EofSensorInputStream()
|