| /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 | 82 self.observers = {
100 self.observers["debug_dumps"].append(debug_dump)
101 self.observers["tf_errors"].append(tf_error)
104 self.observers["profiler_py_graphs"].append(py_graph)
105 self.observers["profiler_run_metadata"].append(run_metadata)
109 self.observers["run_start_cli_run_numbers"].append(self._run_call_count)
111 self.observers["run_end_cli_run_numbers"].append(self._run_call_count)
127 self.observers["print_feed_responses"].append(
221 self.assertEqual([1], wrapped_sess.observers["run_start_cli_run_numbers"])
222 self.assertEqual([1, 2], wrapped_sess.observers["run_end_cli_run_numbers"])
[all …]
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | waker.rs | 31 observers: Vec<Entry>, field
40 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/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/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-subject.hpp | 57 observers.push_back(o); in completer_type()
66 observers.reserve(old->observers.size() + 1); in retain()
68 old->observers.begin(), old->observers.end(), in retain()
69 std::inserter(observers, observers.end()), in retain()
76 list_type observers; member
129 return b->completer && !b->completer->observers.empty(); in has_observers()
185 if (!current_completer || current_completer->observers.empty()) { in on_next()
188 for (auto& o : current_completer->observers) { in on_next()
204 for (auto& o : c->observers) { in on_error()
222 for (auto& o : c->observers) { in on_completed()
|
| /external/tensorflow/tensorflow/python/debug/cli/ |
| D | readline_ui_test.py | 45 self.observers = {"screen_outputs": []}
53 self.observers["screen_outputs"].append(screen_output)
110 self.assertEqual(0, len(ui.observers["screen_outputs"]))
117 self.assertEqual(1, len(ui.observers["screen_outputs"]))
127 screen_outputs = ui.observers["screen_outputs"]
138 screen_outputs = ui.observers["screen_outputs"]
150 screen_outputs = ui.observers["screen_outputs"]
167 self.assertEqual(0, len(ui.observers["screen_outputs"]))
179 screen_outputs = ui.observers["screen_outputs"]
192 outputs = ui.observers["screen_outputs"]
|
| /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()
|
| /external/apache-commons-bcel/src/main/java/org/apache/bcel/generic/ |
| D | FieldGen.java | 265 private List<FieldObserver> observers; field in FieldGen
271 if (observers == null) { in addObserver()
272 observers = new ArrayList<>(); in addObserver()
274 observers.add(o); in addObserver()
281 if (observers != null) { in removeObserver()
282 observers.remove(o); in removeObserver()
292 if (observers != null) { in update()
293 for (final FieldObserver observer : observers ) { in update()
|
| D | ClassGen.java | 523 private List<ClassObserver> observers; field in ClassGen
529 if (observers == null) { in addObserver()
530 observers = new ArrayList<>(); in addObserver()
532 observers.add(o); in addObserver()
539 if (observers != null) { in removeObserver()
540 observers.remove(o); in removeObserver()
550 if (observers != null) { in update()
551 for (final ClassObserver observer : observers) { in update()
|
| D | InstructionList.java | 1225 private List<InstructionListObserver> observers;
1231 if (observers == null) { in addObserver()
1232 observers = new ArrayList<>(); in addObserver()
1234 observers.add(o); in addObserver()
1241 if (observers != null) { in removeObserver()
1242 observers.remove(o); in removeObserver()
1251 if (observers != null) { in update()
1252 for (final InstructionListObserver observer : observers) { in update()
|
| /external/webrtc/video/ |
| D | video_send_stream_impl.cc | 139 RtpSenderObservers observers; in CreateObservers() local
140 observers.rtcp_rtt_stats = call_stats; in CreateObservers()
141 observers.intra_frame_callback = encoder_feedback; in CreateObservers()
142 observers.rtcp_loss_notification_observer = encoder_feedback; in CreateObservers()
143 observers.rtcp_stats = stats_proxy; in CreateObservers()
144 observers.report_block_data_observer = stats_proxy; in CreateObservers()
145 observers.rtp_stats = stats_proxy; in CreateObservers()
146 observers.bitrate_observer = stats_proxy; in CreateObservers()
147 observers.frame_count_observer = stats_proxy; in CreateObservers()
148 observers.rtcp_type_observer = stats_proxy; in CreateObservers()
[all …]
|
| /external/libchrome/base/system_monitor/ |
| D | system_monitor_unittest.cc | 35 MockDevicesChangedObserver observers[kObservers]; in TEST_F() local
37 system_monitor_->AddDevicesChangedObserver(&observers[index]); in TEST_F()
39 EXPECT_CALL(observers[index], in TEST_F()
|
| /external/webrtc/api/ |
| D | notifier.h | 47 std::list<ObserverInterface*> observers = observers_; in FireOnChanged() local
48 for (std::list<ObserverInterface*>::iterator it = observers.begin(); in FireOnChanged()
49 it != observers.end(); ++it) { in FireOnChanged()
|
| /external/webrtc/test/pc/e2e/ |
| D | stats_poller.h | 33 std::vector<StatsObserverInterface*> observers) in InternalStatsObserver() argument
36 observers_(std::move(observers)) {} in InternalStatsObserver()
54 StatsPoller(std::vector<StatsObserverInterface*> observers,
|
| D | stats_poller.cc | 31 StatsPoller::StatsPoller(std::vector<StatsObserverInterface*> observers, in StatsPoller() argument
35 peer.first, peer.second, observers)); in StatsPoller()
|
| /external/skia/modules/sksg/src/ |
| D | SkSGNode.cpp | 67 auto observers = new std::vector<Node*>(); in observeInval() local
68 observers->reserve(2); in observeInval()
69 observers->push_back(node->fInvalObserver); in observeInval()
71 node->fInvalObserverArray = observers; in observeInval()
|
| /external/skqp/modules/sksg/src/ |
| D | SkSGNode.cpp | 66 auto observers = new std::vector<Node*>(); in observeInval() local
67 observers->reserve(2); in observeInval()
68 observers->push_back(node->fInvalObserver); in observeInval()
70 node->fInvalObserverArray = observers; in observeInval()
|
| /external/javaparser/javaparser-core/src/main/java/com/github/javaparser/ast/ |
| D | NodeList.java | 53 private List<AstObserver> observers = new ArrayList<>(); field in NodeList
466 …this.observers.forEach(o -> o.listChange(this, AstObserver.ListChangeType.ADDITION, index, nodeAdd… in notifyElementAdded()
470 …this.observers.forEach(o -> o.listChange(this, AstObserver.ListChangeType.REMOVAL, index, nodeAdde… in notifyElementRemoved()
474 … this.observers.forEach(o -> o.listReplacement(this, index, this.get(index), nodeAddedOrRemoved)); in notifyElementReplaced()
479 this.observers.remove(observer); in unregister()
484 if(!this.observers.contains(observer)) { in register()
485 this.observers.add(observer); in register()
491 return this.observers.contains(observer); in isRegistered()
|
| D | Node.java | 172 private List<AstObserver> observers = new ArrayList<>(); field in Node
379 observers.forEach(o -> o.parentChange(this, parentNode, newParentNode)); in setParentNode()
563 this.observers.forEach(o -> o.propertyChange(this, property, oldValue, newValue)); in notifyPropertyChange()
568 this.observers.remove(observer); in unregister()
573 this.observers.add(observer); in register()
616 return this.observers.contains(observer); in isRegistered()
|
| /external/webrtc/call/ |
| D | rtp_video_sender.cc | 189 const RtpSenderObservers& observers, in CreateRtpStreamSenders() argument
209 configuration.intra_frame_callback = observers.intra_frame_callback; in CreateRtpStreamSenders()
211 observers.rtcp_loss_notification_observer; in CreateRtpStreamSenders()
217 configuration.rtt_stats = observers.rtcp_rtt_stats; in CreateRtpStreamSenders()
219 observers.rtcp_type_observer; in CreateRtpStreamSenders()
220 configuration.rtcp_statistics_callback = observers.rtcp_stats; in CreateRtpStreamSenders()
222 observers.report_block_data_observer; in CreateRtpStreamSenders()
224 configuration.send_bitrate_observer = observers.bitrate_observer; in CreateRtpStreamSenders()
225 configuration.send_side_delay_observer = observers.send_delay_observer; in CreateRtpStreamSenders()
226 configuration.send_packet_observer = observers.send_packet_observer; in CreateRtpStreamSenders()
[all …]
|
| D | rtp_video_sender_unittest.cc | 73 RtpSenderObservers observers; in CreateObservers() local
74 observers.rtcp_rtt_stats = rtcp_rtt_stats; in CreateObservers()
75 observers.intra_frame_callback = intra_frame_callback; in CreateObservers()
76 observers.rtcp_loss_notification_observer = nullptr; in CreateObservers()
77 observers.rtcp_stats = rtcp_stats; in CreateObservers()
78 observers.report_block_data_observer = report_block_data_observer; in CreateObservers()
79 observers.rtp_stats = rtp_stats; in CreateObservers()
80 observers.bitrate_observer = bitrate_observer; in CreateObservers()
81 observers.frame_count_observer = frame_count_observer; in CreateObservers()
82 observers.rtcp_type_observer = rtcp_type_observer; in CreateObservers()
[all …]
|
| /external/openscreen/osp/impl/presentation/ |
| D | url_availability_requester.cc | 79 auto& observers = observer_entry->second; in RemoveObserverUrls() local
80 observers.erase(std::remove(observers.begin(), observers.end(), observer), in RemoveObserverUrls()
81 observers.end()); in RemoveObserverUrls()
82 if (observers.empty()) { in RemoveObserverUrls()
288 std::vector<ReceiverObserver*>& observers = observer_entry->second; in UpdateAvailabilities() local
296 for (auto* observer : observers) in UpdateAvailabilities()
301 for (auto* observer : observers) in UpdateAvailabilities()
|
| /external/webrtc/modules/rtp_rtcp/source/ |
| D | rtcp_transceiver_impl.cc | 52 std::vector<MediaReceiverRtcpObserver*> observers; member
106 auto& stored = remote_senders_[remote_ssrc].observers; in AddMediaReceiverRtcpObserver()
117 auto& stored = remote_sender_it->second.observers; in RemoveMediaReceiverRtcpObserver()
253 for (MediaReceiverRtcpObserver* observer : remote_sender_it->second.observers) in HandleBye()
271 for (MediaReceiverRtcpObserver* observer : remote_sender.observers) in HandleSenderReport()
312 remote_sender_it->second.observers.empty()) in HandleTargetBitrate()
331 for (MediaReceiverRtcpObserver* observer : remote_sender_it->second.observers) in HandleTargetBitrate()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | window.cpp | 93 auto observers = std::vector<rxt::testable_observer<int>>(); variable
111 observers.push_back(result.get_observer()); in __anona1a75c020302()
121 REQUIRE(5 == observers.size());
131 auto actual = observers[0].messages();
142 auto actual = observers[1].messages();
153 auto actual = observers[2].messages();
163 auto actual = observers[3].messages();
171 auto actual = observers[4].messages();
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/ |
| D | subscription.cpp | 14 auto observers = std::make_shared<std::list<rxcpp::subscriber<int>>>(); variable
17 auto it = observers->insert(observers->end(), out); in __anon1ab139c80102()
19 observers->erase(it); in __anon1ab139c80102()
|