| /third_party/node/src/ |
| H A D | stream_pipe.cc | 115 void StreamPipe::ReadableListener::OnStreamRead(ssize_t nread, in OnStreamRead() argument
119 if (nread < 0) { in OnStreamRead()
128 previous_listener_->OnStreamRead(nread, uv_buf_init(nullptr, 0)); in OnStreamRead()
138 pipe->ProcessData(nread, std::move(bs)); in OnStreamRead()
141 void StreamPipe::ProcessData(size_t nread, in ProcessData() argument
144 uv_buf_t buffer = uv_buf_init(static_cast<char*>(bs->Data()), nread); in ProcessData()
237 void StreamPipe::WritableListener::OnStreamRead(ssize_t nread, in OnStreamRead() argument
240 return previous_listener_->OnStreamRead(nread, buf); in OnStreamRead()
|
| /third_party/rust/crates/rustix/src/backend/libc/io/ |
| H A D | syscalls.rs | 37 let nread = unsafe {
44 Ok(nread as usize)
64 let nread = unsafe {
72 Ok(nread as usize)
93 let nread = unsafe {
100 Ok(nread as usize)
122 let nread = unsafe {
130 Ok(nread as usize)
157 let nread = unsafe {
166 Ok(nread a
329 let mut nread = MaybeUninit::<c::c_int>::uninit(); global() variables
[all...] |
| /third_party/rust/crates/rustix/src/backend/libc/rand/ |
| H A D | syscalls.rs | 13 let nread = in getrandom()
15 Ok(nread as usize)
|
| /third_party/libuv/docs/code/udp-dhcp/ |
| H A D | main.c | 17 void on_read(uv_udp_t *req, ssize_t nread, const uv_buf_t *buf, const struct sockaddr *addr, unsigned flags) { in on_read() argument
18 if (nread < 0) { in on_read()
19 fprintf(stderr, "Read error %s\n", uv_err_name(nread)); in on_read()
|
| /third_party/libuv/test/ |
| H A D | benchmark-ping-udp.c | 89 ssize_t nread, in pinger_read_cb()
98 ASSERT_GT(nread, 0); in pinger_read_cb()
101 for (i = 0; i < nread; i++) { in pinger_read_cb()
88 pinger_read_cb(uv_udp_t* udp, ssize_t nread, const uv_buf_t* buf, const struct sockaddr* addr, unsigned flags) pinger_read_cb() argument
|
| H A D | test-tcp-try-write.c | 78 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in read_cb() argument
79 if (nread < 0) { in read_cb()
85 bytes_read += nread; in read_cb()
|
| H A D | test-tcp-close-reset.c | 105 static void read_cb2(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb2() argument
107 if (nread == UV_EOF) in read_cb2()
148 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb() argument
150 if (nread < 0) { in read_cb()
153 read_size += nread; in read_cb()
|
| H A D | test-udp-open.c | 100 ssize_t nread, in recv_cb()
106 if (nread < 0) { in recv_cb()
110 if (nread == 0) { in recv_cb()
119 ASSERT_EQ(4, nread); in recv_cb()
120 ASSERT_OK(memcmp("PING", buf->base, nread)); in recv_cb()
99 recv_cb(uv_udp_t* handle, ssize_t nread, const uv_buf_t* buf, const struct sockaddr* addr, unsigned flags) recv_cb() argument
|
| H A D | test-udp-send-unreachable.c | 78 ssize_t nread, in recv_cb()
85 if (nread < 0) { in recv_cb()
87 } else if (nread == 0) { in recv_cb()
77 recv_cb(uv_udp_t* handle, ssize_t nread, const uv_buf_t* rcvbuf, const struct sockaddr* addr, unsigned flags) recv_cb() argument
|
| /third_party/musl/libc-test/src/functional/ |
| H A D | fopencookie_test.c | 110 size_t nread;
in main() local
136 nread = fread(buf, memberSize, memberNumbers, file);
in main()
137 if (nread == 0) {
in main()
|
| /third_party/musl/libc-test/src/functionalext/supplement/linux/ |
| H A D | name_to_handle_at.c | 65 int nread = read(fd, buf, sizeof(buf)); in name_to_handle_at_0100() local
66 if (nread == -1) { in name_to_handle_at_0100()
|
| /third_party/backends/backend/ |
| H A D | dell1600n_net.c | 304 int nread, iNextDevice; in sane_get_devices() local
428 nread = read (sock, sockBuf, sizeof (sockBuf)); in sane_get_devices()
429 DBG (5, "Got a broadcast response, (%d bytes)\n", nread); in sane_get_devices()
431 if (nread <= 0) in sane_get_devices()
434 HexDump (10, sockBuf, nread); in sane_get_devices()
437 if (!(pDevice = ProcessFindResponse (sockBuf, nread))) continue; in sane_get_devices()
688 int iHandle, nread; in sane_start() local
766 nread = in sane_start()
769 if (nread <= 0) in sane_start()
771 DBG (1, "sane_start: read returned %d\n", nread); in sane_start()
1352 int nread; ProcessUdpResponse() local
[all...] |
| H A D | sharp.c | 823 size_t nread; in reader_process() local
860 nread = bytes_to_queue; in reader_process()
861 if (nread > max_bytes_per_read) in reader_process()
862 nread = max_bytes_per_read; in reader_process()
863 bc->used = nread; in reader_process()
864 cmd[6] = nread >> 16; in reader_process()
865 cmd[7] = nread >> 8; in reader_process()
866 cmd[8] = nread; in reader_process()
1022 nread = bytes_to_queue; in reader_process()
1023 if (nread > max_bytes_per_rea in reader_process()
1134 size_t nread; read_data() local
3959 size_t nread; sane_read_direct() local
4005 size_t nread, ntest, pixel, max_pixel, line, max_line; sane_read_shuffled() local
[all...] |
| /third_party/libuv/src/unix/ |
| H A D | udp.c | 155 ssize_t nread; in uv__udp_recvmmsg() local
179 nread = recvmmsg(handle->io_watcher.fd, msgs, chunks, 0, NULL); in uv__udp_recvmmsg()
180 while (nread == -1 && errno == EINTR); in uv__udp_recvmmsg()
182 if (nread < 1) { in uv__udp_recvmmsg()
183 if (nread == 0 || errno == EAGAIN || errno == EWOULDBLOCK) in uv__udp_recvmmsg()
189 for (k = 0; k < (size_t) nread && handle->recv_cb != NULL; k++) { in uv__udp_recvmmsg()
206 return nread; in uv__udp_recvmmsg()
215 ssize_t nread; in uv__udp_recvmsg() local
238 nread = uv__udp_recvmmsg(handle, &buf); in uv__udp_recvmsg()
239 if (nread > in uv__udp_recvmsg()
[all...] |
| /third_party/node/deps/uv/src/unix/ |
| H A D | udp.c | 191 ssize_t nread; in uv__udp_recvmmsg() local
215 nread = uv__recvmmsg(handle->io_watcher.fd, msgs, chunks); in uv__udp_recvmmsg()
216 while (nread == -1 && errno == EINTR); in uv__udp_recvmmsg()
218 if (nread < 1) { in uv__udp_recvmmsg()
219 if (nread == 0 || errno == EAGAIN || errno == EWOULDBLOCK) in uv__udp_recvmmsg()
225 for (k = 0; k < (size_t) nread && handle->recv_cb != NULL; k++) { in uv__udp_recvmmsg()
242 return nread; in uv__udp_recvmmsg()
249 ssize_t nread; in uv__udp_recvmsg() local
273 nread = uv__udp_recvmmsg(handle, &buf); in uv__udp_recvmsg()
274 if (nread > in uv__udp_recvmsg()
[all...] |
| /foundation/CastEngine/castengine_cast_plus_stream/src/stream/src/local/src/ |
| H A D | cast_local_file_channel_server.cpp | 375 int nread = 0; in ReadFileDataByFd() local
377 nread = read(fd, buffer + total, sendLen - total); in ReadFileDataByFd()
378 while (total < sendLen && nread > 0) { in ReadFileDataByFd()
379 total += nread; in ReadFileDataByFd()
380 nread = read(fd, buffer + total, sendLen - total); in ReadFileDataByFd()
|
| /foundation/CastEngine/castengine_cast_framework/service/src/session/src/stream/src/local/src/ |
| H A D | cast_local_file_channel_server.cpp | 364 int nread = 0; in ReadFileDataByFd() local
366 nread = read(fd, buffer + total, sendLen - total); in ReadFileDataByFd()
367 while (total < sendLen && nread > 0) { in ReadFileDataByFd()
368 total += nread; in ReadFileDataByFd()
369 nread = read(fd, buffer + total, sendLen - total); in ReadFileDataByFd()
|
| /kernel/linux/linux-5.10/drivers/char/ipmi/ |
| H A D | bt-bmc.c | 201 ssize_t nread; in bt_bmc_read() local
232 nread = min_t(ssize_t, len, sizeof(kbuffer) - len_byte); in bt_bmc_read()
234 bt_readn(bt_bmc, kbuffer + len_byte, nread); in bt_bmc_read()
236 if (copy_to_user(buf, kbuffer, nread + len_byte)) { in bt_bmc_read()
240 len -= nread; in bt_bmc_read()
241 buf += nread + len_byte; in bt_bmc_read()
242 ret += nread + len_byte; in bt_bmc_read()
|
| /kernel/linux/linux-6.6/drivers/char/ipmi/ |
| H A D | bt-bmc.c | 183 ssize_t nread; in bt_bmc_read() local
214 nread = min_t(ssize_t, len, sizeof(kbuffer) - len_byte); in bt_bmc_read()
216 bt_readn(bt_bmc, kbuffer + len_byte, nread); in bt_bmc_read()
218 if (copy_to_user(buf, kbuffer, nread + len_byte)) { in bt_bmc_read()
222 len -= nread; in bt_bmc_read()
223 buf += nread + len_byte; in bt_bmc_read()
224 ret += nread + len_byte; in bt_bmc_read()
|
| /third_party/curl/lib/vtls/ |
| H A D | wolfssl.c | 310 ssize_t nread; in wolfssl_bio_cf_in_read() local
318 nread = Curl_conn_cf_recv(cf->next, data, buf, blen, &result); in wolfssl_bio_cf_in_read()
320 CURL_TRC_CF(data, cf, "bio_read(len=%d) -> %zd, %d", blen, nread, result); in wolfssl_bio_cf_in_read()
322 if(nread < 0 && CURLE_AGAIN == result) in wolfssl_bio_cf_in_read()
324 return (int)nread; in wolfssl_bio_cf_in_read()
1083 int nread; in wolfssl_recv() local
1090 nread = wolfSSL_read(backend->handle, buf, buffsize); in wolfssl_recv()
1092 if(nread <= 0) { in wolfssl_recv()
1093 int err = wolfSSL_get_error(backend->handle, nread); in wolfssl_recv()
1119 CURL_TRC_CF(data, cf, "wolfssl_recv(len=%zu) -> %d", blen, nread); in wolfssl_recv()
[all...] |
| /third_party/node/test/cctest/ |
| H A D | test_inspector_socket.cc | 253 static void check_data_cb(read_expects* expectation, ssize_t nread, in check_data_cb() argument
256 EXPECT_TRUE(nread >= 0 && nread != UV_EOF); in check_data_cb()
260 for (i = 0; i < nread && expectation->pos <= expectation->expected_len; i++) { in check_data_cb()
269 GTEST_ASSERT_EQ(i, nread); in check_data_cb()
277 static void check_data_cb(uv_stream_t* stream, ssize_t nread, in check_data_cb() argument
282 check_data_cb(expects, nread, buf, &retval); in check_data_cb()
299 static void fail_callback(uv_stream_t* stream, ssize_t nread, in fail_callback() argument
301 if (nread < 0) { in fail_callback()
302 fprintf(stderr, "IO error: %s\n", uv_strerror(nread)); in fail_callback()
[all...] |
| /third_party/ltp/testcases/kernel/security/dirtyc0w_shmem/ |
| H A D | dirtyc0w_shmem_child.c | 100 int nready, nread; in uffd_thread_fn() local
108 nread = read(uffd, &msg, sizeof(msg)); in uffd_thread_fn()
109 if (nread <= 0) in uffd_thread_fn()
|
| /third_party/nghttp2/src/ |
| H A D | shrpx_memcached_connection.cc | 346 auto nread = conn_.read_tls(recvbuf_.last, recvbuf_.wleft()); in read_tls() local
348 if (nread == 0) { in read_tls()
352 if (nread < 0) { in read_tls()
356 recvbuf_.write(nread); in read_tls()
402 auto nread = conn_.read_clear(recvbuf_.last, recvbuf_.wleft()); in read_clear() local
404 if (nread == 0) { in read_clear()
408 if (nread < 0) { in read_clear()
412 recvbuf_.write(nread); in read_clear()
|
| /kernel/linux/linux-5.10/drivers/usb/gadget/function/ |
| H A D | f_mass_storage.c | 645 ssize_t nread; in do_read() local
711 nread = kernel_read(curlun->filp, bh->buf, amount, in do_read()
714 (unsigned long long)file_offset, (int)nread); in do_read()
718 if (nread < 0) { in do_read()
719 LDBG(curlun, "error in file read: %d\n", (int)nread); in do_read()
720 nread = 0; in do_read()
721 } else if (nread < amount) { in do_read()
723 (int)nread, amount); in do_read()
724 nread = round_down(nread, curlu in do_read()
985 ssize_t nread; do_verify() local
[all...] |
| /kernel/linux/linux-6.6/drivers/usb/gadget/function/ |
| H A D | f_mass_storage.c | 615 ssize_t nread; in do_read() local
684 nread = kernel_read(curlun->filp, bh->buf, amount, in do_read()
687 (unsigned long long)file_offset, (int)nread); in do_read()
691 if (nread < 0) { in do_read()
692 LDBG(curlun, "error in file read: %d\n", (int)nread); in do_read()
693 nread = 0; in do_read()
694 } else if (nread < amount) { in do_read()
696 (int)nread, amount); in do_read()
697 nread = round_down(nread, curlu in do_read()
961 ssize_t nread; do_verify() local
[all...] |