| /third_party/nghttp2/src/ |
| D | shrpx_connection.cc | 195 auto nwrite = conn->write_clear(buf, len); in shrpx_bio_write() local
196 if (nwrite < 0) { in shrpx_bio_write()
200 if (nwrite == 0) { in shrpx_bio_write()
205 return nwrite; in shrpx_bio_write()
489 auto nwrite = writev_clear(iov, iovcnt); in tls_handshake() local
490 if (nwrite > 0) { in tls_handshake()
491 tls.wbuf.drain(nwrite); in tls_handshake()
528 auto nwrite = writev_clear(iov.data(), iovcnt); in tls_handshake() local
529 if (nwrite < 0) { in tls_handshake()
535 tls.wbuf.drain(nwrite); in tls_handshake()
[all …]
|
| D | h2load_quic.cc | 454 auto nwrite = ngtcp2_conn_write_connection_close( in quic_close_connection() local
458 if (nwrite <= 0) { in quic_close_connection()
463 ps.path.remote.addrlen, buf.data(), nwrite, 0); in quic_close_connection()
632 auto nwrite = ngtcp2_conn_writev_stream( in write_quic() local
636 if (nwrite < 0) { in write_quic()
637 switch (nwrite) { in write_quic()
655 &quic.last_error, nwrite, nullptr, 0); in write_quic()
663 if (nwrite == 0) { in write_quic()
678 bufpos += nwrite; in write_quic()
707 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 | 514 auto nwrite = in send_retry() local
517 if (nwrite < 0) { in send_retry()
518 LOG(ERROR) << "ngtcp2_crypto_write_retry: " << ngtcp2_strerror(nwrite); in send_retry()
522 buf.resize(nwrite); in send_retry()
565 auto nwrite = ngtcp2_pkt_write_version_negotiation( in send_version_negotiation() local
568 if (nwrite < 0) { in send_version_negotiation()
570 << ngtcp2_strerror(nwrite); in send_version_negotiation()
576 buf.data(), nwrite, 0); in send_version_negotiation()
622 auto nwrite = in send_stateless_reset() local
625 if (nwrite < 0) { in send_stateless_reset()
[all …]
|
| 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()
786 auto nwrite = ngtcp2_conn_writev_stream( in write_streams() local
789 if (nwrite < 0) { in write_streams()
790 switch (nwrite) { in write_streams()
816 << ngtcp2_strerror(nwrite); in write_streams()
819 &last_error_, nwrite, nullptr, 0); in write_streams()
[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 | 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 | 128 ssize_t nwrite; in quic_send_packet() local
131 nwrite = sendmsg(faddr->fd, &msg, 0); in quic_send_packet()
132 } while (nwrite == -1 && errno == EINTR); in quic_send_packet()
134 if (nwrite == -1) { in quic_send_packet()
147 << " 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 | 1283 auto nwrite = conn_.writev_clear(iov.data(), iovcnt); in write_clear() local
1285 if (nwrite == 0) { in write_clear()
1289 if (nwrite < 0) { in write_clear()
1291 return nwrite; in write_clear()
1302 input->drain(nwrite); in write_clear()
1419 auto nwrite = conn_.write_tls(iov.iov_base, iov.iov_len); in write_tls() local
1421 if (nwrite == 0) { in write_tls()
1425 if (nwrite < 0) { in write_tls()
1427 return nwrite; in write_tls()
1438 input->drain(nwrite); in write_tls()
|
| D | shrpx_api_downstream_connection.cc | 318 ssize_t nwrite; in push_upload_data_chunk() local
319 while ((nwrite = write(fd_, data, datalen)) == -1 && errno == EINTR) in push_upload_data_chunk()
321 if (nwrite == -1) { in push_upload_data_chunk()
|
| D | shrpx_client_handler.cc | 166 auto nwrite = conn_.writev_clear(iov.data(), iovcnt); in write_clear() local
167 if (nwrite < 0) { in write_clear()
171 if (nwrite == 0) { in write_clear()
175 upstream_->response_drain(nwrite); in write_clear()
303 auto nwrite = conn_.write_tls(iov.iov_base, iov.iov_len); in write_tls() local
304 if (nwrite < 0) { in write_tls()
308 if (nwrite == 0) { in write_tls()
312 upstream_->response_drain(nwrite); in write_tls()
|
| D | shrpx_http2_session.cc | 2050 auto nwrite = conn_.writev_clear(iov.data(), iovcnt); in write_clear() local
2052 if (nwrite == 0) { in write_clear()
2056 if (nwrite < 0) { in write_clear()
2065 wb_.drain(nwrite); in write_clear()
2160 auto nwrite = conn_.write_tls(iov.iov_base, iov.iov_len); in write_tls() local
2162 if (nwrite == 0) { in write_tls()
2166 if (nwrite < 0) { in write_tls()
2175 wb_.drain(nwrite); in write_tls()
|
| D | shrpx_memcached_connection.h | 122 void drain_send_queue(size_t nwrite);
|
| D | HttpServer.cc | 667 ssize_t nwrite; in write_clear() local
668 while ((nwrite = write(fd_, wb_.pos, wb_.rleft())) == -1 && in write_clear()
671 if (nwrite == -1) { in write_clear()
678 wb_.drain(nwrite); in write_clear()
1961 ssize_t nwrite; in make_status_body() local
1962 while ((nwrite = write(fd, body.c_str(), body.size())) == -1 && in make_status_body()
1965 if (nwrite == -1) { in make_status_body()
1972 return FileEntry(util::utos(status), nwrite, 0, fd, nullptr, 0); in make_status_body()
|
| D | h2load.cc | 1041 auto nwrite = static_cast<size_t>(std::distance(std::begin(buf), p)); in on_stream_close() local
1042 assert(nwrite <= buf.size()); in on_stream_close()
1043 while (write(worker->config->log_fd, buf.data(), nwrite) == -1 && in on_stream_close()
1295 ssize_t nwrite; in write_clear() local
1296 while ((nwrite = writev(fd, iov.data(), iovcnt)) == -1 && errno == EINTR) in write_clear()
1299 if (nwrite == -1) { in write_clear()
1307 wb.drain(nwrite); in write_clear()
1467 auto nwrite = sendmsg(fd, &msg, 0); in write_udp() local
1468 if (nwrite < 0) { in write_udp()
|
| D | shrpx_connection_handler.cc | 1140 ssize_t nwrite; in forward_quic_packet_to_lingering_worker_process() local
1142 while ((nwrite = sendmsg(quic_lwp->quic_ipc_fd, &msg, 0)) == -1 && in forward_quic_packet_to_lingering_worker_process()
1146 if (nwrite == -1) { in forward_quic_packet_to_lingering_worker_process()
|
| D | nghttp.cc | 835 ssize_t nwrite; in write_clear() local
836 while ((nwrite = writev(fd, iov.data(), iovcnt)) == -1 && errno == EINTR) in write_clear()
838 if (nwrite == -1) { in write_clear()
847 wb.drain(nwrite); in write_clear()
|
| /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/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/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/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()
|
| /third_party/musl/libc-test/src/functionalext/trace/ |
| D | trace_marker.c | 77 int nwrite; in dump_trace() local
88 nwrite = TRACE_TEMP_FAILURE_RETRY(write(out_fd, buffer, nread)); in dump_trace()
89 } while (nwrite > 0); in dump_trace()
|