| /third_party/ltp/lib/ |
| D | tlibio.c | 21 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
38 * program and only a io type field value would have to change to
39 * do different types of io. There is even a couple of functions that
45 * Functions declared in this module - see individual function code for
124 #if 0 /* disabled until it's needed -- roehrich 6/11/97 */
139 "async i/o using a loop to wait for a signal"},
140 {"b", LIO_IO_ASYNC | LIO_WAIT_SIGPAUSE, "async i/o using pause"},
142 "async i/o using recall/aio_suspend"},
160 "single stride async listio using recall"},
162 "single stride async listio using pause"},
[all …]
|
| /third_party/ltp/include/old/ |
| D | tlibio.h | 21 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
36 #define LIO_IO_ALISTIO 00010 /* single stride async listio */
37 #define LIO_IO_SYNCV 00020 /* single-buffer readv/writev */
41 #define LIO_IO_ATYPES 00077 /* all io types */
42 #define LIO_IO_TYPES 00061 /* all io types, non-async */
45 #define LIO_IO_TYPES 00061 /* all io types */
46 #define LIO_IO_ATYPES 00077 /* all io types */
49 #define LIO_IO_TYPES 00021 /* all io types except pread/pwrite */
52 #define LIO_IO_TYPES 00017 /* all io types */
59 #define LIO_WAIT_NONE 00010000 /* return asap -- use with care */
[all …]
|
| /third_party/rust/crates/io-lifetimes/ |
| D | Cargo.toml | 2 name = "io-lifetimes"
4 description = "A low-level I/O ownership and borrowing library"
6 license = "Apache-2.0 WITH LLVM-exception OR Apache-2.0 OR MIT"
7 keywords = ["api", "io"]
8 categories = ["os", "rust-patterns"]
10 repository = "https://github.com/sunfishcode/io-lifetimes"
14 # io-lifetimes only depends on libc/windows-sys for the ability to close
16 # dependencies to add foreign-type impls for the traits. In the future,
21 fs-err = { version = "2.6.0", optional = true }
27 # The following dependencies allow io-lifetimes to define impls for various
[all …]
|
| /third_party/rust/crates/rustix/ |
| D | Cargo.toml | 8 description = "Safe Rust bindings to POSIX/Unix/Linux/Winsock2-like syscalls"
10 license = "Apache-2.0 WITH LLVM-exception OR Apache-2.0 OR MIT"
14 categories = ["os::unix-apis", "date-and-time", "filesystem", "network-programming"]
16 rust-version = "1.48"
18 [build-dependencies]
23 itoa = { version = "1.0.1", default-features = false, optional = true }
24 io-lifetimes = { version = "1.0.0", default-features = false, features = ["close"], optional = true…
26 # Special dependencies used in rustc-dep-of-std mode.
27 core = { version = "1.0.0", optional = true, package = "rustc-std-workspace-core" }
28 alloc = { version = "1.0.0", optional = true, package = "rustc-std-workspace-alloc" }
[all …]
|
| /third_party/libuv/ |
| D | LINKS.md | 5 * [cjdns](https://github.com/cjdelisle/cjdns): Encrypted self-configuring network/VPN routing engine
7 * [CMake](https://cmake.org) open-source, cross-platform family of tools designed to build, test an…
8 * [Cocos-Engine](https://github.com/cocos/cocos-engine): The runtime framework for Cocos Creator ed…
10 * [DPS8M](https://dps8m.gitlab.io): GE ∕ Honeywell ∕ Bull DPS‑8/M and 6180/L68 mainframe simulator.
11 * [DPS-For-IoT](https://github.com/intel/dps-for-iot/wiki): Fully distributed publish/subscribe pro…
12 * [HashLink](https://github.com/HaxeFoundation/hashlink): Haxe run-time with libuv support included.
15 * [Igropyr](https://github.com/guenchi/Igropyr): a async Scheme http server base on libuv.
18 * [Knot DNS Resolver](https://www.knot-resolver.cz/): A minimalistic DNS caching resolver
22 * [libuv_message_framing](https://github.com/litesync/libuv_message_framing) Message-based communic…
24 * [Luvit](http://luvit.io): Node.JS for the Lua Inventor
[all …]
|
| /third_party/ltp/testcases/kernel/io/ltp-aiodio/ |
| D | aiocp.c | 1 // SPDX-License-Identifier: GPL-2.0-or-later
12 * Copy file by using an async I/O state machine.
14 * - Start read request
15 * - When read completes turn it into a write request
16 * - When write completes decrement counter and free up resources
55 # define howmany(x, y) (((x) + ((y) - 1)) / (y))
65 i -= tst_rand_data_len; in fill_with_rand_data()
80 io_prep_pread(iocb_free[i], -1, buff, aio_blksize, 0); in async_init()
91 return iocb_free[--iocb_free_count]; in get_iocb()
94 static void put_iocb(struct iocb *io) in put_iocb() argument
[all …]
|
| D | aiodio_append.c | 1 // SPDX-License-Identifier: GPL-2.0-or-later
63 tst_brk(TBROK, "io_queue_init: %s", tst_strerrno(-w)); in aiodio_append()
79 tst_brk(TBROK, "io_submit (multiple): %s", tst_strerrno(-w)); in aiodio_append()
92 io_prep_pwrite(iocbp, fd, iocbp->u.c.buf, ws, offset); in aiodio_append()
97 tst_brk(TBROK, "io_submit (single): %s", tst_strerrno(-w)); in aiodio_append()
109 tst_brk(TBROK, "Number of async IO blocks '%s'", str_numaio); in setup()
111 SAFE_FILE_SCANF("/proc/sys/fs/aio-max-nr", "%d", &maxaio); in setup()
115 tst_res(TCONF, "Number of async IO blocks passed the maximum (%d)", maxaio); in setup()
129 …run_child = SAFE_MMAP(NULL, sizeof(int), PROT_READ | PROT_WRITE, MAP_SHARED | MAP_ANONYMOUS, -1, 0… in setup()
177 if (SAFE_WAITPID(-1, &status, WNOHANG)) in run()
[all …]
|
| /third_party/python/Doc/library/ |
| D | asyncio.rst | 1 :mod:`asyncio` --- Asynchronous I/O
7 -------------------------------
15 async def main():
23 the **async/await** syntax.
26 frameworks that provide high-performance network and web-servers,
29 asyncio is often a perfect fit for IO-bound and high-level
32 asyncio provides a set of **high-level** APIs to:
37 * perform :ref:`network IO and IPC <asyncio-streams>`;
39 * control :ref:`subprocesses <asyncio-subprocess>`;
41 * distribute tasks via :ref:`queues <asyncio-queues>`;
[all …]
|
| D | asyncio-dev.rst | 3 .. _asyncio-dev:
16 .. _asyncio-debug-mode:
36 * setting the log level of the :ref:`asyncio logger <asyncio-logger>` to
44 using the :option:`-W` ``default`` command line option.
50 <asyncio-coroutine-not-scheduled>` and logs them; this mitigates
53 * Many non-threadsafe asyncio APIs (such as :meth:`loop.call_soon` and
65 .. _asyncio-multithreading:
84 low-level asyncio API, the :meth:`loop.call_soon_threadsafe` method
93 async def coro_func():
112 :mod:`multiprocessing`). The :ref:`asyncio-event-loop-methods`
[all …]
|
| D | asyncio-stream.rst | 3 .. _asyncio-streams:
11 -------------------------------------------------
13 Streams are high-level async/await-ready primitives to work with
15 using callbacks or low-level protocols and transports.
24 async def tcp_echo_client(message):
47 The following top-level asyncio functions can be used to create
155 The *path* parameter can now be a :term:`path-like object`
185 The *path* parameter can now be a :term:`path-like object`.
200 from the IO stream. As an :term:`asynchronous iterable`, the
201 object supports the :keyword:`async for` statement.
[all …]
|
| D | contextlib.rst | 1 :mod:`!contextlib` --- Utilities for :keyword:`!with`\ -statement contexts
5 :synopsis: Utilities for with-statement contexts.
9 --------------
13 :ref:`context-managers`.
17 ---------
39 :ref:`async-context-managers`.
75 The function being decorated must return a :term:`generator`-iterator when
94 each function call (this allows the otherwise "one-shot" context managers
105 :ref:`asynchronous context manager <async-context-managers>`.
108 function for :keyword:`async with` statement asynchronous context managers,
[all …]
|
| D | asyncio-task.rst | 8 This section outlines high-level asyncio APIs to work with coroutines
23 ----------------------------------------------------
25 :term:`Coroutines <coroutine>` declared with the async/await syntax is the
32 >>> async def main():
49 * The :func:`asyncio.run` function to run the top-level
59 async def say_after(delay, what):
63 async def main():
86 async def main():
114 async def main():
115 async with asyncio.TaskGroup() as tg:
[all …]
|
| D | asyncio-api-index.rst | 5 High-level API Index
8 This page lists all high-level async/await enabled asyncio APIs.
17 .. list-table::
19 :class: full-width-table
21 * - :func:`run`
22 - Create event loop, run a coroutine, close the loop.
24 * - :class:`Runner`
25 - A context manager that simplifies multiple async function calls.
27 * - :class:`Task`
28 - Task object.
[all …]
|
| /third_party/ltp/testcases/kernel/fs/doio/ |
| D | doio.h | 21 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
33 * Define io syscalls supported by doio
43 #define LREAD 10 /* listio - single stride, single entry */
47 #define LSREAD 14 /* listio - multi-stride, single entry */
51 #define LEREAD 18 /* listio - single stride, multiple entry */
77 /* used: <<doio>> 1.? <<DOIO>> 1.5 <-DOIO-> 1.7*/
84 * Define various user flags (r_uflag field) that io requests can have
103 * Define async io completion strategies supported by doio.
116 * unionized into a single io_req structure which io generators fill in and
178 int r_aio_strat; /* async I/O completion strategy */
[all …]
|
| D | doio.c | 21 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
33 * doio - a general purpose io initiator with system call and
39 * For disk io, if the O_SSD flag is set doio will allocate
40 * the appropriate amount of ssd and do the transfer - thus, doio
41 * can handle all of the primitive types of file io.
45 * -----------
105 #define MEMF_FILE 01000 /* regular file -- unlink on close */
140 * Name-To-Value map
167 /* ---------------------------------------------------------------------------
172 * the syscall return checking, async I/O wait, iosw check, etc.
[all …]
|
| D | iogen.c | 21 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
33 * iogen - a tool for generating file/sds io for a doio process
98 int f_nextoff; /* offset of end of last io operation */
100 int f_lastoffset; /* offset of last io operation */
101 int f_lastlength; /* length of last io operation */
105 * Simple structure for associating strings with values - useful for converting
134 int a_opt = 0; /* async io comp. types supplied */
137 int i_opt = 0; /* iterations - 0 implies infinite */
138 int L_opt = 0; /* listio min-max nstrides & nents */
141 int p_opt = 0; /* output pipe - default is stdout */
[all …]
|
| /third_party/rust/crates/nix/src/ |
| D | pty.rs | 1 //! Create master and slave virtual pseudo-terminals (PTYs)
7 use std::io;
48 /// so that when it's consumed or goes out of scope, it's automatically cleaned-up.
53 fn as_raw_fd(&self) -> RawFd { in as_raw_fd()
59 fn into_raw_fd(self) -> RawFd { in into_raw_fd()
72 // invalid file descriptor. That frequently indicates a double-close in drop()
82 impl io::Read for PtyMaster {
83 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
84 unistd::read(self.0, buf).map_err(io::Error::from) in read()
88 impl io::Write for PtyMaster {
[all …]
|
| /third_party/openssl/apps/ |
| D | s_server.c | 2 * Copyright 1995-2023 The OpenSSL Project Authors. All Rights Reserved.
17 /* Included before async.h to avoid some warnings */
22 #include <openssl/async.h>
73 static int accept_socket = -1;
97 static int async = 0; variable
109 * We define this but make it always be 0 in no-dtls builds to simplify the
137 * possible to use a single callback for all protocol versions - but it in psk_server_cb()
289 wbuf->alloced = 1024; in ebcdic_new()
290 wbuf->buff[0] = '\0'; in ebcdic_new()
341 if (inl > (num = wbuf->alloced)) { in ebcdic_write()
[all …]
|
| /third_party/rust/crates/rustix/src/ |
| D | runtime.rs | 1 //! Low-level implementation details for libc-like runtime libraries such as
4 //! These functions are for implementing thread-local storage (TLS), managing
5 //! threads, loaded libraries, and other process-wide resources. Most of
29 use crate::io;
41 pub unsafe fn set_thread_area(u_info: &mut UserDesc) -> io::Result<()> { in set_thread_area()
48 pub unsafe fn arm_set_tls(data: *mut c_void) -> io::Result<()> { in arm_set_tls()
61 pub unsafe fn set_tid_address(data: *mut c_void) -> Pid { in set_tid_address()
68 /// - [Linux]: https://man7.org/linux/man-pages/man2/prctl.2.html
72 /// This is a very low-level feature for implementing threading libraries.
75 /// [Linux]: https://man7.org/linux/man-pages/man2/prctl.2.html
[all …]
|
| /third_party/typescript/tests/baselines/reference/ |
| D | parserharness.js | 8 // http://www.apache.org/licenses/LICENSE-2.0
17 ///<reference path='..\compiler\io.ts'/>
26 declare var IO: IIO;
27 declare var __dirname; // Node-specific
36 var path: string[] = components.slice(0, components.length - 1);
40 var typescriptServiceFileName = filePath(IO.getExecutingFilePath()) + "typescriptServices.js";
41 var typescriptServiceFile = IO.readFile(typescriptServiceFileName);
203 // we have to string-based splitting instead and try to figure out the delimiting chars
218 var content = IO.readFile(Harness.userSpecifiedroot + path);
255 // Logger-related functions
[all …]
|
| /third_party/ffmpeg/libavfilter/dnn/ |
| D | dnn_backend_common.h | 16 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
33 …{ "async", "use DNN async inference", OFFSET(options.async), AV_OPT_TYPE…
42 uint8_t async; member
56 * Common Async Execution Mechanism for the DNN Backends.
92 * @param async flag for async execution. Must be 0 or 1
93 * @param do_ioproc flag for IO processing. Must be 0 or 1
97 int ff_dnn_fill_task(TaskItem *task, DNNExecBaseParams *exec_params, void *backend_model, int async…
100 * Join the Async Execution thread and set module pointers to NULL.
120 * @returns 0 on the start of async inference or error code otherwise.
|
| /third_party/typescript/tests/cases/conformance/parser/ecmascript5/RealWorld/ |
| D | parserharness.ts | 8 // http://www.apache.org/licenses/LICENSE-2.0
17 ///<reference path='..\compiler\io.ts'/>
26 declare var IO: IIO; variable
27 declare var __dirname; // Node-specific
36 var path: string[] = components.slice(0, components.length - 1);
40 var typescriptServiceFileName = filePath(IO.getExecutingFilePath()) + "typescriptServices.js";
41 var typescriptServiceFile = IO.readFile(typescriptServiceFileName);
203 // we have to string-based splitting instead and try to figure out the delimiting chars
218 var content = IO.readFile(Harness.userSpecifiedroot + path);
255 // Logger-related functions
[all …]
|
| /third_party/rust/crates/rustix/.github/workflows/ |
| D | test-users.yml | 10 runs-on: ${{ matrix.os }}
15 …build: [ubuntu, i686-linux, aarch64-linux, powerpc64le-linux, riscv64-linux, mipsel-linux, mips64e…
17 - build: ubuntu
18 os: ubuntu-latest
20 - build: i686-linux
21 os: ubuntu-latest
23 target: i686-unknown-linux-gnu
24 gcc_package: gcc-i686-linux-gnu
25 gcc: i686-linux-gnu-gcc
26 libc_package: libc-dev-i386-cross
[all …]
|
| /third_party/skia/third_party/externals/abseil-cpp/absl/base/internal/ |
| D | thread_identity.cc | 7 // https://www.apache.org/licenses/LICENSE-2.0
37 // Used to co-ordinate one-time creation of our pthread_key
75 // barrier to CurrentThreadIdentity() always being async signal safe. in SetCurrentThreadIdentity()
77 // NOTE: Not async-safe. But can be open-coded. in SetCurrentThreadIdentity()
83 // See https://kripken.github.io/emscripten-site/docs/porting/pthreads.html in SetCurrentThreadIdentity()
92 // While not officially async-signal safe, getspecific within a signal handler in SetCurrentThreadIdentity()
104 // NOTE: Not async-safe. But can be open-coded. in SetCurrentThreadIdentity()
124 // headers, we opt for the correct-but-slower option of not inlining this
|
| /third_party/ltp/testcases/kernel/fs/doio/include/ |
| D | write_log.h | 21 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
56 int w_oflags; /* low-order open() flags */
57 int w_done; /* 1 if io confirmed done */
58 int w_async; /* 1 if async write (writea) */
60 char w_host[WLOG_MAX_HOST+1]; /* host doing write - */
63 char w_path[WLOG_MAX_PATH+1]; /* file written to - */
66 char w_pattern[WLOG_MAX_PATTERN+1]; /* pattern written - */
76 * On-disk structure of a wlog_rec. Actually, the record consists of
84 * wlog_rec_disk structure. Thus, the actual on-disk record looks like
88 * path (w_pathlen bytes - not null terminated)
[all …]
|