Home
last modified time | relevance | path

Searched refs:buf (Results 76 – 100 of 149) sorted by relevance

123456

/libuv/test/
H A Dtest-close-fd.c30 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 Drunner-unix.c355 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 Dtest-fs-poll.c173 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 Dtest-not-readable-nor-writable-on-read-error.c43 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 Dtest-process-title.c130 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 Dtest-readable-on-eof.c43 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 Dtest-iouring-pollhup.c44 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 Dtest-tcp-writealot.c53 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 Dtest-tcp-close-reset.c58 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 Dtest-threadpool-cancel.c46 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 Dtest-udp-sendmmsg-error.c55 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 Dtest-udp-dgram-too-big.c62 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 Dtest-fs-open-flags.c48 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 Dbenchmark-spawn.c78 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 Dtest-osx-select.c33 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 Dtest-udp-multicast-ttl.c59 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 Dtest-udp-multicast-interface.c64 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 Dtest-udp-multicast-interface6.c64 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 Dtest-fs.c430 memset(buf, 0, sizeof(buf)); in open_cb()
431 iov = uv_buf_init(buf, sizeof(buf)); in open_cb()
1040 memset(buf, 0, sizeof(buf)); in fs_file_sync()
1380 memset(buf, 0, sizeof(buf)); in TEST_IMPL()
2024 memset(buf, 0, sizeof(buf)); in TEST_IMPL()
2045 memset(buf, 0, sizeof(buf)); in TEST_IMPL()
2214 memset(buf, 0, sizeof(buf)); in TEST_IMPL()
2267 memset(buf, 0, sizeof(buf)); in TEST_IMPL()
3162 memset(buf, 0, sizeof(buf)); in TEST_IMPL()
3277 memset(buf, 0, sizeof(buf)); in fs_read_file_eof()
[all …]
H A Dtest-udp-send-hang-loop.c35 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/unix/
H A Dstream.c149 char buf[1024]; in uv__stream_osx_select() local
196 r = read(s->int_fd, buf, sizeof(buf)); in uv__stream_osx_select()
198 if (r == 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 buf->base += len; in uv__write_req_update()
702 buf->len -= len; in uv__write_req_update()
703 buf += (buf->len == 0); /* Advance to next buffer if this one is empty. */ in uv__write_req_update()
1025 uv_buf_t buf; in uv__read() local
1052 if (buf.base == NULL || buf.len == 0) { in uv__read()
[all …]
H A Drandom-getentropy.c39 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 Dgetaddrinfo.c149 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 Dinternal.h283 int uv__slurp(const char* filename, char* buf, size_t len);
322 int uv__search_path(const char* prog, char* buf, size_t* buflen);
326 int uv__random_devurandom(void* buf, size_t buflen);
327 int uv__random_getrandom(void* buf, size_t buflen);
328 int uv__random_getentropy(void* buf, size_t buflen);
329 int uv__random_readpath(const char* path, void* buf, size_t buflen);
330 int uv__random_sysctl(void* buf, size_t buflen);
441 void uv__statx_to_stat(const struct uv__statx* statxbuf, uv_stat_t* buf);
442 ssize_t uv__getrandom(void* buf, size_t buflen, unsigned flags);
/libuv/src/
H A Duv-common.c191 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 …]

Completed in 87 milliseconds

123456