/netbsd/external/mit/libuv/dist/src/win/ |
H A 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() 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 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);
|
H A 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()
|
H A D | fs.c | 906 } while (result && index < req->fs.info.nbufs); in fs__read() 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() 2931 if (nbufs > ARRAY_SIZE(req->fs.info.bufsml)) in uv_fs_read() 2950 unsigned int nbufs, in uv_fs_write() argument 2955 if (bufs == NULL || nbufs == 0) { in uv_fs_write() 2962 req->fs.info.nbufs = nbufs; in uv_fs_write() [all …]
|
H A D | pipe.c | 1426 size_t nbufs, in uv__build_coalesced_write_req() argument 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() argument 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() argument 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, cb, 0); in uv__pipe_write()
|
/netbsd/external/mit/libuv/dist/src/ |
H A D | uv-common.c | 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() 657 if (*nbufs > 0 && *nbufs != (unsigned int) req->result) in uv__fs_scandir_cleanup() 658 (*nbufs)--; in uv__fs_scandir_cleanup() 659 for (; *nbufs < (unsigned int) req->result; (*nbufs)++) in uv__fs_scandir_cleanup() 670 unsigned int* nbufs; in uv_fs_scandir_next() local 680 nbufs = uv__get_nbufs(req); in uv_fs_scandir_next() 681 assert(nbufs); in uv_fs_scandir_next() 686 if (*nbufs > 0) in uv_fs_scandir_next() [all …]
|
H A 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);
|
/netbsd/external/mit/libuv/dist/src/unix/ |
H A D | fs.c | 421 assert(nbufs > 0); in uv__fs_preadv() 426 end = bufs + nbufs; in uv__fs_preadv() 512 req->nbufs = 0; in uv__fs_read() 555 req->nbufs = 0; in uv__fs_scandir() 1653 unsigned int nbufs; in uv__fs_write_all() local 1659 nbufs = req->nbufs; in uv__fs_write_all() 1664 req->nbufs = nbufs; in uv__fs_write_all() 1683 nbufs -= req->nbufs; in uv__fs_write_all() 1691 req->nbufs = 0; in uv__fs_write_all() 2010 req->nbufs = nbufs; in uv_fs_read() [all …]
|
H A D | stream.c | 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() 1360 assert(nbufs > 0); in uv__check_before_write() 1398 unsigned int nbufs, in uv_write2() argument 1425 if (nbufs > ARRAY_SIZE(req->bufsml)) in uv_write2() 1432 req->nbufs = nbufs; in uv_write2() 1470 unsigned int nbufs, in uv_write() argument 1478 unsigned int nbufs) { in uv_try_write() argument 1479 return uv_try_write2(stream, bufs, nbufs, NULL); in uv_try_write() [all …]
|
H A D | udp.c | 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() 800 unsigned int nbufs, in uv__udp_try_send() argument 807 assert(nbufs > 0); in uv__udp_try_send() [all …]
|
/netbsd/distrib/utils/more/ |
H A D | ch.c | 69 int nbufs; variable 399 cbufs = nbufs; 400 if (nbufs < want_nbufs && ch_addbuf(want_nbufs - nbufs)) { 407 "cannot allocate %d buffers", want_nbufs - nbufs); 409 if (nbufs == 0) 451 nbufs += nnew; 452 cbufs = nbufs;
|
/netbsd/sys/dev/dtv/ |
H A D | dtv_buffer.c | 135 unsigned int i, nbufs, oldnbufs, minnbufs; in dtv_buffer_realloc() local 140 nbufs = BLOCK_ALIGN(bufsize) / BLOCK_SIZE; in dtv_buffer_realloc() 149 ds->ds_nbufs = nbufs; in dtv_buffer_realloc() 150 if (nbufs > 0) { in dtv_buffer_realloc() 151 ds->ds_buf = kmem_alloc(sizeof(struct dtv_buffer *) * nbufs, in dtv_buffer_realloc() 157 minnbufs = uimin(nbufs, oldnbufs); in dtv_buffer_realloc() 160 for (; i < nbufs; i++) in dtv_buffer_realloc() 170 for (i = 0; i < nbufs; i++) { in dtv_buffer_realloc()
|
/netbsd/usr.sbin/lockstat/ |
H A D | main.c | 85 u_int nbufs; member 142 static int nbufs; variable 185 nbufs = 0; in main() 209 nbufs = (int)strtol(optarg, &p, 0); in main() 288 le.le_nbufs = nbufs; in main() 365 nbufs = (int)(ld.ld_size / sizeof(lsbuf_t)); in main() 592 for (lb = bufs, max = bufs + nbufs; lb < max; lb++) { in collapse() 627 for (lb = bufs, max = bufs + nbufs; lb < max; lb++) { in makelists() 648 l->nbufs = 0; in makelists() 679 l->nbufs++; in makelists() [all …]
|
/netbsd/regress/sys/uvm/pdsim/ |
H A D | lirs.c | 65 int nbufs; variable 113 DFPRINTF(stderr, "nlirs=%d, nbufs=%d\n", nlirs, nbufs); in dump() 122 if (nbufs <= nbufs_max) { in reclaim() 131 nbufs--; in reclaim() 235 nbufs++; in fault()
|
/netbsd/external/bsd/ntp/dist/libntp/ |
H A D | recvbuff.c | 98 size_t nbufs) in create_buffers() argument 117 abuf = nbufs + buffer_shortfall; in create_buffers() 120 if (abuf < nbufs || abuf > RECV_BATCH) in create_buffers() 146 init_recvbuff(int nbufs) in init_recvbuff() argument 158 create_buffers(nbufs); in init_recvbuff()
|
/netbsd/sbin/fsck_lfs/ |
H A D | bufcache.c | 67 int nbufs = 0; variable 163 --nbufs; in buf_destroy() 205 assert(depth <= nbufs); in incore() 253 while (nbufs >= maxbufs + locked_queue_count) { in getblk() 277 ++nbufs; in getblk()
|
/netbsd/lib/libc/db/hash/ |
H A D | hash_buf.c | 173 if (hashp->nbufs || (bp->flags & BUF_PIN)) { in newbuf() 181 if (hashp->nbufs) in newbuf() 182 hashp->nbufs--; in newbuf() 286 hashp->nbufs = npages; in __buf_init()
|
/netbsd/external/mit/libuv/dist/test/ |
H A 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()
|
/netbsd/external/gpl3/binutils/dist/gprofng/libcollector/ |
H A D | iolib.c | 1020 int blk_off, buf_indices[NBUFS], ibuf, nbufs; in __collector_write_string() local 1047 nbufs = lastbuf - firstbuf; in __collector_write_string() 1049 firstbuf, lastbuf, nbufs, log2blksz); in __collector_write_string() 1050 if (nbufs >= NBUFS) in __collector_write_string() 1057 if (nbufs == 0) in __collector_write_string() 1095 for (ibuf = 0; ibuf < nbufs; ibuf++) in __collector_write_string() 1105 if (ibuf == nbufs) in __collector_write_string() 1106 npos = CUR_MAKE (0, buf_indices[nbufs - 1], foff + len); in __collector_write_string() 1124 if (ibuf < nbufs) in __collector_write_string() 1141 for (ibuf = 0; ibuf < nbufs; ibuf++) in __collector_write_string()
|
/netbsd/external/mit/libuv/dist/include/uv/ |
H A D | unix.h | 264 unsigned int nbufs; \ 276 unsigned int nbufs; \ 364 unsigned int nbufs; \
|
/netbsd/external/mpl/bind/dist/lib/isc/tests/ |
H A D | uv_wrap.h | 54 unsigned int nbufs, const struct sockaddr *addr, 156 unsigned int nbufs, const struct sockaddr *addr, in __wrap_uv_udp_send() argument 159 return (uv_udp_send(req, handle, bufs, nbufs, addr, send_cb)); in __wrap_uv_udp_send()
|
/netbsd/external/bsd/less/dist/ |
H A D | ch.c | 66 int nbufs; member 74 #define ch_nbufs thisfile->nbufs 844 thisfile->nbufs = 0; 935 printf(" %d bufs:\n", fs->nbufs);
|
/netbsd/external/mit/libuv/dist/include/ |
H A 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, 1365 unsigned int nbufs, 1376 unsigned int nbufs,
|
/netbsd/external/mit/libuv/dist/docs/src/ |
H A D | stream.rst | 159 …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…
|
/netbsd/sys/external/bsd/drm2/dist/drm/savage/ |
H A D | savage_state.c | 815 unsigned int i, nbufs; in savage_dispatch_clear() local 825 nbufs = ((flags & SAVAGE_FRONT) ? 1 : 0) + in savage_dispatch_clear() 827 if (nbufs == 0) in savage_dispatch_clear() 843 BEGIN_DMA(nbufs * 6); in savage_dispatch_clear()
|