Home
last modified time | relevance | path

Searched refs:nwrite (Results 1 – 25 of 44) sorted by relevance

12

/third_party/node/deps/base64/base64/bin/
Dbase64.c89 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/
Dshrpx_connection.cc192 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 …]
Dh2load_quic.cc479 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 …]
Dshrpx_memcached_connection.cc321 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 …]
Dshrpx_quic_connection_handler.cc502 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 …]
Dshrpx_live_check.cc486 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()
Dshrpx_http3_upstream.cc162 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 …]
Dlibevent_util.cc76 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()
Dshrpx_quic.cc150 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()
Dshrpx_log.cc204 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()
Dshrpx_http_downstream_connection.cc1298 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/
Dpacket.cc256 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/
Dngtcp2_conn.c2992 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/
Dmsync01.c156 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()
Dmsync02.c109 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()
Dmsync03.c103 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/
Dnghttp3_tnode.c85 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()
Dnghttp3_stream.c990 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/
Dsendf.c551 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/
Dnghttp2_buf.c337 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/
Dnghttp2_buf.c337 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/
Dsockfilt.c280 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()
Dsocksd.c652 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/
Dlibssh2.c3213 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/
Dzram03.c111 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()

12