Lines Matching refs:buf
102 uv_buf_t* buf) { in on_alloc() argument
103 buf->base = malloc(suggested_size); in on_alloc()
104 buf->len = suggested_size; in on_alloc()
145 const uv_buf_t* buf) { in on_read() argument
155 free(buf->base); in on_read()
161 free(buf->base); in on_read()
175 ASSERT_NOT_NULL(buf->base); in on_read()
193 ASSERT_MEM_EQ("hello\n", buf->base, nread); in on_read()
201 } else if (memcmp("accepted_connection\n", buf->base, nread) == 0) { in on_read()
209 free(buf->base); in on_read()
215 const uv_buf_t* buf) { in on_read_listen_after_bound_twice() argument
224 free(buf->base); in on_read_listen_after_bound_twice()
230 free(buf->base); in on_read_listen_after_bound_twice()
243 ASSERT_NOT_NULL(buf->base); in on_read_listen_after_bound_twice()
276 free(buf->base); in on_read_listen_after_bound_twice()
331 uv_buf_t* buf) { in on_read_alloc() argument
332 buf->base = malloc(suggested_size); in on_read_alloc()
333 buf->len = suggested_size; in on_read_alloc()
337 static void on_tcp_read(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in on_tcp_read() argument
339 ASSERT_MEM_EQ("hello again\n", buf->base, nread); in on_tcp_read()
341 free(buf->base); in on_tcp_read()
352 const uv_buf_t* buf) { in on_read_connection() argument
361 free(buf->base); in on_read_connection()
367 free(buf->base); in on_read_connection()
381 ASSERT_NOT_NULL(buf->base); in on_read_connection()
394 ASSERT_MEM_EQ("hello\n", buf->base, nread); in on_read_connection()
405 free(buf->base); in on_read_connection()
411 const uv_buf_t* buf) { in on_read_send_zero() argument
413 free(buf->base); in on_read_send_zero()
572 const uv_buf_t* buf) { in on_tcp_child_process_read() argument
578 free(buf->base); in on_tcp_child_process_read()
587 ASSERT_MEM_EQ("world\n", buf->base, nread); in on_tcp_child_process_read()
589 free(buf->base); in on_tcp_child_process_read()
611 uv_buf_t buf; in ipc_on_connection() local
629 buf = uv_buf_init("accepted_connection\n", 20); in ipc_on_connection()
630 r = uv_write2(&conn_notify_req, (uv_stream_t*)&channel, &buf, 1, in ipc_on_connection()
646 uv_buf_t buf; in ipc_on_connection_tcp_conn() local
662 buf = uv_buf_init("hello\n", 6); in ipc_on_connection_tcp_conn()
663 r = uv_write2(&conn_notify_req, (uv_stream_t*)&channel, &buf, 1, in ipc_on_connection_tcp_conn()
683 uv_buf_t buf; in ipc_helper() local
707 buf = uv_buf_init("hello\n", 6); in ipc_helper()
708 r = uv_write2(&write_req, (uv_stream_t*)&channel, &buf, 1, in ipc_helper()
788 uv_buf_t buf; in ipc_helper_bind_twice() local
801 buf = uv_buf_init("hello\n", 6); in ipc_helper_bind_twice()
813 r = uv_write2(&write_req, (uv_stream_t*)&channel, &buf, 1, in ipc_helper_bind_twice()
816 r = uv_write2(&write_req2, (uv_stream_t*)&channel, &buf, 1, in ipc_helper_bind_twice()
