| /external/rust/crates/tokio/docs/ |
| D | reactor-refactor.md | 32 `&self`. This supports concurrent waiters with a different readiness interest.
49 /// Awaits for any readiness event included in `interest`. Returns a
50 /// `ReadyEvent` representing the received readiness event.
51 async fn readiness(&self, interest: mio::Ready) -> io::Result<ReadyEvent>;
53 /// Clears resource level readiness represented by the specified `ReadyEvent`
62 receives readiness from the OS once the ready state **changes**. The I/O driver
63 must track each resource's known readiness state. This helps prevent syscalls
66 A call to `readiness()` checks if the currently known resource readiness
67 overlaps with `interest`. If it does, then the `readiness()` immediately
69 readiness event.
[all …]
|
| /external/rust/crates/tokio/src/io/driver/ |
| D | scheduled_io.rs | 26 readiness: AtomicUsize, field
106 let state = self.readiness.load(Acquire); in reset()
111 self.readiness.store(next, Release); in reset()
118 readiness: AtomicUsize::new(0), in default()
126 GENERATION.unpack(self.readiness.load(Acquire)) in generation()
157 let mut current = self.readiness.load(Acquire); in set_readiness()
190 .readiness in set_readiness()
282 let curr = self.readiness.load(Acquire); in ready_event()
300 let curr = self.readiness.load(Acquire); in poll_readiness()
327 let curr = self.readiness.load(Acquire); in poll_readiness()
[all …]
|
| D | registration.rs | 229 pub(crate) async fn readiness(&self, interest: Interest) -> io::Result<ReadyEvent> {
233 let fut = self.shared.readiness(interest);
250 let event = self.readiness(interest).await?;
|
| /external/rust/crates/tokio/src/io/ |
| D | async_fd.rs | 392 async fn readiness(&self, interest: Interest) -> io::Result<AsyncFdReadyGuard<'_, T>> { in readiness() method
393 let event = self.registration.readiness(interest).await?; in readiness()
405 let event = self.registration.readiness(interest).await?; in readiness_mut()
423 self.readiness(Interest::READABLE).await in readable()
447 self.readiness(Interest::WRITABLE).await in writable()
|
| /external/cros/system_api/dbus/power_manager/ |
| D | suspend.proto | 40 // reported readiness; this can happen if a user closes and then quickly opens
43 // readiness. It's unnecessary for clients to report readiness for the original
51 // client may wish to unqueue the undo operation and instead report readiness
128 // readiness call.
|
| /external/rust/crates/mio/ |
| D | CHANGELOG.md | 208 * Custom user-space readiness queue was removed, this includes the public
229 example instead checking for readable readiness using
301 * Add EPOLLPRI readiness to UnixReady on supported platforms (#867)
369 * Fix bug in custom readiness queue
376 * Reimplement custom readiness queue
382 * Only support readable and writable readiness on all platforms
383 * Expose additional readiness in a platform specific capacity
|
| D | README.md | 151 This uses the Windows AFD system to access socket readiness events.
|
| /external/rust/crates/tokio/tests/ |
| D | sync_mutex_owned.rs | 36 fn readiness() { in readiness() function
|
| D | sync_mutex.rs | 36 fn readiness() { in readiness() function
|
| /external/rust/crates/libz-sys/src/zlib/contrib/delphi/ |
| D | readme.txt | 21 readiness.
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | RetriableStreamTest.java | 748 final List<Boolean> readiness = new ArrayList<>(); in isReady_whileDraining() local
757 readiness.add(retriableStream.isReady()); // expected false b/c in draining in isReady_whileDraining()
773 readiness.add(retriableStream.isReady()); // expected false b/c in draining in isReady_whileDraining()
786 readiness.add(retriableStream.isReady()); // expected true in isReady_whileDraining()
796 readiness.add(retriableStream.isReady()); // expected false b/c in backoff in isReady_whileDraining()
801 readiness.add(retriableStream.isReady()); // expected true in isReady_whileDraining()
803 assertThat(readiness).containsExactly(false, true, false, false, true).inOrder(); in isReady_whileDraining()
|
| /external/python/cpython3/Doc/library/ |
| D | selectors.rst | 22 that can be used to wait for I/O readiness notification on multiple file
95 A :class:`BaseSelector` is used to wait for I/O event readiness on multiple
|
| /external/rust/crates/tokio/src/net/unix/ |
| D | stream.rs | 120 let event = self.io.registration().readiness(interest).await?; in ready()
|
| /external/rust/crates/grpcio/src/call/ |
| D | server.rs | 570 let readiness = self.call.call(|c| { localVariable
583 readiness.map(Ok)
|
| /external/rust/crates/tokio/src/net/unix/datagram/ |
| D | socket.rs | 161 let event = self.io.registration().readiness(interest).await?; in ready()
|
| /external/rust/crates/tokio/src/net/tcp/ |
| D | stream.rs | 414 let event = self.io.registration().readiness(interest).await?; in ready()
|
| /external/rust/crates/tokio/src/net/ |
| D | udp.rs | 380 let event = self.io.registration().readiness(interest).await?; in ready()
|
| /external/grpc-grpc/doc/ |
| D | compression_cookbook.md | 13 ## Criteria for GA readiness
|
| /external/libwebsockets/READMEs/ |
| D | README.lws_system.md | 186 Lws implements a state in the context that reflects the readiness of the system
|
| /external/rust/crates/tokio/ |
| D | CHANGELOG.md | 278 - net: `UnixStream` readiness and non-blocking ops ([#3246]).
361 - net: TCP/UDP readiness and non-blocking ops ([#3130], [#2743], [#3138]).
416 - io: `AsyncFd` for receiving readiness events on raw FDs ([#2903]).
|
| /external/curl/ |
| D | RELEASE-NOTES | 102 o multi: expand pre-check for socket readiness [21]
|
| /external/perfetto/protos/perfetto/config/ |
| D | trace_config.proto | 240 // trace ends to notify it about the trace readiness.
|
| /external/swiftshader/docs/ |
| D | Regres.md | 46 To keep Regres responsive, changes are prioritized based on their 'readiness to
|
| /external/parameter-framework/asio-1.10.6/include/asio/detail/impl/ |
| D | socket_ops.ipp | 411 // get spurious readiness notifications from the reactor.
|
| /external/arm-trusted-firmware/docs/components/ |
| D | secure-partition-manager-mm.rst | 387 ``MM_SP_EVENT_COMPLETE_AARCH64`` call (described later) to signal readiness for
|