Home
last modified time | relevance | path

Searched refs:nbufs (Results 1 – 22 of 22) sorted by relevance

/libuv/src/win/
H A Dstream.c117 unsigned int nbufs, in uv_write() argument
129 err = uv__tcp_write(loop, req, (uv_tcp_t*) handle, bufs, nbufs, cb); in uv_write()
133 loop, req, (uv_pipe_t*) handle, bufs, nbufs, NULL, cb); in uv_write()
149 unsigned int nbufs, in uv_write2() argument
156 return uv_write(req, handle, bufs, nbufs, cb); in uv_write2()
166 loop, req, (uv_pipe_t*) handle, bufs, nbufs, send_handle, cb); in uv_write2()
173 unsigned int nbufs) { in uv_try_write() argument
181 return uv__tcp_try_write((uv_tcp_t*) stream, bufs, nbufs); in uv_try_write()
183 return uv__tty_try_write((uv_tty_t*) stream, bufs, nbufs); in uv_try_write()
195 unsigned int nbufs, in uv_try_write2() argument
[all …]
H A Dinternal.h80 const uv_buf_t bufs[], unsigned int nbufs, uv_write_cb cb);
82 unsigned int nbufs);
133 size_t nbufs,
162 const uv_buf_t bufs[], unsigned int nbufs, uv_write_cb cb);
164 unsigned int nbufs);
H A Dudp.c357 unsigned int nbufs, in uv__send() argument
371 nbufs, in uv__send()
389 req->u.io.queued_bytes = uv__count_bufs(bufs, nbufs); in uv__send()
1066 unsigned int nbufs, in uv__udp_send() argument
1086 err = uv__send(req, handle, bufs, nbufs, addr, addrlen, send_cb); in uv__udp_send()
1096 unsigned int nbufs, in uv__udp_try_send() argument
1104 assert(nbufs > 0); in uv__udp_try_send()
1131 nbufs, in uv__udp_try_send()
H A Dfs.c862 } while (result && index < req->fs.info.nbufs); in fs__read()
1067 } while (result && index < req->fs.info.nbufs); in fs__write()
1526 req->fs.info.nbufs = 0; in fs__scandir()
3046 unsigned int nbufs, in uv_fs_read() argument
3051 if (bufs == NULL || nbufs == 0) { in uv_fs_read()
3058 req->fs.info.nbufs = nbufs; in uv_fs_read()
3060 if (nbufs > ARRAY_SIZE(req->fs.info.bufsml)) in uv_fs_read()
3079 unsigned int nbufs, in uv_fs_write() argument
3084 if (bufs == NULL || nbufs == 0) { in uv_fs_write()
3091 req->fs.info.nbufs = nbufs; in uv_fs_write()
[all …]
H A Dpipe.c1520 size_t nbufs, in uv__build_coalesced_write_req() argument
1537 for (i = 0; i < nbufs; i++) in uv__build_coalesced_write_req()
1563 for (i = 0; i < nbufs; i++) { in uv__build_coalesced_write_req()
1582 size_t nbufs, in uv__pipe_write_data() argument
1611 if (nbufs == 0) { in uv__pipe_write_data()
1614 } else if (nbufs == 1 && !copy_always) { in uv__pipe_write_data()
1620 err = uv__build_coalesced_write_req(req, bufs, nbufs, &req, &write_buf); in uv__pipe_write_data()
1852 size_t nbufs, in uv__pipe_write() argument
1857 return uv__pipe_write_ipc(loop, req, handle, bufs, nbufs, send_handle, cb); in uv__pipe_write()
1861 return uv__pipe_write_data(loop, req, handle, bufs, nbufs, cb, 0); in uv__pipe_write()
H A Dtty.c1665 unsigned int nbufs, argument
1698 for (i = 0; i < nbufs; i++) {
2176 unsigned int nbufs, argument
2190 if (!uv__tty_write_bufs(handle, bufs, nbufs, &error)) {
2204 unsigned int nbufs) { argument
2210 if (uv__tty_write_bufs(handle, bufs, nbufs, &error))
2213 return uv__count_bufs(bufs, nbufs);
H A Dtcp.c895 unsigned int nbufs, in uv__tcp_write() argument
917 nbufs, in uv__tcp_write()
932 req->u.io.queued_bytes = uv__count_bufs(bufs, nbufs); in uv__tcp_write()
960 unsigned int nbufs) { in uv__tcp_try_write() argument
969 nbufs, in uv__tcp_try_write()
/libuv/src/unix/
H A Dfs.c514 size_t nbufs; in uv__fs_read() local
522 nbufs = req->nbufs; in uv__fs_read()
559 req->nbufs = 0; in uv__fs_read()
583 req->nbufs = 0; in uv__fs_scandir()
1209 size_t nbufs; in uv__fs_write() local
1217 nbufs = req->nbufs; in uv__fs_write()
1652 nbufs = req->nbufs; in uv__fs_write_all()
1657 req->nbufs = nbufs; in uv__fs_write_all()
1676 nbufs -= req->nbufs; in uv__fs_write_all()
2038 req->nbufs = nbufs; in uv_fs_read()
[all …]
H A Dstream.c710 return req->write_index == req->nbufs; in uv__write_req_update()
756 unsigned int nbufs, in uv__try_write() argument
768 iovcnt = nbufs; in uv__try_write()
1298 assert(nbufs > 0); in uv__check_before_write()
1336 unsigned int nbufs, in uv_write2() argument
1363 if (nbufs > ARRAY_SIZE(req->bufsml)) in uv_write2()
1370 req->nbufs = nbufs; in uv_write2()
1408 unsigned int nbufs, in uv_write() argument
1416 unsigned int nbufs) { in uv_try_write() argument
1417 return uv_try_write2(stream, bufs, nbufs, NULL); in uv_try_write()
[all …]
H A Dudp.c309 h.msg_iovlen = req->nbufs; in uv__udp_sendmsg_one()
373 h[pkts].msg_hdr.msg_iovlen = req->nbufs; in uv__udp_sendmsg_many()
724 unsigned int nbufs, in uv__udp_send() argument
731 assert(nbufs > 0); in uv__udp_send()
753 req->nbufs = nbufs; in uv__udp_send()
756 if (nbufs > ARRAY_SIZE(req->bufsml)) in uv__udp_send()
757 req->bufs = uv__malloc(nbufs * sizeof(bufs[0])); in uv__udp_send()
764 memcpy(req->bufs, bufs, nbufs * sizeof(bufs[0])); in uv__udp_send()
789 unsigned int nbufs, in uv__udp_try_send() argument
796 assert(nbufs > 0); in uv__udp_try_send()
[all …]
H A Dlinux.c1033 if (req->nbufs > IOV_MAX) { in uv__iou_fs_read_or_write()
1035 req->nbufs = IOV_MAX; in uv__iou_fs_read_or_write()
1048 sqe->len = req->nbufs; in uv__iou_fs_read_or_write()
/libuv/src/
H A Duv-common.c630 for (i = 0; i < nbufs; i++) in uv__count_bufs()
671 return &req->fs.info.nbufs; in uv__get_nbufs()
673 return &req->nbufs; in uv__get_nbufs()
689 unsigned int* nbufs; in uv__fs_scandir_cleanup() local
698 if (*nbufs > 0) in uv__fs_scandir_cleanup()
699 i = *nbufs - 1; in uv__fs_scandir_cleanup()
714 unsigned int* nbufs; in uv_fs_scandir_next() local
724 nbufs = uv__get_nbufs(req); in uv_fs_scandir_next()
725 assert(nbufs); in uv_fs_scandir_next()
730 if (*nbufs > 0) in uv_fs_scandir_next()
[all …]
H A Duv-common.h183 unsigned int nbufs,
190 unsigned int nbufs,
217 size_t uv__count_bufs(const uv_buf_t bufs[], unsigned int nbufs);
/libuv/test/
H A Dtest-ping-pong.c96 int i, nbufs; in pinger_write_ping() local
102 nbufs = 1; in pinger_write_ping()
106 nbufs = sizeof PING - 1; in pinger_write_ping()
107 for (i = 0; i < nbufs; i++) { in pinger_write_ping()
115 ASSERT_OK(uv_write(req, stream, bufs, nbufs, pinger_after_write)); in pinger_write_ping()
/libuv/include/uv/
H A Dunix.h263 unsigned int nbufs; \
275 unsigned int nbufs; \
366 unsigned int nbufs; \
H A Dwin.h635 unsigned int nbufs; \
/libuv/docs/src/
H A Dstream.rst159 …te(uv_write_t* req, uv_stream_t* handle, const uv_buf_t bufs[], unsigned int nbufs, uv_write_cb cb)
190 …uv_write_t* req, uv_stream_t* handle, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send…
200 .. c:function:: int uv_try_write(uv_stream_t* handle, const uv_buf_t bufs[], unsigned int nbufs)
211 .. c:function:: int uv_try_write2(uv_stream_t* handle, const uv_buf_t bufs[], unsigned int nbufs, u…
H A Dudp.rst375 …uv_udp_send_t* req, uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, const struct sock…
398 :param nbufs: Number of buffers in `bufs`.
412 .. c:function:: int uv_udp_try_send(uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, co…
H A Dfs.rst240 …_t* loop, uv_fs_t* req, uv_file file, const uv_buf_t bufs[], unsigned int nbufs, int64_t offset, u…
254 …_t* loop, uv_fs_t* req, uv_file file, const uv_buf_t bufs[], unsigned int nbufs, int64_t offset, u…
/libuv/include/
H A Duv.h553 unsigned int nbufs,
558 unsigned int nbufs,
563 unsigned int nbufs);
566 unsigned int nbufs,
771 unsigned int nbufs,
776 unsigned int nbufs,
1463 unsigned int nbufs,
1474 unsigned int nbufs,
/libuv/docs/src/guide/
H A Dfilesystem.rst129 …_t* loop, uv_fs_t* req, uv_file file, const uv_buf_t bufs[], unsigned int nbufs, int64_t offset, u…
131 …_t* loop, uv_fs_t* req, uv_file file, const uv_buf_t bufs[], unsigned int nbufs, int64_t offset, u…
182 const uv_buf_t bufs[], unsigned int nbufs, uv_write_cb cb);
/libuv/
H A DChangeLog4239 * unix: allow nbufs > IOV_MAX in uv_fs_{read,write} (ronkorving)
4733 * windows: fix fs_read with nbufs > 1 and offset (Unknown W. Brackets)
4796 * windows: fix fs_write with nbufs > 1 and offset (Unknown W. Brackets)

Completed in 137 milliseconds