| /third_party/node/deps/uv/src/win/ |
| D | stream.c | 117 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()
136 err = uv__tty_write(loop, req, (uv_tty_t*) handle, bufs, nbufs, 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()
[all …]
|
| D | internal.h | 80 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);
|
| D | udp.c | 407 unsigned int nbufs, in uv__send() argument
421 nbufs, in uv__send()
439 req->u.io.queued_bytes = uv__count_bufs(bufs, nbufs); in uv__send()
1105 unsigned int nbufs, in uv__udp_send() argument
1125 err = uv__send(req, handle, bufs, nbufs, addr, addrlen, send_cb); in uv__udp_send()
1135 unsigned int nbufs, in uv__udp_try_send() argument
1143 assert(nbufs > 0); in uv__udp_try_send()
1170 nbufs, in uv__udp_try_send()
|
| D | fs.c | 782 for (index = 0; index < req->fs.info.nbufs; ++index) { in fs__read_filemap()
808 index < req->fs.info.nbufs && done_read < read_size; in fs__read_filemap()
906 } while (result && index < req->fs.info.nbufs); in fs__read()
952 for (index = 0; index < req->fs.info.nbufs; ++index) { in fs__write_filemap()
1010 for (index = 0; index < req->fs.info.nbufs; ++index) { in fs__write_filemap()
1111 } while (result && index < req->fs.info.nbufs); in fs__write()
1546 req->fs.info.nbufs = 0; in fs__scandir()
2917 unsigned int nbufs, in uv_fs_read() argument
2922 if (bufs == NULL || nbufs == 0) { in uv_fs_read()
2929 req->fs.info.nbufs = nbufs; in uv_fs_read()
[all …]
|
| /third_party/libuv/src/win/ |
| D | stream.c | 117 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()
136 err = uv__tty_write(loop, req, (uv_tty_t*) handle, bufs, nbufs, 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()
[all …]
|
| D | internal.h | 82 const uv_buf_t bufs[], unsigned int nbufs, uv_write_cb cb);
84 unsigned int nbufs);
135 size_t nbufs,
164 const uv_buf_t bufs[], unsigned int nbufs, uv_write_cb cb);
166 unsigned int nbufs);
|
| D | udp.c | 407 unsigned int nbufs, in uv__send() argument
421 nbufs, in uv__send()
439 req->u.io.queued_bytes = uv__count_bufs(bufs, nbufs); in uv__send()
1105 unsigned int nbufs, in uv__udp_send() argument
1125 err = uv__send(req, handle, bufs, nbufs, addr, addrlen, send_cb); in uv__udp_send()
1135 unsigned int nbufs, in uv__udp_try_send() argument
1143 assert(nbufs > 0); in uv__udp_try_send()
1170 nbufs, in uv__udp_try_send()
|
| D | fs.c | 782 for (index = 0; index < req->fs.info.nbufs; ++index) { in fs__read_filemap()
808 index < req->fs.info.nbufs && done_read < read_size; in fs__read_filemap()
906 } while (result && index < req->fs.info.nbufs); in fs__read()
952 for (index = 0; index < req->fs.info.nbufs; ++index) { in fs__write_filemap()
1010 for (index = 0; index < req->fs.info.nbufs; ++index) { in fs__write_filemap()
1111 } while (result && index < req->fs.info.nbufs); in fs__write()
1546 req->fs.info.nbufs = 0; in fs__scandir()
2917 unsigned int nbufs, in uv_fs_read() argument
2922 if (bufs == NULL || nbufs == 0) { in uv_fs_read()
2929 req->fs.info.nbufs = nbufs; in uv_fs_read()
[all …]
|
| /third_party/node/deps/uv/src/ |
| D | uv-common.c | 457 unsigned int nbufs, in uv_udp_send() argument
466 return uv__udp_send(req, handle, bufs, nbufs, addr, addrlen, send_cb); in uv_udp_send()
472 unsigned int nbufs, in uv_udp_try_send() argument
480 return uv__udp_try_send(handle, bufs, nbufs, addr, addrlen); in uv_udp_try_send()
589 size_t uv__count_bufs(const uv_buf_t bufs[], unsigned int nbufs) { in uv__count_bufs() argument
594 for (i = 0; i < nbufs; i++) in uv__count_bufs()
635 return &req->fs.info.nbufs; in uv__get_nbufs()
637 return &req->nbufs; in uv__get_nbufs()
654 unsigned int* nbufs = uv__get_nbufs(req); in uv__fs_scandir_cleanup() local
657 if (*nbufs > 0 && *nbufs != (unsigned int) req->result) in uv__fs_scandir_cleanup()
[all …]
|
| D | uv-common.h | 179 unsigned int nbufs,
186 unsigned int nbufs,
213 size_t uv__count_bufs(const uv_buf_t bufs[], unsigned int nbufs);
|
| /third_party/libuv/src/ |
| D | uv-common.c | 457 unsigned int nbufs, in uv_udp_send() argument
466 return uv__udp_send(req, handle, bufs, nbufs, addr, addrlen, send_cb); in uv_udp_send()
472 unsigned int nbufs, in uv_udp_try_send() argument
480 return uv__udp_try_send(handle, bufs, nbufs, addr, addrlen); in uv_udp_try_send()
589 size_t uv__count_bufs(const uv_buf_t bufs[], unsigned int nbufs) { in uv__count_bufs() argument
594 for (i = 0; i < nbufs; i++) in uv__count_bufs()
635 return &req->fs.info.nbufs; in uv__get_nbufs()
637 return &req->nbufs; in uv__get_nbufs()
654 unsigned int* nbufs = uv__get_nbufs(req); in uv__fs_scandir_cleanup() local
657 if (*nbufs > 0 && *nbufs != (unsigned int) req->result) in uv__fs_scandir_cleanup()
[all …]
|
| D | uv-common.h | 179 unsigned int nbufs,
186 unsigned int nbufs,
216 size_t uv__count_bufs(const uv_buf_t bufs[], unsigned int nbufs);
|
| /third_party/node/deps/uv/src/unix/ |
| D | fs.c | 413 unsigned int nbufs, in uv__fs_preadv() argument
421 assert(nbufs > 0); in uv__fs_preadv()
426 end = bufs + nbufs; in uv__fs_preadv()
468 if (req->nbufs > iovmax) in uv__fs_read()
469 req->nbufs = iovmax; in uv__fs_read()
472 if (req->nbufs == 1) in uv__fs_read()
475 result = readv(req->file, (struct iovec*) req->bufs, req->nbufs); in uv__fs_read()
477 if (req->nbufs == 1) { in uv__fs_read()
483 result = preadv(req->file, (struct iovec*) req->bufs, req->nbufs, req->off); in uv__fs_read()
489 result = uv__fs_preadv(req->file, req->bufs, req->nbufs, req->off); in uv__fs_read()
[all …]
|
| D | stream.c | 708 req->nbufs - req->write_index); in uv__write_req_size()
742 return req->write_index == req->nbufs; in uv__write_req_update()
788 unsigned int nbufs, in uv__try_write() argument
800 iovcnt = nbufs; in uv__try_write()
900 req->nbufs - req->write_index, in uv__write()
1358 unsigned int nbufs, in uv__check_before_write() argument
1360 assert(nbufs > 0); in uv__check_before_write()
1398 unsigned int nbufs, in uv_write2() argument
1404 err = uv__check_before_write(stream, nbufs, send_handle); in uv_write2()
1425 if (nbufs > ARRAY_SIZE(req->bufsml)) in uv_write2()
[all …]
|
| D | udp.c | 141 handle->send_queue_size -= uv__count_bufs(req->bufs, req->nbufs); in uv__udp_run_completed()
354 h[pkts].msg_hdr.msg_iovlen = req->nbufs; in uv__udp_sendmmsg()
447 h.msg_iovlen = req->nbufs; in uv__udp_sendmsg()
735 unsigned int nbufs, in uv__udp_send() argument
742 assert(nbufs > 0); in uv__udp_send()
764 req->nbufs = nbufs; in uv__udp_send()
767 if (nbufs > ARRAY_SIZE(req->bufsml)) in uv__udp_send()
768 req->bufs = uv__malloc(nbufs * sizeof(bufs[0])); in uv__udp_send()
775 memcpy(req->bufs, bufs, nbufs * sizeof(bufs[0])); in uv__udp_send()
776 handle->send_queue_size += uv__count_bufs(req->bufs, req->nbufs); in uv__udp_send()
[all …]
|
| /third_party/libuv/src/unix/ |
| D | fs.c | 434 unsigned int nbufs, in uv__fs_preadv() argument
442 assert(nbufs > 0); in uv__fs_preadv()
447 end = bufs + nbufs; in uv__fs_preadv()
489 if (req->nbufs > iovmax) in uv__fs_read()
490 req->nbufs = iovmax; in uv__fs_read()
493 if (req->nbufs == 1) in uv__fs_read()
496 result = readv(req->file, (struct iovec*) req->bufs, req->nbufs); in uv__fs_read()
498 if (req->nbufs == 1) { in uv__fs_read()
504 result = preadv(req->file, (struct iovec*) req->bufs, req->nbufs, req->off); in uv__fs_read()
510 result = uv__fs_preadv(req->file, req->bufs, req->nbufs, req->off); in uv__fs_read()
[all …]
|
| D | stream.c | 708 req->nbufs - req->write_index); in uv__write_req_size()
742 return req->write_index == req->nbufs; in uv__write_req_update()
788 unsigned int nbufs, in uv__try_write() argument
800 iovcnt = nbufs; in uv__try_write()
900 req->nbufs - req->write_index, in uv__write()
1358 unsigned int nbufs, in uv__check_before_write() argument
1360 assert(nbufs > 0); in uv__check_before_write()
1398 unsigned int nbufs, in uv_write2() argument
1404 err = uv__check_before_write(stream, nbufs, send_handle); in uv_write2()
1425 if (nbufs > ARRAY_SIZE(req->bufsml)) in uv_write2()
[all …]
|
| D | udp.c | 141 handle->send_queue_size -= uv__count_bufs(req->bufs, req->nbufs); in uv__udp_run_completed()
354 h[pkts].msg_hdr.msg_iovlen = req->nbufs; in uv__udp_sendmmsg()
447 h.msg_iovlen = req->nbufs; in uv__udp_sendmsg()
735 unsigned int nbufs, in uv__udp_send() argument
742 assert(nbufs > 0); in uv__udp_send()
764 req->nbufs = nbufs; in uv__udp_send()
767 if (nbufs > ARRAY_SIZE(req->bufsml)) in uv__udp_send()
768 req->bufs = uv__malloc(nbufs * sizeof(bufs[0])); in uv__udp_send()
775 memcpy(req->bufs, bufs, nbufs * sizeof(bufs[0])); in uv__udp_send()
776 handle->send_queue_size += uv__count_bufs(req->bufs, req->nbufs); in uv__udp_send()
[all …]
|
| /third_party/python/Objects/stringlib/ |
| D | join.h | 16 Py_ssize_t i, nbufs; in STRINGLIB() local
61 for (i = 0, nbufs = 0; i < seqlen; i++) { in STRINGLIB()
87 nbufs = i + 1; /* for error cleanup */ in STRINGLIB()
125 for (i = 0; i < nbufs; i++) { in STRINGLIB()
133 for (i = 0; i < nbufs; i++) { in STRINGLIB()
155 for (i = 0; i < nbufs; i++) in STRINGLIB()
|
| /third_party/node/src/ |
| D | js_udp_wrap.cc | 34 size_t nbufs,
91 size_t nbufs, in Send() argument
100 MaybeStackBuffer<Local<Value>, 16> buffers(nbufs); in Send()
101 for (size_t i = 0; i < nbufs; i++) { in Send()
112 Array::New(env()->isolate(), buffers.out(), nbufs), in Send()
|
| D | udp_wrap.h | 96 size_t nbufs,
165 size_t nbufs,
|
| /third_party/libuv/test/ |
| D | test-ping-pong.c | 96 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_EQ(0, uv_write(req, stream, bufs, nbufs, pinger_after_write)); in pinger_write_ping()
|
| /third_party/node/deps/uv/include/uv/ |
| D | unix.h | 264 unsigned int nbufs; \
276 unsigned int nbufs; \
364 unsigned int nbufs; \
|
| /third_party/libuv/include/uv/ |
| D | unix.h | 265 unsigned int nbufs; \
277 unsigned int nbufs; \
365 unsigned int nbufs; \
|
| /third_party/libuv/include/ |
| D | uv.h | 522 unsigned int nbufs,
527 unsigned int nbufs,
532 unsigned int nbufs);
535 unsigned int nbufs,
714 unsigned int nbufs,
719 unsigned int nbufs,
1392 unsigned int nbufs,
1403 unsigned int nbufs,
|