| /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/memory/ |
| D | scoped_vector_unittest.cc | 121 LifeCycleWatcher watcher; in TEST() local
122 EXPECT_EQ(LC_INITIAL, watcher.life_cycle_state()); in TEST()
123 LifeCycleObject* object = watcher.NewLifeCycleObject(); in TEST()
124 EXPECT_EQ(LC_CONSTRUCTED, watcher.life_cycle_state()); in TEST()
126 EXPECT_EQ(LC_DESTROYED, watcher.life_cycle_state()); in TEST()
130 LifeCycleWatcher watcher; in TEST() local
131 EXPECT_EQ(LC_INITIAL, watcher.life_cycle_state()); in TEST()
133 scoped_vector.push_back(watcher.NewLifeCycleObject()); in TEST()
134 EXPECT_EQ(LC_CONSTRUCTED, watcher.life_cycle_state()); in TEST()
135 EXPECT_TRUE(watcher.IsWatching(scoped_vector.back())); in TEST()
[all …]
|
| /external/libchrome/base/files/ |
| D | file_path_watcher_unittest.cc | 135 FilePathWatcher* watcher, in SetupWatchCallback() argument
140 *result = watcher->Watch(target, recursive_watch, in SetupWatchCallback()
193 FilePathWatcher* watcher,
219 FilePathWatcher* watcher, in SetupWatch() argument
226 FROM_HERE, base::Bind(SetupWatchCallback, target, watcher, delegate, in SetupWatch()
234 FilePathWatcher watcher; in TEST_F() local
236 ASSERT_TRUE(SetupWatch(test_file(), &watcher, delegate.get(), false)); in TEST_F()
247 FilePathWatcher watcher; in TEST_F() local
249 ASSERT_TRUE(SetupWatch(test_file(), &watcher, delegate.get(), false)); in TEST_F()
262 FilePathWatcher watcher; in TEST_F() local
[all …]
|
| D | file_path_watcher_linux.cc | 55 Watch AddWatch(const FilePath& path, FilePathWatcherImpl* watcher);
58 void RemoveWatch(Watch watch, FilePathWatcherImpl* watcher);
294 const FilePath& path, FilePathWatcherImpl* watcher) { in AddWatch() argument
308 watchers_[watch].insert(watcher); in AddWatch()
313 void InotifyReader::RemoveWatch(Watch watch, FilePathWatcherImpl* watcher) { in RemoveWatch() argument
319 watchers_[watch].erase(watcher); in RemoveWatch()
334 for (WatcherSet::iterator watcher = watchers_[event->wd].begin(); in OnInotifyEvent() local
335 watcher != watchers_[event->wd].end(); in OnInotifyEvent()
336 ++watcher) { in OnInotifyEvent()
337 (*watcher)->OnFilePathChanged(event->wd, in OnInotifyEvent()
|
| D | file_path_watcher_fsevents.cc | 126 FilePathWatcherFSEvents* watcher = in FSEventsCallback() local
128 bool root_changed = watcher->ResolveTargetPath(); in FSEventsCallback()
146 dispatch_async(watcher->queue_, ^{ in FSEventsCallback()
147 watcher->UpdateEventStream(root_change_at); in FSEventsCallback()
151 watcher->OnFilePathsChanged(paths); in FSEventsCallback()
|
| /external/libmojo/mojo/edk/system/ |
| D | request_context.cc | 49 for (const scoped_refptr<Watcher>& watcher : in ~RequestContext() local
51 watcher->Cancel(); in ~RequestContext()
59 watch.watcher->MaybeInvokeCallback(watch.result, watch.state, flags); in ~RequestContext()
75 scoped_refptr<Watcher> watcher, in AddWatchNotifyFinalizer() argument
80 WatchNotifyFinalizer(watcher, result, state)); in AddWatchNotifyFinalizer()
83 void RequestContext::AddWatchCancelFinalizer(scoped_refptr<Watcher> watcher) { in AddWatchCancelFinalizer() argument
85 watch_cancel_finalizers_->push_back(watcher); in AddWatchCancelFinalizer()
93 scoped_refptr<Watcher> watcher, in WatchNotifyFinalizer() argument
96 : watcher(watcher), result(result), state(state) { in WatchNotifyFinalizer()
|
| D | request_context.h | 55 void AddWatchNotifyFinalizer(scoped_refptr<Watcher> watcher,
60 void AddWatchCancelFinalizer(scoped_refptr<Watcher> watcher);
67 WatchNotifyFinalizer(scoped_refptr<Watcher> watcher,
73 scoped_refptr<Watcher> watcher; member
|
| D | watcher_set.cc | 38 scoped_refptr<Watcher> watcher(new Watcher(signals, callback)); in Add() local
39 watchers_.insert(std::make_pair(context, watcher)); in Add()
41 watcher->NotifyForStateChange(current_state); in Add()
|
| /external/libmojo/mojo/message_pump/ |
| D | handle_watcher_perftest.cc | 98 HandleWatcher watcher; in TEST_P() local
102 watcher.Start(pipe.handle0.get(), MOJO_HANDLE_SIGNAL_READABLE, in TEST_P()
104 watcher.Stop(); in TEST_P()
114 HandleWatcher watcher; in TEST_P() member
130 test_data->watcher.Start( in TEST_P()
136 test_data->watcher.Stop(); in TEST_P()
145 HandleWatcher watcher; in TEST_P() local
151 watcher.Start(pipe.handle0.get(), MOJO_HANDLE_SIGNAL_READABLE, in TEST_P()
156 watcher.Stop(); in TEST_P()
170 HandleWatcher watcher; in TEST_P() local
[all …]
|
| D | handle_watcher_unittest.cc | 46 HandleWatcher* watcher, in DeleteWatcherAndForwardResult() argument
49 delete watcher; in DeleteWatcherAndForwardResult()
93 void Start(HandleWatcher* watcher, const MessagePipeHandle& handle) { in Start() argument
94 StartWithCallback(watcher, handle, GetCallback()); in Start()
97 void StartWithCallback(HandleWatcher* watcher, in StartWithCallback() argument
100 watcher->Start(handle, MOJO_HANDLE_SIGNAL_READABLE, in StartWithCallback()
165 HandleWatcher watcher; in TEST_P() local
166 callback_helper.Start(&watcher, test_pipe.handle0.get()); in TEST_P()
299 HandleWatcher watcher; in TEST_P() local
300 callback_helper.Start(&watcher, test_pipe.handle0.get()); in TEST_P()
[all …]
|
| D | handle_watcher.cc | 312 StateBase(HandleWatcher* watcher, in StateBase() argument
314 : watcher_(watcher), in StateBase()
360 SameThreadWatchingState(HandleWatcher* watcher, in SameThreadWatchingState() argument
365 : StateBase(watcher, callback), in SameThreadWatchingState()
404 SecondaryThreadWatchingState(HandleWatcher* watcher, in SecondaryThreadWatchingState() argument
409 : StateBase(watcher, callback), in SecondaryThreadWatchingState()
|
| /external/libmojo/third_party/catapult/devil/devil/utils/ |
| D | reraiser_thread.py | 130 def _JoinAll(self, watcher=None, timeout=None): argument
142 if watcher is None:
143 watcher = watchdog_timer.WatchdogTimer(None)
149 if watcher.IsTimedOut():
170 def JoinAll(self, watcher=None, timeout=None, argument
186 self._JoinAll(watcher, timeout)
193 def GetAllReturnValues(self, watcher=None): argument
200 self.JoinAll(watcher)
216 def RunAsync(funcs, watcher=None): argument
228 return thread_group.GetAllReturnValues(watcher=watcher)
|
| /external/chromium-trace/catapult/devil/devil/utils/ |
| D | reraiser_thread.py | 130 def _JoinAll(self, watcher=None, timeout=None): argument
142 if watcher is None:
143 watcher = watchdog_timer.WatchdogTimer(None)
149 if watcher.IsTimedOut():
170 def JoinAll(self, watcher=None, timeout=None, argument
186 self._JoinAll(watcher, timeout)
193 def GetAllReturnValues(self, watcher=None): argument
200 self.JoinAll(watcher)
216 def RunAsync(funcs, watcher=None): argument
228 return thread_group.GetAllReturnValues(watcher=watcher)
|
| /external/libmojo/mojo/public/cpp/system/ |
| D | watcher.cc | 18 explicit MessageLoopObserver(Watcher* watcher) : watcher_(watcher) { in MessageLoopObserver() argument
135 Watcher* watcher = reinterpret_cast<Watcher*>(context); in CallOnHandleReady() local
137 watcher->task_runner_->RunsTasksOnCurrentThread() && in CallOnHandleReady()
138 watcher->is_default_task_runner_) { in CallOnHandleReady()
142 watcher->OnHandleReady(result); in CallOnHandleReady()
144 watcher->task_runner_->PostTask( in CallOnHandleReady()
146 base::Bind(&Watcher::OnHandleReady, watcher->weak_self_, result)); in CallOnHandleReady()
|
| D | BUILD.gn | 17 "watcher.cc",
18 "watcher.h",
|
| /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 …]
|
| D | nft-bridge.c | 34 free(m->u.watcher->t); in ebt_cs_clean()
212 if (add_target(r, iter->u.watcher->t)) in nft_bridge_add()
331 m->u.watcher = object; in parse_watcher()
524 watcherp = m->u.watcher; in nft_bridge_print_firewall()
|
| /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/robolectric/v1/src/main/java/com/xtremelabs/robolectric/shadows/ |
| D | ShadowTextView.java | 117 for (TextWatcher watcher : watchers) { in sendAfterTextChanged()
118 watcher.afterTextChanged(new SpannableStringBuilder(getText())); in sendAfterTextChanged()
123 for (TextWatcher watcher : watchers) { in sendOnTextChanged()
124 watcher.onTextChanged(text, 0, oldValue.length(), text.length()); in sendOnTextChanged()
129 for (TextWatcher watcher : watchers) { in sendBeforeTextChanged()
130 watcher.beforeTextChanged(this.text, 0, this.text.length(), newValue.length()); in sendBeforeTextChanged()
469 public void addTextChangedListener(TextWatcher watcher) { in addTextChangedListener() argument
470 this.watchers.add(watcher); in addTextChangedListener()
474 public void removeTextChangedListener(TextWatcher watcher) { in removeTextChangedListener() argument
475 this.watchers.remove(watcher); in removeTextChangedListener()
|
| /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/libmojo/mojo/android/system/ |
| D | core_impl.cc | 41 void AsyncWaitCallback(mojo::common::HandleWatcher* watcher, in AsyncWaitCallback() argument
44 delete watcher; in AsyncWaitCallback()
379 common::HandleWatcher* watcher = new common::HandleWatcher(); in AsyncWait() local
380 cancel_id = reinterpret_cast<MojoAsyncWaitID>(watcher); in AsyncWait()
381 watcher->Start(Handle(static_cast<MojoHandle>(mojo_handle)), signals, in AsyncWait()
383 base::Bind(&AsyncWaitCallback, watcher, callback_data)); in AsyncWait()
|
| /external/libchrome/base/message_loop/ |
| D | message_pump_libevent.h | 64 void set_watcher(Watcher* watcher) { watcher_ = watcher; } in set_watcher() argument
|
| /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/apache-http/src/org/apache/http/conn/ |
| D | EofSensorInputStream.java | 109 final EofSensorWatcher watcher) { in EofSensorInputStream() argument
117 eofWatcher = watcher; in EofSensorInputStream()
|
| /external/robolectric/v1/src/test/java/com/xtremelabs/robolectric/shadows/ |
| D | TextViewTest.java | 279 MockTextWatcher watcher = new MockTextWatcher(); in removeTextChangedListener_shouldRemoveTheListener() local
280 textView.addTextChangedListener(watcher); in removeTextChangedListener_shouldRemoveTheListener()
281 assertTrue(shadowOf(textView).getWatchers().contains(watcher)); in removeTextChangedListener_shouldRemoveTheListener()
283 textView.removeTextChangedListener(watcher); in removeTextChangedListener_shouldRemoveTheListener()
284 assertFalse(shadowOf(textView).getWatchers().contains(watcher)); in removeTextChangedListener_shouldRemoveTheListener()
|