Home
last modified time | relevance | path

Searched refs:watcher_ (Results 1 – 19 of 19) sorted by relevance

/external/libchrome/mojo/public/java/system/
Dwatcher_impl.cc25 : 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::__anonc431d9080111::WatcherImpl
/external/libchrome/mojo/public/cpp/system/
Dstring_data_pipe_producer.cc61 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()
Dfile_data_pipe_producer.cc109 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
Dstring_data_pipe_producer.h82 SimpleWatcher watcher_; variable
DREADME.md242 watcher_(mojo::SimpleWatcher::ArmingPolicy::AUTOMATIC) {
245 watcher_.Watch(pipe_.get(), MOJO_HANDLE_SIGNAL_READABLE,
264 mojo::SimpleWatcher watcher_;
/external/libchrome/mojo/core/
Dwatch.cc18 : watcher_(watcher), in Watch()
78 watcher_->InvokeWatchCallback(context_, result, state, flags); in InvokeCallback()
85 watcher_->lock_.AssertAcquired(); in AssertWatcherLockAcquired()
Dwatch.h96 const scoped_refptr<WatcherDispatcher> watcher_; variable
/external/libchrome/base/message_loop/
Dmessage_pump_libevent.cc68 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()
Dmessage_pump_libevent.h51 void set_watcher(FdWatcher* watcher) { watcher_ = watcher; } in set_watcher()
58 FdWatcher* watcher_ = nullptr; variable
/external/libchrome/mojo/public/cpp/system/tests/
Dstring_data_pipe_producer_unittest.cc33 watcher_(FROM_HERE, in DataPipeReader()
36 watcher_.Watch( in DataPipeReader()
65 watcher_.Cancel(); in OnDataAvailable()
72 SimpleWatcher watcher_; member in mojo::__anon9c6c354b0111::DataPipeReader
Dfile_data_pipe_producer_unittest.cc38 watcher_(FROM_HERE, in DataPipeReader()
41 watcher_.Watch( in DataPipeReader()
70 watcher_.Cancel(); in OnDataAvailable()
78 SimpleWatcher watcher_; member in mojo::__anondb6b72940111::DataPipeReader
/external/tensorflow/tensorflow/core/framework/
Dop.cc144 if (watcher_ && watcher) { in SetWatcher()
148 watcher_ = watcher; in SetWatcher()
232 if (watcher_) { in RegisterAlreadyLocked()
233 watcher_status = watcher_(s, op_reg_data->op_def); in RegisterAlreadyLocked()
Dop.h159 mutable Watcher watcher_ GUARDED_BY(mu_);
/external/libchrome/base/files/
Dfile_descriptor_watcher_posix.cc39 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()
Dfile_descriptor_watcher_posix.h74 std::unique_ptr<Watcher> watcher_; variable
Dfile_path_watcher_unittest.cc282 : watcher_(std::make_unique<FilePathWatcher>()), in Deleter()
287 watcher_.reset(); in OnFileChanged()
291 FilePathWatcher* watcher() const { return watcher_.get(); } in watcher()
294 std::unique_ptr<FilePathWatcher> watcher_; member in base::__anonbec4f5360111::Deleter
/external/webrtc/talk/media/devices/
Ddevicemanager.h189 void set_watcher(DeviceWatcher* watcher) { watcher_.reset(watcher); } in set_watcher()
190 DeviceWatcher* watcher() { return watcher_.get(); } in watcher()
205 rtc::scoped_ptr<DeviceWatcher> watcher_; variable
/external/libchrome/base/synchronization/
Dwaitable_event_watcher.h114 win::ObjectWatcher watcher_; variable
/external/libchrome/ipc/
Dipc_sync_channel.cc116 watcher_.StartWatching( in StartWatching()
122 void StopWatching() { watcher_.StopWatching(); } in StopWatching()
129 base::WaitableEventWatcher watcher_; member in IPC::SyncChannel::ReceivedSyncMsgQueue::NestedSendDoneWatcher