| /external/libmojo/mojo/public/cpp/system/ |
| D | watcher.cc | 15 class Watcher::MessageLoopObserver
18 explicit MessageLoopObserver(Watcher* watcher) : watcher_(watcher) { in MessageLoopObserver()
44 Watcher* watcher_;
49 Watcher::Watcher(scoped_refptr<base::SingleThreadTaskRunner> runner) in Watcher() function in mojo::Watcher
58 Watcher::~Watcher() { in ~Watcher()
63 bool Watcher::IsWatching() const { in IsWatching()
68 MojoResult Watcher::Start(Handle handle, in Start()
79 &Watcher::CallOnHandleReady, in Start()
93 void Watcher::Cancel() { in Cancel()
110 void Watcher::OnHandleReady(MojoResult result) { in OnHandleReady()
[all …]
|
| D | watcher.h | 25 class Watcher {
45 explicit Watcher(scoped_refptr<base::SingleThreadTaskRunner> runner =
50 ~Watcher();
108 base::WeakPtr<Watcher> weak_self_;
118 base::WeakPtrFactory<Watcher> weak_factory_;
120 DISALLOW_COPY_AND_ASSIGN(Watcher);
|
| /external/libmojo/mojo/edk/system/ |
| D | watcher.cc | 13 Watcher::Watcher(MojoHandleSignals signals, const WatchCallback& callback) in Watcher() function in mojo::edk::Watcher
17 void Watcher::MaybeInvokeCallback(MojoResult result, in MaybeInvokeCallback()
27 void Watcher::NotifyForStateChange(const HandleSignalsState& signals_state) { in NotifyForStateChange()
39 void Watcher::NotifyClosed() { in NotifyClosed()
45 void Watcher::Cancel() { in Cancel()
50 Watcher::~Watcher() {} in ~Watcher()
|
| D | watcher.h | 30 class Watcher : public base::RefCountedThreadSafe<Watcher> {
39 Watcher(MojoHandleSignals signals, const WatchCallback& callback);
62 friend class base::RefCountedThreadSafe<Watcher>;
64 ~Watcher();
82 DISALLOW_COPY_AND_ASSIGN(Watcher);
|
| D | request_context.h | 55 void AddWatchNotifyFinalizer(scoped_refptr<Watcher> watcher,
60 void AddWatchCancelFinalizer(scoped_refptr<Watcher> watcher);
67 WatchNotifyFinalizer(scoped_refptr<Watcher> watcher,
73 scoped_refptr<Watcher> watcher;
88 base::StackVector<scoped_refptr<Watcher>, kStaticWatchFinalizersCapacity>;
|
| D | request_context.cc | 49 for (const scoped_refptr<Watcher>& watcher : in ~RequestContext()
75 scoped_refptr<Watcher> watcher, in AddWatchNotifyFinalizer()
83 void RequestContext::AddWatchCancelFinalizer(scoped_refptr<Watcher> watcher) { in AddWatchCancelFinalizer()
93 scoped_refptr<Watcher> watcher, in WatchNotifyFinalizer()
|
| D | watcher_set.cc | 28 const Watcher::WatchCallback& callback, in Add()
38 scoped_refptr<Watcher> watcher(new Watcher(signals, callback)); in Add()
|
| D | watcher_set.h | 37 const Watcher::WatchCallback& callback,
46 std::unordered_map<uintptr_t, scoped_refptr<Watcher>> watchers_;
|
| D | awakable_list.h | 44 const Watcher::WatchCallback& callback,
|
| D | awakable_list.cc | 76 const Watcher::WatchCallback& callback, in AddWatcher()
|
| D | message_pipe_dispatcher.h | 53 const Watcher::WatchCallback& callback,
|
| D | data_pipe_consumer_dispatcher.h | 48 const Watcher::WatchCallback& callback,
|
| D | data_pipe_producer_dispatcher.h | 47 const Watcher::WatchCallback& callback,
|
| D | dispatcher.h | 73 const Watcher::WatchCallback& callback,
|
| /external/libmojo/mojo/public/cpp/system/tests/ |
| D | watcher_unittest.cc | 25 Watcher::ReadyCallback OnReady(Handler f) { in OnReady()
29 Watcher::ReadyCallback NotReached() { in NotReached()
56 Watcher b_watcher; in TEST_F()
79 Watcher b_watcher; in TEST_F()
92 Watcher b_watcher; in TEST_F()
104 Watcher b_watcher; in TEST_F()
126 Watcher b_watcher; in TEST_F()
148 Watcher b_watcher; in TEST_F()
170 Watcher b_watcher; in TEST_F()
191 Watcher b_watcher; in TEST_F()
|
| /external/clang/unittests/Sema/ |
| D | ExternalSemaSourceTest.cpp | 219 void PushWatcher(DiagnosticWatcher *Watcher) { Watchers.push_back(Watcher); } in PushWatcher() argument
226 DiagnosticWatcher Watcher("AAB", "BBB"); in TEST() local
227 Installer->PushWatcher(&Watcher); in TEST()
231 ASSERT_EQ(0, Watcher.SeenCount); in TEST()
240 DiagnosticWatcher Watcher("AAB", "BBB"); in TEST() local
242 Installer->PushWatcher(&Watcher); in TEST()
247 ASSERT_EQ(1, Watcher.SeenCount); in TEST()
258 DiagnosticWatcher Watcher("AAB", "CCC"); in TEST() local
262 Installer->PushWatcher(&Watcher); in TEST()
269 ASSERT_EQ(1, Watcher.SeenCount); in TEST()
[all …]
|
| /external/libchrome/base/message_loop/ |
| D | message_pump_libevent.h | 26 class Watcher {
34 virtual ~Watcher() {} in ~Watcher()
64 void set_watcher(Watcher* watcher) { watcher_ = watcher; } in set_watcher()
71 Watcher* watcher_;
104 Watcher *delegate);
|
| D | message_loop.h | 611 MessagePumpLibevent::Watcher* delegate);
655 typedef MessagePumpIOSForIO::Watcher Watcher; typedef
665 typedef MessagePumpLibevent::Watcher Watcher; typedef
687 Watcher* delegate);
|
| /external/owasp/sanitizer/src/tests/org/owasp/html/ |
| D | CssFuzzerTest.java | 59 final class Watcher implements Runnable { class in CssFuzzerTest
87 Watcher watcher = new Watcher(); in testUnderStress()
|
| /external/libmojo/mojo/common/ |
| D | data_pipe_drainer.h | 39 mojo::Watcher handle_watcher_;
|
| /external/libmojo/mojo/edk/js/ |
| D | drain_data.h | 53 Watcher handle_watcher_;
|
| D | waiting_callback.h | 57 Watcher watcher_;
|
| /external/libchrome/base/files/ |
| D | file_path_watcher_kqueue.h | 31 public MessageLoopForIO::Watcher,
|
| /external/libmojo/mojo/public/cpp/bindings/ |
| D | connector.h | 181 Watcher handle_watcher_;
|
| /external/libbrillo/brillo/message_loops/ |
| D | base_message_loop.h | 95 class IOTask : public base::MessageLoopForIO::Watcher {
|