| /external/openscreen/osp/impl/presentation/ |
| D | url_availability_requester_unittest.cc | 133 UrlAvailabilityRequester listener_{FakeClock::now}; member in openscreen::osp::UrlAvailabilityRequesterTest
144 listener_.AddObserver({url1_}, &mock_observer); in TEST_F()
146 listener_.AddReceiver(info1_); in TEST_F()
167 listener_.AddReceiver(info1_); in TEST_F()
170 listener_.AddObserver({url1_}, &mock_observer); in TEST_F()
191 listener_.AddReceiver(info1_); in TEST_F()
194 listener_.AddObserver({url1_}, &mock_observer); in TEST_F()
214 listener_.AddReceiver(info1_); in TEST_F()
217 listener_.AddObserver({url1_}, &mock_observer1); in TEST_F()
238 listener_.AddObserver({url1_}, &mock_observer2); in TEST_F()
[all …]
|
| /external/protobuf/src/google/protobuf/util/internal/ |
| D | protostream_objectwriter_test.cc | 104 listener_(), in BaseProtoStreamObjectWriterTest()
110 listener_(), in BaseProtoStreamObjectWriterTest()
121 listener_(), in BaseProtoStreamObjectWriterTest()
131 &listener_, options_)); in ResetTypeInfo()
163 MockErrorListener listener_; member in google::protobuf::util::converter::BaseProtoStreamObjectWriterTest
548 EXPECT_CALL(listener_, InvalidValue(_, StringPiece("TYPE_INT32"), in TEST_P()
551 EXPECT_CALL(listener_, InvalidValue(_, StringPiece("TYPE_UINT32"), in TEST_P()
554 EXPECT_CALL(listener_, InvalidValue(_, StringPiece("TYPE_SFIXED64"), in TEST_P()
557 EXPECT_CALL(listener_, InvalidValue(_, StringPiece("TYPE_BOOL"), in TEST_P()
581 EXPECT_CALL(listener_, InvalidValue(_, StringPiece("TYPE_INT32"), in TEST_P()
[all …]
|
| D | proto_writer.cc | 79 listener_(listener), in ProtoWriter()
100 listener_(listener), in ProtoWriter()
442 listener_->InvalidName(location(), ToSnakeCase(unknown_name), message); in InvalidName()
447 listener_->InvalidValue(location(), type_name, value); in InvalidValue()
451 listener_->MissingField(location(), missing_name); in MissingField()
|
| D | proto_writer.h | 135 ErrorListener* listener() { return listener_; } in listener()
359 ErrorListener* listener_; variable
|
| /external/webrtc/video/adaptation/ |
| D | video_stream_encoder_resource.cc | 23 listener_(nullptr) {} in VideoStreamEncoderResource()
26 RTC_DCHECK(!listener_) in ~VideoStreamEncoderResource()
58 RTC_DCHECK(!listener_ || !listener) << "A listener is already set"; in SetResourceListener()
59 listener_ = listener; in SetResourceListener()
69 if (listener_) { in OnResourceUsageStateMeasured()
70 listener_->OnResourceUsageStateMeasured(this, usage_state); in OnResourceUsageStateMeasured()
|
| D | video_stream_encoder_resource.h | 76 ResourceListener* listener_ RTC_GUARDED_BY(listener_lock_);
|
| /external/libchrome/ipc/ |
| D | ipc_channel_proxy_unittest.cc | 255 listener_.reset(new QuitListener()); in SetUp()
257 TakeHandle().release(), IPC::Channel::MODE_SERVER, listener_.get(), in SetUp()
264 listener_.reset(); in TearDown()
270 CreateRunLoopAndRun(&listener_->run_loop_); in SendQuitMessageAndWaitForIdle()
275 return listener_->bad_message_received_; in DidListenerGetBadMessage()
283 std::unique_ptr<QuitListener> listener_; member in __anonce8a47ef0111::IPCChannelProxyTest
397 listener_.reset(new QuitListener()); in SetUp()
398 CreateChannel(listener_.get()); in SetUp()
404 listener_.reset(); in TearDown()
409 CreateRunLoopAndRun(&listener_->run_loop_); in SendQuitMessageAndWaitForIdle()
[all …]
|
| D | ipc_channel_proxy.cc | 36 listener_(listener), in Context()
219 listener_ = NULL; in Clear()
304 if (!listener_) in OnDispatchMessage()
320 listener_->OnMessageReceived(message); in OnDispatchMessage()
322 listener_->OnBadMessageReceived(message); in OnDispatchMessage()
341 if (listener_) in OnDispatchConnected()
342 listener_->OnChannelConnected(peer_pid); in OnDispatchConnected()
347 if (listener_) in OnDispatchError()
348 listener_->OnChannelError(); in OnDispatchError()
353 if (listener_) in OnDispatchBadMessage()
[all …]
|
| D | ipc_channel_reader.h | 37 void set_listener(Listener* listener) { listener_ = listener; } in COMPONENT_EXPORT()
74 Listener* listener() const { return listener_; } in COMPONENT_EXPORT()
146 Listener* listener_; in COMPONENT_EXPORT() local
|
| D | ipc_channel_mojo.cc | 121 listener_(listener), in ChannelMojo()
195 listener_->OnChannelError(); in OnPipeError()
216 listener_->OnAssociatedInterfaceRequest(name, std::move(handle)); in OnAssociatedInterfaceRequest()
256 listener_->OnChannelConnected(peer_pid); in OnPeerPidReceived()
263 listener_->OnMessageReceived(message); in OnMessageReceived()
265 listener_->OnBadMessageReceived(message); in OnMessageReceived()
269 listener_->OnBadMessageReceived(Message()); in OnBrokenDataReceived()
|
| D | ipc_perftest_util.cc | 104 : listener_(new ChannelReflectorListener()) { in MojoPerfTestClient()
116 handle_.release(), Channel::MODE_CLIENT, listener_.get(), in Run()
118 listener_->Init(channel.get(), run_loop.QuitWhenIdleClosure()); in Run()
|
| D | ipc_channel_reader.cc | 47 : listener_(listener), in ChannelReader()
93 listener_->OnMessageReceived(*m); in DispatchMessage()
202 listener_->OnBadMessageReceived(message); in HandleDispatchError()
|
| D | ipc_perftest_util.h | 93 std::unique_ptr<ChannelReflectorListener> listener_; variable
|
| D | ipc_channel_mojo.h | 128 Listener* listener_; in COMPONENT_EXPORT() local
|
| D | ipc_channel_proxy.h | 337 Listener* listener_; in COMPONENT_EXPORT() local
|
| /external/webrtc/call/adaptation/ |
| D | broadcast_resource_listener.cc | 28 ~AdapterResource() override { RTC_DCHECK(!listener_); } in ~AdapterResource()
33 if (!listener_) in OnResourceUsageStateMeasured()
35 listener_->OnResourceUsageStateMeasured(this, usage_state); in OnResourceUsageStateMeasured()
42 RTC_DCHECK(!listener_ || !listener); in SetResourceListener()
43 listener_ = listener; in SetResourceListener()
49 ResourceListener* listener_ RTC_GUARDED_BY(lock_) = nullptr;
|
| /external/webrtc/call/adaptation/test/ |
| D | fake_resource.cc | 26 : Resource(), name_(std::move(name)), listener_(nullptr) {} in FakeResource()
31 if (listener_) { in SetUsageState()
32 listener_->OnResourceUsageStateMeasured(this, usage_state); in SetUsageState()
41 listener_ = listener; in SetResourceListener()
|
| D | fake_resource.h | 39 ResourceListener* listener_; variable
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/server/ |
| D | chttp2_server.cc | 90 : listener_(listener) {} in ConfigFetcherWatcher()
94 MutexLock lock(&listener_->mu_); in UpdateConfig()
98 if (!listener_->shutdown_) return; // Already started listening. in UpdateConfig()
102 listener_->tcp_server_, &listener_->resolved_address_, &port_temp); in UpdateConfig()
111 listener_->StartListening(); in UpdateConfig()
115 Chttp2ServerListener* listener_; member in grpc_core::__anon213f7a340111::Chttp2ServerListener::ConfigFetcherWatcher
133 Chttp2ServerListener* const listener_; member in grpc_core::__anon213f7a340111::Chttp2ServerListener::ConnectionState
188 : listener_(listener), in ConnectionState()
237 MutexLock lock(&self->listener_->mu_); in OnHandshakeDone()
239 self->listener_->server_->default_resource_user(); in OnHandshakeDone()
[all …]
|
| /external/libchrome/base/memory/ |
| D | memory_pressure_listener_unittest.cc | 20 listener_.reset(new MemoryPressureListener( in SetUp()
25 listener_.reset(); in TearDown()
51 std::unique_ptr<MemoryPressureListener> listener_; member in base::MemoryPressureListenerTest
|
| /external/libchrome/base/android/ |
| D | application_status_listener_unittest.cc | 81 listener_.reset(new ApplicationStatusListener(base::Bind( in RegisterThreadForEvents()
83 EXPECT_TRUE(listener_.get()); in RegisterThreadForEvents()
97 std::unique_ptr<ApplicationStatusListener> listener_; member in base::android::__anon2007fe850111::MultiThreadedTest
|
| /external/openscreen/osp/impl/ |
| D | mdns_responder_service.cc | 185 if (!listener_ || listener_->state() == ServiceListener::State::kStopped || in StopPublisherInternal()
186 listener_->state() == ServiceListener::State::kSuspended) { in StopPublisherInternal()
188 if (!listener_ || listener_->state() == ServiceListener::State::kStopped) in StopPublisherInternal()
266 listener_->OnReceiverRemoved(receiver_info); in HandleMdnsEvents()
284 listener_->OnReceiverAdded(receiver_info); in HandleMdnsEvents()
294 listener_->OnReceiverChanged(receiver_info); in HandleMdnsEvents()
421 listener_->OnAllReceiversRemoved(); in RemoveAllReceivers()
|
| D | service_listener_impl.h | 37 void SetState(State state) { listener_->SetState(state); } in SetState()
39 ServiceListenerImpl* listener_ = nullptr; variable
|
| D | service_listener_impl.cc | 54 OSP_DCHECK(!listener_); in SetListenerImpl()
55 listener_ = listener; in SetListenerImpl()
|
| /external/tensorflow/tensorflow/compiler/jit/ |
| D | xla_activity_listener_test.cc | 68 listener_ = listener.get(); in XlaActivityListenerTest()
72 TestListener* listener() const { return listener_; } in listener()
75 TestListener* listener_; member in tensorflow::__anoneb6dd9850111::XlaActivityListenerTest
|