| /external/chromium-trace/catapult/devil/devil/utils/ |
| timeout_retry.py | 157 thread_group.JoinAll(watcher=thread_group.GetWatcher(), timeout=60,
|
| /external/iptables/iptables/ |
| nft-bridge.c | 34 free(m->u.watcher->t);
212 if (add_target(r, iter->u.watcher->t))
331 m->u.watcher = object;
524 watcherp = m->u.watcher;
|
| /external/kernel-headers/original/uapi/linux/netfilter_bridge/ |
| ebtables.h | 141 struct xt_target *watcher; member in union:ebt_entry_watcher::__anon25820
|
| /external/libchrome/mojo/core/ |
| data_pipe_consumer_dispatcher.cc | 272 const scoped_refptr<WatcherDispatcher>& watcher,
277 return watchers_.Add(watcher, context, GetHandleSignalsStateNoLock());
281 WatcherDispatcher* watcher,
286 return watchers_.Remove(watcher, context);
|
| multiprocess_message_pipe_unittest.cc | [all...] |
| /external/tensorflow/tensorflow/core/framework/ |
| op.h | 95 // Watcher, a function object.
96 // The watcher, if set by SetWatcher(), is called every time an op is
97 // registered via the Register function. The watcher is passed the Status
99 // itself if it was successfully built. A watcher returns a Status which is in
101 typedef std::function<Status(const Status&, const OpDef&)> Watcher;
103 // An OpRegistry object has only one watcher. This interface is not thread
104 // safe, as different clients are free to set the watcher any time.
111 // Returns a non-OK status if a non-null watcher is over-written by another
112 // non-null watcher.
113 Status SetWatcher(const Watcher& watcher)
[all...] |
| /external/libchrome/mojo/public/cpp/bindings/ |
| thread_safe_interface_ptr.h | 153 SyncEventWatcher watcher(&response->event,
156 watcher.SyncWatch(stop_flags, 1);
|
| /external/libchrome/mojo/public/cpp/system/tests/ |
| simple_watcher_unittest.cc | 90 SimpleWatcher watcher(FROM_HERE, SimpleWatcher::ArmingPolicy::AUTOMATIC);
92 watcher.Watch(pipe.consumer_handle.get(), MOJO_HANDLE_SIGNAL_READABLE,
147 // This should never trigger the watcher.
171 // This should trigger the watcher above.
194 // This should never trigger the watcher above.
213 // This should trigger the watcher above...
215 // ...but the watcher is cancelled first.
239 // This message write will not wake up the watcher since the watcher isn't
|
| /external/syzkaller/vendor/google.golang.org/grpc/ |
| balancer_conn_wrappers.go | 113 go ccb.watcher()
118 // watcher balancer functions sequentially, so the balancer can be implemented
120 func (ccb *ccBalancerWrapper) watcher() { func
|
| /external/webrtc/talk/media/devices/ |
| win32devicemanager.cc | 123 if (!watcher()->Start()) {
133 watcher()->Stop();
|
| /external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/ |
| ShadowTextViewTest.java | 313 MockTextWatcher watcher = new MockTextWatcher(); local
314 textView.addTextChangedListener(watcher);
315 assertTrue(shadowOf(textView).getWatchers().contains(watcher));
317 textView.removeTextChangedListener(watcher);
318 assertFalse(shadowOf(textView).getWatchers().contains(watcher));
|
| /external/python/cpython3/Lib/asyncio/ |
| events.py | 602 "Get the watcher for child processes."
605 def set_child_watcher(self, watcher):
606 """Set the watcher for child processes."""
770 def set_child_watcher(watcher):
772 get_event_loop_policy().set_child_watcher(watcher)."""
773 return get_event_loop_policy().set_child_watcher(watcher)
|
| unix_events.py | 185 with events.get_child_watcher() as watcher:
192 watcher.add_child_handler(transp.get_pid(),
776 process must be done within a 'with' block to allow the watcher to suspend
781 with watcher:
783 watcher.add_child_handler(proc.pid, callback)
788 Since child watcher objects may catch the SIGCHLD signal and call
812 """Attach the watcher to an event loop.
814 If the watcher was previously attached to an event loop, then it is
822 """Close the watcher.
829 """Enter the watcher's context and allow starting new processe
[all...] |
| /external/python/cpython3/Lib/test/test_asyncio/ |
| test_subprocess.py | 461 # manually to avoid a warning when the watcher is detached.
513 Watcher = None
521 watcher = self.Watcher()
522 watcher.attach_loop(self.loop)
523 policy.set_child_watcher(watcher)
529 Watcher = unix_events.SafeChildWatcher
534 Watcher = unix_events.FastChildWatcher
|
| test_streams.py | 708 # watcher to the event loop.
725 watcher = asyncio.SafeChildWatcher()
726 watcher.attach_loop(self.loop)
728 asyncio.set_child_watcher(watcher)
[all...] |
| test_events.py | [all...] |
| /external/python/cpython3/Lib/unittest/ |
| case.py | 285 self.watcher = _LoggingWatcher([], [])
291 self.watcher.records.append(record)
293 self.watcher.output.append(msg)
319 self.watcher = handler.watcher
326 return handler.watcher
335 if len(self.watcher.records) == 0:
[all...] |
| /art/test/etc/ |
| run-test-jar | [all...] |
| /cts/tests/tests/animation/src/android/animation/cts/ |
| ValueAnimatorTest.java | 648 final Animator.AnimatorListener watcher = mock(Animator.AnimatorListener.class);
649 animator.addListener(watcher);
651 verify(watcher, times(1)).onAnimationStart(animator, false);
|
| /frameworks/av/media/codec2/sfplugin/ |
| CCodecBufferChannel.cpp | [all...] |
| /external/libchrome/ipc/ |
| ipc_sync_channel.cc | 71 // A reference to the innermost (i.e. topmost) watcher is held in
387 // OnObjectSignalled, another Send can happen which would stop the watcher
699 ReceivedSyncMsgQueue::NestedSendDoneWatcher watcher(
|
| /cts/tests/autofillservice/src/android/autofillservice/cts/ |
| LoginActivityTest.java | 190 final OneTimeTextWatcher watcher = new OneTimeTextWatcher("child", child, local
192 child.addTextChangedListener(watcher);
208 watcher.assertAutoFilled();
[all...] |
| /cts/tests/tests/text/src/android/text/cts/ |
| SelectionTest.java | 983 SpanWatcher watcher = new SpanWatcher() { local
[all...] |
| /external/replicaisland/src/com/replica/replicaisland/ |
| GameObjectFactory.java | [all...] |
