| /external/rust/crates/tokio/src/io/driver/ |
| D | ready.rs | 170 pub(crate) fn from_interest(interest: Interest) -> Ready {
173 if interest.is_readable() {
178 if interest.is_writable() {
186 pub(crate) fn intersection(self, interest: Interest) -> Ready {
187 Ready(self.0 & Ready::from_interest(interest).0)
190 pub(crate) fn satisfies(self, interest: Interest) -> bool {
191 self.0 & Ready::from_interest(interest).0 != 0
|
| D | registration.rs | 71 interest: Interest, in new_with_interest_and_handle()
75 inner.add_source(io, interest)? in new_with_interest_and_handle()
190 interest: Interest, in try_io()
193 let ev = self.shared.ready_event(interest); in try_io()
229 pub(crate) async fn readiness(&self, interest: Interest) -> io::Result<ReadyEvent> {
233 let fut = self.shared.readiness(interest);
248 …pub(crate) async fn async_io<R>(&self, interest: Interest, mut f: impl FnMut() -> io::Result<R>) -…
250 let event = self.readiness(interest).await?;
|
| D | scheduled_io.rs | 60 interest: Interest,
242 let mut iter = waiters.list.drain_filter(|w| ready.satisfies(w.interest)); in wake0()
281 pub(super) fn ready_event(&self, interest: Interest) -> ReadyEvent { in ready_event()
286 ready: interest.mask() & Ready::from_usize(READINESS.unpack(curr)), in ready_event()
378 pub(crate) async fn readiness(&self, interest: Interest) -> ReadyEvent {
379 self.readiness_fut(interest).await
386 fn readiness_fut(&self, interest: Interest) -> Readiness<'_> {
394 interest,
439 let interest = unsafe { (*waiter.get()).interest }; localVariable
440 let ready = ready.intersection(interest);
[all …]
|
| D | mod.rs | 3 mod interest; module
5 pub use interest::Interest;
323 interest: Interest, in add_source()
335 .register(source, mio::Token(token), interest.to_mio())?; in add_source()
|
| /external/rust/crates/tokio/docs/ |
| D | reactor-refactor.md | 31 `Registration` is updated to support waiting for an arbitrary interest set with
32 `&self`. This supports concurrent waiters with a different readiness interest.
44 /// `interest` must be a super set of **all** interest sets specified in
45 /// the other methods. This is the interest set passed to `mio`.
46 pub fn new<T>(io: &T, interest: mio::Ready) -> io::Result<Registration>
49 /// Awaits for any readiness event included in `interest`. Returns a
51 async fn readiness(&self, interest: mio::Ready) -> io::Result<ReadyEvent>;
57 A new registration is created for a `T: mio::Evented` and a `interest`. This
67 overlaps with `interest`. If it does, then the `readiness()` immediately
77 let event = self.readiness(interest).await?;
[all …]
|
| /external/rust/crates/tokio/src/io/ |
| D | async_fd.rs | 185 pub fn with_interest(inner: T, interest: Interest) -> io::Result<Self> in with_interest()
189 Self::new_with_handle_and_interest(inner, Handle::current(), interest) in with_interest()
195 interest: Interest, in new_with_handle_and_interest()
200 Registration::new_with_interest_and_handle(&mut SourceFd(&fd), interest, handle)?; in new_with_handle_and_interest()
392 async fn readiness(&self, interest: Interest) -> io::Result<AsyncFdReadyGuard<'_, T>> { in readiness()
393 let event = self.registration.readiness(interest).await?; in readiness()
403 interest: Interest, in readiness_mut()
405 let event = self.registration.readiness(interest).await?; in readiness_mut()
|
| D | poll_evented.rs | 107 pub(crate) fn new_with_interest(io: E, interest: Interest) -> io::Result<Self> { in new_with_interest()
108 Self::new_with_interest_and_handle(io, interest, Handle::current()) in new_with_interest()
113 interest: Interest, in new_with_interest_and_handle()
116 let registration = Registration::new_with_interest_and_handle(&mut io, interest, handle)?; in new_with_interest_and_handle()
|
| /external/expat/win32/ |
| D | MANIFEST.txt | 4 Some of these directories contain components of interest to all Expat
5 users, and some contain material of interest to developers who wish to
19 <top>\Source\ Source code, which may interest some developers,
|
| /external/rust/crates/tokio/src/process/unix/ |
| D | mod.rs | 196 interest: mio::Interest, in register()
198 SourceFd(&self.as_raw_fd()).register(registry, token, interest) in register()
205 interest: mio::Interest, in reregister()
207 SourceFd(&self.as_raw_fd()).reregister(registry, token, interest) in reregister()
|
| /external/rust/crates/mio/src/ |
| D | lib.rs | 48 mod interest; module
66 pub use interest::Interest;
|
| /external/rust/crates/mio/src/sys/windows/ |
| D | named_pipe.rs | 363 interest: Interest, in register()
387 io.read_interest = interest.is_readable(); in register()
388 io.write_interest = interest.is_writable(); in register()
400 interest: Interest, in reregister()
407 io.read_interest = interest.is_readable(); in reregister()
408 io.write_interest = interest.is_writable(); in reregister()
|
| /external/perfetto/ |
| D | heapprofd.rc | 21 # as fast as possible in the interest of the app being profiled.
37 # as fast as possible in the interest of the app being profiled.
|
| /external/antlr/runtime/ActionScript/ |
| D | README | 44 <http://www.antlr.org:8080/mailman/listinfo/antlr-interest> or
45 <george.scott-antrl@gmail.com>. Direct e-mail is preferable as the antlr-interest
|
| /external/iperf3/contrib/ |
| D | README.txt | 9 Other iperf3 related projects that might be of interest:
|
| /external/pigweed/pw_build/ |
| D | copy_from_cipd.gni | 47 # package of interest is defined in.
48 # library_path: (required) The path of the static library of interest,
|
| /external/llvm-project/ |
| D | CONTRIBUTING.md | 3 Thank you for your interest in contributing to LLVM! There are many ways to
|
| /external/tensorflow/tensorflow/core/api_def/base_api/ |
| D | api_def_GenerateBoundingBoxProposals.pbtxt | 51 region of interest boxes. Sorted in descending order in scores.
58 region of interest box in `rois` tensor at the same index.
|
| /external/crosvm/ |
| D | CONTRIBUTING.md | 3 This article goes into detail about multiple areas of interest to contributors,
4 which includes reviewers, developers, and integrators who each share an interest
|
| /external/cros/system_api/dbus/metrics_event/ |
| D | metrics_event.proto | 13 // signal in the AnomalyEventService) to report events of interest for
|
| /external/python/pyopenssl/ |
| D | CODE_OF_CONDUCT.rst | 7 In the interest of fostering an open and welcoming environment, we as contributors and maintainers …
45 …ntainer Hynek Schlawack at hs@ox.cx or -- e.g. in case of a conflict of interest -- Amber Brown at…
|
| /external/grpc-grpc/src/csharp/unitypackage/ |
| D | README.md | 3 Scripts in this directory are of no interest for end users. They are part
|
| /external/llvm-project/clang/include/clang/Basic/ |
| D | DiagnosticRefactoringKinds.td | 22 "not overlap with the AST nodes of interest">;
|
| /external/rust/crates/tokio/src/net/unix/ |
| D | stream.rs | 119 pub async fn ready(&self, interest: Interest) -> io::Result<Ready> { in ready()
120 let event = self.io.registration().readiness(interest).await?; in ready()
|
| /external/autotest/client/tests/pktgen/ |
| D | control | 11 network devices. Especially of interest is the use of pktgen to test routers or
|
| /external/rust/crates/tokio/src/net/unix/datagram/ |
| D | socket.rs | 160 pub async fn ready(&self, interest: Interest) -> io::Result<Ready> { in ready()
161 let event = self.io.registration().readiness(interest).await?; in ready()
|