/libuv/src/unix/ |
H A D | stream.c | 149 char buf[1024]; in uv__stream_osx_select() local 196 r = read(s->int_fd, buf, sizeof(buf)); in uv__stream_osx_select() 691 uv_buf_t* buf; in uv__write_req_update() local 700 len = n < buf->len ? n : buf->len; in uv__write_req_update() 701 if (buf->len != 0) in uv__write_req_update() 702 buf->base += len; in uv__write_req_update() 703 buf->len -= len; in uv__write_req_update() 704 buf += (buf->len == 0); /* Advance to next buffer if this one is empty. */ in uv__write_req_update() 1026 uv_buf_t buf; in uv__read() local 1053 if (buf.base == NULL || buf.len == 0) { in uv__read() [all …]
|
H A D | random-getentropy.c | 39 int uv__random_getentropy(void* buf, size_t buflen) { in uv__random_getentropy() argument 50 if (uv__getentropy((char *) buf + pos, stride)) in uv__random_getentropy() 53 if (uv__getentropy((char *) buf + pos, buflen - pos)) in uv__random_getentropy()
|
H A D | getaddrinfo.c | 149 char* buf; in uv_getaddrinfo() local 175 buf = uv__malloc(hostname_len + service_len + hints_len); in uv_getaddrinfo() 177 if (buf == NULL) in uv_getaddrinfo() 193 req->hints = memcpy(buf + len, hints, sizeof(*hints)); in uv_getaddrinfo() 198 req->service = memcpy(buf + len, service, service_len); in uv_getaddrinfo() 203 req->hostname = memcpy(buf + len, hostname, hostname_len); in uv_getaddrinfo()
|
H A D | internal.h | 292 int uv__slurp(const char* filename, char* buf, size_t len); 334 int uv__search_path(const char* prog, char* buf, size_t* buflen); 338 int uv__random_devurandom(void* buf, size_t buflen); 339 int uv__random_getrandom(void* buf, size_t buflen); 340 int uv__random_getentropy(void* buf, size_t buflen); 341 int uv__random_readpath(const char* path, void* buf, size_t buflen); 342 int uv__random_sysctl(void* buf, size_t buflen); 453 void uv__statx_to_stat(const struct uv__statx* statxbuf, uv_stat_t* buf); 454 ssize_t uv__getrandom(void* buf, size_t buflen, unsigned flags);
|
/libuv/test/ |
H A D | test-close-fd.c | 30 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_cb() argument 32 buf->base = slab; in alloc_cb() 33 buf->len = sizeof(slab); in alloc_cb() 36 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) { in read_cb() argument
|
H A D | runner-unix.c | 355 struct stat buf; in process_output_size() local 357 memset(&buf, 0, sizeof(buf)); in process_output_size() 358 int r = fstat(fileno(p->stdout_file), &buf); in process_output_size() 363 return (long)buf.st_size; in process_output_size() 369 char buf[1024]; in process_copy_output() local 379 while ((r = fread(buf, 1, sizeof(buf), p->stdout_file)) != 0) in process_copy_output() 380 print_lines(buf, r, stream); in process_copy_output()
|
H A D | test-fs-poll.c | 173 char buf[1024]; in TEST_IMPL() local 180 len = sizeof buf; in TEST_IMPL() 181 ASSERT_EQ(UV_EINVAL, uv_fs_poll_getpath(&poll_handle, buf, &len)); in TEST_IMPL() 183 len = sizeof buf; in TEST_IMPL() 184 ASSERT_OK(uv_fs_poll_getpath(&poll_handle, buf, &len)); in TEST_IMPL() 185 ASSERT_NE(0, buf[len - 1]); in TEST_IMPL() 186 ASSERT_EQ(buf[len], '\0'); in TEST_IMPL() 187 ASSERT_OK(memcmp(buf, FIXTURE, len)); in TEST_IMPL()
|
H A D | test-not-readable-nor-writable-on-read-error.c | 43 uv_buf_t* buf) { in alloc_cb() argument 45 buf->base = slab; in alloc_cb() 46 buf->len = sizeof(slab); in alloc_cb() 53 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) { in read_cb() argument
|
H A D | test-process-title.c | 130 char buf[256] = "fail"; in process_title_big_argv() local 133 uv_get_process_title(buf, sizeof(buf)); in process_title_big_argv() 134 ASSERT_NE(0, strcmp(buf, "fail")); in process_title_big_argv()
|
H A D | test-readable-on-eof.c | 43 uv_buf_t* buf) { in alloc_cb() argument 45 buf->base = slab; in alloc_cb() 46 buf->len = sizeof(slab); in alloc_cb() 53 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) { in read_cb() argument
|
H A D | test-iouring-pollhup.c | 44 uv_buf_t* buf) { in alloc_buffer() argument 46 *buf = uv_buf_init(slab, sizeof(slab)); in alloc_buffer() 51 const uv_buf_t* buf) { in read_data2() argument 80 const uv_buf_t* buf) { in read_data() argument
|
H A D | test-tcp-writealot.c | 53 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_cb() argument 54 buf->base = malloc(size); in alloc_cb() 55 buf->len = size; in alloc_cb() 84 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in read_cb() argument 96 free(buf->base); in read_cb()
|
H A D | test-tcp-close-reset.c | 58 uv_buf_t buf; in do_write() local 62 buf = uv_buf_init("PING", 4); in do_write() 64 r = uv_write(&write_reqs[i], (uv_stream_t*) handle, &buf, 1, write_cb); in do_write() 99 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_cb() argument 101 buf->base = slab; in alloc_cb() 102 buf->len = sizeof(slab); in alloc_cb() 105 static void read_cb2(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb2() argument 148 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb() argument
|
H A D | test-threadpool-cancel.c | 46 char buf[1]; member 69 char buf[64]; in saturate_threadpool() local 72 snprintf(buf, in saturate_threadpool() 73 sizeof(buf), in saturate_threadpool() 76 putenv(buf); in saturate_threadpool() 187 static void nop_random_cb(uv_random_t* req, int status, void* buf, size_t len) { in nop_random_cb() argument 193 ASSERT_PTR_EQ(buf, (void*) ri->buf); in nop_random_cb() 194 ASSERT_EQ(len, sizeof(ri->buf)); in nop_random_cb() 277 &req.buf, in TEST_IMPL() 278 sizeof(req.buf), in TEST_IMPL()
|
H A D | test-udp-sendmmsg-error.c | 55 uv_buf_t buf; in TEST_IMPL() local 62 buf = uv_buf_init("TEST", 4); in TEST_IMPL() 64 ASSERT_OK(uv_udp_send(&req[i], &client, &buf, 1, NULL, send_cb)); in TEST_IMPL()
|
H A D | test-udp-dgram-too-big.c | 62 uv_buf_t buf; in TEST_IMPL() local 70 buf = uv_buf_init(dgram, sizeof dgram); in TEST_IMPL() 75 &buf, in TEST_IMPL()
|
H A D | test-fs-open-flags.c | 48 static char buf[32]; variable 186 iov = uv_buf_init(buf, sizeof(buf)); in writeExpect() 190 ASSERT_OK(strncmp(buf, expected, size)); in writeExpect() 231 iov = uv_buf_init(buf, sizeof(buf)); in readExpect() 235 ASSERT_OK(strncmp(buf, expected, size)); in readExpect() 251 iov = uv_buf_init(buf, sizeof(buf)); in readFail() 257 iov = uv_buf_init(buf, sizeof(buf)); in readFail()
|
H A D | benchmark-spawn.c | 78 uv_buf_t* buf) { in on_alloc() argument 79 buf->base = output + output_used; in on_alloc() 80 buf->len = OUTPUT_SIZE - output_used; in on_alloc() 91 static void on_read(uv_stream_t* pipe, ssize_t nread, const uv_buf_t* buf) { in on_read() argument
|
H A D | test-osx-select.c | 33 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_cb() argument 35 buf->base = slab; in alloc_cb() 36 buf->len = sizeof(slab); in alloc_cb() 40 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb() argument
|
H A D | test-udp-multicast-ttl.c | 59 uv_buf_t buf; in TEST_IMPL() local 73 buf = uv_buf_init("PING", 4); in TEST_IMPL() 77 &buf, in TEST_IMPL()
|
H A D | test-udp-multicast-interface.c | 64 uv_buf_t buf; in TEST_IMPL() local 81 buf = uv_buf_init("PING", 4); in TEST_IMPL() 84 &buf, in TEST_IMPL()
|
H A D | test-udp-multicast-interface6.c | 64 uv_buf_t buf; in TEST_IMPL() local 88 buf = uv_buf_init("PING", 4); in TEST_IMPL() 91 &buf, in TEST_IMPL()
|
H A D | test-fs.c | 431 memset(buf, 0, sizeof(buf)); in open_cb() 432 iov = uv_buf_init(buf, sizeof(buf)); in open_cb() 1041 memset(buf, 0, sizeof(buf)); in fs_file_sync() 1420 memset(buf, 0, sizeof(buf)); in TEST_IMPL() 2064 memset(buf, 0, sizeof(buf)); in TEST_IMPL() 2085 memset(buf, 0, sizeof(buf)); in TEST_IMPL() 2254 memset(buf, 0, sizeof(buf)); in TEST_IMPL() 2307 memset(buf, 0, sizeof(buf)); in TEST_IMPL() 3202 memset(buf, 0, sizeof(buf)); in TEST_IMPL() 3317 memset(buf, 0, sizeof(buf)); in fs_read_file_eof() [all …]
|
H A D | test-udp-send-hang-loop.c | 35 static uv_buf_t buf; variable 60 &buf, in idle_cb() 89 buf = uv_buf_init(send_data, sizeof(send_data)); in TEST_IMPL()
|
/libuv/src/ |
H A D | uv-common.c | 191 uv_buf_t buf; in uv_buf_init() local 192 buf.base = base; in uv_buf_init() 193 buf.len = len; in uv_buf_init() 194 return buf; in uv_buf_init() 199 char buf[32]; in uv__unknown_err_code() local 202 snprintf(buf, sizeof(buf), "Unknown system error %d", err); in uv__unknown_err_code() 203 copy = uv__strdup(buf); in uv__unknown_err_code() 210 uv__strscpy(buf, #name, buflen); break; 216 return buf; in uv_err_name_r() 233 snprintf(buf, buflen, "%s", msg); break; [all …]
|