Home
last modified time | relevance | path

Searched refs:nbufs (Results 1 - 25 of 38) sorted by relevance

12

/third_party/libuv/src/win/
H A Dstream.c117 unsigned int nbufs, in uv_write()
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()
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()
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()
114 uv_write(uv_write_t* req, uv_stream_t* handle, const uv_buf_t bufs[], unsigned int nbufs, uv_write_cb cb) uv_write() argument
146 uv_write2(uv_write_t* req, uv_stream_t* handle, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle, uv_write_cb cb) uv_write2() argument
171 uv_try_write(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs) uv_try_write() argument
193 uv_try_write2(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle) uv_try_write2() argument
[all...]
H A Dinternal.h82 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);
H A Dudp.c351 unsigned int nbufs, in uv__send()
365 nbufs, in uv__send()
383 req->u.io.queued_bytes = uv__count_bufs(bufs, nbufs); in uv__send()
1060 unsigned int nbufs, in uv__udp_send()
1080 err = uv__send(req, handle, bufs, nbufs, addr, addrlen, send_cb); in uv__udp_send()
1090 unsigned int nbufs, in uv__udp_try_send()
1098 assert(nbufs > 0); in uv__udp_try_send()
1125 nbufs, in uv__udp_try_send()
348 uv__send(uv_udp_send_t* req, uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, const struct sockaddr* addr, unsigned int addrlen, uv_udp_send_cb cb) uv__send() argument
1057 uv__udp_send(uv_udp_send_t* req, uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, const struct sockaddr* addr, unsigned int addrlen, uv_udp_send_cb send_cb) uv__udp_send() argument
1088 uv__udp_try_send(uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, const struct sockaddr* addr, unsigned int addrlen) uv__udp_try_send() argument
H A Dfs.c716 for (index = 0; index < req->fs.info.nbufs; ++index) { in fs__read_filemap()
742 index < req->fs.info.nbufs && done_read < read_size; in fs__read_filemap()
840 } while (result && index < req->fs.info.nbufs); in fs__read()
886 for (index = 0; index < req->fs.info.nbufs; ++index) { in fs__write_filemap()
944 for (index = 0; index < req->fs.info.nbufs; ++index) { in fs__write_filemap()
1045 } while (result && index < req->fs.info.nbufs); in fs__write()
1468 /* `nbufs` will be used as index by uv_fs_scandir_next. */ in fs__scandir()
1469 req->fs.info.nbufs = 0; in fs__scandir()
2904 unsigned int nbufs, in uv_fs_read()
2909 if (bufs == NULL || nbufs in uv_fs_read()
2900 uv_fs_read(uv_loop_t* loop, uv_fs_t* req, uv_file fd, const uv_buf_t bufs[], unsigned int nbufs, int64_t offset, uv_fs_cb cb) uv_fs_read() argument
2933 uv_fs_write(uv_loop_t* loop, uv_fs_t* req, uv_file fd, const uv_buf_t bufs[], unsigned int nbufs, int64_t offset, uv_fs_cb cb) uv_fs_write() argument
[all...]
/third_party/node/deps/uv/src/win/
H A Dstream.c117 unsigned int nbufs, in uv_write()
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()
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()
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()
114 uv_write(uv_write_t* req, uv_stream_t* handle, const uv_buf_t bufs[], unsigned int nbufs, uv_write_cb cb) uv_write() argument
146 uv_write2(uv_write_t* req, uv_stream_t* handle, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle, uv_write_cb cb) uv_write2() argument
171 uv_try_write(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs) uv_try_write() argument
193 uv_try_write2(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle) 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.c407 unsigned int nbufs, in uv__send()
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()
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()
1143 assert(nbufs > 0); in uv__udp_try_send()
1170 nbufs, in uv__udp_try_send()
404 uv__send(uv_udp_send_t* req, uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, const struct sockaddr* addr, unsigned int addrlen, uv_udp_send_cb cb) uv__send() argument
1102 uv__udp_send(uv_udp_send_t* req, uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, const struct sockaddr* addr, unsigned int addrlen, uv_udp_send_cb send_cb) uv__udp_send() argument
1133 uv__udp_try_send(uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, const struct sockaddr* addr, unsigned int addrlen) uv__udp_try_send() argument
H A Dfs.c782 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()
1545 /* `nbufs` will be used as index by uv_fs_scandir_next. */ in fs__scandir()
1546 req->fs.info.nbufs = 0; in fs__scandir()
2917 unsigned int nbufs, in uv_fs_read()
2922 if (bufs == NULL || nbufs in uv_fs_read()
2913 uv_fs_read(uv_loop_t* loop, uv_fs_t* req, uv_file fd, const uv_buf_t bufs[], unsigned int nbufs, int64_t offset, uv_fs_cb cb) uv_fs_read() argument
2946 uv_fs_write(uv_loop_t* loop, uv_fs_t* req, uv_file fd, const uv_buf_t bufs[], unsigned int nbufs, int64_t offset, uv_fs_cb cb) uv_fs_write() argument
[all...]
H A Dpipe.c1426 size_t nbufs, in uv__build_coalesced_write_req()
1443 for (i = 0; i < nbufs; i++) in uv__build_coalesced_write_req()
1469 for (i = 0; i < nbufs; i++) { in uv__build_coalesced_write_req()
1488 size_t nbufs, in uv__pipe_write_data()
1517 if (nbufs == 0) { in uv__pipe_write_data()
1520 } else if (nbufs == 1 && !copy_always) { in uv__pipe_write_data()
1526 err = uv__build_coalesced_write_req(req, bufs, nbufs, &req, &write_buf); in uv__pipe_write_data()
1754 size_t nbufs, in uv__pipe_write()
1759 return uv__pipe_write_ipc(loop, req, handle, bufs, nbufs, send_handle, cb); in uv__pipe_write()
1763 return uv__pipe_write_data(loop, req, handle, bufs, nbufs, c in uv__pipe_write()
1424 uv__build_coalesced_write_req(uv_write_t* user_req, const uv_buf_t bufs[], size_t nbufs, uv_write_t** req_out, uv_buf_t* write_buf_out) uv__build_coalesced_write_req() argument
1484 uv__pipe_write_data(uv_loop_t* loop, uv_write_t* req, uv_pipe_t* handle, const uv_buf_t bufs[], size_t nbufs, uv_write_cb cb, int copy_always) uv__pipe_write_data() argument
1750 uv__pipe_write(uv_loop_t* loop, uv_write_t* req, uv_pipe_t* handle, const uv_buf_t bufs[], size_t nbufs, uv_stream_t* send_handle, uv_write_cb cb) uv__pipe_write() argument
[all...]
/third_party/libuv/src/unix/
H A Dfs.c90 #define preadv(fd, bufs, nbufs, off) \
92 #define pwritev(fd, bufs, nbufs, off) \
433 size_t nbufs; in uv__fs_read() local
441 nbufs = req->nbufs; in uv__fs_read()
444 if (nbufs > iovmax) in uv__fs_read()
445 nbufs = iovmax; in uv__fs_read()
449 if (nbufs == 1) in uv__fs_read()
451 else if (nbufs > 1) in uv__fs_read()
452 r = readv(fd, bufs, nbufs); in uv__fs_read()
1116 size_t nbufs; uv__fs_write() local
1523 unsigned int nbufs; uv__fs_write_all() local
1904 uv_fs_read(uv_loop_t* loop, uv_fs_t* req, uv_file file, const uv_buf_t bufs[], unsigned int nbufs, int64_t off, uv_fs_cb cb) uv_fs_read() argument
2093 uv_fs_write(uv_loop_t* loop, uv_fs_t* req, uv_file file, const uv_buf_t bufs[], unsigned int nbufs, int64_t off, uv_fs_cb cb) uv_fs_write() argument
[all...]
H A Dstream.c675 req->nbufs - req->write_index); in uv__write_req_size()
709 return req->write_index == req->nbufs; in uv__write_req_update()
755 unsigned int nbufs, in uv__try_write()
767 iovcnt = nbufs; in uv__try_write()
863 req->nbufs - req->write_index, in uv__write()
1291 unsigned int nbufs, in uv__check_before_write()
1293 assert(nbufs > 0); in uv__check_before_write()
1331 unsigned int nbufs, in uv_write2()
1337 err = uv__check_before_write(stream, nbufs, send_handle); in uv_write2()
1358 if (nbufs > ARRAY_SIZ in uv_write2()
753 uv__try_write(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle) uv__try_write() argument
1290 uv__check_before_write(uv_stream_t* stream, unsigned int nbufs, uv_stream_t* send_handle) uv__check_before_write() argument
1328 uv_write2(uv_write_t* req, uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle, uv_write_cb cb) uv_write2() argument
1400 uv_write(uv_write_t* req, uv_stream_t* handle, const uv_buf_t bufs[], unsigned int nbufs, uv_write_cb cb) uv_write() argument
1409 uv_try_write(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs) uv_try_write() argument
1416 uv_try_write2(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle) uv_try_write2() argument
[all...]
H A Dudp.c105 handle->send_queue_size -= uv__count_bufs(req->bufs, req->nbufs); in uv__udp_run_completed()
318 h[pkts].msg_hdr.msg_iovlen = req->nbufs; in uv__udp_sendmsg()
399 h.msg_iovlen = req->nbufs; in uv__udp_sendmsg()
689 unsigned int nbufs, in uv__udp_send()
696 assert(nbufs > 0); in uv__udp_send()
718 req->nbufs = nbufs; in uv__udp_send()
721 if (nbufs > ARRAY_SIZE(req->bufsml)) in uv__udp_send()
722 req->bufs = uv__malloc(nbufs * sizeof(bufs[0])); in uv__udp_send()
729 memcpy(req->bufs, bufs, nbufs * sizeo in uv__udp_send()
686 uv__udp_send(uv_udp_send_t* req, uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, const struct sockaddr* addr, unsigned int addrlen, uv_udp_send_cb send_cb) uv__udp_send() argument
752 uv__udp_try_send(uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, const struct sockaddr* addr, unsigned int addrlen) uv__udp_try_send() argument
[all...]
/third_party/python/Objects/stringlib/
H A Djoin.h16 Py_ssize_t i, nbufs; in bytes_join() local
61 for (i = 0, nbufs = 0; i < seqlen; i++) { in bytes_join()
87 nbufs = i + 1; /* for error cleanup */ in bytes_join()
125 for (i = 0; i < nbufs; i++) { in bytes_join()
133 for (i = 0; i < nbufs; i++) { in bytes_join()
155 for (i = 0; i < nbufs; i++) in bytes_join()
/third_party/node/deps/uv/src/
H A Duv-common.c457 unsigned int nbufs, in uv_udp_send()
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()
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()
630 * the unix implementation (nbufs is not directly inside req but is
635 return &req->fs.info.nbufs; in uv__get_nbufs()
637 return &req->nbufs; in uv__get_nbufs()
654 unsigned int* nbufs in uv__fs_scandir_cleanup() local
454 uv_udp_send(uv_udp_send_t* req, uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, const struct sockaddr* addr, uv_udp_send_cb send_cb) uv_udp_send() argument
470 uv_udp_try_send(uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, const struct sockaddr* addr) uv_udp_try_send() argument
670 unsigned int* nbufs; uv_fs_scandir_next() local
[all...]
H A Duv-common.h179 unsigned int nbufs,
186 unsigned int nbufs,
213 size_t uv__count_bufs(const uv_buf_t bufs[], unsigned int nbufs);
/third_party/node/deps/uv/src/unix/
H A Dfs.c413 unsigned int nbufs, in uv__fs_preadv()
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, re in uv__fs_read()
411 uv__fs_preadv(uv_file fd, uv_buf_t* bufs, unsigned int nbufs, off_t off) uv__fs_preadv() argument
1653 unsigned int nbufs; uv__fs_write_all() local
1997 uv_fs_read(uv_loop_t* loop, uv_fs_t* req, uv_file file, const uv_buf_t bufs[], unsigned int nbufs, int64_t off, uv_fs_cb cb) uv_fs_read() argument
2166 uv_fs_write(uv_loop_t* loop, uv_fs_t* req, uv_file file, const uv_buf_t bufs[], unsigned int nbufs, int64_t off, uv_fs_cb cb) uv_fs_write() argument
[all...]
H A Dstream.c708 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()
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()
1360 assert(nbufs > 0); in uv__check_before_write()
1398 unsigned int nbufs, in uv_write2()
1404 err = uv__check_before_write(stream, nbufs, send_handle); in uv_write2()
1425 if (nbufs > ARRAY_SIZ in uv_write2()
786 uv__try_write(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle) uv__try_write() argument
1357 uv__check_before_write(uv_stream_t* stream, unsigned int nbufs, uv_stream_t* send_handle) uv__check_before_write() argument
1395 uv_write2(uv_write_t* req, uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle, uv_write_cb cb) uv_write2() argument
1467 uv_write(uv_write_t* req, uv_stream_t* handle, const uv_buf_t bufs[], unsigned int nbufs, uv_write_cb cb) uv_write() argument
1476 uv_try_write(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs) uv_try_write() argument
1483 uv_try_write2(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle) uv_try_write2() argument
[all...]
H A Dudp.c141 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()
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 * sizeo in uv__udp_send()
732 uv__udp_send(uv_udp_send_t* req, uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, const struct sockaddr* addr, unsigned int addrlen, uv_udp_send_cb send_cb) uv__udp_send() argument
798 uv__udp_try_send(uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, const struct sockaddr* addr, unsigned int addrlen) uv__udp_try_send() argument
[all...]
/third_party/libuv/src/
H A Duv-common.c491 unsigned int nbufs, in uv_udp_send()
500 return uv__udp_send(req, handle, bufs, nbufs, addr, addrlen, send_cb); in uv_udp_send()
506 unsigned int nbufs, in uv_udp_try_send()
514 return uv__udp_try_send(handle, bufs, nbufs, addr, addrlen); in uv_udp_try_send()
626 size_t uv__count_bufs(const uv_buf_t bufs[], unsigned int nbufs) { in uv__count_bufs() argument
631 for (i = 0; i < nbufs; i++) in uv__count_bufs()
667 * the unix implementation (nbufs is not directly inside req but is
672 return &req->fs.info.nbufs; in uv__get_nbufs()
674 return &req->nbufs; in uv__get_nbufs()
690 unsigned int* nbufs; in uv__fs_scandir_cleanup() local
488 uv_udp_send(uv_udp_send_t* req, uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, const struct sockaddr* addr, uv_udp_send_cb send_cb) uv_udp_send() argument
504 uv_udp_try_send(uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, const struct sockaddr* addr) uv_udp_try_send() argument
715 unsigned int* nbufs; uv_fs_scandir_next() local
[all...]
H A Duv-common.h183 unsigned int nbufs,
190 unsigned int nbufs,
220 size_t uv__count_bufs(const uv_buf_t bufs[], unsigned int nbufs);
/third_party/node/src/
H A Djs_udp_wrap.cc34 size_t nbufs,
91 size_t nbufs, in Send()
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()
90 Send(uv_buf_t* bufs, size_t nbufs, const sockaddr* addr) Send() argument
H A Dudp_wrap.h96 size_t nbufs,
165 size_t nbufs,
/third_party/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()
/third_party/libuv/include/uv/
H A Dunix.h264 unsigned int nbufs; \
276 unsigned int nbufs; \
364 unsigned int nbufs; \
/third_party/node/deps/uv/include/uv/
H A Dunix.h264 unsigned int nbufs; \
276 unsigned int nbufs; \
364 unsigned int nbufs; \

Completed in 43 milliseconds

12