| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | ChannelzServiceTest.java | 149 StreamObserver<GetTopChannelsResponse> observer = mock(StreamObserver.class); in getTopChannelHelper() local
154 observer); in getTopChannelHelper() local
162 StreamObserver<GetChannelResponse> observer = mock(StreamObserver.class); in getChannelHelper() local
165 service.getChannel(GetChannelRequest.newBuilder().setChannelId(id).build(), observer); in getChannelHelper() local
173 StreamObserver<GetChannelResponse> observer = mock(StreamObserver.class); in assertChannelNotFound() local
175 service.getChannel(GetChannelRequest.newBuilder().setChannelId(id).build(), observer); in assertChannelNotFound() local
183 StreamObserver<GetSubchannelResponse> observer = mock(StreamObserver.class); in getSubchannelHelper() local
186 service.getSubchannel(GetSubchannelRequest.newBuilder().setSubchannelId(id).build(), observer); in getSubchannelHelper() local
194 StreamObserver<GetSubchannelResponse> observer = mock(StreamObserver.class); in assertSubchannelNotFound() local
196 service.getSubchannel(GetSubchannelRequest.newBuilder().setSubchannelId(id).build(), observer); in assertSubchannelNotFound() local
[all …]
|
| /external/openscreen/osp/impl/ |
| D | service_listener_impl.cc | 67 for (auto* observer : observers_) { in OnReceiverAdded() local
75 for (auto* observer : observers_) { in OnReceiverChanged() local
84 for (auto* observer : observers_) { in OnReceiverRemoved() local
93 for (auto* observer : observers_) { in OnAllReceiversRemoved() local
101 for (auto* observer : observers_) { in OnError() local
156 void ServiceListenerImpl::AddObserver(Observer* observer) { in AddObserver()
161 void ServiceListenerImpl::RemoveObserver(Observer* observer) { in RemoveObserver()
184 for (auto* observer : observers_) { in MaybeNotifyObservers() local
189 for (auto* observer : observers_) { in MaybeNotifyObservers() local
194 for (auto* observer : observers_) { in MaybeNotifyObservers() local
[all …]
|
| /external/cronet/net/dns/ |
| D | system_dns_config_change_notifier_unittest.cc | 98 TestObserver observer; in LoadConfig() local
122 TestObserver observer; in TEST_F() local
139 TestObserver observer; in TEST_F() local
165 TestObserver observer; in TEST_F() local
182 TestObserver observer; in TEST_F() local
194 TestObserver observer; in TEST_F() local
208 TestObserver observer; in TEST_F() local
239 TestObserver observer; in TEST_F() local
261 TestObserver observer; in TEST_F() local
294 TestObserver observer; in TEST_F() local
[all …]
|
| /external/webrtc/video/ |
| D | stats_counter_unittest.cc | 65 StatsCounterObserverImpl* observer = new StatsCounterObserverImpl(); in TEST_F() local
82 StatsCounterObserverImpl* observer = new StatsCounterObserverImpl(); in TEST_F() local
102 StatsCounterObserverImpl* observer = new StatsCounterObserverImpl(); in TEST_F() local
123 StatsCounterObserverImpl* observer = new StatsCounterObserverImpl(); in TEST_F() local
143 StatsCounterObserverImpl* observer = new StatsCounterObserverImpl(); in TEST_F() local
161 StatsCounterObserverImpl* observer = new StatsCounterObserverImpl(); in TEST_F() local
179 StatsCounterObserverImpl* observer = new StatsCounterObserverImpl(); in TEST_F() local
198 StatsCounterObserverImpl* observer = new StatsCounterObserverImpl(); in TEST_F() local
216 StatsCounterObserverImpl* observer = new StatsCounterObserverImpl(); in TEST_F() local
230 StatsCounterObserverImpl* observer = new StatsCounterObserverImpl(); in TEST_F() local
[all …]
|
| /external/cronet/components/metrics/structured/ |
| D | recorder.cc | 48 for (auto& observer : observers_) { in RecordEvent() local
65 for (auto& observer : observers_) { in ProfileAdded() local
81 for (auto& observer : observers_) { in LastKeyRotation() local
88 for (auto& observer : observers_) { in OnReportingStateChanged() local
94 for (auto& observer : observers_) { in OnSystemProfileInitialized() local
104 void Recorder::AddObserver(RecorderImpl* observer) { in AddObserver()
108 void Recorder::RemoveObserver(RecorderImpl* observer) { in RemoveObserver()
|
| /external/cronet/net/reporting/ |
| D | reporting_context.cc | 59 void ReportingContext::AddCacheObserver(ReportingCacheObserver* observer) { in AddCacheObserver()
64 void ReportingContext::RemoveCacheObserver(ReportingCacheObserver* observer) { in RemoveCacheObserver()
70 for (auto& observer : cache_observers_) in NotifyCachedReportsUpdated() local
75 for (auto& observer : cache_observers_) in NotifyReportAdded() local
80 for (auto& observer : cache_observers_) in NotifyReportUpdated() local
85 for (auto& observer : cache_observers_) in NotifyCachedClientsUpdated() local
91 for (auto& observer : cache_observers_) in NotifyEndpointsUpdatedForOrigin() local
|
| /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()
47 public static Builder builder(PeerConnection.Observer observer) { in builder()
61 PeerConnection.Observer observer, SSLCertificateVerifier sslCertificateVerifier) { in PeerConnectionDependencies()
|
| /external/pigweed/pw_rpc/java/main/dev/pigweed/pw_rpc/ |
| D | MethodClient.java | 64 public Call invokeUnary(MessageLite request, StreamObserver<? extends MessageLite> observer) in invokeUnary()
84 public Call openUnary(StreamObserver<? extends MessageLite> observer) { in openUnary()
96 StreamObserver<? extends MessageLite> observer) throws ChannelOutputException { in invokeServerStreaming()
115 public Call openServerStreaming(StreamObserver<? extends MessageLite> observer) { in openServerStreaming()
128 StreamObserver<? extends MessageLite> observer) throws ChannelOutputException { in invokeClientStreaming()
148 StreamObserver<? extends MessageLite> observer) { in openClientStreaming()
161 StreamObserver<? extends MessageLite> observer) throws ChannelOutputException { in invokeBidirectionalStreaming()
182 StreamObserver<? extends MessageLite> observer) { in openBidirectionalStreaming()
|
| D | StreamObserverCall.java | 32 private final StreamObserver<ResponseT> observer; field in StreamObserverCall
36 StreamObserver<ResponseT> observer) { in getFactory()
41 Endpoint endpoint, PendingRpc rpc, StreamObserver<ResponseT> observer) { in StreamObserverCall()
|
| /external/mockito/src/test/java/org/mockito/internal/util/reflection/ |
| D | ParameterizedConstructorInstantiatorTest.java | 71 Observer observer = mock(Observer.class); in should_instantiate_type_if_resolver_provide_matching_types() local
84 Observer observer = mock(Observer.class); in should_fail_if_an_argument_instance_type_do_not_match_wanted_type() local
129 public OneConstructor(Observer observer) { } in OneConstructor()
133 … public ThrowingConstructor(Observer observer) throws IOException { throw new IOException(); } in ThrowingConstructor()
137 Observer observer; field in ParameterizedConstructorInstantiatorTest.MultipleConstructor
140 public MultipleConstructor(Observer observer) { this(observer, null); } in MultipleConstructor()
141 public MultipleConstructor(Observer observer, Map map) { in MultipleConstructor()
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowBackupManager.java | 103 public int getAvailableRestoreSets(IRestoreObserver observer) throws RemoteException { in getAvailableRestoreSets()
108 public int getAvailableRestoreSets(IRestoreObserver observer, IBackupManagerMonitor monitor) in getAvailableRestoreSets()
123 public int restoreAll(long token, IRestoreObserver observer) throws RemoteException { in restoreAll()
128 public int restoreAll(long token, IRestoreObserver observer, IBackupManagerMonitor monitor) in restoreAll()
134 public int restoreSome(long token, IRestoreObserver observer, String[] packages) in restoreSome()
140 public int restoreSome(long token, IRestoreObserver observer, IBackupManagerMonitor monitor, in restoreSome()
146 public int restorePackages(long token, IRestoreObserver observer, String[] packages, in restorePackages()
164 public int restorePackage(String packageName, IRestoreObserver observer) in restorePackage()
171 String packageName, IRestoreObserver observer, IBackupManagerMonitor monitor) in restorePackage()
|
| /external/webrtc/pc/ |
| D | rtp_transport_unittest.cc | 79 SignalObserver observer(&transport); in TEST() local
93 SignalObserver observer(&transport); in TEST() local
107 SignalObserver observer(&transport); in TEST() local
117 SignalObserver observer(&transport); in TEST() local
130 SignalObserver observer(&transport); in TEST() local
144 SignalObserver observer(&transport); in TEST() local
173 SignalObserver observer(&transport); in TEST() local
210 SignalObserver observer(&transport); in TEST() local
228 TransportObserver observer(&transport); in TEST() local
256 TransportObserver observer(&transport); in TEST() local
[all …]
|
| D | peer_connection_message_handler.cc | 36 SetSessionDescriptionObserver* observer) { in PostSetSessionDescriptionSuccess()
43 SetSessionDescriptionObserver* observer, in PostSetSessionDescriptionFailure()
54 CreateSessionDescriptionObserver* observer, in PostCreateSessionDescriptionFailure()
66 StatsObserver* observer, in PostGetStats()
|
| D | peer_connection_wrapper.cc | 38 std::unique_ptr<MockPeerConnectionObserver> observer) in PeerConnectionWrapper()
61 MockPeerConnectionObserver* PeerConnectionWrapper::observer() { in observer() function in webrtc::PeerConnectionWrapper
74 [this, options](CreateSessionDescriptionObserver* observer) { in CreateOffer()
106 [this, options](CreateSessionDescriptionObserver* observer) { in CreateAnswer()
136 auto observer = rtc::make_ref_counted<MockCreateSessionDescriptionObserver>(); in CreateSdp() local
149 [this, &desc](SetSessionDescriptionObserver* observer) { in SetLocalDescription()
159 [this, &desc](SetSessionDescriptionObserver* observer) { in SetRemoteDescription()
168 auto observer = rtc::make_ref_counted<FakeSetRemoteDescriptionObserver>(); in SetRemoteDescription() local
180 auto observer = rtc::make_ref_counted<MockSetSessionDescriptionObserver>(); in SetSdp() local
|
| /external/robolectric/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowBackupManager.java | 126 public int getAvailableRestoreSets(IRestoreObserver observer) throws RemoteException { in getAvailableRestoreSets()
131 public int getAvailableRestoreSets(IRestoreObserver observer, IBackupManagerMonitor monitor) in getAvailableRestoreSets()
146 public int restoreAll(long token, IRestoreObserver observer) throws RemoteException { in restoreAll()
151 public int restoreAll(long token, IRestoreObserver observer, IBackupManagerMonitor monitor) in restoreAll()
157 public int restoreSome(long token, IRestoreObserver observer, String[] packages) in restoreSome()
164 long token, IRestoreObserver observer, IBackupManagerMonitor monitor, String[] packages) in restoreSome()
170 long token, IRestoreObserver observer, String[] packages, IBackupManagerMonitor monitor) in restorePackages()
188 public int restorePackage(String packageName, IRestoreObserver observer) in restorePackage()
195 String packageName, IRestoreObserver observer, IBackupManagerMonitor monitor) in restorePackage()
|
| /external/cronet/net/proxy_resolution/ |
| D | proxy_config_service.cc | 69 void AddObserver(Observer* observer) override {} in AddObserver()
70 void RemoveObserver(Observer* observer) override {} in RemoveObserver()
82 void AddObserver(Observer* observer) override {} in AddObserver()
83 void RemoveObserver(Observer* observer) override {} in RemoveObserver()
|
| /external/cronet/net/base/ |
| D | network_change_notifier.cc | 658 void NetworkChangeNotifier::AddIPAddressObserver(IPAddressObserver* observer) { in AddIPAddressObserver()
665 ConnectionTypeObserver* observer) { in AddConnectionTypeObserver()
671 void NetworkChangeNotifier::AddDNSObserver(DNSObserver* observer) { in AddDNSObserver()
678 NetworkChangeObserver* observer) { in AddNetworkChangeObserver()
685 MaxBandwidthObserver* observer) { in AddMaxBandwidthObserver()
691 void NetworkChangeNotifier::AddNetworkObserver(NetworkObserver* observer) { in AddNetworkObserver()
700 ConnectionCostObserver* observer) { in AddConnectionCostObserver()
712 DefaultNetworkActiveObserver* observer) { in AddDefaultNetworkActiveObserver()
728 IPAddressObserver* observer) { in RemoveIPAddressObserver()
736 ConnectionTypeObserver* observer) { in RemoveConnectionTypeObserver()
[all …]
|
| /external/javaparser/javaparser-core/src/main/java/com/github/javaparser/ast/observer/ |
| D | Observable.java | 32 void register(AstObserver observer); in register()
37 void unregister(AstObserver observer); in unregister()
43 boolean isRegistered(AstObserver observer); in isRegistered()
|
| /external/pdfium/core/fxcrt/ |
| D | shared_copy_on_write_unittest.cpp | 34 Object(Observer* observer, const std::string& name) in Object()
53 Observer observer; in TEST() local
61 Observer observer; in TEST() local
82 Observer observer; in TEST() local
96 Observer observer; in TEST() local
112 Observer observer; in TEST() local
|
| /external/cronet/net/log/ |
| D | net_log.cc | 88 void NetLog::AddObserver(NetLog::ThreadSafeObserver* observer, in AddObserver()
103 void NetLog::RemoveObserver(NetLog::ThreadSafeObserver* observer) { in RemoveObserver()
118 NetLog::ThreadSafeCaptureModeObserver* observer) { in AddCaptureModeObserver()
130 NetLog::ThreadSafeCaptureModeObserver* observer) { in RemoveCaptureModeObserver()
147 for (const auto* observer : observers_) in UpdateObserverCaptureModes() local
157 bool NetLog::HasObserver(ThreadSafeObserver* observer) { in HasObserver()
162 bool NetLog::HasCaptureModeObserver(ThreadSafeCaptureModeObserver* observer) { in HasCaptureModeObserver()
251 for (auto* observer : observers_) { in AddEntryInternal() local
275 for (auto* observer : observers_) { in AddEntryAtTimeWithMaterializedParams() local
|
| /external/cronet/net/url_request/ |
| D | url_request_context_getter.cc | 17 URLRequestContextGetterObserver* observer) { in AddObserver()
23 URLRequestContextGetterObserver* observer) { in RemoveObserver()
61 for (auto& observer : observer_list_) in NotifyContextShuttingDown() local
|
| /external/cronet/base/power_monitor/ |
| D | battery_state_sampler.cc | 64 void BatteryStateSampler::AddObserver(Observer* observer) { in AddObserver()
74 void BatteryStateSampler::RemoveObserver(Observer* observer) { in RemoveObserver()
118 for (auto& observer : observer_list_) in OnInitialBatteryStateSampled() local
137 for (auto& observer : observer_list_) in OnBatteryStateSampled() local
|
| /external/cronet/net/nqe/ |
| D | network_quality_estimator.cc | 410 for (auto& observer : effective_connection_type_observer_list_) in ReportEffectiveConnectionTypeForTesting() local
425 for (auto& observer : rtt_and_throughput_estimates_observer_list_) in ReportRTTsAndThroughputForTesting() local
813 EffectiveConnectionTypeObserver* observer) { in AddEffectiveConnectionTypeObserver()
831 EffectiveConnectionTypeObserver* observer) { in RemoveEffectiveConnectionTypeObserver()
837 PeerToPeerConnectionsCountObserver* observer) { in AddPeerToPeerConnectionsCountObserver()
855 PeerToPeerConnectionsCountObserver* observer) { in RemovePeerToPeerConnectionsCountObserver()
861 RTTAndThroughputEstimatesObserver* observer) { in AddRTTAndThroughputEstimatesObserver()
876 RTTAndThroughputEstimatesObserver* observer) { in RemoveRTTAndThroughputEstimatesObserver()
1093 for (auto& observer : rtt_observer_list_) { in AddAndNotifyObserversOfRTT() local
1124 for (auto& observer : throughput_observer_list_) { in AddAndNotifyObserversOfThroughput() local
[all …]
|
| /external/libchrome/components/policy/core/common/ |
| D | schema_registry.cc | 26 for (auto& observer : internal_observers_) in ~SchemaRegistry() local
81 for (auto& observer : observers_) in SetDomainReady() local
98 void SchemaRegistry::AddObserver(Observer* observer) { in AddObserver()
103 void SchemaRegistry::RemoveObserver(Observer* observer) { in RemoveObserver()
108 void SchemaRegistry::AddInternalObserver(InternalObserver* observer) { in AddInternalObserver()
113 void SchemaRegistry::RemoveInternalObserver(InternalObserver* observer) { in RemoveInternalObserver()
120 for (auto& observer : observers_) in Notify() local
|
| /external/webrtc/sdk/android/native_unittests/org/webrtc/ |
| D | JavaVideoSourceTestHelper.java | 15 public static void startCapture(CapturerObserver observer, boolean success) { in startCapture()
20 public static void stopCapture(CapturerObserver observer) { in stopCapture()
26 int width, int height, int rotation, long timestampNs, CapturerObserver observer) { in deliverFrame()
|