/libuv/test/ |
H A D | test-pipe-set-non-blocking.c | 33 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 D | test-udp-recv-in-a-row.c | 32 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 D | test-tcp-write-in-a-row.c | 62 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 D | test-udp-try-send.c | 42 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 D | test-tcp-open.c | 90 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 D | test-tcp-close-after-read-timeout.c | 38 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 D | test-udp-send-immediate.c | 42 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 D | test-watcher-cross-stop.c | 42 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 D | test-shutdown-eof.c | 42 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 D | test-pipe-close-stdout-read-stdin.c | 36 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 D | test-tcp-alloc-cb-fail.c | 48 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 D | test-udp-ipv6.c | 67 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 D | test-udp-multicast-join.c | 47 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 D | test-tcp-shutdown-after-write.c | 54 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 D | test-udp-alloc-cb-fail.c | 46 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 D | test-udp-mmsg.c | 47 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 D | test-stdio-over-pipes.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() 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 D | test-udp-multicast-join6.c | 58 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 D | test-udp-send-and-recv.c | 46 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 D | test-signal-pending-on-close.c | 33 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 D | hurd.c | 111 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 D | core.c | 1082 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 D | main.c | 11 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 D | main.c | 8 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 D | main.c | 12 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()
|