/external/libchrome/base/memory/ |
H A D | scoped_vector_unittest.cc | 62 // 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 D | scoped_vector_unittest.cc | 61 // 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 D | request_context.cc | 49 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 D | request_context.h | 12 #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 D | watcher_set.cc | 38 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 D | watcher.cc | 5 #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 D | reraiser_thread.py | 130 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 D | timeout_retry.py | 156 thread_group.JoinAll(watcher=thread_group.GetWatcher(), timeout=60,
|
/external/libmojo/third_party/catapult/devil/devil/utils/ |
H A D | reraiser_thread.py | 130 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 D | file_path_watcher_unittest.cc | 113 // 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 D | file_path_watcher_linux.cc | 55 // 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 D | test_unix_events.py | 811 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 D | ShadowTextView.java | 108 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 D | EofSensorInputStream.java | 47 * 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 D | message_pump_libevent.h | 69 void set_watcher(Watcher* watcher) { watcher_ = watcher; } argument
|
/external/libmojo/mojo/android/system/ |
H A D | watcher_impl.cc | 18 #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 D | CssFuzzerTest.java | 87 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 D | xtables-eb.c | 626 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 D | ShadowTextView.java | 117 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 D | pimp.py | 124 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 D | Connector.java | 38 * 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 D | RouterImpl.java | 124 * @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 D | macdevicemanagermm.mm | 100 void ReleaseDeviceWatcherCallback(DeviceWatcherImpl* watcher) { 103 [watcher release];
|
H A D | devicemanager.h | 189 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 D | op.cc | 113 Status OpRegistry::SetWatcher(const Watcher& watcher) { argument 115 if (watcher_ && watcher) { 117 "Cannot over-write a valid watcher with another."); 119 watcher_ = watcher;
|