| /external/webrtc/webrtc/system_wrappers/source/ |
| 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.NewLifeCycleObject())
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/libchrome/mojo/public/cpp/bindings/lib/ |
| sequence_local_sync_event_watcher.cc | 32 // Ref-counted watcher state which may outlive the watcher to which it pertains.
35 // may destroy the watcher.
82 // Registers a new watcher and returns an iterator into the WatcherStateMap to
85 const SequenceLocalSyncEventWatcher* watcher) {
87 watcher, base::MakeRefCounted<WatcherState>());
94 // If the watcher being unregistered is currently blocking in a
115 void SignalForWatcher(const SequenceLocalSyncEventWatcher* watcher) {
120 ready_watchers_.insert(watcher);
129 void ResetForWatcher(const SequenceLocalSyncEventWatcher* watcher) {
[all...] |
| /external/libchrome/mojo/core/ |
| watcher_set.cc | 30 MojoResult WatcherSet::Add(const scoped_refptr<WatcherDispatcher>& watcher,
33 auto it = watchers_.find(watcher.get());
36 watchers_.insert(std::make_pair(watcher.get(), Entry{watcher}));
49 // Otherwise only notify the newly added Watcher.
50 watcher->NotifyHandleState(owner_, current_state);
55 MojoResult WatcherSet::Remove(WatcherDispatcher* watcher, uintptr_t context) {
56 auto it = watchers_.find(watcher);
|
| watcher_set.h | 21 // Dispatchers which may be watched by a watcher should own a WatcherSet and
35 // Adds a new watcher+context.
36 MojoResult Add(const scoped_refptr<WatcherDispatcher>& watcher,
40 // Removes a watcher+context.
41 MojoResult Remove(WatcherDispatcher* watcher, uintptr_t context);
|
| watch.cc | 13 Watch::Watch(const scoped_refptr<WatcherDispatcher>& watcher,
18 : watcher_(watcher),
|
| message_pipe_dispatcher.h | 60 MojoResult AddWatcherRef(const scoped_refptr<WatcherDispatcher>& watcher,
62 MojoResult RemoveWatcherRef(WatcherDispatcher* watcher,
|
| /external/libchrome/base/message_loop/ |
| message_loop_io_posix_unittest.cc | 73 // If set then the contained watcher will be deleted on notification.
77 // Watcher that calls specified closures when read/write events occur. Verifies
101 // base:MessagePumpFuchsia::Watcher interface.
132 // Arrange for watcher to live longer than message loop.
133 MessagePumpForIO::FdWatchController watcher(FROM_HERE);
139 write_fd_.get(), true, MessagePumpForIO::WATCH_WRITE, &watcher,
151 // Arrange for message loop to live longer than watcher.
154 MessagePumpForIO::FdWatchController watcher(FROM_HERE);
158 write_fd_.get(), true, MessagePumpForIO::WATCH_WRITE, &watcher,
160 ASSERT_TRUE(watcher.StopWatchingFileDescriptor())
[all...] |
| message_pump_libevent.h | 51 void set_watcher(FdWatcher* watcher) { watcher_ = watcher; }
|
| /art/test/154-gc-loop/src/ |
| Main.java | 22 watcher = new WeakReference<GcWatcher>(new GcWatcher());
26 static WeakReference<GcWatcher> watcher = new WeakReference<GcWatcher>(new GcWatcher()); field in class:Main
|
| /cts/common/device-side/util/src/com/android/compatibility/common/util/ |
| ActivityLauncher.java | 38 public ActivityLauncher(@NonNull Context context, @NonNull ActivitiesWatcher watcher,
40 mWatcher = watcher.watch(activityClass);
46 * Gets a watcher for the activity lifecycle events.
|
| ActivitiesWatcher.java | 96 * Gets a watcher for the given activity.
110 * Gets a watcher for the given activity.
118 Log.d(TAG, "Registering watcher for " + className);
119 final ActivityWatcher watcher = new ActivityWatcher(mTimeoutMs); local
120 mWatchers.put(className, watcher);
121 return watcher;
126 final ActivityWatcher watcher = mWatchers.get(className); local
127 if (watcher != null) {
128 Log.d(TAG, "notifying watcher of " + className + " of " + lifecycle);
129 watcher.notify(lifecycle)
[all...] |
| /cts/common/device-side/util-axt/src/com/android/compatibility/common/util/ |
| ActivityLauncher.java | 38 public ActivityLauncher(@NonNull Context context, @NonNull ActivitiesWatcher watcher,
40 mWatcher = watcher.watch(activityClass);
46 * Gets a watcher for the activity lifecycle events.
|
| ActivitiesWatcher.java | 96 * Gets a watcher for the given activity.
110 * Gets a watcher for the given activity.
118 Log.d(TAG, "Registering watcher for " + className);
119 final ActivityWatcher watcher = new ActivityWatcher(mTimeoutMs); local
120 mWatchers.put(className, watcher);
121 return watcher;
126 final ActivityWatcher watcher = mWatchers.get(className); local
127 if (watcher != null) {
128 Log.d(TAG, "notifying watcher of " + className + " of " + lifecycle);
129 watcher.notify(lifecycle)
[all...] |
| /external/libchrome/base/files/ |
| file_path_watcher_unittest.cc | 118 // reset expectations while the file watcher is running.
186 FilePathWatcher* watcher,
220 FilePathWatcher* watcher,
223 return watcher->Watch(
230 FilePathWatcher watcher; local
232 ASSERT_TRUE(SetupWatch(test_file(), &watcher, delegate.get(), false));
242 FilePathWatcher watcher; local
244 ASSERT_TRUE(SetupWatch(test_file(), &watcher, delegate.get(), false));
256 FilePathWatcher watcher; local
258 ASSERT_TRUE(SetupWatch(test_file(), &watcher, delegate.get(), false))
268 FilePathWatcher watcher; local
291 FilePathWatcher* watcher() const { return watcher_.get(); } function in class:base::__anon27372::Deleter
319 FilePathWatcher watcher; local
338 FilePathWatcher watcher; local
371 FilePathWatcher watcher; local
397 FilePathWatcher watcher; local
412 FilePathWatcher watcher; local
426 FilePathWatcher watcher; local
483 FilePathWatcher watcher; local
629 FilePathWatcher watcher; local
642 FilePathWatcher watcher; local
659 FilePathWatcher watcher; local
673 FilePathWatcher watcher; local
687 FilePathWatcher watcher; local
702 FilePathWatcher watcher; local
715 FilePathWatcher watcher; local
743 FilePathWatcher watcher; local
772 FilePathWatcher watcher; local
853 FilePathWatcher watcher; local
[all...] |
| /external/python/cpython3/Lib/test/test_asyncio/ |
| test_unix_events.py | [all...] |
| /external/chromium-trace/catapult/devil/devil/utils/ |
| reraiser_thread.py | 133 def _JoinAll(self, watcher=None, timeout=None):
140 watcher: Watchdog object providing the thread timeout. If none is
145 if watcher is None:
146 watcher = watchdog_timer.WatchdogTimer(None)
152 if watcher.IsTimedOut():
173 def JoinAll(self, watcher=None, timeout=None,
182 watcher: Watchdog object providing the thread timeout. If none is
189 self._JoinAll(watcher, timeout)
196 def GetAllReturnValues(self, watcher=None):
200 watcher: same as in |JoinAll|. Only used if threads are alive
[all...] |
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/ |
| ShadowTextView.java | 108 protected void addTextChangedListener(TextWatcher watcher) {
109 this.watchers.add(watcher);
110 directlyOn(realTextView, TextView.class).addTextChangedListener(watcher);
114 protected void removeTextChangedListener(TextWatcher watcher) {
115 this.watchers.remove(watcher);
116 directlyOn(realTextView, TextView.class).removeTextChangedListener(watcher);
|
| /external/libchrome/mojo/public/cpp/system/ |
| handle_signal_tracker.cc | 38 // Arm either the low watcher or high watcher. We cycle until one of them
43 SimpleWatcher& watcher = arm_low_watcher ? low_watcher_ : high_watcher_; local
44 MojoResult result = watcher.Arm(&ready_result, &last_known_state_);
53 // The high watcher failed to arm because the watched signal will never
|
| /external/libchrome/mojo/public/cpp/system/tests/ |
| scope_to_message_pipe_unittest.cc | 54 SimpleWatcher watcher(FROM_HERE, SimpleWatcher::ArmingPolicy::AUTOMATIC);
55 watcher.Watch(pipe.handle1.get(), MOJO_HANDLE_SIGNAL_READABLE,
|
| /cts/tests/contentcaptureservice/src/android/contentcaptureservice/cts/ |
| CustomViewActivityTest.java | 95 final ActivityWatcher watcher = startWatcher(); local
98 watcher.waitFor(RESUMED);
101 watcher.waitFor(DESTROYED);
117 final ActivityWatcher watcher = startWatcher(); local
137 watcher.waitFor(RESUMED);
140 watcher.waitFor(DESTROYED);
182 final ActivityWatcher watcher = startWatcher(); local
215 watcher.waitFor(RESUMED);
219 watcher.waitFor(DESTROYED);
250 final ActivityWatcher watcher = startWatcher() local
367 final ActivityWatcher watcher = startWatcher(); local
426 final ActivityWatcher watcher = startWatcher(); local
450 final ActivityWatcher watcher = startWatcher(); local
468 final ActivityWatcher watcher = startWatcher(); local
494 final ActivityWatcher watcher = startWatcher(); local
524 final ActivityWatcher watcher = startWatcher(); local
[all...] |
| /external/apache-http/src/org/apache/http/conn/ |
| 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 will be notified and this strea
[all...] |
| /external/libchrome/mojo/public/java/system/ |
| watcher_impl.cc | 87 auto* watcher = reinterpret_cast<WatcherImpl*>(watcher_ptr); local
88 return watcher->Start(env, jcaller, mojo_handle, signals);
|
| /external/owasp/sanitizer/src/tests/org/owasp/html/ |
| CssFuzzerTest.java | 59 final class Watcher implements Runnable {
87 Watcher watcher = new Watcher(); local
106 synchronized (watcher) {
107 watcher.input = randomCss;
108 watcher.started = System.nanoTime();
111 watcherThread = new Thread(watcher);
168 synchronized (watcher) {
169 watcher.input = null
[all...] |
| /external/grpc-grpc/src/core/lib/iomgr/ |
| ev_poll_posix.cc | 92 /* The watcher list.
94 The following watcher related fields are protected by watcher_mu.
102 If a watcher is asked to poll for reads or writes, the read_watcher
103 or write_watcher fields are set respectively. A watcher may be asked
106 read_watcher and write_watcher may be NULL if no watcher has been
437 static grpc_error* pollset_kick_locked(grpc_fd_watcher* watcher) {
438 gpr_mu_lock(&watcher->pollset->mu);
439 GPR_ASSERT(watcher->worker);
440 grpc_error* err = pollset_kick_ext(watcher->pollset, watcher->worker
457 grpc_fd_watcher* watcher; local
1576 grpc_cv_node* watcher = result->watchers; local
[all...] |
| /external/iptables/iptables/ |
| 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->t->u.user.name[sizeof(watcher->t->u.user.name)-1] = '\0'
[all...] |
