/third_party/node/deps/base64/base64/bin/ |
D | base64.c | 89 ssize_t r, nwrite = 0; in writev() local 105 nwrite += r; in writev() 116 return nwrite; in writev() 151 ssize_t nwrite; in writev_retry() local 154 if ((nwrite = writev(1, iov, nvec)) < 0) { in writev_retry() 173 if (iov->iov_len > (size_t) nwrite) { in writev_retry() 176 iov->iov_base = (size_t) nwrite + base; in writev_retry() 177 iov->iov_len -= (size_t) nwrite; in writev_retry() 182 nwrite -= iov->iov_len; in writev_retry() 216 ssize_t nwrite; in write_stdout() local [all …]
|
/third_party/nghttp2/src/ |
D | shrpx_connection.cc | 192 auto nwrite = conn->write_clear(buf, len); in shrpx_bio_write() local 193 if (nwrite < 0) { in shrpx_bio_write() 197 if (nwrite == 0) { in shrpx_bio_write() 202 return nwrite; in shrpx_bio_write() 486 auto nwrite = writev_clear(iov, iovcnt); in tls_handshake() local 487 if (nwrite > 0) { in tls_handshake() 488 tls.wbuf.drain(nwrite); in tls_handshake() 525 auto nwrite = writev_clear(iov.data(), iovcnt); in tls_handshake() local 526 if (nwrite < 0) { in tls_handshake() 532 tls.wbuf.drain(nwrite); in tls_handshake() [all …]
|
D | h2load_quic.cc | 479 auto nwrite = ngtcp2_conn_write_connection_close( in quic_close_connection() local 483 if (nwrite <= 0) { in quic_close_connection() 488 ps.path.remote.addrlen, buf.data(), nwrite, 0); in quic_close_connection() 688 auto nwrite = ngtcp2_conn_writev_stream( in write_quic() local 691 if (nwrite < 0) { in write_quic() 692 switch (nwrite) { in write_quic() 709 ngtcp2_ccerr_set_liberr(&quic.last_error, nwrite, nullptr, 0); in write_quic() 717 if (nwrite == 0) { in write_quic() 732 bufpos += nwrite; in write_quic() 761 gso_size = nwrite; in write_quic() [all …]
|
D | shrpx_memcached_connection.cc | 321 auto nwrite = conn_.write_tls(buf.data(), p - std::begin(buf)); in write_tls() local 322 if (nwrite < 0) { in write_tls() 325 if (nwrite == 0) { in write_tls() 329 drain_send_queue(nwrite); in write_tls() 377 auto nwrite = conn_.writev_clear(iov.data(), iovcnt); in write_clear() local 378 if (nwrite < 0) { in write_clear() 381 if (nwrite == 0) { in write_clear() 385 drain_send_queue(nwrite); in write_clear() 633 void MemcachedConnection::drain_send_queue(size_t nwrite) { in drain_send_queue() argument 634 sendsum_ -= nwrite; in drain_send_queue() [all …]
|
D | shrpx_quic_connection_handler.cc | 502 auto nwrite = in send_retry() local 505 if (nwrite < 0) { in send_retry() 506 LOG(ERROR) << "ngtcp2_crypto_write_retry: " << ngtcp2_strerror(nwrite); in send_retry() 510 buf.resize(nwrite); in send_retry() 551 auto nwrite = ngtcp2_pkt_write_version_negotiation( in send_version_negotiation() local 554 if (nwrite < 0) { in send_version_negotiation() 556 << ngtcp2_strerror(nwrite); in send_version_negotiation() 562 buf.data(), nwrite, 0); in send_version_negotiation() 608 auto nwrite = in send_stateless_reset() local 611 if (nwrite < 0) { in send_stateless_reset() [all …]
|
D | shrpx_live_check.cc | 486 auto nwrite = conn_.write_tls(iov.iov_base, iov.iov_len); in write_tls() local 488 if (nwrite == 0) { in write_tls() 492 if (nwrite < 0) { in write_tls() 493 return nwrite; in write_tls() 496 wb_.drain(nwrite); in write_tls() 555 auto nwrite = conn_.write_clear(iov.iov_base, iov.iov_len); in write_clear() local 557 if (nwrite == 0) { in write_clear() 561 if (nwrite < 0) { in write_clear() 562 return nwrite; in write_clear() 565 wb_.drain(nwrite); in write_clear()
|
D | shrpx_http3_upstream.cc | 162 auto nwrite = vsnprintf(buf.data(), buf.size(), fmt, ap); in log_printf() local 165 if (static_cast<size_t>(nwrite) >= buf.size()) { in log_printf() 166 nwrite = buf.size() - 1; in log_printf() 169 buf[nwrite++] = '\n'; in log_printf() 171 while (write(fileno(stderr), buf.data(), nwrite) == -1 && errno == EINTR) in log_printf() 842 auto nwrite = ngtcp2_conn_writev_stream( in write_streams() local 845 if (nwrite < 0) { in write_streams() 846 switch (nwrite) { in write_streams() 872 << ngtcp2_strerror(nwrite); in write_streams() 874 ngtcp2_ccerr_set_liberr(&last_error_, nwrite, nullptr, 0); in write_streams() [all …]
|
D | libevent_util.cc | 76 auto nwrite = std::min(end - pos, limit_); in write_buffer() local 77 auto rv = evbuffer_add(bucket_, pos, nwrite); in write_buffer() 85 pos += nwrite; in write_buffer()
|
D | shrpx_quic.cc | 150 ssize_t nwrite; in quic_send_packet() local 153 nwrite = sendmsg(faddr->fd, &msg, 0); in quic_send_packet() 154 } while (nwrite == -1 && errno == EINTR); in quic_send_packet() 156 if (nwrite == -1) { in quic_send_packet() 169 << " ecn=" << log::hex << pi.ecn << log::dec << " " << nwrite in quic_send_packet()
|
D | shrpx_log.cc | 204 auto nwrite = std::min(static_cast<size_t>(rv), sizeof(buf) - 1); in ~Log() local 206 while (write(lgconf->errorlog_fd, buf, nwrite) == -1 && errno == EINTR) in ~Log() 365 auto nwrite = in copy() local 367 return std::make_pair(std::copy_n(src, nwrite, d_first), d_last); in copy() 416 auto nwrite = std::min(static_cast<size_t>(std::distance(d_first, d_last)), in copy_hex_low() local 419 for (size_t i = 0; i < nwrite; ++i) { in copy_hex_low() 867 auto nwrite = std::distance(std::begin(buf), p); in upstream_accesslog() local 868 while (write(lgconf->accesslog_fd, buf.data(), nwrite) == -1 && in upstream_accesslog()
|
D | shrpx_http_downstream_connection.cc | 1298 auto nwrite = conn_.writev_clear(iov.data(), iovcnt); in write_clear() local 1300 if (nwrite == 0) { in write_clear() 1304 if (nwrite < 0) { in write_clear() 1306 return nwrite; in write_clear() 1317 input->drain(nwrite); in write_clear() 1434 auto nwrite = conn_.write_tls(iov.iov_base, iov.iov_len); in write_tls() local 1436 if (nwrite == 0) { in write_tls() 1440 if (nwrite < 0) { in write_tls() 1442 return nwrite; in write_tls() 1453 input->drain(nwrite); in write_tls()
|
/third_party/node/src/quic/ |
D | packet.cc | 256 ssize_t nwrite = ngtcp2_crypto_write_retry(dest.base, in CreateRetryPacket() local 264 if (nwrite <= 0) return BaseObjectPtr<Packet>(); in CreateRetryPacket() 265 packet->Truncate(static_cast<size_t>(nwrite)); in CreateRetryPacket() 279 ssize_t nwrite = ngtcp2_conn_write_connection_close( in CreateConnectionClosePacket() local 281 if (nwrite < 0) return BaseObjectPtr<Packet>(); in CreateConnectionClosePacket() 282 packet->Truncate(static_cast<size_t>(nwrite)); in CreateConnectionClosePacket() 298 ssize_t nwrite = ngtcp2_crypto_write_connection_close( in CreateImmediateConnectionClosePacket() local 309 if (nwrite <= 0) return BaseObjectPtr<Packet>(); in CreateImmediateConnectionClosePacket() 310 packet->Truncate(static_cast<size_t>(nwrite)); in CreateImmediateConnectionClosePacket() 340 ssize_t nwrite = ngtcp2_pkt_write_stateless_reset( in CreateStatelessResetPacket() local [all …]
|
/third_party/node/deps/ngtcp2/ngtcp2/lib/ |
D | ngtcp2_conn.c | 2992 ngtcp2_ssize res = 0, nwrite = 0; in conn_write_handshake_ack_pkts() local 3001 nwrite = in conn_write_handshake_ack_pkts() 3003 if (nwrite < 0) { in conn_write_handshake_ack_pkts() 3004 assert(nwrite != NGTCP2_ERR_NOBUF); in conn_write_handshake_ack_pkts() 3005 return nwrite; in conn_write_handshake_ack_pkts() 3008 res += nwrite; in conn_write_handshake_ack_pkts() 3009 dest += nwrite; in conn_write_handshake_ack_pkts() 3010 destlen -= (size_t)nwrite; in conn_write_handshake_ack_pkts() 3014 nwrite = in conn_write_handshake_ack_pkts() 3016 if (nwrite < 0) { in conn_write_handshake_ack_pkts() [all …]
|
/third_party/ltp/testcases/kernel/syscalls/msync/ |
D | msync01.c | 156 size_t c_total = 0, nwrite = 0; /* no. of bytes to be written */ in setup() local 170 nwrite = write(fildes, write_buf, sizeof(write_buf)); in setup() 171 if (nwrite <= 0) in setup() 174 c_total += nwrite; in setup()
|
D | msync02.c | 109 size_t c_total = 0, nwrite = 0; /* no. of bytes to be written */ in setup() local 125 if ((nwrite = write(fildes, tst_buf, sizeof(tst_buf))) <= 0) in setup() 128 c_total += nwrite; in setup()
|
D | msync03.c | 103 size_t nwrite = 0; in setup() local 118 while (nwrite < page_sz) { in setup() 120 nwrite += BUF_SIZE; in setup()
|
/third_party/node/deps/ngtcp2/nghttp3/lib/ |
D | nghttp3_tnode.c | 85 uint64_t nwrite) { in nghttp3_tnode_schedule() argument 86 uint64_t penalty = nwrite / NGHTTP3_STREAM_MIN_WRITELEN; in nghttp3_tnode_schedule() 90 ((nwrite == 0 || !nghttp3_pri_uint8_inc(tnode->pri)) in nghttp3_tnode_schedule() 93 } else if (nwrite > 0) { in nghttp3_tnode_schedule()
|
D | nghttp3_stream.c | 990 size_t nwrite; in nghttp3_stream_buffer_data() local 998 nwrite = nghttp3_min(datalen, bufleft); in nghttp3_stream_buffer_data() 999 buf->last = nghttp3_cpymem(buf->last, data, nwrite); in nghttp3_stream_buffer_data() 1000 data += nwrite; in nghttp3_stream_buffer_data() 1001 datalen -= nwrite; in nghttp3_stream_buffer_data() 1022 nwrite = nghttp3_min(datalen, bufleft); in nghttp3_stream_buffer_data() 1023 buf->last = nghttp3_cpymem(buf->last, data, nwrite); in nghttp3_stream_buffer_data() 1024 data += nwrite; in nghttp3_stream_buffer_data() 1025 datalen -= nwrite; in nghttp3_stream_buffer_data()
|
/third_party/curl/lib/ |
D | sendf.c | 551 size_t nwrite, excess_len = 0; in cw_download_write() local 585 nwrite = nbytes; in cw_download_write() 588 if(nwrite > wmax) { in cw_download_write() 590 nwrite = wmax; in cw_download_write() 593 if(nwrite == wmax) { in cw_download_write() 602 if(nwrite > wmax) { in cw_download_write() 603 nwrite = wmax; in cw_download_write() 608 data->req.bytecount += nwrite; in cw_download_write() 610 if(!data->req.ignorebody && nwrite) { in cw_download_write() 611 result = Curl_cwriter_write(data, writer->next, type, buf, nwrite); in cw_download_write() [all …]
|
/third_party/node/deps/nghttp2/lib/ |
D | nghttp2_buf.c | 337 size_t nwrite; in nghttp2_bufs_add() local 346 nwrite = nghttp2_min(nghttp2_buf_avail(buf), len); in nghttp2_bufs_add() 347 if (nwrite == 0) { in nghttp2_bufs_add() 355 buf->last = nghttp2_cpymem(buf->last, p, nwrite); in nghttp2_bufs_add() 356 p += nwrite; in nghttp2_bufs_add() 357 len -= nwrite; in nghttp2_bufs_add()
|
/third_party/nghttp2/lib/ |
D | nghttp2_buf.c | 337 size_t nwrite; in nghttp2_bufs_add() local 346 nwrite = nghttp2_min(nghttp2_buf_avail(buf), len); in nghttp2_bufs_add() 347 if (nwrite == 0) { in nghttp2_bufs_add() 355 buf->last = nghttp2_cpymem(buf->last, p, nwrite); in nghttp2_bufs_add() 356 p += nwrite; in nghttp2_bufs_add() 357 len -= nwrite; in nghttp2_bufs_add()
|
/third_party/curl/tests/server/ |
D | sockfilt.c | 280 ssize_t nwrite = 0; in fullwrite() local 283 ssize_t wc = write(filedes, (const unsigned char *)buffer + nwrite, in fullwrite() 284 nbytes - nwrite); in fullwrite() 306 nwrite += wc; in fullwrite() 308 } while((size_t)nwrite < nbytes); in fullwrite() 311 logmsg("wrote %zd bytes", nwrite); in fullwrite() 313 return nwrite; in fullwrite() 342 ssize_t nwrite = fullwrite(fileno(stdout), buffer, nbytes); in write_stdout() local 343 if(nwrite != (ssize_t)nbytes) { in write_stdout()
|
D | socksd.c | 652 ssize_t nwrite; in tunnel() local 658 nwrite = send(cp->remotefd, (char *)buffer, in tunnel() 660 if(nwrite != nread) in tunnel() 662 cp->fromclient += nwrite; in tunnel() 671 nwrite = send(cp->clientfd, (char *)buffer, in tunnel() 673 if(nwrite != nread) in tunnel() 675 cp->fromremote += nwrite; in tunnel()
|
/third_party/curl/lib/vssh/ |
D | libssh2.c | 3213 ssize_t nwrite; in ssh_tls_send() local 3223 result = Curl_write(data, sock, buffer, length, &nwrite); in ssh_tls_send() 3229 Curl_debug(data, CURLINFO_DATA_OUT, (char *)buffer, (size_t)nwrite); in ssh_tls_send() 3230 return nwrite; in ssh_tls_send() 3538 ssize_t nwrite; in scp_send() local 3544 nwrite = (ssize_t) libssh2_channel_write(sshc->ssh_channel, mem, len); in scp_send() 3546 ssh_block2waitfor(data, (nwrite == LIBSSH2_ERROR_EAGAIN)?TRUE:FALSE); in scp_send() 3548 if(nwrite == LIBSSH2_ERROR_EAGAIN) { in scp_send() 3550 nwrite = 0; in scp_send() 3552 else if(nwrite < LIBSSH2_ERROR_NONE) { in scp_send() [all …]
|
/third_party/ltp/testcases/kernel/device-drivers/zram/ |
D | zram03.c | 111 static void print_stat(char *nread, char *nwrite) in print_stat() argument 119 tst_res(TINFO, "%s from %s is %s", nwrite, zram_stat_path, nwrite_val); in print_stat()
|