| /external/openscreen/discovery/public/ |
| D | dns_sd_service_watcher_unittest.cc | 109 DnsSdServiceWatcherTests() : watcher_(&service_) { in DnsSdServiceWatcherTests()
111 EXPECT_FALSE(watcher_.is_running()); in DnsSdServiceWatcherTests()
113 watcher_.StartDiscovery(); in DnsSdServiceWatcherTests()
120 ConvertRefs(watcher_.GetServices()); in CreateNewInstance()
124 EXPECT_CALL(watcher_, Callback(_)) in CreateNewInstance()
129 watcher_.OnEndpointCreated(record); in CreateNewInstance()
130 testing::Mock::VerifyAndClearExpectations(&watcher_); in CreateNewInstance()
133 ConvertRefs(watcher_.GetServices()); in CreateNewInstance()
142 ConvertRefs(watcher_.GetServices()); in CreateExistingInstance()
146 EXPECT_CALL(watcher_, Callback(_)) in CreateExistingInstance()
[all …]
|
| /external/libchrome/libchrome_tools/patches/ |
| D | fix-fd-watcher-leak.patch | 41 - // Delete |watcher_| on the MessageLoopForIO.
44 - // |watcher_| is leaked. If the MessageLoopForIO is deleted after
46 - // |watcher_| is deleted from Watcher::WillDestroyCurrentMessageLoop().
47 - message_loop_for_io_task_runner_->DeleteSoon(FROM_HERE, watcher_.release());
66 + watcher_.reset();
68 + // Synchronously wait until |watcher_| is deleted on the MessagePumpForIO
99 + Unretained(watcher_.release()),
128 + controller_->watcher_.reset();
145 - // It is safe to use Unretained() below because |watcher_| can only be deleted
150 - FROM_HERE, BindOnce(&Watcher::StartWatching, Unretained(watcher_.get())));
[all …]
|
| /external/libchrome/mojo/public/java/system/ |
| D | watcher_impl.cc | 25 : watcher_(FROM_HERE, in WatcherImpl()
41 watcher_.Watch(mojo::Handle(static_cast<MojoHandle>(mojo_handle)), in Start()
51 watcher_.Cancel(); in Cancel()
68 SimpleWatcher watcher_; member in mojo::android::__anon5e8a88260111::WatcherImpl
|
| /external/libchrome/mojo/public/cpp/system/ |
| D | string_data_pipe_producer.cc | 61 watcher_(FROM_HERE, in StringDataPipeProducer()
92 watcher_.Watch(producer_.get(), MOJO_HANDLE_SIGNAL_WRITABLE, in Write()
119 watcher_.Cancel(); in OnProducerHandleReady()
127 watcher_.Cancel(); in OnProducerHandleReady()
|
| D | file_data_pipe_producer.cc | 109 watcher_ = std::make_unique<SimpleWatcher>( in StartFromFileOnFileSequence()
112 watcher_->Watch(producer_handle_.get(), MOJO_HANDLE_SIGNAL_WRITABLE, in StartFromFileOnFileSequence()
212 watcher_.reset(); in Finish()
226 std::unique_ptr<SimpleWatcher> watcher_; member in mojo::FileDataPipeProducer::FileSequenceState
|
| D | string_data_pipe_producer.h | 82 SimpleWatcher watcher_; variable
|
| /external/libchrome/mojo/core/ |
| D | watch.cc | 18 : watcher_(watcher), in Watch()
78 watcher_->InvokeWatchCallback(context_, result, state, flags); in InvokeCallback()
85 watcher_->lock_.AssertAcquired(); in AssertWatcherLockAcquired()
|
| D | watch.h | 96 const scoped_refptr<WatcherDispatcher> watcher_; variable
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/ |
| D | connectivity_state.cc | 63 : watcher_(std::move(watcher)), state_(state), status_(status) { in Notifier()
80 self->watcher_.get(), ConnectivityStateName(self->state_), in SendNotification()
83 self->watcher_->OnConnectivityStateChange(self->state_, self->status_); in SendNotification()
87 RefCountedPtr<AsyncConnectivityStateWatcherInterface> watcher_; member in grpc_core::AsyncConnectivityStateWatcherInterface::Notifier
|
| /external/libchrome/base/message_loop/ |
| D | message_pump_libevent.cc | 68 watcher_ = nullptr; in StopWatchingFileDescriptor()
88 if (!watcher_) in OnFileCanReadWithoutBlocking()
90 watcher_->OnFileCanReadWithoutBlocking(fd); in OnFileCanReadWithoutBlocking()
96 DCHECK(watcher_); in OnFileCanWriteWithoutBlocking()
97 watcher_->OnFileCanWriteWithoutBlocking(fd); in OnFileCanWriteWithoutBlocking()
|
| D | message_pump_libevent.h | 51 void set_watcher(FdWatcher* watcher) { watcher_ = watcher; } in set_watcher()
58 FdWatcher* watcher_ = nullptr; variable
|
| /external/libbrillo/brillo/ |
| D | binder_watcher.cc | 56 watcher_ = base::FileDescriptorWatcher::WatchReadable( in Init()
59 if (!watcher_) { in Init()
|
| D | binder_watcher.h | 38 std::unique_ptr<base::FileDescriptorWatcher::Controller> watcher_;
|
| /external/libchrome/mojo/public/cpp/system/tests/ |
| D | string_data_pipe_producer_unittest.cc | 33 watcher_(FROM_HERE, in DataPipeReader()
36 watcher_.Watch( in DataPipeReader()
65 watcher_.Cancel(); in OnDataAvailable()
72 SimpleWatcher watcher_; member in mojo::__anonb19f71a90111::DataPipeReader
|
| D | file_data_pipe_producer_unittest.cc | 38 watcher_(FROM_HERE, in DataPipeReader()
41 watcher_.Watch( in DataPipeReader()
70 watcher_.Cancel(); in OnDataAvailable()
78 SimpleWatcher watcher_; member in mojo::__anon8747ff720111::DataPipeReader
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | op.cc | 158 if (watcher_ && watcher) { in SetWatcher()
162 watcher_ = watcher; in SetWatcher()
246 if (watcher_) { in RegisterAlreadyLocked()
247 watcher_status = watcher_(s, op_reg_data->op_def); in RegisterAlreadyLocked()
|
| /external/libchrome/base/files/ |
| D | file_descriptor_watcher_posix.cc | 39 message_loop_for_io_task_runner_->DeleteSoon(FROM_HERE, watcher_.release()); in ~Controller()
169 watcher_ = std::make_unique<Watcher>(weak_factory_.GetWeakPtr(), mode, fd); in Controller()
180 FROM_HERE, BindOnce(&Watcher::StartWatching, Unretained(watcher_.get()))); in StartWatching()
|
| D | file_descriptor_watcher_posix.h | 74 std::unique_ptr<Watcher> watcher_; variable
|
| /external/openscreen/cast/standalone_sender/ |
| D | receiver_chooser.cc | 49 watcher_ = std::make_unique<discovery::DnsSdServiceWatcher<ServiceInfo>>( in ReceiverChooser()
57 task_runner->PostTask([this] { watcher_->StartDiscovery(); }); in ReceiverChooser()
|
| D | receiver_chooser.h | 54 std::unique_ptr<discovery::DnsSdServiceWatcher<ServiceInfo>> watcher_; variable
|
| /external/libbrillo/brillo/message_loops/ |
| D | base_message_loop.cc | 56 watcher_ = std::make_unique<base::FileDescriptorWatcher>(base_loop_); in BaseMessageLoop()
61 watcher_(std::make_unique<base::FileDescriptorWatcher>(base_loop_)) {} in BaseMessageLoop()
|
| D | base_message_loop.h | 106 std::unique_ptr<base::FileDescriptorWatcher> watcher_; variable
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/ |
| D | health_check_client.cc | 62 watcher_(std::move(watcher)), in HealthCheckClient()
97 if (watcher_ != nullptr) { in SetHealthStatusLocked()
98 watcher_->Notify(state, in SetHealthStatusLocked()
112 watcher_.reset(); in Orphan()
|
| /external/libchrome/base/synchronization/ |
| D | waitable_event_watcher.h | 114 win::ObjectWatcher watcher_; variable
|
| /external/webrtc/test/network/ |
| D | network_emulation.cc | 91 if (watcher_) { in OnPacketReceived()
92 watcher_(packet); in OnPacketReceived()
128 watcher_ = watcher; in SetWatcher()
|