Home
last modified time | relevance | path

Searched refs:buf (Results 26 – 50 of 149) sorted by relevance

123456

/libuv/test/
H A Dtest-pipe-set-non-blocking.c33 char buf[4096]; in thread_main() local
37 bufs[0] = uv_buf_init(buf, sizeof(buf)); in thread_main()
73 uv_buf_t buf; in TEST_IMPL() local
91 buf.len = sizeof(data); in TEST_IMPL()
92 buf.base = data; in TEST_IMPL()
100 n = uv_try_write((uv_stream_t*) &pipe_handle, &buf, 1); in TEST_IMPL()
105 &buf, in TEST_IMPL()
111 n = buf.len; in TEST_IMPL()
H A Dtest-udp-recv-in-a-row.c32 static uv_buf_t buf; variable
42 uv_buf_t* buf) { in alloc_cb() argument
44 buf->base = slab; in alloc_cb()
45 buf->len = sizeof(slab); in alloc_cb()
94 buf = uv_buf_init(send_data, sizeof(send_data)); in TEST_IMPL()
97 &buf, in TEST_IMPL()
104 buf = uv_buf_init(NULL, 0); in TEST_IMPL()
106 &buf, in TEST_IMPL()
H A Dtest-tcp-write-in-a-row.c62 uv_buf_t buf; in connect_cb() local
69 buf = uv_buf_init(data, sizeof(data)); in connect_cb()
70 r = uv_write(&small_write, (uv_stream_t*) &client, &buf, 1, write_cb); in connect_cb()
78 buf = uv_buf_init("A", 1); in connect_cb()
79 r = uv_write(&big_write, (uv_stream_t*) &client, &buf, 1, write_cb); in connect_cb()
86 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_cb() argument
89 buf->base = base; in alloc_cb()
90 buf->len = sizeof(base); in alloc_cb()
93 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) {} in read_cb() argument
H A Dtest-udp-try-send.c42 uv_buf_t* buf) { in alloc_cb() argument
46 buf->base = slab; in alloc_cb()
47 buf->len = sizeof(slab); in alloc_cb()
84 uv_buf_t buf; in TEST_IMPL() local
103 buf = uv_buf_init(buffer, sizeof(buffer)); in TEST_IMPL()
104 r = uv_udp_try_send(&client, &buf, 1, (const struct sockaddr*) &addr); in TEST_IMPL()
107 buf = uv_buf_init("EXIT", 4); in TEST_IMPL()
108 r = uv_udp_try_send(&client, &buf, 1, (const struct sockaddr*) &addr); in TEST_IMPL()
H A Dtest-tcp-open.c90 uv_buf_t* buf) { in alloc_cb() argument
93 buf->base = slab; in alloc_cb()
94 buf->len = sizeof(slab); in alloc_cb()
133 ASSERT_EQ(buf->base[i], 'P'); in read1_cb()
155 uv_buf_t buf; in write1_cb() local
167 buf = uv_buf_init("P", 1); in write1_cb()
186 uv_buf_t buf = uv_buf_init("PING", 4); in connect_cb() local
210 uv_buf_t buf; in connect1_cb() local
226 buf = uv_buf_init("P", 1); in connect1_cb()
339 uv_buf_t buf = uv_buf_init("PING", 4); in TEST_IMPL() local
[all …]
H A Dtest-tcp-close-after-read-timeout.c38 uv_buf_t* buf);
41 const uv_buf_t* buf);
60 uv_buf_t* buf) { in on_client_alloc() argument
62 buf->base = slab; in on_client_alloc()
63 buf->len = sizeof(slab); in on_client_alloc()
68 const uv_buf_t* buf) { in on_client_read() argument
85 uv_buf_t* buf) { in on_connection_alloc() argument
87 buf->base = slab; in on_connection_alloc()
88 buf->len = sizeof(slab); in on_connection_alloc()
94 const uv_buf_t* buf) { in on_connection_read() argument
H A Dtest-udp-send-immediate.c42 uv_buf_t* buf) { in alloc_cb() argument
46 buf->base = slab; in alloc_cb()
47 buf->len = sizeof(slab); in alloc_cb()
100 uv_buf_t buf; in TEST_IMPL() local
120 buf = uv_buf_init("PING", 4); in TEST_IMPL()
124 &buf, in TEST_IMPL()
130 buf = uv_buf_init("PANG", 4); in TEST_IMPL()
134 &buf, in TEST_IMPL()
H A Dtest-watcher-cross-stop.c42 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_cb() argument
43 buf->base = slab; in alloc_cb()
44 buf->len = sizeof(slab); in alloc_cb()
50 const uv_buf_t* buf, in recv_cb() argument
74 uv_buf_t buf; in TEST_IMPL() local
81 buf = uv_buf_init(big_string, sizeof(big_string)); in TEST_IMPL()
91 &buf, in TEST_IMPL()
H A Dtest-shutdown-eof.c42 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_cb() argument
43 buf->base = malloc(size); in alloc_cb()
44 buf->len = size; in alloc_cb()
48 static void read_cb(uv_stream_t* t, ssize_t nread, const uv_buf_t* buf) { in read_cb() argument
52 free(buf->base); in read_cb()
59 ASSERT_EQ(buf->base[0], 'Q'); in read_cb()
60 free(buf->base); in read_cb()
65 if (buf->base) { in read_cb()
66 free(buf->base); in read_cb()
H A Dtest-pipe-close-stdout-read-stdin.c36 void alloc_buffer(uv_handle_t *handle, size_t suggested_size, uv_buf_t* buf) in alloc_buffer() argument
40 buf->base = buffer; in alloc_buffer()
41 buf->len = sizeof(buffer); in alloc_buffer()
44 void read_stdin(uv_stream_t *stream, ssize_t nread, const uv_buf_t* buf) in read_stdin() argument
60 char buf; in TEST_IMPL() local
79 r = read(fd[0], &buf, 1); in TEST_IMPL()
H A Dtest-tcp-alloc-cb-fail.c48 static void conn_alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in conn_alloc_cb() argument
54 const uv_buf_t* buf) { in conn_read_cb() argument
56 ASSERT_NULL(buf->base); in conn_read_cb()
57 ASSERT_OK(buf->len); in conn_read_cb()
66 uv_buf_t buf; in connect_cb() local
71 buf = uv_buf_init(hello, sizeof(hello)); in connect_cb()
72 r = uv_write(&write_req, req->handle, &buf, 1, write_cb); in connect_cb()
H A Dtest-udp-ipv6.c67 uv_buf_t* buf) { in alloc_cb() argument
70 buf->base = slab; in alloc_cb()
71 buf->len = sizeof(slab); in alloc_cb()
111 const uv_buf_t* buf, in ipv6_recv_fail() argument
114 printf("got %d %.*s\n", (int) nread, nread > 0 ? (int) nread : 0, buf->base); in ipv6_recv_fail()
123 const uv_buf_t* buf, in ipv6_recv_ok() argument
128 printf("got %d %.*s\n", (int) nread, nread > 0 ? (int) nread : 0, buf->base); in ipv6_recv_ok()
133 ASSERT(!memcmp(buf->base, data, 9)); in ipv6_recv_ok()
150 uv_buf_t buf; in do_test() local
187 buf = uv_buf_init(data, 9); in do_test()
[all …]
H A Dtest-udp-multicast-join.c47 uv_buf_t* buf) { in alloc_cb() argument
51 buf->base = slab; in alloc_cb()
52 buf->len = sizeof(slab); in alloc_cb()
75 uv_buf_t buf; in do_send() local
78 buf = uv_buf_init("PING", 4); in do_send()
85 &buf, in do_send()
94 const uv_buf_t* buf, in cl_recv_cb() argument
112 ASSERT(!memcmp("PING", buf->base, nread)); in cl_recv_cb()
H A Dtest-tcp-shutdown-after-write.c54 uv_buf_t* buf) { in alloc_cb() argument
56 buf->base = slab; in alloc_cb()
57 buf->len = sizeof(slab); in alloc_cb()
62 uv_buf_t buf; in timer_cb() local
67 buf = uv_buf_init("TEST", 4); in timer_cb()
68 r = uv_write(&write_req, (uv_stream_t*)&conn, &buf, 1, write_cb); in timer_cb()
76 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) { in read_cb() argument
H A Dtest-udp-alloc-cb-fail.c46 uv_buf_t* buf) { in sv_alloc_cb() argument
49 buf->base = slab; in sv_alloc_cb()
50 buf->len = sizeof(slab); in sv_alloc_cb()
56 uv_buf_t* buf) { in cl_alloc_cb() argument
70 const uv_buf_t* buf, in cl_recv_cb() argument
152 uv_buf_t buf; in TEST_IMPL() local
171 buf = uv_buf_init("PING", 4); in TEST_IMPL()
174 &buf, in TEST_IMPL()
H A Dtest-udp-mmsg.c47 uv_buf_t* buf) { in alloc_cb() argument
57 buf->base = malloc(buffer_size); in alloc_cb()
58 ASSERT_NOT_NULL(buf->base); in alloc_cb()
59 buf->len = buffer_size; in alloc_cb()
110 uv_buf_t buf; in TEST_IMPL() local
126 buf = uv_buf_init("PING", 4); in TEST_IMPL()
128 ASSERT_EQ(4, uv_udp_try_send(&sender, &buf, 1, (const struct sockaddr*) &addr)); in TEST_IMPL()
H A Dtest-stdio-over-pipes.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()
183 ASSERT_OK(memcmp("hello world\n", buf->base, nread)); in on_pipe_read()
186 free(buf->base); in on_pipe_read()
200 uv_buf_t* buf) { in on_read_alloc() argument
201 buf->base = malloc(suggested_size); in on_read_alloc()
202 buf->len = suggested_size; in on_read_alloc()
219 uv_buf_t buf[ARRAY_SIZE(buffers)]; in stdio_over_pipes_helper() local
250 buf[i] = uv_buf_init((char*) buffers[i], strlen(buffers[i])); in stdio_over_pipes_helper()
[all …]
H A Dtest-udp-multicast-join6.c58 uv_buf_t* buf) { in alloc_cb() argument
62 buf->base = slab; in alloc_cb()
63 buf->len = sizeof(slab); in alloc_cb()
86 uv_buf_t buf; in do_send() local
89 buf = uv_buf_init("PING", 4); in do_send()
96 &buf, in do_send()
105 const uv_buf_t* buf, in cl_recv_cb() argument
123 ASSERT(!memcmp("PING", buf->base, nread)); in cl_recv_cb()
H A Dtest-udp-send-and-recv.c46 uv_buf_t* buf) { in alloc_cb() argument
50 buf->base = slab; in alloc_cb()
51 buf->len = sizeof(slab); in alloc_cb()
64 const uv_buf_t* buf, in cl_recv_cb() argument
82 ASSERT(!memcmp("PONG", buf->base, nread)); in cl_recv_cb()
163 uv_buf_t buf; in TEST_IMPL() local
183 buf = uv_buf_init("PING", 4); in TEST_IMPL()
187 &buf, in TEST_IMPL()
H A Dtest-signal-pending-on-close.c33 static char* buf; variable
54 free(buf); in write_cb()
78 buf = malloc(1<<24); in TEST_IMPL()
79 ASSERT_NOT_NULL(buf); in TEST_IMPL()
80 memset(buf, '.', 1<<24); in TEST_IMPL()
81 buffer = uv_buf_init(buf, 1<<24); in TEST_IMPL()
/libuv/src/unix/
H A Dhurd.c111 char buf[128]; in uv_uptime() local
114 if (0 == uv__slurp("/proc/uptime", buf, sizeof(buf))) in uv_uptime()
115 if (1 == sscanf(buf, "%lf", uptime)) in uv_uptime()
124 char buf[128]; /* Large enough to hold all of /proc/loadavg. */ in uv_loadavg() local
126 if (0 == uv__slurp("/proc/loadavg", buf, sizeof(buf))) in uv_loadavg()
127 if (3 == sscanf(buf, "%lf %lf %lf", &avg[0], &avg[1], &avg[2])) in uv_loadavg()
H A Dcore.c1082 buf[n] = '\0'; in uv__slurp()
1153 const char* buf; in uv_os_tmpdir() local
1179 buf = "/tmp"; in uv_os_tmpdir()
1206 char* buf; in uv__getpwuid_r() local
1249 uv__free(buf); in uv__getpwuid_r()
1268 uv__free(buf); in uv__getpwuid_r()
1281 char* buf; in uv_os_get_group()
1329 uv__free(buf); in uv_os_get_group()
1352 uv__free(buf); in uv_os_get_group()
1390 char* buf; in uv_os_environ() local
[all …]
/libuv/docs/code/tty/
H A Dmain.c11 uv_buf_t buf; in main() local
25 buf.base = "Hello TTY\n"; in main()
26 buf.len = strlen(buf.base); in main()
27 uv_write(&req, (uv_stream_t*) &tty, &buf, 1, NULL); in main()
/libuv/docs/code/dns/
H A Dmain.c8 void alloc_buffer(uv_handle_t *handle, size_t suggested_size, uv_buf_t *buf) { in alloc_buffer() argument
9 buf->base = malloc(suggested_size); in alloc_buffer()
10 buf->len = suggested_size; in alloc_buffer()
13 void on_read(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf) { in on_read() argument
18 free(buf->base); in on_read()
25 strncpy(data, buf->base, nread); in on_read()
29 free(buf->base); in on_read()
/libuv/docs/code/udp-dhcp/
H A Dmain.c12 void alloc_buffer(uv_handle_t *handle, size_t suggested_size, uv_buf_t *buf) { in alloc_buffer() argument
13 buf->base = malloc(suggested_size); in alloc_buffer()
14 buf->len = suggested_size; in alloc_buffer()
17 void on_read(uv_udp_t *req, ssize_t nread, const uv_buf_t *buf, const struct sockaddr *addr, unsign… in on_read() argument
21 free(buf->base); in on_read()
30 unsigned int *as_integer = (unsigned int*)buf->base; in on_read()
38 free(buf->base); in on_read()

Completed in 47 milliseconds

123456