| /external/libmojo/mojo/edk/system/ |
| watcher.cc | 5 #include "mojo/edk/system/watcher.h"
13 Watcher::Watcher(MojoHandleSignals signals, const WatchCallback& callback)
17 void Watcher::MaybeInvokeCallback(MojoResult result,
27 void Watcher::NotifyForStateChange(const HandleSignalsState& signals_state) {
39 void Watcher::NotifyClosed() {
45 void Watcher::Cancel() {
50 Watcher::~Watcher() {}
|
| watcher.h | 22 // An event may occur at any time which should trigger a Watcher to run its
28 // Therefore a Watcher needs to have some associated thread-safe state to track
30 class Watcher : public base::RefCountedThreadSafe<Watcher> {
36 // Constructs a new Watcher which watches for |signals| to be satisfied on a
39 Watcher(MojoHandleSignals signals, const WatchCallback& callback);
41 // Runs the Watcher's callback with the given arguments if it hasn't been
47 // Notifies the Watcher of a state change. This may result in the Watcher
52 // Notifies the Watcher of handle closure. This always results in the Watche
[all...] |
| /external/libmojo/mojo/public/cpp/system/ |
| watcher.cc | 5 #include "mojo/public/cpp/system/watcher.h"
15 Watcher::Watcher(const tracked_objects::Location& from_here,
26 Watcher::~Watcher() {
31 bool Watcher::IsWatching() const {
36 MojoResult Watcher::Start(Handle handle,
46 &Watcher::CallOnHandleReady,
59 void Watcher::Cancel() {
75 void Watcher::OnHandleReady(MojoResult result)
101 Watcher* watcher = reinterpret_cast<Watcher*>(context); local
[all...] |
| watcher.h | 21 // A Watcher watches a single Mojo handle for signal state changes.
24 class MOJO_CPP_SYSTEM_EXPORT Watcher {
39 Watcher(const tracked_objects::Location& from_here,
43 // NOTE: This destructor automatically calls |Cancel()| if the Watcher is
45 ~Watcher();
47 // Indicates if the Watcher is currently watching a handle.
50 // Starts watching |handle|. A Watcher may only watch one handle at a time,
66 // Destroying the Watcher implicitly calls |Cancel()|.
72 // passed to |Start()| will never be called again for this Watcher.
94 // The TaskRunner of this Watcher's owning thread. This field is safe t
[all...] |
| /external/libmojo/mojo/public/java/system/src/org/chromium/mojo/system/ |
| Watcher.java | 12 public interface Watcher {
14 * Callback passed to {@link Watcher#start}.
|
| /external/libchrome/base/files/ |
| file_descriptor_watcher_posix.cc | 33 // If the MessageLoopForIO is deleted before Watcher::StartWatching() runs,
35 // Watcher::StartWatching() runs but before the DeleteSoon task runs,
36 // |watcher_| is deleted from Watcher::WillDestroyCurrentMessageLoop().
43 class FileDescriptorWatcher::Controller::Watcher
44 : public MessageLoopForIO::Watcher,
47 Watcher(WeakPtr<Controller> controller, MessageLoopForIO::Mode mode, int fd);
48 ~Watcher() override;
55 // MessageLoopForIO::Watcher:
70 // The Controller that created this Watcher.
73 // Whether this Watcher is notified when |fd_| becomes readable or writabl
[all...] |
| /external/libchrome/base/message_loop/ |
| message_pump_libevent.h | 27 class Watcher {
35 virtual ~Watcher() {}
69 void set_watcher(Watcher* watcher) { watcher_ = watcher; }
76 Watcher* watcher_;
111 Watcher* delegate);
|
| message_loop.h | 541 MessagePumpLibevent::Watcher* delegate);
586 typedef MessagePumpIOSForIO::Watcher Watcher;
596 typedef MessagePumpLibevent::Watcher Watcher;
618 Watcher* delegate);
|
| /external/tensorflow/tensorflow/core/framework/ |
| op.h | 92 // Watcher, a function object.
93 // The watcher, if set by SetWatcher(), is called every time an op is
94 // registered via the Register function. The watcher is passed the Status
96 // itself if it was successfully built. A watcher returns a Status which is in
98 typedef std::function<Status(const Status&, const OpDef&)> Watcher;
100 // An OpRegistry object has only one watcher. This interface is not thread
101 // safe, as different clients are free to set the watcher any time.
108 // Returns a non-OK status if a non-null watcher is over-written by another
109 // non-null watcher.
110 Status SetWatcher(const Watcher& watcher)
[all...] |
| /frameworks/base/core/tests/coretests/src/android/text/ |
| SpannedTest.java | 140 s.setSpan(new Watcher(2), 0, s.length(),
143 s.setSpan(new Watcher(4), 0, s.length(),
146 s.setSpan(new Watcher(1), 0, s.length(),
149 s.setSpan(new Watcher(3), 0, s.length(),
166 private class Watcher implements SpanWatcher, TextWatcher {
169 public Watcher(int sequence) {
|
| /external/owasp/sanitizer/src/tests/org/owasp/html/ |
| CssFuzzerTest.java | 59 final class Watcher implements Runnable {
87 Watcher watcher = new Watcher(); local
106 synchronized (watcher) {
107 watcher.input = randomCss;
108 watcher.started = System.nanoTime();
111 watcherThread = new Thread(watcher);
168 synchronized (watcher) {
169 watcher.input = null
[all...] |
| /external/python/cpython3/Lib/test/test_asyncio/ |
| test_subprocess.py | 439 # manually to avoid a warning when the watcher is detached.
491 Watcher = None
499 watcher = self.Watcher()
500 watcher.attach_loop(self.loop)
501 policy.set_child_watcher(watcher)
507 Watcher = unix_events.SafeChildWatcher
512 Watcher = unix_events.FastChildWatcher
|
| /hardware/google/av/media/sfplugin/ |
| CCodecConfig.h | 257 struct Watcher {
258 ~Watcher() = default;
280 Watcher(C2Param::Index index, const CCodecConfig *parent)
293 * Returns a watcher object for a parameter.
296 Watcher<T> watch(C2Param::Index index = T::PARAM_TYPE) const {
300 return Watcher<T>(index, this);
|
| /packages/apps/Gallery2/src/com/android/gallery3d/filtershow/ui/ |
| ExportDialog.java | 72 private class Watcher implements TextWatcher {
74 Watcher(EditText text) {
117 mWidthText.addTextChangedListener(new Watcher(mWidthText));
118 mHeightText.addTextChangedListener(new Watcher(mHeightText));
|
| /prebuilts/tools/common/m2/repository/io/netty/netty-common/4.1.0.CR3/ |
| netty-common-4.1.0.CR3.jar | |
| /prebuilts/tools/common/m2/repository/io/netty/netty-common/4.1.3.Final/ |
| netty-common-4.1.3.Final.jar | |
| /prebuilts/tools/common/m2/repository/io/netty/netty-common/4.1.6.Final/ |
| netty-common-4.1.6.Final.jar | |
