| /external/pdfium/core/fxcrt/ |
| D | retained_tree_node_unittest.cpp | 44 ObservedPtr<ObservableRetainedTreeNodeForTest> watcher; in TEST() local
49 watcher = ObservedPtr<ObservableRetainedTreeNodeForTest>(ptr.Get()); in TEST()
50 EXPECT_TRUE(watcher.Get()); in TEST()
52 EXPECT_FALSE(watcher.Get()); in TEST()
56 ObservedPtr<ObservableRetainedTreeNodeForTest> watcher; in TEST() local
62 watcher = ObservedPtr<ObservableRetainedTreeNodeForTest>(ptr.Get()); in TEST()
66 EXPECT_TRUE(watcher.Get()); in TEST()
68 EXPECT_TRUE(watcher.Get()); in TEST()
69 parent->RemoveChild(pdfium::WrapRetain(watcher.Get())); in TEST()
70 EXPECT_FALSE(watcher.Get()); in TEST()
[all …]
|
| /external/jimfs/jimfs/src/test/java/com/google/common/jimfs/ |
| D | AbstractWatchServiceTest.java | 53 private AbstractWatchService watcher; field in AbstractWatchServiceTest
57 watcher = new AbstractWatchService() {}; in setUp()
62 assertThat(watcher.isOpen()).isTrue(); in testNewWatcher()
63 assertThat(watcher.poll()).isNull(); in testNewWatcher()
64 assertThat(watcher.queuedKeys()).isEmpty(); in testNewWatcher()
65 watcher.close(); in testNewWatcher()
66 assertThat(watcher.isOpen()).isFalse(); in testNewWatcher()
72 AbstractWatchService.Key key = watcher.register(watchable, ImmutableSet.of(ENTRY_CREATE)); in testRegister()
84 watcher.register(new StubWatchable(), ImmutableSet.of(ENTRY_CREATE)); in testPostEvent()
91 assertThat(watcher.queuedKeys()).containsExactly(key); in testPostEvent()
[all …]
|
| D | PollingWatchServiceTest.java | 56 private PollingWatchService watcher; field in PollingWatchServiceTest
61 watcher = in setUp()
72 watcher.close(); in tearDown()
74 watcher = null; in tearDown()
80 assertThat(watcher.isOpen()).isTrue(); in testNewWatcher()
81 assertThat(watcher.isPolling()).isFalse(); in testNewWatcher()
86 Key key = watcher.register(createDirectory(), ImmutableList.of(ENTRY_CREATE)); in testRegister()
89 assertThat(watcher.isPolling()).isTrue(); in testRegister()
95 watcher.register(fs.getPath("/a/b/c"), ImmutableList.of(ENTRY_CREATE)); in testRegister_fileDoesNotExist()
106 watcher.register(path, ImmutableList.of(ENTRY_CREATE)); in testRegister_fileIsNotDirectory()
[all …]
|
| /external/libchrome/base/synchronization/ |
| D | waitable_event_watcher_unittest.cc | 60 WaitableEventWatcher watcher; in TEST_P() local
61 watcher.StartWatching(&event, BindOnce(&QuitWhenSignaled), in TEST_P()
77 WaitableEventWatcher watcher; in TEST_P() local
78 watcher.StartWatching(&event, BindOnce(&QuitWhenSignaled), in TEST_P()
96 WaitableEventWatcher watcher; in TEST_P() local
98 watcher.StartWatching(&event, BindOnce(&QuitWhenSignaled), in TEST_P()
101 watcher.StopWatching(); in TEST_P()
111 WaitableEventWatcher watcher; in TEST_P() local
117 watcher.StartWatching(&event, std::move(callback), in TEST_P()
125 watcher.StopWatching(); in TEST_P()
[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_unittest.cc | 126 MessagePumpLibevent::FdWatchController* watcher = in TEST_F() local
128 DeleteWatcher delegate(watcher); in TEST_F()
130 false, MessagePumpLibevent::WATCH_READ_WRITE, watcher, &delegate); in TEST_F()
133 OnLibeventNotification(pump.get(), watcher); in TEST_F()
150 MessagePumpLibevent::FdWatchController watcher(FROM_HERE); in TEST_F() local
151 StopWatcher delegate(&watcher); in TEST_F()
153 false, MessagePumpLibevent::WATCH_READ_WRITE, &watcher, &delegate); in TEST_F()
156 OnLibeventNotification(pump.get(), &watcher); in TEST_F()
184 MessagePumpLibevent::FdWatchController watcher(FROM_HERE); in TEST_F() local
187 false, MessagePumpLibevent::WATCH_READ, &watcher, &delegate); in TEST_F()
[all …]
|
| /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_fsevents.cc | 133 FilePathWatcherFSEvents* watcher = in FSEventsCallback() local
135 bool root_changed = watcher->ResolveTargetPath(); in FSEventsCallback()
162 watcher->task_runner()->PostTask( in FSEventsCallback()
168 FilePathWatcherFSEvents* watcher = weak_watcher.get(); in FSEventsCallback() local
169 dispatch_async(watcher->queue_, ^{ in FSEventsCallback()
170 watcher->UpdateEventStream(root_change_at); in FSEventsCallback()
173 watcher->weak_factory_.GetWeakPtr(), root_change_at)); in FSEventsCallback()
176 watcher->OnFilePathsChanged(paths); in FSEventsCallback()
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_unix_events.py | 1111 watcher = asyncio.AbstractChildWatcher()
1113 NotImplementedError, watcher.add_child_handler, f, f)
1115 NotImplementedError, watcher.remove_child_handler, f)
1117 NotImplementedError, watcher.attach_loop, f)
1119 NotImplementedError, watcher.close)
1121 NotImplementedError, watcher.is_active)
1123 NotImplementedError, watcher.__enter__)
1125 NotImplementedError, watcher.__exit__, f, f, f)
1132 watcher = unix_events.BaseChildWatcher()
1134 NotImplementedError, watcher._do_waitpid, f)
[all …]
|
| /external/libwebsockets/lib/event-libs/libevent/ |
| D | libevent.c | 119 event_del(lws_io->event.watcher); in lws_event_cb()
120 event_free(lws_io->event.watcher); in lws_event_cb()
164 struct event *signal = pt_to_priv_event(pt)->w_sigint.watcher; in lws_event_sigint_cb()
187 w_read->watcher = event_new(ptpr->io_loop, wsi->desc.sockfd, in elops_listen_init_event()
189 event_add(w_read->watcher, NULL); in elops_listen_init_event()
238 ptpr->w_sigint.watcher = evsignal_new(loop, SIGINT, in elops_init_pt_event()
240 event_add(ptpr->w_sigint.watcher, NULL); in elops_init_pt_event()
280 wpr->w_read.watcher = event_new(ptpr->io_loop, fd, in elops_accept_event()
282 wpr->w_write.watcher = event_new(ptpr->io_loop, fd, in elops_accept_event()
304 event_add(wpr->w_write.watcher, NULL); in elops_io_event()
[all …]
|
| /external/libwebsockets/lib/event-libs/libev/ |
| D | libev.c | 33 lws_ev_hrtimer_cb(struct ev_loop *loop, struct ev_timer *watcher, int revents) in lws_ev_hrtimer_cb() argument
35 struct lws_pt_eventlibs_libev *ptpr = lws_container_of(watcher, in lws_ev_hrtimer_cb()
88 lws_accept_cb(struct ev_loop *loop, struct ev_io *watcher, int revents) in lws_accept_cb() argument
90 struct lws_io_watcher_libev *lws_io = lws_container_of(watcher, in lws_accept_cb()
91 struct lws_io_watcher_libev, watcher); in lws_accept_cb()
101 eventfd.fd = watcher->fd; in lws_accept_cb()
114 wsi = wsi_from_fd(context, watcher->fd); in lws_accept_cb()
124 lws_ev_sigint_cb(struct ev_loop *loop, struct ev_signal *watcher, int revents) in lws_ev_sigint_cb() argument
126 struct lws_context *context = watcher->data; in lws_ev_sigint_cb()
129 context->eventlib_signal_cb((void *)watcher, watcher->signum); in lws_ev_sigint_cb()
[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/python/cpython3/Lib/unittest/ |
| D | _log.py | 17 self.watcher = _LoggingWatcher([], [])
23 self.watcher.records.append(record)
25 self.watcher.output.append(msg)
52 self.watcher = handler.watcher
61 return handler.watcher
74 if len(self.watcher.records) > 0:
77 self.watcher.output
83 if len(self.watcher.records) == 0:
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/ |
| D | connectivity_state.cc | 60 Notifier(RefCountedPtr<AsyncConnectivityStateWatcherInterface> watcher, in Notifier() argument
63 : watcher_(std::move(watcher)), state_(state), status_(status) { in Notifier()
119 OrphanablePtr<ConnectivityStateWatcherInterface> watcher) { in AddWatcher() argument
122 this, watcher.get()); in AddWatcher()
129 name_, this, watcher.get(), ConnectivityStateName(initial_state), in AddWatcher()
132 watcher->Notify(current_state, status_); in AddWatcher()
137 watchers_.insert(std::make_pair(watcher.get(), std::move(watcher))); in AddWatcher()
142 ConnectivityStateWatcherInterface* watcher) { in RemoveWatcher() argument
145 name_, this, watcher); in RemoveWatcher()
147 watchers_.erase(watcher); in RemoveWatcher()
|
| /external/chromium-trace/catapult/devil/devil/utils/ |
| D | reraiser_thread.py | 143 def _JoinAll(self, watcher=None, timeout=None): argument
155 if watcher is None:
156 watcher = watchdog_timer.WatchdogTimer(None)
162 if watcher.IsTimedOut():
183 def JoinAll(self, watcher=None, timeout=None, argument
199 self._JoinAll(watcher, timeout)
206 def GetAllReturnValues(self, watcher=None): argument
213 self.JoinAll(watcher)
229 def RunAsync(funcs, watcher=None): argument
241 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()
|
| /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*.
125 A process watcher allows customization of how an event loop monitors
142 The following two functions can be used to customize the child process watcher
147 Return the current child watcher for the current policy.
149 .. function:: set_child_watcher(watcher)
151 Set the current child watcher to *watcher* for the current
152 policy. *watcher* must implement methods defined in the
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | subchannel_interface.h | 71 std::unique_ptr<ConnectivityStateWatcherInterface> watcher) = 0;
76 ConnectivityStateWatcherInterface* watcher) = 0;
110 std::unique_ptr<ConnectivityStateWatcherInterface> watcher) override { in WatchConnectivityState() argument
112 std::move(watcher)); in WatchConnectivityState()
115 ConnectivityStateWatcherInterface* watcher) override { in CancelConnectivityStateWatch() argument
116 return wrapped_subchannel_->CancelConnectivityStateWatch(watcher); in CancelConnectivityStateWatch()
|
| D | subchannel.cc | 105 OrphanablePtr<ConnectivityStateWatcherInterface> watcher) { in StartWatch() argument
107 op->start_connectivity_watch = std::move(watcher); in StartWatch()
365 RefCountedPtr<Subchannel::ConnectivityStateWatcherInterface> watcher, in AsyncWatcherNotifierLocked() argument
368 : watcher_(std::move(watcher)) { in AsyncWatcherNotifierLocked()
398 RefCountedPtr<ConnectivityStateWatcherInterface> watcher) { in AddWatcherLocked() argument
399 watchers_.insert(std::make_pair(watcher.get(), std::move(watcher))); in AddWatcherLocked()
403 ConnectivityStateWatcherInterface* watcher) { in RemoveWatcherLocked() argument
404 watchers_.erase(watcher); in RemoveWatcherLocked()
447 RefCountedPtr<Subchannel::ConnectivityStateWatcherInterface> watcher) { in AddWatcherLocked() argument
449 new AsyncWatcherNotifierLocked(watcher, subchannel_.get(), state_, in AddWatcherLocked()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/xds/ |
| D | cds.cc | 112 ClusterWatcher* watcher = nullptr; member
149 XdsClient::ClusterWatcherInterface* watcher,
295 for (auto& watcher : watchers_) { in ShutdownLocked() local
298 watcher.first.c_str()); in ShutdownLocked()
300 CancelClusterDataWatch(watcher.first, watcher.second.watcher, in ShutdownLocked()
341 for (auto& watcher : watchers_) { in UpdateLocked() local
344 watcher.first.c_str()); in UpdateLocked()
346 CancelClusterDataWatch(watcher.first, watcher.second.watcher, in UpdateLocked()
351 auto watcher = absl::make_unique<ClusterWatcher>(Ref(), config_->cluster()); in UpdateLocked() local
352 watchers_[config_->cluster()].watcher = watcher.get(); in UpdateLocked()
[all …]
|
| /external/robolectric/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowTextView.java | 83 protected void addTextChangedListener(TextWatcher watcher) { in addTextChangedListener() argument
84 this.watchers.add(watcher); in addTextChangedListener()
85 reflector(TextViewReflector.class, realTextView).addTextChangedListener(watcher); in addTextChangedListener()
89 protected void removeTextChangedListener(TextWatcher watcher) { in removeTextChangedListener() argument
90 this.watchers.remove(watcher); in removeTextChangedListener()
91 reflector(TextViewReflector.class, realTextView).removeTextChangedListener(watcher); in removeTextChangedListener()
164 void addTextChangedListener(TextWatcher watcher); in addTextChangedListener() argument
167 void removeTextChangedListener(TextWatcher watcher); in removeTextChangedListener() argument
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | ev_poll_posix.cc | 151 uint32_t write_mask, grpc_fd_watcher* watcher);
156 static void fd_end_poll(grpc_fd_watcher* watcher, int got_read, int got_write);
397 static grpc_error_handle pollset_kick_locked(grpc_fd_watcher* watcher) { argument
398 gpr_mu_lock(&watcher->pollset->mu);
399 GPR_ASSERT(watcher->worker);
401 pollset_kick_ext(watcher->pollset, watcher->worker,
403 gpr_mu_unlock(&watcher->pollset->mu);
418 grpc_fd_watcher* watcher; local
419 for (watcher = fd->inactive_watcher_root.next;
420 watcher != &fd->inactive_watcher_root; watcher = watcher->next) {
[all …]
|
| /external/iptables/iptables/ |
| D | xtables-eb.c | 498 struct xtables_target *watcher; in __ebt_load_watcher() local
501 watcher = xtables_find_target(name, XTF_TRY_LOAD); in __ebt_load_watcher()
502 if (!watcher) { in __ebt_load_watcher()
507 size = XT_ALIGN(sizeof(struct xt_entry_target)) + watcher->size; in __ebt_load_watcher()
509 watcher->t = xtables_calloc(1, size); in __ebt_load_watcher()
510 watcher->t->u.target_size = size; in __ebt_load_watcher()
511 snprintf(watcher->t->u.user.name, in __ebt_load_watcher()
512 sizeof(watcher->t->u.user.name), "%s", name); in __ebt_load_watcher()
513 watcher->t->u.user.name[sizeof(watcher->t->u.user.name)-1] = '\0'; in __ebt_load_watcher()
514 watcher->t->u.user.revision = watcher->revision; in __ebt_load_watcher()
[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/rust/crates/grpcio-sys/grpc/src/core/lib/security/credentials/tls/ |
| D | grpc_tls_certificate_distributor.cc | 158 for (const auto& watcher : watchers_) { in SetError() local
159 const auto watcher_ptr = watcher.first; in SetError()
161 const auto& watcher_info = watcher.second; in SetError()
177 std::unique_ptr<TlsCertificatesWatcherInterface> watcher, in WatchTlsCertificates() argument
185 TlsCertificatesWatcherInterface* watcher_ptr = watcher.get(); in WatchTlsCertificates()
194 watchers_[watcher_ptr] = {std::move(watcher), root_cert_name, in WatchTlsCertificates()
264 TlsCertificatesWatcherInterface* watcher) { in CancelTlsCertificatesWatch() argument
274 auto it = watchers_.find(watcher); in CancelTlsCertificatesWatch()
284 cert_info.root_cert_watchers.erase(watcher); in CancelTlsCertificatesWatch()
296 cert_info.identity_cert_watchers.erase(watcher); in CancelTlsCertificatesWatch()
|