| /external/python/watchdog/tests/ |
| D | test_observer.py | 18 def observer() -> Iterator[BaseObserver]: function
35 def test_schedule_should_start_emitter_if_running(observer): argument
36 observer.start()
37 observer.schedule(None, "")
38 (emitter,) = observer.emitters
42 def test_schedule_should_not_start_emitter_if_not_running(observer): argument
43 observer.schedule(None, "")
44 (emitter,) = observer.emitters
48 def test_start_should_start_emitter(observer): argument
49 observer.schedule(None, "")
[all …]
|
| /external/webrtc/video/ |
| D | stats_counter_unittest.cc | 65 StatsCounterObserverImpl* observer = new StatsCounterObserverImpl(); in TEST_F() local
67 AvgCounter counter(&clock_, observer, false); in TEST_F()
71 EXPECT_EQ(1, observer->num_calls_); in TEST_F()
82 StatsCounterObserverImpl* observer = new StatsCounterObserverImpl(); in TEST_F() local
83 AvgCounter counter(&clock_, observer, false); in TEST_F()
88 EXPECT_EQ(0, observer->num_calls_); in TEST_F()
94 EXPECT_EQ(1, observer->num_calls_); in TEST_F()
95 EXPECT_EQ(6, observer->last_sample_); in TEST_F()
102 StatsCounterObserverImpl* observer = new StatsCounterObserverImpl(); in TEST_F() local
103 AvgCounter counter(&clock_, observer, false); in TEST_F()
[all …]
|
| /external/cronet/tot/net/dns/ |
| D | system_dns_config_change_notifier_unittest.cc | 99 TestObserver observer; in LoadConfig() local
100 notifier_->AddObserver(&observer); in LoadConfig()
105 observer.WaitForNotification(); in LoadConfig()
111 observer.WaitForNotification(); in LoadConfig()
113 notifier_->RemoveObserver(&observer); in LoadConfig()
123 TestObserver observer; in TEST_F() local
125 notifier_->AddObserver(&observer); in TEST_F()
130 observer.WaitForNotification(); in TEST_F()
132 EXPECT_THAT(observer.configs_received(), in TEST_F()
134 observer.ExpectNoMoreNotifications(); in TEST_F()
[all …]
|
| /external/cronet/stable/net/dns/ |
| D | system_dns_config_change_notifier_unittest.cc | 99 TestObserver observer; in LoadConfig() local
100 notifier_->AddObserver(&observer); in LoadConfig()
105 observer.WaitForNotification(); in LoadConfig()
111 observer.WaitForNotification(); in LoadConfig()
113 notifier_->RemoveObserver(&observer); in LoadConfig()
123 TestObserver observer; in TEST_F() local
125 notifier_->AddObserver(&observer); in TEST_F()
130 observer.WaitForNotification(); in TEST_F()
132 EXPECT_THAT(observer.configs_received(), in TEST_F()
134 observer.ExpectNoMoreNotifications(); in TEST_F()
[all …]
|
| /external/pdfium/core/fxcrt/ |
| D | shared_copy_on_write_unittest.cpp | 39 Object(Observer* observer, const std::string& name) in Object() argument
40 : name_(name), observer_(observer) { in Object()
41 observer->OnConstruct(name_); in Object()
55 Observer observer; in TEST() local
63 Observer observer; in TEST() local
66 ptr1.Emplace(&observer, std::string("one")); in TEST()
69 EXPECT_EQ(1, observer.GetConstructionCount("one")); in TEST()
70 EXPECT_EQ(0, observer.GetDestructionCount("one")); in TEST()
74 EXPECT_EQ(1, observer.GetConstructionCount("one")); in TEST()
75 EXPECT_EQ(0, observer.GetDestructionCount("one")); in TEST()
[all …]
|
| /external/libchrome/components/policy/core/common/ |
| D | schema_registry_unittest.cc | 69 MockSchemaRegistryObserver observer; in TEST() local
71 registry.AddObserver(&observer); in TEST()
77 EXPECT_CALL(observer, OnSchemaRegistryUpdated(true)); in TEST()
80 Mock::VerifyAndClearExpectations(&observer); in TEST()
84 EXPECT_CALL(observer, OnSchemaRegistryUpdated(true)); in TEST()
87 Mock::VerifyAndClearExpectations(&observer); in TEST()
92 EXPECT_CALL(observer, OnSchemaRegistryUpdated(false)); in TEST()
95 Mock::VerifyAndClearExpectations(&observer); in TEST()
105 EXPECT_CALL(observer, OnSchemaRegistryUpdated(true)); in TEST()
107 Mock::VerifyAndClearExpectations(&observer); in TEST()
[all …]
|
| D | async_policy_provider_unittest.cc | 134 MockConfigurationPolicyObserver observer; in TEST_F() local
135 provider_->AddObserver(&observer); in TEST_F()
136 EXPECT_CALL(observer, OnUpdatePolicy(provider_.get())).Times(1); in TEST_F()
141 provider_->RemoveObserver(&observer); in TEST_F()
149 MockConfigurationPolicyObserver observer; in TEST_F() local
150 provider_->AddObserver(&observer); in TEST_F()
151 EXPECT_CALL(observer, OnUpdatePolicy(provider_.get())).Times(0); in TEST_F()
154 Mock::VerifyAndClearExpectations(&observer); in TEST_F()
157 EXPECT_CALL(observer, OnUpdatePolicy(provider_.get())).Times(0); in TEST_F()
159 Mock::VerifyAndClearExpectations(&observer); in TEST_F()
[all …]
|
| /external/webrtc/pc/ |
| D | rtp_transport_unittest.cc | 79 SignalObserver observer(&transport); in TEST() local
86 EXPECT_FALSE(observer.ready()); in TEST()
88 EXPECT_TRUE(observer.ready()); in TEST()
93 SignalObserver observer(&transport); in TEST() local
100 EXPECT_FALSE(observer.ready()); in TEST()
102 EXPECT_TRUE(observer.ready()); in TEST()
107 SignalObserver observer(&transport); in TEST() local
112 EXPECT_TRUE(observer.ready()); in TEST()
117 SignalObserver observer(&transport); in TEST() local
122 EXPECT_TRUE(observer.ready()); in TEST()
[all …]
|
| D | peer_connection_message_handler.cc | 36 SetSessionDescriptionObserver* observer) { in PostSetSessionDescriptionSuccess() argument
39 [observer = WrapScoped(observer)] { observer->OnSuccess(); })); in PostSetSessionDescriptionSuccess()
43 SetSessionDescriptionObserver* observer, in PostSetSessionDescriptionFailure() argument
48 [observer = WrapScoped(observer), error = std::move(error)]() mutable { in PostSetSessionDescriptionFailure()
49 observer->OnFailure(std::move(error)); in PostSetSessionDescriptionFailure()
54 CreateSessionDescriptionObserver* observer, in PostCreateSessionDescriptionFailure() argument
60 [observer = WrapScoped(observer), error = std::move(error)]() mutable { in PostCreateSessionDescriptionFailure()
61 observer->OnFailure(std::move(error)); in PostCreateSessionDescriptionFailure()
66 StatsObserver* observer, in PostGetStats() argument
70 SafeTask(safety_.flag(), [observer = WrapScoped(observer), legacy_stats, in PostGetStats()
[all …]
|
| /external/pytorch/torch/ao/nn/quantized/modules/ |
| D | utils.py | 24 def _get_weight_observer(observer): argument
26 if hasattr(observer, "activation_post_process"):
27 observer = observer.activation_post_process
29 return observer
32 def _needs_weight_clamping(observer, dtype): argument
33 observer = _get_weight_observer(observer)
36 return observer.quant_min > info.min or observer.quant_max < info.max
40 def _clamp_weights(qweight, observer, scale, zp): argument
41 if not _needs_weight_clamping(observer, qweight.dtype):
44 observer = _get_weight_observer(observer)
[all …]
|
| /external/cronet/tot/net/base/ |
| D | network_change_notifier.cc | 658 void NetworkChangeNotifier::AddIPAddressObserver(IPAddressObserver* observer) { in AddIPAddressObserver() argument
659 DCHECK(!observer->observer_list_); in AddIPAddressObserver()
660 observer->observer_list_ = GetObserverList().ip_address_observer_list_; in AddIPAddressObserver()
661 observer->observer_list_->AddObserver(observer); in AddIPAddressObserver()
665 ConnectionTypeObserver* observer) { in AddConnectionTypeObserver() argument
666 DCHECK(!observer->observer_list_); in AddConnectionTypeObserver()
667 observer->observer_list_ = GetObserverList().connection_type_observer_list_; in AddConnectionTypeObserver()
668 observer->observer_list_->AddObserver(observer); in AddConnectionTypeObserver()
671 void NetworkChangeNotifier::AddDNSObserver(DNSObserver* observer) { in AddDNSObserver() argument
672 DCHECK(!observer->observer_list_); in AddDNSObserver()
[all …]
|
| D | network_change_notifier_passive_unittest.cc | 62 testing::StrictMock<MockIPAddressObserver> observer; in TEST_F() local
63 NetworkChangeNotifier::AddIPAddressObserver(&observer); in TEST_F()
65 EXPECT_CALL(observer, OnIPAddressChanged()); in TEST_F()
69 NetworkChangeNotifier::RemoveIPAddressObserver(&observer); in TEST_F()
79 testing::StrictMock<MockNetworkChangeObserver> observer; in TEST_F() local
80 NetworkChangeNotifier::AddNetworkChangeObserver(&observer); in TEST_F()
82 EXPECT_CALL(observer, in TEST_F()
84 EXPECT_CALL(observer, OnNetworkChanged(NetworkChangeNotifier::CONNECTION_3G)); in TEST_F()
88 NetworkChangeNotifier::RemoveNetworkChangeObserver(&observer); in TEST_F()
99 testing::StrictMock<MockMaxBandwidthObserver> observer; in TEST_F() local
[all …]
|
| /external/cronet/stable/net/base/ |
| D | network_change_notifier.cc | 658 void NetworkChangeNotifier::AddIPAddressObserver(IPAddressObserver* observer) { in AddIPAddressObserver() argument
659 DCHECK(!observer->observer_list_); in AddIPAddressObserver()
660 observer->observer_list_ = GetObserverList().ip_address_observer_list_; in AddIPAddressObserver()
661 observer->observer_list_->AddObserver(observer); in AddIPAddressObserver()
665 ConnectionTypeObserver* observer) { in AddConnectionTypeObserver() argument
666 DCHECK(!observer->observer_list_); in AddConnectionTypeObserver()
667 observer->observer_list_ = GetObserverList().connection_type_observer_list_; in AddConnectionTypeObserver()
668 observer->observer_list_->AddObserver(observer); in AddConnectionTypeObserver()
671 void NetworkChangeNotifier::AddDNSObserver(DNSObserver* observer) { in AddDNSObserver() argument
672 DCHECK(!observer->observer_list_); in AddDNSObserver()
[all …]
|
| D | network_change_notifier_passive_unittest.cc | 62 testing::StrictMock<MockIPAddressObserver> observer; in TEST_F() local
63 NetworkChangeNotifier::AddIPAddressObserver(&observer); in TEST_F()
65 EXPECT_CALL(observer, OnIPAddressChanged()); in TEST_F()
69 NetworkChangeNotifier::RemoveIPAddressObserver(&observer); in TEST_F()
79 testing::StrictMock<MockNetworkChangeObserver> observer; in TEST_F() local
80 NetworkChangeNotifier::AddNetworkChangeObserver(&observer); in TEST_F()
82 EXPECT_CALL(observer, in TEST_F()
84 EXPECT_CALL(observer, OnNetworkChanged(NetworkChangeNotifier::CONNECTION_3G)); in TEST_F()
88 NetworkChangeNotifier::RemoveNetworkChangeObserver(&observer); in TEST_F()
99 testing::StrictMock<MockMaxBandwidthObserver> observer; in TEST_F() local
[all …]
|
| /external/grpc-grpc-java/binder/src/test/java/io/grpc/binder/internal/ |
| D | ServiceBindingTest.java | 59 private TestObserver observer; field in ServiceBindingTest
66 observer = new TestObserver(); in setUp()
83 .setObserver(observer); in newBuilder()
89 assertThat(observer.gotBoundEvent).isFalse(); in testInitialState()
90 assertThat(observer.gotUnboundEvent).isFalse(); in testInitialState()
100 assertThat(observer.gotBoundEvent).isTrue(); in testBind()
101 assertThat(observer.binder).isSameInstanceAs(mockBinder); in testBind()
102 assertThat(observer.gotUnboundEvent).isFalse(); in testBind()
124 assertThat(observer.gotBoundEvent).isFalse(); in testUnbind()
125 assertThat(observer.gotUnboundEvent).isTrue(); in testUnbind()
[all …]
|
| /external/cronet/tot/net/log/ |
| D | net_log.cc | 89 void NetLog::AddObserver(NetLog::ThreadSafeObserver* observer, in AddObserver() argument
93 DCHECK(!observer->net_log_); in AddObserver()
94 DCHECK(!HasObserver(observer)); in AddObserver()
97 observers_.push_back(observer); in AddObserver()
99 observer->net_log_ = this; in AddObserver()
100 observer->capture_mode_ = capture_mode; in AddObserver()
104 void NetLog::RemoveObserver(NetLog::ThreadSafeObserver* observer) { in RemoveObserver() argument
107 DCHECK_EQ(this, observer->net_log_); in RemoveObserver()
109 auto it = base::ranges::find(observers_, observer); in RemoveObserver()
113 observer->net_log_ = nullptr; in RemoveObserver()
[all …]
|
| D | net_log_unittest.cc | 347 for (auto& observer : observers) { in TEST() local
348 NetLog::Get()->AddObserver(&observer, NetLogCaptureMode::kEverything); in TEST()
357 for (const auto& observer : observers) in TEST() local
358 EXPECT_EQ(kTotalEvents, observer.count()); in TEST()
363 CountingObserver observer; in TEST() local
366 EXPECT_EQ(0, observer.count()); in TEST()
367 EXPECT_EQ(nullptr, observer.net_log()); in TEST()
371 NetLog::Get()->AddObserver(&observer, NetLogCaptureMode::kIncludeSensitive); in TEST()
373 EXPECT_EQ(NetLog::Get(), observer.net_log()); in TEST()
374 EXPECT_EQ(NetLogCaptureMode::kIncludeSensitive, observer.capture_mode()); in TEST()
[all …]
|
| /external/cronet/stable/net/log/ |
| D | net_log.cc | 89 void NetLog::AddObserver(NetLog::ThreadSafeObserver* observer, in AddObserver() argument
93 DCHECK(!observer->net_log_); in AddObserver()
94 DCHECK(!HasObserver(observer)); in AddObserver()
97 observers_.push_back(observer); in AddObserver()
99 observer->net_log_ = this; in AddObserver()
100 observer->capture_mode_ = capture_mode; in AddObserver()
104 void NetLog::RemoveObserver(NetLog::ThreadSafeObserver* observer) { in RemoveObserver() argument
107 DCHECK_EQ(this, observer->net_log_); in RemoveObserver()
109 auto it = base::ranges::find(observers_, observer); in RemoveObserver()
113 observer->net_log_ = nullptr; in RemoveObserver()
[all …]
|
| D | net_log_unittest.cc | 347 for (auto& observer : observers) { in TEST() local
348 NetLog::Get()->AddObserver(&observer, NetLogCaptureMode::kEverything); in TEST()
357 for (const auto& observer : observers) in TEST() local
358 EXPECT_EQ(kTotalEvents, observer.count()); in TEST()
363 CountingObserver observer; in TEST() local
366 EXPECT_EQ(0, observer.count()); in TEST()
367 EXPECT_EQ(nullptr, observer.net_log()); in TEST()
371 NetLog::Get()->AddObserver(&observer, NetLogCaptureMode::kIncludeSensitive); in TEST()
373 EXPECT_EQ(NetLog::Get(), observer.net_log()); in TEST()
374 EXPECT_EQ(NetLogCaptureMode::kIncludeSensitive, observer.capture_mode()); in TEST()
[all …]
|
| /external/openscreen/osp/impl/ |
| D | service_listener_impl.cc | 67 for (auto* observer : observers_) { in OnReceiverAdded() local
68 observer->OnReceiverAdded(info); in OnReceiverAdded()
75 for (auto* observer : observers_) { in OnReceiverChanged() local
76 observer->OnReceiverChanged(info); in OnReceiverChanged()
84 for (auto* observer : observers_) { in OnReceiverRemoved() local
85 observer->OnReceiverRemoved(info); in OnReceiverRemoved()
93 for (auto* observer : observers_) { in OnAllReceiversRemoved() local
94 observer->OnAllReceiversRemoved(); in OnAllReceiversRemoved()
101 for (auto* observer : observers_) { in OnError() local
102 observer->OnError(error); in OnError()
[all …]
|
| /external/webrtc/sdk/android/api/org/webrtc/ |
| D | PeerConnectionDependencies.java | 23 private final PeerConnection.Observer observer; field in PeerConnectionDependencies
29 private PeerConnection.Observer observer; field in PeerConnectionDependencies.Builder
32 private Builder(PeerConnection.Observer observer) { in Builder() argument
33 this.observer = observer; in Builder()
43 return new PeerConnectionDependencies(observer, sslCertificateVerifier); in createPeerConnectionDependencies()
47 public static Builder builder(PeerConnection.Observer observer) { in builder() argument
48 return new Builder(observer); in builder()
52 return observer; in getObserver()
61 PeerConnection.Observer observer, SSLCertificateVerifier sslCertificateVerifier) { in PeerConnectionDependencies() argument
62 this.observer = observer; in PeerConnectionDependencies()
|
| /external/cronet/tot/net/ssl/ |
| D | ssl_config_service_unittest.cc | 60 MockSSLConfigServiceObserver observer; in TEST() local
61 mock_service.AddObserver(&observer); in TEST()
63 EXPECT_CALL(observer, OnSSLContextConfigChanged()).Times(0); in TEST()
66 mock_service.RemoveObserver(&observer); in TEST()
75 MockSSLConfigServiceObserver observer; in TEST() local
76 mock_service.AddObserver(&observer); in TEST()
78 EXPECT_CALL(observer, OnSSLContextConfigChanged()).Times(1); in TEST()
81 mock_service.RemoveObserver(&observer); in TEST()
89 MockSSLConfigServiceObserver observer; in TEST() local
90 mock_service.AddObserver(&observer); in TEST()
[all …]
|
| /external/cronet/stable/net/ssl/ |
| D | ssl_config_service_unittest.cc | 60 MockSSLConfigServiceObserver observer; in TEST() local
61 mock_service.AddObserver(&observer); in TEST()
63 EXPECT_CALL(observer, OnSSLContextConfigChanged()).Times(0); in TEST()
66 mock_service.RemoveObserver(&observer); in TEST()
75 MockSSLConfigServiceObserver observer; in TEST() local
76 mock_service.AddObserver(&observer); in TEST()
78 EXPECT_CALL(observer, OnSSLContextConfigChanged()).Times(1); in TEST()
81 mock_service.RemoveObserver(&observer); in TEST()
89 MockSSLConfigServiceObserver observer; in TEST() local
90 mock_service.AddObserver(&observer); in TEST()
[all …]
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/ |
| D | ChannelzServiceTest.java | 169 StreamObserver<GetTopChannelsResponse> observer = mock(StreamObserver.class); in getTopChannelHelper() local
174 observer); in getTopChannelHelper() local
175 verify(observer).onNext(responseCaptor.capture()); in getTopChannelHelper()
176 verify(observer).onCompleted(); in getTopChannelHelper()
182 StreamObserver<GetChannelResponse> observer = mock(StreamObserver.class); in getChannelHelper() local
185 service.getChannel(GetChannelRequest.newBuilder().setChannelId(id).build(), observer); in getChannelHelper() local
186 verify(observer).onNext(response.capture()); in getChannelHelper()
187 verify(observer).onCompleted(); in getChannelHelper()
193 StreamObserver<GetChannelResponse> observer = mock(StreamObserver.class); in assertChannelNotFound() local
195 service.getChannel(GetChannelRequest.newBuilder().setChannelId(id).build(), observer); in assertChannelNotFound() local
[all …]
|
| /external/robolectric/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowContentObserverTest.java | 16 private TestContentObserver observer; field in ShadowContentObserverTest
20 observer = new TestContentObserver(null); in setUp()
25 assertThat(observer.changed).isFalse(); in testDispatchChangeBooleanUri()
26 assertThat(observer.selfChange).isFalse(); in testDispatchChangeBooleanUri()
27 assertThat(observer.uri).isNull(); in testDispatchChangeBooleanUri()
30 observer.dispatchChange(true, uri); in testDispatchChangeBooleanUri()
32 assertThat(observer.changed).isTrue(); in testDispatchChangeBooleanUri()
33 assertThat(observer.selfChange).isTrue(); in testDispatchChangeBooleanUri()
34 assertThat(observer.uri).isSameInstanceAs(uri); in testDispatchChangeBooleanUri()
39 assertThat(observer.changed).isFalse(); in testDispatchChangeBoolean()
[all …]
|