| /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/libwebsockets/lib/event-libs/libev/ |
| D | libev.c | 28 lws_ev_hrtimer_cb(struct ev_loop *loop, struct ev_timer *watcher, int revents) in lws_ev_hrtimer_cb() argument
31 (struct lws_context_per_thread *)watcher->data; in lws_ev_hrtimer_cb()
79 lws_accept_cb(struct ev_loop *loop, struct ev_io *watcher, int revents) in lws_accept_cb() argument
81 struct lws_io_watcher *lws_io = lws_container_of(watcher, in lws_accept_cb()
82 struct lws_io_watcher, ev.watcher); in lws_accept_cb()
91 eventfd.fd = watcher->fd; in lws_accept_cb()
104 wsi = wsi_from_fd(context, watcher->fd); in lws_accept_cb()
113 lws_ev_sigint_cb(struct ev_loop *loop, struct ev_signal *watcher, int revents) in lws_ev_sigint_cb() argument
115 struct lws_context *context = watcher->data; in lws_ev_sigint_cb()
118 context->eventlib_signal_cb((void *)watcher, watcher->signum); in lws_ev_sigint_cb()
[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/libwebsockets/lib/event-libs/libevent/ |
| D | libevent.c | 108 event_del(lws_io->event.watcher); in lws_event_cb()
109 event_free(lws_io->event.watcher); in lws_event_cb()
195 vh->lserv_wsi->w_read.event.watcher = event_new( in elops_init_pt_event()
199 event_add(vh->lserv_wsi->w_read.event.watcher, NULL); in elops_init_pt_event()
217 pt->w_sigint.event.watcher = evsignal_new(loop, SIGINT, in elops_init_pt_event()
219 event_add(pt->w_sigint.event.watcher, NULL); in elops_init_pt_event()
256 wsi->w_read.event.watcher = event_new(pt->event.io_loop, fd, in elops_accept_event()
258 wsi->w_write.event.watcher = event_new(pt->event.io_loop, fd, in elops_accept_event()
278 event_add(wsi->w_write.event.watcher, NULL); in elops_io_event()
281 event_add(wsi->w_read.event.watcher, NULL); in elops_io_event()
[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/test/test_asyncio/ |
| D | test_unix_events.py | 1102 watcher = asyncio.AbstractChildWatcher()
1104 NotImplementedError, watcher.add_child_handler, f, f)
1106 NotImplementedError, watcher.remove_child_handler, f)
1108 NotImplementedError, watcher.attach_loop, f)
1110 NotImplementedError, watcher.close)
1112 NotImplementedError, watcher.is_active)
1114 NotImplementedError, watcher.__enter__)
1116 NotImplementedError, watcher.__exit__, f, f, f)
1123 watcher = unix_events.BaseChildWatcher()
1125 NotImplementedError, watcher._do_waitpid, f)
[all …]
|
| /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/Lib/unittest/ |
| D | _log.py | 17 self.watcher = _LoggingWatcher([], [])
23 self.watcher.records.append(record)
25 self.watcher.output.append(msg)
50 self.watcher = handler.watcher
57 return handler.watcher
66 if len(self.watcher.records) == 0:
|
| /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()
368 RefCountedPtr<Subchannel::ConnectivityStateWatcherInterface> watcher, in AsyncWatcherNotifierLocked() argument
371 : watcher_(std::move(watcher)) { in AsyncWatcherNotifierLocked()
401 RefCountedPtr<ConnectivityStateWatcherInterface> watcher) { in AddWatcherLocked() argument
402 watchers_.insert(std::make_pair(watcher.get(), std::move(watcher))); in AddWatcherLocked()
406 ConnectivityStateWatcherInterface* watcher) { in RemoveWatcherLocked() argument
407 watchers_.erase(watcher); in RemoveWatcherLocked()
450 RefCountedPtr<Subchannel::ConnectivityStateWatcherInterface> watcher) { in AddWatcherLocked() argument
452 new AsyncWatcherNotifierLocked(watcher, subchannel_, state_, status_); in AddWatcherLocked()
[all …]
|
| /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/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* pollset_kick_locked(grpc_fd_watcher* watcher) { argument
398 gpr_mu_lock(&watcher->pollset->mu);
399 GPR_ASSERT(watcher->worker);
400 grpc_error* err = pollset_kick_ext(watcher->pollset, watcher->worker,
402 gpr_mu_unlock(&watcher->pollset->mu);
417 grpc_fd_watcher* watcher; local
418 for (watcher = fd->inactive_watcher_root.next;
419 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/rust/crates/grpcio-sys/grpc/src/core/ext/xds/ |
| D | xds_server_config_fetcher.cc | 37 watcher) override { in StartWatch()
38 grpc_server_config_fetcher::WatcherInterface* watcher_ptr = watcher.get(); in StartWatch()
40 absl::make_unique<ListenerWatcher>(std::move(watcher)); in StartWatch()
54 grpc_server_config_fetcher::WatcherInterface* watcher) override { in CancelWatch() argument
56 auto it = watchers_.find(watcher); in CancelWatch()
|
| D | xds_client.h | 119 std::unique_ptr<ListenerWatcherInterface> watcher);
121 ListenerWatcherInterface* watcher,
133 std::unique_ptr<RouteConfigWatcherInterface> watcher);
135 RouteConfigWatcherInterface* watcher,
146 std::unique_ptr<ClusterWatcherInterface> watcher);
148 ClusterWatcherInterface* watcher,
159 std::unique_ptr<EndpointWatcherInterface> watcher);
161 EndpointWatcherInterface* watcher,
|
| /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 | 157 for (const auto& watcher : watchers_) { in SetError() local
158 const auto watcher_ptr = watcher.first; in SetError()
160 const auto& watcher_info = watcher.second; in SetError()
176 std::unique_ptr<TlsCertificatesWatcherInterface> watcher, in WatchTlsCertificates() argument
184 TlsCertificatesWatcherInterface* watcher_ptr = watcher.get(); in WatchTlsCertificates()
193 watchers_[watcher_ptr] = {std::move(watcher), root_cert_name, in WatchTlsCertificates()
263 TlsCertificatesWatcherInterface* watcher) { in CancelTlsCertificatesWatch() argument
273 auto it = watchers_.find(watcher); in CancelTlsCertificatesWatch()
283 cert_info.root_cert_watchers.erase(watcher); in CancelTlsCertificatesWatch()
295 cert_info.identity_cert_watchers.erase(watcher); in CancelTlsCertificatesWatch()
|