Home
last modified time | relevance | path

Searched refs:Watcher (Results 1 – 25 of 52) sorted by relevance

123

/external/libmojo/mojo/public/cpp/system/
Dwatcher.cc15 Watcher::Watcher(const tracked_objects::Location& from_here, in Watcher() function in mojo::Watcher
26 Watcher::~Watcher() { in ~Watcher()
31 bool Watcher::IsWatching() const { in IsWatching()
36 MojoResult Watcher::Start(Handle handle, in Start()
46 &Watcher::CallOnHandleReady, in Start()
59 void Watcher::Cancel() { in Cancel()
75 void Watcher::OnHandleReady(MojoResult result) { in OnHandleReady()
92 void Watcher::CallOnHandleReady(uintptr_t context, in CallOnHandleReady()
101 Watcher* watcher = reinterpret_cast<Watcher*>(context); in CallOnHandleReady()
113 base::Bind(&Watcher::OnHandleReady, watcher->weak_self_, result)); in CallOnHandleReady()
Dwatcher.h24 class MOJO_CPP_SYSTEM_EXPORT Watcher {
39 Watcher(const tracked_objects::Location& from_here,
45 ~Watcher();
104 base::WeakPtr<Watcher> weak_self_;
118 base::WeakPtrFactory<Watcher> weak_factory_;
120 DISALLOW_COPY_AND_ASSIGN(Watcher);
/external/libchrome/base/files/
Dfile_descriptor_watcher_posix.cc43 class FileDescriptorWatcher::Controller::Watcher class in base::FileDescriptorWatcher::Controller
44 : public MessageLoopForIO::Watcher,
47 Watcher(WeakPtr<Controller> controller, MessageLoopForIO::Mode mode, int fd);
48 ~Watcher() override;
88 DISALLOW_COPY_AND_ASSIGN(Watcher);
91 FileDescriptorWatcher::Controller::Watcher::Watcher( in Watcher() function in base::FileDescriptorWatcher::Controller::Watcher
103 FileDescriptorWatcher::Controller::Watcher::~Watcher() { in ~Watcher()
108 void FileDescriptorWatcher::Controller::Watcher::StartWatching() { in StartWatching()
120 void FileDescriptorWatcher::Controller::Watcher::OnFileCanReadWithoutBlocking( in OnFileCanReadWithoutBlocking()
131 void FileDescriptorWatcher::Controller::Watcher::OnFileCanWriteWithoutBlocking( in OnFileCanWriteWithoutBlocking()
[all …]
Dfile_descriptor_watcher_posix.h36 class Watcher; variable
64 std::unique_ptr<Watcher> watcher_;
/external/libmojo/mojo/edk/system/
Dwatcher.cc13 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()
Dwatcher.h30 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);
Drequest_context.h55 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>;
Drequest_context.cc49 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()
Dwatcher_set.cc28 const Watcher::WatchCallback& callback, in Add()
38 scoped_refptr<Watcher> watcher(new Watcher(signals, callback)); in Add()
Dwatcher_set.h37 const Watcher::WatchCallback& callback,
46 std::unordered_map<uintptr_t, scoped_refptr<Watcher>> watchers_;
/external/libmojo/mojo/public/cpp/system/tests/
Dwatcher_unittest.cc25 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/
DExternalSemaSourceTest.cpp219 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/
Dmessage_pump_libevent.h27 class Watcher {
35 virtual ~Watcher() {} in ~Watcher()
69 void set_watcher(Watcher* watcher) { watcher_ = watcher; } in set_watcher()
76 Watcher* watcher_;
111 Watcher* delegate);
Dmessage_loop.h541 MessagePumpLibevent::Watcher* delegate);
586 typedef MessagePumpIOSForIO::Watcher Watcher; typedef
596 typedef MessagePumpLibevent::Watcher Watcher; typedef
618 Watcher* delegate);
/external/libmojo/mojo/public/java/bindings/src/org/chromium/mojo/bindings/
DConnector.java13 import org.chromium.mojo.system.Watcher;
40 private final Watcher mWatcher;
64 public Connector(MessagePipeHandle messagePipeHandle, Watcher watcher) { in Connector()
136 private class WatcherCallback implements Watcher.Callback {
DExecutorFactory.java14 import org.chromium.mojo.system.Watcher;
15 import org.chromium.mojo.system.Watcher.Callback;
63 private final Watcher mWatcher;
DBindingsHelper.java8 import org.chromium.mojo.system.Watcher;
192 static Watcher getWatcherForHandle(Handle handle) { in getWatcherForHandle()
DRouterImpl.java11 import org.chromium.mojo.system.Watcher;
127 public RouterImpl(MessagePipeHandle messagePipeHandle, Watcher watcher) { in RouterImpl()
/external/tensorflow/tensorflow/core/framework/
Dop.h98 typedef std::function<Status(const Status&, const OpDef&)> Watcher; typedef
110 Status SetWatcher(const Watcher& watcher);
153 mutable Watcher watcher_ GUARDED_BY(mu_);
/external/libmojo/mojo/android/system/src/org/chromium/mojo/system/impl/
DWatcherImpl.java12 import org.chromium.mojo.system.Watcher;
15 class WatcherImpl implements Watcher {
/external/owasp/sanitizer/src/tests/org/owasp/html/
DCssFuzzerTest.java59 final class Watcher implements Runnable { class in CssFuzzerTest
87 Watcher watcher = new Watcher(); in testUnderStress()
/external/python/cpython3/Lib/test/test_asyncio/
Dtest_subprocess.py491 Watcher = None variable in SubprocessWatcherMixin
499 watcher = self.Watcher()
507 Watcher = unix_events.SafeChildWatcher variable in SubprocessSafeWatcherTests
512 Watcher = unix_events.FastChildWatcher variable in SubprocessFastWatcherTests
/external/libmojo/mojo/public/java/system/src/org/chromium/mojo/system/
DWatcher.java12 public interface Watcher { interface
/external/libmojo/mojo/common/
Ddata_pipe_drainer.h39 mojo::Watcher handle_watcher_;
/external/libmojo/mojo/edk/js/
Ddrain_data.h53 Watcher handle_watcher_;

123