| /external/apache-commons-lang/src/test/java/org/apache/commons/lang3/time/ |
| D | StopWatchTest.java | 59 * final StopWatch watch = createMockStopWatch(nanos);
62 * @param nanos Time in nanoseconds to have elapsed on the stop watch
66 final StopWatch watch = StopWatch.createStarted(); in createMockStopWatch() local
67 watch.suspend(); in createMockStopWatch()
70 FieldUtils.writeField(watch, "startTimeNanos", currentNanos - nanos, true); in createMockStopWatch()
71 FieldUtils.writeField(watch, "stopTimeNanos", currentNanos, true); in createMockStopWatch()
75 return watch; in createMockStopWatch()
85 final StopWatch watch = new StopWatch(); in testBadStates() local
86 assertThrows(IllegalStateException.class, watch::stop, in testBadStates()
89 assertThrows(IllegalStateException.class, watch::suspend, in testBadStates()
[all …]
|
| /external/libchrome/base/files/ |
| D | file_path_watcher_linux.cc | 67 typedef int Watch; // Watch descriptor used by AddWatch and RemoveWatch. typedef in base::__anon72d957510111::InotifyReader
68 static const Watch kInvalidWatch = -1;
70 // Watch directory |path| for changes. |watcher| will be notified on each
72 Watch AddWatch(const FilePath& path, FilePathWatcherImpl* watcher);
74 // Remove |watch| if it's valid.
75 void RemoveWatch(Watch watch, FilePathWatcherImpl* watcher);
94 std::unordered_map<Watch, WatcherSet> watchers_;
116 // Called for each event coming from the watch. |fired_watch| identifies the
117 // watch that fired, |child| indicates what has changed, and is relative to
123 void OnFilePathChanged(InotifyReader::Watch fired_watch,
[all …]
|
| /external/rust/crates/hyper/src/common/ |
| D | drain.rs | 7 use tokio::sync::watch;
9 pub(crate) fn channel() -> (Signal, Watch) { in channel()
10 let (tx, rx) = watch::channel(()); in channel()
11 (Signal { tx }, Watch { rx }) in channel()
15 tx: watch::Sender<()>,
21 pub(crate) struct Watch { struct
22 rx: watch::Receiver<()>,
31 watch: Pin<Box<dyn Future<Output = ()> + Send + Sync>>,
32 _rx: watch::Receiver<()>,
37 Watch(F), argument
[all …]
|
| /external/cronet/base/files/ |
| D | file_path_watcher_inotify.cc | 111 // Watch descriptor used by AddWatch() and RemoveWatch().
113 using Watch = uint32_t; typedef in base::__anon634860590111::InotifyReader
115 using Watch = int;
118 // Record of watchers tracked for watch descriptors.
124 static constexpr Watch kInvalidWatch = static_cast<Watch>(-1);
125 static constexpr Watch kWatchLimitExceeded = static_cast<Watch>(-2);
130 // Watch directory |path| for changes. |watcher| will be notified on each
132 Watch AddWatch(const FilePath& path, FilePathWatcherImpl* watcher);
134 // Remove |watch| if it's valid.
135 void RemoveWatch(Watch watch, FilePathWatcherImpl* watcher);
[all …]
|
| D | file_path_watcher_win.cc | 35 bool Watch(const FilePath& path,
44 // Setup a watch handle for directory |dir|. Set |recursive| to true to watch
52 // (Re-)Initialize the watch handle.
55 // Destroy the watch handle.
61 // Path we're supposed to watch (passed to callback).
70 // ObjectWatcher to watch handle_ for events.
73 // The type of watch requested.
91 bool FilePathWatcherImpl::Watch(const FilePath& path, in Watch() function in base::__anone0a147050111::FilePathWatcherImpl
94 DCHECK(target_.value().empty()); // Can only watch one path. in Watch()
118 // Watch was never called, or the |task_runner_| has already quit. in Cancel()
[all …]
|
| /external/libchrome/mojo/core/ |
| D | watcher_dispatcher.cc | 13 #include "mojo/core/watch.h"
28 // Maybe fire a notification to the watch associated with this dispatcher, in NotifyHandleState()
33 // If we were armed and got here, we notified the watch. Disarm. in NotifyHandleState()
41 scoped_refptr<Watch> watch; in NotifyHandleClosed() local
48 watch = std::move(it->second); in NotifyHandleClosed()
51 watches_.erase(watch->context()); in NotifyHandleClosed()
52 ready_watches_.erase(watch.get()); in NotifyHandleClosed()
57 // acquires internal Watch locks. in NotifyHandleClosed()
58 watch->Cancel(); in NotifyHandleClosed()
100 base::flat_map<uintptr_t, scoped_refptr<Watch>> watches; in Close()
[all …]
|
| D | watch.h | 21 // Encapsulates the state associated with a single watch context within a
24 // Every Watch has its own cancellation state, and is captured by RequestContext
27 class Watch : public base::RefCountedThreadSafe<Watch> {
29 // Constructs a Watch which represents a watch within |watcher| associated
31 Watch(const scoped_refptr<WatcherDispatcher>& watcher,
37 // Notifies the Watch of a potential state change.
41 // with this watch's context. See return values below.
43 // This is called directly by WatcherDispatcher whenever the Watch's observed
46 // Returns |true| if the Watch entered or remains in a ready state as a result
48 // the Watch will have also attached a notification finalizer to the current
[all …]
|
| D | request_context.cc | 47 // From the application's perspective the watch is cancelled as soon as this in ~RequestContext()
49 // updates some internal Watch state to ensure no further notifications in ~RequestContext()
50 // fire. Because notifications on a single Watch are mutually exclusive, in ~RequestContext()
53 for (const scoped_refptr<Watch>& watch : in ~RequestContext() local
66 watch->InvokeCallback(MOJO_RESULT_CANCELLED, closed_state, flags); in ~RequestContext()
69 for (const WatchNotifyFinalizer& watch : in ~RequestContext() local
72 watch.watch->InvokeCallback(watch.result, watch.state, flags); in ~RequestContext()
87 void RequestContext::AddWatchNotifyFinalizer(scoped_refptr<Watch> watch, in AddWatchNotifyFinalizer() argument
92 WatchNotifyFinalizer(std::move(watch), result, state)); in AddWatchNotifyFinalizer()
95 void RequestContext::AddWatchCancelFinalizer(scoped_refptr<Watch> watch) { in AddWatchCancelFinalizer() argument
[all …]
|
| D | request_context.h | 12 #include "mojo/core/watch.h"
51 // Adds a finalizer to this RequestContext corresponding to a watch callback
56 void AddWatchNotifyFinalizer(scoped_refptr<Watch> watch,
60 // Adds a finalizer to this RequestContext corresponding to a watch callback
61 // which should be triggered to notify of watch cancellation. This appends to
64 void AddWatchCancelFinalizer(scoped_refptr<Watch> watch);
71 WatchNotifyFinalizer(scoped_refptr<Watch> watch,
77 scoped_refptr<Watch> watch; member
90 base::StackVector<scoped_refptr<Watch>, kStaticWatchFinalizersCapacity>;
|
| D | watcher_dispatcher.h | 24 class Watch; variable
30 // registered watch observes some relevant state change.
38 // Method used by RequestContext (indirectly, via Watch) to complete
57 friend class Watch;
59 using WatchSet = std::set<const Watch*>;
76 // A mapping from context to Watch.
77 base::flat_map<uintptr_t, scoped_refptr<Watch>> watches_;
79 // A mapping from watched dispatcher to Watch.
80 base::flat_map<Dispatcher*, scoped_refptr<Watch>> watched_handles_;
82 // The set of all Watch instances which are currently ready to signal. This is
[all …]
|
| D | watch.cc | 5 #include "mojo/core/watch.h"
13 Watch::Watch(const scoped_refptr<WatcherDispatcher>& watcher, in Watch() function in mojo::core::Watch
24 bool Watch::NotifyState(const HandleSignalsState& state, in NotifyState()
57 void Watch::Cancel() { in Cancel()
61 void Watch::InvokeCallback(MojoResult result, in InvokeCallback()
81 Watch::~Watch() {} in ~Watch()
84 void Watch::AssertWatcherLockAcquired() const { in AssertWatcherLockAcquired()
|
| /external/mesa3d/src/broadcom/common/ |
| D | v3d_performance_counters.h | 88 {"AXI", "AXI-writes-seen-watch-0", "[AXI] Writes seen by watch 0"},
89 {"AXI", "AXI-reads-seen-watch-0", "[AXI] Reads seen by watch 0"},
90 {"AXI", "AXI-writes-stalled-seen-watch-0", "[AXI] Write stalls seen by watch 0"},
91 {"AXI", "AXI-reads-stalled-seen-watch-0", "[AXI] Read stalls seen by watch 0"},
92 {"AXI", "AXI-write-bytes-seen-watch-0", "[AXI] Total bytes written seen by watch 0"},
93 {"AXI", "AXI-read-bytes-seen-watch-0", "[AXI] Total bytes read seen by watch 0"},
94 {"AXI", "AXI-writes-seen-watch-1", "[AXI] Writes seen by watch 1"},
95 {"AXI", "AXI-reads-seen-watch-1", "[AXI] Reads seen by watch 1"},
96 {"AXI", "AXI-writes-stalled-seen-watch-1", "[AXI] Write stalls seen by watch 1"},
97 {"AXI", "AXI-reads-stalled-seen-watch-1", "[AXI] Read stalls seen by watch 1"},
[all …]
|
| /external/webp/examples/ |
| D | stopwatch.h | 24 static WEBP_INLINE void StopwatchReset(Stopwatch* watch) { in StopwatchReset() argument
25 QueryPerformanceCounter(watch); in StopwatchReset()
28 static WEBP_INLINE double StopwatchReadAndReset(Stopwatch* watch) { in StopwatchReadAndReset() argument
29 const LARGE_INTEGER old_value = *watch; in StopwatchReadAndReset()
31 if (!QueryPerformanceCounter(watch)) in StopwatchReadAndReset()
37 return (watch->QuadPart - old_value.QuadPart) / (double)freq.QuadPart; in StopwatchReadAndReset()
47 static WEBP_INLINE void StopwatchReset(Stopwatch* watch) { in StopwatchReset() argument
48 gettimeofday(watch, NULL); in StopwatchReset()
51 static WEBP_INLINE double StopwatchReadAndReset(Stopwatch* watch) { in StopwatchReadAndReset() argument
54 memcpy(&old_value, watch, sizeof(old_value)); in StopwatchReadAndReset()
[all …]
|
| /external/grpc-grpc/src/objective-c/examples/watchOS-sample/WatchKit-App/Assets.xcassets/AppIcon.appiconset/ |
| D | Contents.json | 5 "idiom" : "watch",
12 "idiom" : "watch",
19 "idiom" : "watch",
25 "idiom" : "watch",
31 "idiom" : "watch",
38 "idiom" : "watch",
45 "idiom" : "watch",
52 "idiom" : "watch",
59 "idiom" : "watch",
66 "idiom" : "watch",
[all …]
|
| /external/wpa_supplicant_8/wpa_supplicant/dbus/ |
| D | dbus_common.c | 59 DBusWatch *watch, eloop_event_type type) in process_watch() argument
66 dbus_watch_handle(watch, DBUS_WATCH_READABLE); in process_watch()
68 dbus_watch_handle(watch, DBUS_WATCH_WRITABLE); in process_watch()
70 dbus_watch_handle(watch, DBUS_WATCH_ERROR); in process_watch()
99 static dbus_bool_t add_watch(DBusWatch *watch, void *data) in add_watch() argument
105 if (!dbus_watch_get_enabled(watch)) in add_watch()
108 flags = dbus_watch_get_flags(watch); in add_watch()
109 fd = dbus_watch_get_unix_fd(watch); in add_watch()
112 process_watch_exception, priv, watch) < 0) in add_watch()
117 priv, watch) < 0) in add_watch()
[all …]
|
| /external/ltp/testcases/kernel/syscalls/utils/ |
| D | inotify.h | 19 __s32 wd; /* watch descriptor */
20 __u32 mask; /* watch mask */
26 /* the following are legal, implemented events that user-space can watch for */
40 /* the following are legal events. they are sent as needed to any watch */
50 #define IN_ONLYDIR 0x01000000 /* only watch the path if it is a directory */
52 #define IN_MASK_ADD 0x20000000 /* add to the mask of an already existing watch */
72 * struct inotify_watch - represents a watch request on a specific inode
76 * ih, inode, and wd are never written to once the watch is created.
88 __s32 wd; /* watch descriptor */
89 __u32 mask; /* event mask for this watch */
[all …]
|
| /external/googleapis/google/watcher/v1/ |
| D | watch.proto | 30 // [Watcher][] lets a client watch for updates to a named entity, such as a
32 // reliable stream of watch events, without re-ordering.
49 // The Watch API allows a client to watch an entity E's immediate
56 // ## Watch request
58 // When a client makes a request to watch an entity, it can indicate
61 // point in a previous watch stream, specified with a `resume_marker` value.
62 // It can also indicate whether it wants to watch only one entity or all
65 // On receiving a watch request for an entity, the server sends one or more
68 // client receives the event is referred to as the client's "watch
79 // documentation of a particular system that implements the Watch API to
[all …]
|
| /external/tensorflow/tensorflow/python/eager/ |
| D | backprop_test.py | 141 t.watch(x)
142 t.watch(x1)
143 t.watch(x2)
144 t.watch(x3)
145 t.watch(x4)
165 tape.watch(x)
166 tape.watch(h)
200 t.watch([x, y])
242 tape.watch(x)
251 t.watch([x, y])
[all …]
|
| /external/libchrome/mojo/public/cpp/system/ |
| D | simple_watcher.h | 28 // watch a single handle, dispatching state change notifications to an arbitrary
63 // The SimpleWatcher is armed automatically on Watch() and rearmed again
66 // to calling ArmOrNotify() once after Watch() and once again after every
98 // Starts watching |handle|. A SimpleWatcher may only watch one handle at a
100 // watch has been cancelled (i.e. |IsWatching()| returns |false|.)
103 // |signals| is not a valid set of signals to watch, this returns
110 // Once the watch is started, |callback| may be called at any time on the
120 MojoResult Watch(Handle handle,
130 MojoResult Watch(Handle handle, in Watch() function
133 return Watch(handle, signals, MOJO_WATCH_CONDITION_SATISFIED, in Watch()
[all …]
|
| /external/pigweed/pw_watch/ |
| D | guide.rst | 21 pw watch
43 pw watch -C out2
55 pw watch
66 pw watch -C out2
74 pw watch stm32f429i python.lint
86 pw watch -C out1 -C out2
97 pw watch stm32f429i -C out2 python.lint
113 This section discusses general use cases that all apply to all ``pw watch``
119 ``pw watch`` only rebuilds when a file that is not ignored by Git changes.
120 Adding exclusions to a ``.gitignore`` causes ``pw watch`` to ignore them, even
[all …]
|
| /external/tensorflow/tensorflow/core/debug/ |
| D | grpc_session_debug_test.cc | 162 // Iteration 0: No watch. in TEST_F()
163 // Iterations 1 and 2: Watch one Tensor. in TEST_F()
164 // Iterations 3 and 4: Watch two Tensors. in TEST_F()
165 // Iteration 5: No watch. in TEST_F()
170 DebugTensorWatch* watch = debug_options->add_debug_tensor_watch_opts(); in TEST_F() local
171 watch->set_node_name(node_names[0]); in TEST_F()
172 watch->set_output_slot(0); in TEST_F()
173 watch->add_debug_ops("DebugIdentity"); in TEST_F()
174 watch->add_debug_urls(GetDebugURL()); in TEST_F()
177 watch = debug_options->add_debug_tensor_watch_opts(); in TEST_F()
[all …]
|
| /external/rust/crates/tokio-stream/src/wrappers/ |
| D | watch.rs | 2 use tokio::sync::watch::Receiver;
9 use tokio::sync::watch::error::RecvError;
11 /// A wrapper around [`tokio::sync::watch::Receiver`] that implements [`Stream`].
23 /// use tokio::sync::watch;
25 /// let (tx, rx) = watch::channel("hello");
39 /// use tokio::sync::watch;
41 /// let (tx, rx) = watch::channel("hello");
57 /// use tokio::sync::watch;
60 /// let (tx, rx) = watch::channel("hello");
71 /// [`tokio::sync::watch::Receiver`]: struct@tokio::sync::watch::Receiver
|
| /external/tensorflow/tensorflow/python/kernel_tests/ |
| D | gradient_correctness_test.py | 34 tape.watch(x)
48 tape.watch(x)
56 tape.watch(x)
64 tape.watch(x)
75 tape.watch(x)
87 tape.watch([k, x])
97 tape.watch(k)
107 tape.watch(k)
117 tape.watch(k)
129 tape.watch(k)
|
| /external/llvm/test/CodeGen/ARM/ |
| D | vfp-reg-stride.ll | 2 …cpu=swift -mtriple=thumbv7k-apple-watchos -o - %s | FileCheck %s --check-prefix=CHECK-STRIDE4-WATCH
10 ; CHECK-STRIDE4-WATCH-LABEL: test_reg_stride:
11 ; CHECK-STRIDE4-WATCH-DAG: vmov.f64 d16, d
12 ; CHECK-STRIDE4-WATCH-DAG: vmov.f64 d18, d
28 ; CHECK-STRIDE4-WATCH-LABEL: test_stride_minsize:
29 ; CHECK-STRIDE4-WATCH-DAG: vmov.f32 s4, {{s[01]}}
30 ; CHECK-STRIDE4-WATCH-DAG: vmov.f32 s8, {{s[01]}}
|
| /external/openscreen/osp/public/ |
| D | message_demuxer_unittest.cc | 62 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F() local
65 ASSERT_TRUE(watch); in TEST_F()
88 watch = MessageDemuxer::MessageWatch(); in TEST_F()
98 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F() local
101 ASSERT_TRUE(watch); in TEST_F()
129 MessageDemuxer::MessageWatch watch = demuxer_.SetDefaultMessageTypeWatch( in TEST_F() local
131 ASSERT_TRUE(watch); in TEST_F()
162 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F() local
165 ASSERT_TRUE(watch); in TEST_F()
218 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F() local
[all …]
|