• Home
  • Raw
  • Download

Lines Matching refs:uv_stream_t

129 static void on_read(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) {  in on_read()
139 static void on_read_once(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in on_read_once()
291 options.stdio[1].data.stream = (uv_stream_t*) &out; in TEST_IMPL()
297 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
595 options.stdio[0].data.stream = (uv_stream_t*) ∈ in TEST_IMPL()
597 options.stdio[1].data.stream = (uv_stream_t*) &out; in TEST_IMPL()
605 r = uv_write(&write_req, (uv_stream_t*) &in, &buf, 1, write_cb); in TEST_IMPL()
608 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
636 options.stdio[3].data.stream = (uv_stream_t*) &pipe; in TEST_IMPL()
642 r = uv_read_start((uv_stream_t*) &pipe, on_alloc, on_read); in TEST_IMPL()
677 r = uv_listen((uv_stream_t*) &tcp, SOMAXCONN, NULL); in spawn_tcp_server_helper()
794 options.stdio[1].data.stream = (uv_stream_t*) &out; in TEST_IMPL()
806 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
874 options.stdio[0].data.stream = (uv_stream_t*) ∈ in TEST_IMPL()
876 options.stdio[1].data.stream = (uv_stream_t*) &out; in TEST_IMPL()
878 options.stdio[2].data.stream = (uv_stream_t*) &err; in TEST_IMPL()
885 r = uv_write(&write, (uv_stream_t*) &in, &buf, 1, write_cb); in TEST_IMPL()
888 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
891 r = uv_read_start((uv_stream_t*) &err, on_alloc, on_read); in TEST_IMPL()
925 options.stdio[0].data.stream = (uv_stream_t*) ∈ in TEST_IMPL()
927 options.stdio[1].data.stream = (uv_stream_t*) &out; in TEST_IMPL()
939 r = uv_write(&write_req, (uv_stream_t*) &in, &buf, 1, write_cb); in TEST_IMPL()
942 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
972 options.stdio[0].data.stream = (uv_stream_t*) ∈ in TEST_IMPL()
974 options.stdio[1].data.stream = (uv_stream_t*) &out; in TEST_IMPL()
986 r = uv_write(&write_req, (uv_stream_t*) &in, &buf, 1, write_cb); in TEST_IMPL()
989 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
1017 options.stdio[0].data.stream = (uv_stream_t*) ∈ in TEST_IMPL()
1025 ASSERT(0 == uv_write(&write_req, (uv_stream_t*) &in, &buf, 1, write_cb)); in TEST_IMPL()
1105 options.stdio[1].data.stream = (uv_stream_t*) &out; in TEST_IMPL()
1127 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
1532 options.stdio[0].data.stream = (uv_stream_t*) ∈ in TEST_IMPL()
1550 ASSERT(0 == uv_write(&write_req, (uv_stream_t*) &in, &buf, 1, write_null_cb)); in TEST_IMPL()
1553 ASSERT(0 == uv_write(&write_req2, (uv_stream_t*) &in, &buf, 1, write_cb)); in TEST_IMPL()
1597 ASSERT(0 == uv_read_start((uv_stream_t*) &pipe_handle, on_alloc, on_read_once)); in TEST_IMPL()
1739 ASSERT(uv_is_readable((uv_stream_t*) &pipe_stdin_child)); in TEST_IMPL()
1740 ASSERT(uv_is_writable((uv_stream_t*) &pipe_stdout_child)); in TEST_IMPL()
1741 ASSERT(uv_is_writable((uv_stream_t*) &pipe_stdin_parent)); in TEST_IMPL()
1742 ASSERT(uv_is_readable((uv_stream_t*) &pipe_stdout_parent)); in TEST_IMPL()
1744 bidir = uv_is_writable((uv_stream_t*) &pipe_stdin_child); in TEST_IMPL()
1745 ASSERT(uv_is_readable((uv_stream_t*) &pipe_stdout_child) == bidir); in TEST_IMPL()
1746 ASSERT(uv_is_readable((uv_stream_t*) &pipe_stdin_parent) == bidir); in TEST_IMPL()
1747 ASSERT(uv_is_writable((uv_stream_t*) &pipe_stdout_parent) == bidir); in TEST_IMPL()
1750 child_stdio[0].data.stream = (uv_stream_t *) &pipe_stdin_child; in TEST_IMPL()
1753 child_stdio[1].data.stream = (uv_stream_t *) &pipe_stdout_child; in TEST_IMPL()
1769 (uv_stream_t*) &pipe_stdin_parent, in TEST_IMPL()
1775 r = uv_read_start((uv_stream_t*) &pipe_stdout_parent, on_alloc, on_read); in TEST_IMPL()