| /external/cronet/stable/base/allocator/dispatcher/internal/ |
| D | dispatcher_internal_unittest.cc | 190 std::array<ObserverMock, 1> observers; in TEST_F() local
193 GetNotificationHooks(CreateTupleOfPointers(observers)); in TEST_F()
209 std::array<ObserverMock, kMaximumNumberOfObservers> observers; in TEST_F() local
211 for (auto& mock : observers) { in TEST_F()
220 GetNotificationHooks(CreateTupleOfPointers(observers)); in TEST_F()
230 std::array<ObserverMock, kMaximumNumberOfObservers> observers; in TEST_F() local
232 for (auto& mock : observers) { in TEST_F()
239 GetNotificationHooks(CreateTupleOfPointers(observers)); in TEST_F()
247 std::array<ObserverMock, 1> observers; in TEST_F() local
250 GetNotificationHooks(CreateTupleOfPointers(observers)); in TEST_F()
[all …]
|
| D | dispatcher_internal.h | 37 void inline PerformObserverCheck(const std::tuple<ObserverTypes...>& observers, in PerformObserverCheck() argument
40 ([](bool b) { DCHECK(b); }(check_observer(std::get<Indices>(observers))), in PerformObserverCheck()
46 const std::tuple<ObserverTypes...>& observers, in PerformAllocationNotification() argument
49 ((std::get<Indices>(observers)->OnAllocation(notification_data)), ...); in PerformAllocationNotification()
54 const std::tuple<ObserverTypes...>& observers, in PerformFreeNotification() argument
57 ((std::get<Indices>(observers)->OnFree(notification_data)), ...); in PerformFreeNotification()
75 std::tuple<ObserverTypes*...> observers) { in GetNotificationHooks()
76 s_observers = std::move(observers); in GetNotificationHooks()
371 std::tuple<ObserverTypes*...> observers) {
373 std::move(observers));
|
| /external/cronet/tot/base/allocator/dispatcher/internal/ |
| D | dispatcher_internal_unittest.cc | 190 std::array<ObserverMock, 1> observers; in TEST_F() local
193 GetNotificationHooks(CreateTupleOfPointers(observers)); in TEST_F()
209 std::array<ObserverMock, kMaximumNumberOfObservers> observers; in TEST_F() local
211 for (auto& mock : observers) { in TEST_F()
220 GetNotificationHooks(CreateTupleOfPointers(observers)); in TEST_F()
230 std::array<ObserverMock, kMaximumNumberOfObservers> observers; in TEST_F() local
232 for (auto& mock : observers) { in TEST_F()
239 GetNotificationHooks(CreateTupleOfPointers(observers)); in TEST_F()
247 std::array<ObserverMock, 1> observers; in TEST_F() local
250 GetNotificationHooks(CreateTupleOfPointers(observers)); in TEST_F()
[all …]
|
| D | dispatcher_internal.h | 37 void inline PerformObserverCheck(const std::tuple<ObserverTypes...>& observers, in PerformObserverCheck() argument
40 ([](bool b) { DCHECK(b); }(check_observer(std::get<Indices>(observers))), in PerformObserverCheck()
46 const std::tuple<ObserverTypes...>& observers, in PerformAllocationNotification() argument
49 ((std::get<Indices>(observers)->OnAllocation(notification_data)), ...); in PerformAllocationNotification()
54 const std::tuple<ObserverTypes...>& observers, in PerformFreeNotification() argument
57 ((std::get<Indices>(observers)->OnFree(notification_data)), ...); in PerformFreeNotification()
75 std::tuple<ObserverTypes*...> observers) { in GetNotificationHooks()
76 s_observers = std::move(observers); in GetNotificationHooks()
371 std::tuple<ObserverTypes*...> observers) {
373 std::move(observers));
|
| /external/cronet/stable/base/power_monitor/ |
| D | power_monitor_unittest.cc | 43 PowerMonitorTestObserver observers[kObservers]; in TEST_F() local
45 for (auto& index : observers) { in TEST_F()
53 EXPECT_EQ(observers[0].resumes(), 0); in TEST_F()
58 for (const auto& index : observers) in TEST_F()
63 EXPECT_EQ(observers[0].suspends(), 1); in TEST_F()
67 EXPECT_EQ(observers[0].resumes(), 1); in TEST_F()
71 EXPECT_EQ(observers[0].resumes(), 1); in TEST_F()
76 EXPECT_EQ(observers[0].power_state_changes(), 1); in TEST_F()
77 EXPECT_EQ(observers[0].last_power_status(), in TEST_F()
83 EXPECT_EQ(observers[0].power_state_changes(), 1); in TEST_F()
[all …]
|
| /external/cronet/tot/base/power_monitor/ |
| D | power_monitor_unittest.cc | 43 PowerMonitorTestObserver observers[kObservers]; in TEST_F() local
45 for (auto& index : observers) { in TEST_F()
53 EXPECT_EQ(observers[0].resumes(), 0); in TEST_F()
58 for (const auto& index : observers) in TEST_F()
63 EXPECT_EQ(observers[0].suspends(), 1); in TEST_F()
67 EXPECT_EQ(observers[0].resumes(), 1); in TEST_F()
71 EXPECT_EQ(observers[0].resumes(), 1); in TEST_F()
76 EXPECT_EQ(observers[0].power_state_changes(), 1); in TEST_F()
77 EXPECT_EQ(observers[0].last_power_status(), in TEST_F()
83 EXPECT_EQ(observers[0].power_state_changes(), 1); in TEST_F()
[all …]
|
| /external/libchrome/base/power_monitor/ |
| D | power_monitor_unittest.cc | 38 PowerMonitorTestObserver observers[kObservers]; in TEST_F() local
40 monitor()->AddObserver(&observers[index]); in TEST_F()
44 EXPECT_EQ(observers[0].resumes(), 0); in TEST_F()
50 EXPECT_EQ(observers[index].suspends(), 1); in TEST_F()
54 EXPECT_EQ(observers[0].suspends(), 1); in TEST_F()
58 EXPECT_EQ(observers[0].resumes(), 1); in TEST_F()
62 EXPECT_EQ(observers[0].resumes(), 1); in TEST_F()
66 EXPECT_EQ(observers[0].power_state_changes(), 1); in TEST_F()
67 EXPECT_EQ(observers[0].last_power_state(), true); in TEST_F()
71 EXPECT_EQ(observers[0].power_state_changes(), 1); in TEST_F()
[all …]
|
| /external/tensorflow/tensorflow/python/debug/wrappers/ |
| D | local_cli_wrapper_test.py | 78 self.observers = {
96 self.observers["debug_dumps"].append(debug_dump)
97 self.observers["tf_errors"].append(tf_error)
100 self.observers["profiler_py_graphs"].append(py_graph)
101 self.observers["profiler_run_metadata"].append(run_metadata)
105 self.observers["run_start_cli_run_numbers"].append(self._run_call_count)
107 self.observers["run_end_cli_run_numbers"].append(self._run_call_count)
123 self.observers["print_feed_responses"].append(
208 self.assertEqual([1], wrapped_sess.observers["run_start_cli_run_numbers"])
209 self.assertEqual([1, 2], wrapped_sess.observers["run_end_cli_run_numbers"])
[all …]
|
| /external/apache-commons-io/src/main/java/org/apache/commons/io/monitor/ |
| D | FileAlterationMonitor.java | 42 private final List<FileAlterationObserver> observers = new CopyOnWriteArrayList<>(); field in FileAlterationMonitor
72 …ic FileAlterationMonitor(final long interval, final Collection<FileAlterationObserver> observers) { in FileAlterationMonitor() argument
76 .ofNullable(observers) in FileAlterationMonitor()
90 public FileAlterationMonitor(final long interval, final FileAlterationObserver... observers) { in FileAlterationMonitor() argument
92 if (observers != null) { in FileAlterationMonitor()
93 Stream.of(observers).forEach(this::addObserver); in FileAlterationMonitor()
104 observers.add(observer); in addObserver()
124 return observers; in getObservers()
134 observers.removeIf(observer::equals); in removeObserver()
144 observers.forEach(FileAlterationObserver::checkAndNotify); in run()
[all …]
|
| /external/apache-commons-io/src/main/java/org/apache/commons/io/input/ |
| D | ObservableInputStream.java | 110 private final List<Observer> observers; field in ObservableInputStream
127 private ObservableInputStream(final InputStream inputStream, final List<Observer> observers) { in ObservableInputStream() argument
129 this.observers = observers; in ObservableInputStream()
139 public ObservableInputStream(final InputStream inputStream, final Observer... observers) { in ObservableInputStream() argument
140 this(inputStream, Arrays.asList(observers)); in ObservableInputStream()
149 observers.add(observer); in add()
177 IOConsumer.forAll(action, observers); in forEachObserver()
187 return observers; in getObservers()
306 observers.remove(observer); in remove()
313 observers.clear(); in removeAllObservers()
|
| /external/python/watchdog/src/watchdog/observers/ |
| D | __init__.py | 46 from watchdog.observers.api import BaseObserver
56 from watchdog.observers.inotify import InotifyObserver
61 from watchdog.observers.fsevents import FSEventsObserver
64 from watchdog.observers.kqueue import KqueueObserver
74 from watchdog.observers.read_directory_changes import WindowsApiObserver
80 from watchdog.observers.kqueue import KqueueObserver
84 from watchdog.observers.polling import PollingObserver
|
| /external/python/watchdog/ |
| D | tox.ini | 49 src/watchdog/observers/fsevents.py \
50 src/watchdog/observers/fsevents2.py
52 src/watchdog/observers/kqueue.py
54 src/watchdog/observers/inotify.py \
55 src/watchdog/observers/inotify_buffer.py \
56 src/watchdog/observers/inotify_c.py
58 src/watchdog/observers/read_directory_changes.py \
59 src/watchdog/observers/winapi.py
|
| /external/setupdesign/main/src/com/google/android/setupdesign/items/ |
| D | AbstractItemHierarchy.java | 36 private final ArrayList<Observer> observers = new ArrayList<>(); field in AbstractItemHierarchy
61 observers.add(observer); in registerObserver()
66 observers.remove(observer); in unregisterObserver()
71 for (Observer observer : observers) { in notifyChanged()
87 for (Observer observer : observers) { in notifyItemRangeChanged()
103 for (Observer observer : observers) { in notifyItemRangeInserted()
123 for (Observer observer : observers) { in notifyItemRangeMoved()
139 for (Observer observer : observers) { in notifyItemRangeRemoved()
|
| /external/rust/android-crates-io/crates/crossbeam-channel/src/ |
| D | waker.rs | 33 observers: Vec<Entry>, field
42 observers: Vec::new(), in new()
126 self.observers.push(Entry { in watch()
136 self.observers.retain(|e| e.oper != oper); in unwatch()
142 for entry in self.observers.drain(..) { in notify()
171 debug_assert_eq!(self.observers.len(), 0); in drop()
202 inner.selectors.is_empty() && inner.observers.is_empty(), in register()
213 inner.selectors.is_empty() && inner.observers.is_empty(), in unregister()
228 inner.selectors.is_empty() && inner.observers.is_empty(), in notify()
241 inner.selectors.is_empty() && inner.observers.is_empty(), in watch()
[all …]
|
| /external/python/watchdog/docs/source/ |
| D | api.rst | 15 `watchdog.observers.api`
18 .. automodule:: watchdog.observers.api
50 `watchdog.observers`
53 .. automodule:: watchdog.observers
56 `watchdog.observers.polling`
59 .. automodule:: watchdog.observers.polling
|
| /external/autotest/client/cros/bluetooth/floss/ |
| D | observer_base.py | 16 self.observers = {}
26 if name not in self.observers:
27 self.observers[name] = observer
35 if name in self.observers:
36 del self.observers[name]
|
| /external/cronet/tot/base/allocator/dispatcher/ |
| D | dispatcher_unittest.cc | 60 explicit DispatcherInitializerGuard(std::tuple<Observers*...> observers) { in DispatcherInitializerGuard()
61 Dispatcher::GetInstance().Initialize(observers); in DispatcherInitializerGuard()
74 std::array<ObserverMock, kMaximumNumberOfObservers> observers; in DoBasicTest() local
78 testing::CreateTupleOfPointers(observers)); in DoBasicTest()
85 for (const auto& mock : observers) { in DoBasicTest()
92 std::array<ObserverMock, kMaximumNumberOfObservers> observers; in TEST_F() local
94 DispatcherInitializerGuard g(testing::CreateTupleOfPointers(observers)); in TEST_F()
|
| /external/cronet/stable/base/allocator/dispatcher/ |
| D | dispatcher_unittest.cc | 60 explicit DispatcherInitializerGuard(std::tuple<Observers*...> observers) { in DispatcherInitializerGuard()
61 Dispatcher::GetInstance().Initialize(observers); in DispatcherInitializerGuard()
74 std::array<ObserverMock, kMaximumNumberOfObservers> observers; in DoBasicTest() local
78 testing::CreateTupleOfPointers(observers)); in DoBasicTest()
85 for (const auto& mock : observers) { in DoBasicTest()
92 std::array<ObserverMock, kMaximumNumberOfObservers> observers; in TEST_F() local
94 DispatcherInitializerGuard g(testing::CreateTupleOfPointers(observers)); in TEST_F()
|
| /external/python/watchdog/src/watchdog/ |
| D | watchmedo.py | 28 from watchdog.observers import ObserverType
29 from watchdog.observers.api import BaseObserver
264 from watchdog.observers.polling import PollingObserver
268 from watchdog.observers.kqueue import KqueueObserver
272 from watchdog.observers.read_directory_changes import WindowsApiObserver
276 from watchdog.observers.inotify import InotifyObserver
280 from watchdog.observers.fsevents import FSEventsObserver
286 from watchdog.observers import Observer
291 observers = []
312 observers.append(observer)
[all …]
|
| /external/tensorflow/tensorflow/python/debug/cli/ |
| D | readline_ui_test.py | 43 self.observers = {"screen_outputs": []}
51 self.observers["screen_outputs"].append(screen_output)
108 self.assertEqual(0, len(ui.observers["screen_outputs"]))
115 self.assertEqual(1, len(ui.observers["screen_outputs"]))
125 screen_outputs = ui.observers["screen_outputs"]
136 screen_outputs = ui.observers["screen_outputs"]
148 screen_outputs = ui.observers["screen_outputs"]
165 self.assertEqual(0, len(ui.observers["screen_outputs"]))
177 screen_outputs = ui.observers["screen_outputs"]
190 outputs = ui.observers["screen_outputs"]
|
| /external/apache-commons-io/src/test/java/org/apache/commons/io/monitor/ |
| D | FileAlterationMonitorTest.java | 69 FileAlterationObserver[] observers = null; in testAddRemoveObservers() local
72 FileAlterationMonitor monitor = new FileAlterationMonitor(123, observers); in testAddRemoveObservers()
77 observers = new FileAlterationObserver[1]; // observer is null in testAddRemoveObservers()
78 monitor = new FileAlterationMonitor(456, observers); in testAddRemoveObservers()
102 final Collection<FileAlterationObserver> observers = Arrays.asList(observer); in testCollectionConstructor() local
103 final FileAlterationMonitor monitor = new FileAlterationMonitor(0, observers); in testCollectionConstructor()
110 final Collection<FileAlterationObserver> observers = null; in testCollectionConstructorShouldDoNothingWithNullCollection() local
111 final FileAlterationMonitor monitor = new FileAlterationMonitor(0, observers); in testCollectionConstructorShouldDoNothingWithNullCollection()
117 final Collection<FileAlterationObserver> observers = new ArrayList<>(5); in testCollectionConstructorShouldDoNothingWithNullObservers() local
118 final FileAlterationMonitor monitor = new FileAlterationMonitor(0, observers); in testCollectionConstructorShouldDoNothingWithNullObservers()
|
| /external/python/watchdog/tests/ |
| D | utils.py | 9 from watchdog.observers.api import EventEmitter, ObservedWatch
15 from watchdog.observers.inotify import InotifyEmitter as Emitter
16 from watchdog.observers.inotify import InotifyFullEmitter
18 from watchdog.observers.fsevents import FSEventsEmitter as Emitter
20 from watchdog.observers.read_directory_changes import WindowsApiEmitter as Emitter
22 from watchdog.observers.kqueue import KqueueEmitter as Emitter
72 from watchdog.observers.fsevents import FSEventsEmitter
|
| /external/android_onboarding/java/com/android/onboarding/nodes/ |
| D | DefaultOnboardingGraphLog.kt | 5 private val observers = mutableSetOf<OnboardingGraphLog.Observer>() constant
8 observers.add(observer) in addObserver()
12 observers.remove(observer) in removeObserver()
16 observers.forEach { it.onEvent(event) } in log()
|
| /external/webrtc/video/ |
| D | video_send_stream.cc | 95 RtpSenderObservers observers; in CreateObservers() local
96 observers.rtcp_rtt_stats = call_stats; in CreateObservers()
97 observers.intra_frame_callback = encoder_feedback; in CreateObservers()
98 observers.rtcp_loss_notification_observer = encoder_feedback; in CreateObservers()
99 observers.report_block_data_observer = stats_proxy; in CreateObservers()
100 observers.rtp_stats = stats_proxy; in CreateObservers()
101 observers.bitrate_observer = stats_proxy; in CreateObservers()
102 observers.frame_count_observer = stats_proxy; in CreateObservers()
103 observers.rtcp_type_observer = stats_proxy; in CreateObservers()
104 observers.send_delay_observer = stats_proxy; in CreateObservers()
[all …]
|
| /external/apache-commons-bcel/src/main/java/org/apache/bcel/verifier/ |
| D | VerifierFactory.java | 43 private static final List<VerifierFactoryObserver> observers = new Vector<>(); field in VerifierFactory
74 for (final VerifierFactoryObserver vfo : observers) { in notify()
97 observers.add(o); in attach()
105 observers.remove(o); in detach()
|