Searched refs:watcher (Results 1 - 25 of 57) sorted by relevance

123

/external/libchrome/base/memory/
H A Dscoped_vector_unittest.cc62 // pairing of the watcher, which observes the object and notifies of
108 // Returns true iff |object| is the same object that this watcher is tracking.
121 LifeCycleWatcher watcher; local
122 EXPECT_EQ(LC_INITIAL, watcher.life_cycle_state());
123 LifeCycleObject* object = watcher.NewLifeCycleObject();
124 EXPECT_EQ(LC_CONSTRUCTED, watcher.life_cycle_state());
126 EXPECT_EQ(LC_DESTROYED, watcher.life_cycle_state());
130 LifeCycleWatcher watcher; local
131 EXPECT_EQ(LC_INITIAL, watcher.life_cycle_state());
133 scoped_vector.push_back(watcher
142 LifeCycleWatcher watcher; local
154 LifeCycleWatcher watcher; local
193 LifeCycleWatcher watcher; local
211 LifeCycleWatcher watcher; local
223 LifeCycleWatcher watcher; local
242 LifeCycleWatcher watcher; local
[all...]
/external/webrtc/webrtc/system_wrappers/source/
H A Dscoped_vector_unittest.cc61 // pairing of the watcher, which observes the object and notifies of
101 // Returns true iff |object| is the same object that this watcher is tracking.
114 LifeCycleWatcher watcher; local
115 EXPECT_EQ(LC_INITIAL, watcher.life_cycle_state());
116 LifeCycleObject* object = watcher.NewLifeCycleObject();
117 EXPECT_EQ(LC_CONSTRUCTED, watcher.life_cycle_state());
119 EXPECT_EQ(LC_DESTROYED, watcher.life_cycle_state());
123 LifeCycleWatcher watcher; local
124 EXPECT_EQ(LC_INITIAL, watcher.life_cycle_state());
126 scoped_vector.push_back(watcher
135 LifeCycleWatcher watcher; local
147 LifeCycleWatcher watcher; local
186 LifeCycleWatcher watcher; local
204 LifeCycleWatcher watcher; local
216 LifeCycleWatcher watcher; local
236 LifeCycleWatcher watcher; local
[all...]
/external/libmojo/mojo/edk/system/
H A Drequest_context.cc49 for (const scoped_refptr<Watcher>& watcher :
51 watcher->Cancel();
57 // watcher lock.
59 watch.watcher->MaybeInvokeCallback(watch.result, watch.state, flags);
75 scoped_refptr<Watcher> watcher,
80 WatchNotifyFinalizer(std::move(watcher), result, state));
83 void RequestContext::AddWatchCancelFinalizer(scoped_refptr<Watcher> watcher) { argument
85 watch_cancel_finalizers_->push_back(std::move(watcher));
93 scoped_refptr<Watcher> watcher,
96 : watcher(st
74 AddWatchNotifyFinalizer( scoped_refptr<Watcher> watcher, MojoResult result, const HandleSignalsState& state) argument
92 WatchNotifyFinalizer( scoped_refptr<Watcher> watcher, MojoResult result, const HandleSignalsState& state) argument
[all...]
H A Drequest_context.h12 #include "mojo/edk/system/watcher.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 in struct:mojo::edk::RequestContext::WatchNotifyFinalizer
H A Dwatcher_set.cc38 scoped_refptr<Watcher> watcher(new Watcher(signals, callback));
39 watchers_.insert(std::make_pair(context, watcher));
41 watcher->NotifyForStateChange(current_state);
/external/libmojo/mojo/public/cpp/system/
H A Dwatcher.cc5 #include "mojo/public/cpp/system/watcher.h"
101 Watcher* watcher = reinterpret_cast<Watcher*>(context); local
104 watcher->task_runner_->RunsTasksOnCurrentThread() &&
105 watcher->is_default_task_runner_) {
109 watcher->OnHandleReady(result);
111 watcher->task_runner_->PostTask(
113 base::Bind(&Watcher::OnHandleReady, watcher->weak_self_, result));
/external/chromium-trace/catapult/devil/devil/utils/
H A Dreraiser_thread.py130 def _JoinAll(self, watcher=None, timeout=None):
137 watcher: Watchdog object providing the thread timeout. If none is
142 if watcher is None:
143 watcher = watchdog_timer.WatchdogTimer(None)
149 if watcher.IsTimedOut():
170 def JoinAll(self, watcher=None, timeout=None,
179 watcher: Watchdog object providing the thread timeout. If none is
186 self._JoinAll(watcher, timeout)
193 def GetAllReturnValues(self, watcher=None):
197 watcher
[all...]
H A Dtimeout_retry.py156 thread_group.JoinAll(watcher=thread_group.GetWatcher(), timeout=60,
/external/libmojo/third_party/catapult/devil/devil/utils/
H A Dreraiser_thread.py130 def _JoinAll(self, watcher=None, timeout=None):
137 watcher: Watchdog object providing the thread timeout. If none is
142 if watcher is None:
143 watcher = watchdog_timer.WatchdogTimer(None)
149 if watcher.IsTimedOut():
170 def JoinAll(self, watcher=None, timeout=None,
179 watcher: Watchdog object providing the thread timeout. If none is
186 self._JoinAll(watcher, timeout)
193 def GetAllReturnValues(self, watcher=None):
197 watcher
[all...]
/external/libchrome/base/files/
H A Dfile_path_watcher_unittest.cc113 // reset expectations while the file watcher is running.
181 FilePathWatcher* watcher,
212 FilePathWatcher* watcher,
215 return watcher->Watch(
222 FilePathWatcher watcher; local
224 ASSERT_TRUE(SetupWatch(test_file(), &watcher, delegate.get(), false));
234 FilePathWatcher watcher; local
236 ASSERT_TRUE(SetupWatch(test_file(), &watcher, delegate.get(), false));
248 FilePathWatcher watcher; local
250 ASSERT_TRUE(SetupWatch(test_file(), &watcher, delegat
211 SetupWatch(const FilePath& target, FilePathWatcher* watcher, TestDelegateBase* delegate, bool recursive_watch) argument
260 FilePathWatcher watcher; local
273 Deleter(FilePathWatcher* watcher, MessageLoop* loop) argument
285 FilePathWatcher* watcher() const { return watcher_.get(); } function in class:base::__anon10831::Deleter
296 FilePathWatcher* watcher = new FilePathWatcher; local
314 FilePathWatcher watcher; local
333 FilePathWatcher watcher; local
366 FilePathWatcher watcher; local
392 FilePathWatcher watcher; local
407 FilePathWatcher watcher; local
421 FilePathWatcher watcher; local
478 FilePathWatcher watcher; local
625 FilePathWatcher watcher; local
638 FilePathWatcher watcher; local
655 FilePathWatcher watcher; local
669 FilePathWatcher watcher; local
683 FilePathWatcher watcher; local
698 FilePathWatcher watcher; local
711 FilePathWatcher watcher; local
739 FilePathWatcher watcher; local
768 FilePathWatcher watcher; local
849 FilePathWatcher watcher; local
[all...]
H A Dfile_path_watcher_linux.cc55 // Watch directory |path| for changes. |watcher| will be notified on each
57 Watch AddWatch(const FilePath& path, FilePathWatcherImpl* watcher);
60 void RemoveWatch(Watch watch, FilePathWatcherImpl* watcher);
265 const FilePath& path, FilePathWatcherImpl* watcher) {
279 watchers_[watch].insert(watcher);
284 void InotifyReader::RemoveWatch(Watch watch, FilePathWatcherImpl* watcher) { argument
290 watchers_[watch].erase(watcher);
305 for (WatcherSet::iterator watcher = watchers_[event->wd].begin();
306 watcher != watchers_[event->wd].end();
307 ++watcher) {
264 AddWatch( const FilePath& path, FilePathWatcherImpl* watcher) argument
[all...]
/external/python/cpython3/Lib/test/test_asyncio/
H A Dtest_unix_events.py811 watcher = asyncio.AbstractChildWatcher()
813 NotImplementedError, watcher.add_child_handler, f, f)
815 NotImplementedError, watcher.remove_child_handler, f)
817 NotImplementedError, watcher.attach_loop, f)
819 NotImplementedError, watcher.close)
821 NotImplementedError, watcher.__enter__)
823 NotImplementedError, watcher.__exit__, f, f, f)
830 watcher = unix_events.BaseChildWatcher()
832 NotImplementedError, watcher._do_waitpid, f)
856 self.watcher
[all...]
/external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/
H A DShadowTextView.java108 public void addTextChangedListener(TextWatcher watcher) { argument
109 this.watchers.add(watcher);
110 directlyOn(realTextView, TextView.class).addTextChangedListener(watcher);
114 public void removeTextChangedListener(TextWatcher watcher) { argument
115 this.watchers.remove(watcher);
116 directlyOn(realTextView, TextView.class).removeTextChangedListener(watcher);
/external/apache-http/src/org/apache/http/conn/
H A DEofSensorInputStream.java47 * on EOF. That decision is left to the {@link EofSensorWatcher watcher}.
93 /** The watcher to be notified, if any. */
99 * If no watcher is passed, the underlying stream will simply be
101 * Otherwise, the watcher decides whether the underlying stream
105 * @param watcher the watcher for events, or <code>null</code> for
109 final EofSensorWatcher watcher) {
117 eofWatcher = watcher;
223 * Detects EOF and notifies the watcher.
228 * If EOF is detected, the watcher wil
108 EofSensorInputStream(final InputStream in, final EofSensorWatcher watcher) argument
[all...]
/external/libchrome/base/message_loop/
H A Dmessage_pump_libevent.h69 void set_watcher(Watcher* watcher) { watcher_ = watcher; } argument
/external/libmojo/mojo/android/system/
H A Dwatcher_impl.cc18 #include "mojo/public/cpp/system/watcher.h"
88 auto* watcher = reinterpret_cast<WatcherImpl*>(watcher_ptr); local
89 return watcher->Start(env, jcaller, mojo_handle, signals);
/external/owasp/sanitizer/src/tests/org/owasp/html/
H A DCssFuzzerTest.java87 Watcher watcher = new Watcher();
106 synchronized (watcher) {
107 watcher.input = randomCss;
108 watcher.started = System.nanoTime();
111 watcherThread = new Thread(watcher);
168 synchronized (watcher) {
169 watcher.input = null;
170 watcher.notifyAll();
/external/iptables/iptables/
H A Dxtables-eb.c626 struct xtables_target *watcher; local
629 watcher = xtables_find_target(name, XTF_LOAD_MUST_SUCCEED);
630 if (!watcher)
632 "Unable to load %s watcher", name);
634 size = XT_ALIGN(sizeof(struct xt_entry_target)) + watcher->size;
636 watcher->t = xtables_calloc(1, size);
637 watcher->t->u.target_size = size;
638 strncpy(watcher->t->u.user.name, name,
639 sizeof(watcher->t->u.user.name));
640 watcher
699 ebt_add_watcher(struct xtables_target *watcher, struct ebtables_command_state *cs) argument
[all...]
/external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/shadows/
H A DShadowTextView.java117 for (TextWatcher watcher : watchers) {
118 watcher.afterTextChanged(new SpannableStringBuilder(getText()));
123 for (TextWatcher watcher : watchers) {
124 watcher.onTextChanged(text, 0, oldValue.length(), text.length());
129 for (TextWatcher watcher : watchers) {
130 watcher.beforeTextChanged(this.text, 0, this.text.length(), newValue.length());
469 public void addTextChangedListener(TextWatcher watcher) { argument
470 this.watchers.add(watcher);
474 public void removeTextChangedListener(TextWatcher watcher) { argument
475 this.watchers.remove(watcher);
[all...]
/external/python/cpython2/Lib/plat-mac/
H A Dpimp.py124 watcher=None):
127 self._watcher = watcher
189 watcher=None):
195 self._watcher = watcher
295 self.watcher = None
297 def setWatcher(self, watcher):
298 self.watcher = watcher
683 watcher=self._db.preferences.watcher)
[all...]
/external/libmojo/mojo/public/java/bindings/src/org/chromium/mojo/bindings/
H A DConnector.java38 * A watcher which is notified when a new message is available on the owned message pipe.
64 public Connector(MessagePipeHandle messagePipeHandle, Watcher watcher) { argument
66 mWatcher = watcher;
H A DRouterImpl.java124 * @param watcher the {@link Watcher} to use to get notification of new messages on the
127 public RouterImpl(MessagePipeHandle messagePipeHandle, Watcher watcher) { argument
128 mConnector = new Connector(messagePipeHandle, watcher);
/external/webrtc/talk/media/devices/
H A Dmacdevicemanagermm.mm100 void ReleaseDeviceWatcherCallback(DeviceWatcherImpl* watcher) {
103 [watcher release];
H A Ddevicemanager.h189 void set_watcher(DeviceWatcher* watcher) { watcher_.reset(watcher); } argument
190 DeviceWatcher* watcher() { return watcher_.get(); } function in class:cricket::DeviceManager
/external/tensorflow/tensorflow/core/framework/
H A Dop.cc113 Status OpRegistry::SetWatcher(const Watcher& watcher) { argument
115 if (watcher_ && watcher) {
117 "Cannot over-write a valid watcher with another.");
119 watcher_ = watcher;

Completed in 596 milliseconds

123