Home
last modified time | relevance | path

Searched refs:uv_pipe_t (Results 1 - 25 of 69) sorted by relevance

123

/third_party/node/deps/uv/src/win/
H A Dpipe.c93 static void eof_timer_init(uv_pipe_t* pipe);
94 static void eof_timer_start(uv_pipe_t* pipe);
95 static void eof_timer_stop(uv_pipe_t* pipe);
97 static void eof_timer_destroy(uv_pipe_t* pipe);
106 int uv_pipe_init(uv_loop_t* loop, uv_pipe_t* handle, int ipc) { in uv_pipe_init()
123 static void uv__pipe_connection_init(uv_pipe_t* handle) { in uv__pipe_connection_init()
189 static void close_pipe(uv_pipe_t* pipe) { in close_pipe()
382 uv_pipe_t* parent_pipe, HANDLE* child_pipe_ptr, unsigned int flags) { in uv__create_stdio_pipe_pair()
451 uv_pipe_t* handle, in uv__set_pipe_handle()
528 static int pipe_alloc_accept(uv_loop_t* loop, uv_pipe_t* handl
[all...]
H A Dinternal.h122 uv_pipe_t* parent_pipe, HANDLE* child_pipe_ptr, unsigned int flags);
124 int uv__pipe_listen(uv_pipe_t* handle, int backlog, uv_connection_cb cb);
125 int uv__pipe_accept(uv_pipe_t* server, uv_stream_t* client);
126 int uv__pipe_read_start(uv_pipe_t* handle, uv_alloc_cb alloc_cb,
128 void uv__pipe_read_stop(uv_pipe_t* handle);
131 uv_pipe_t* handle,
136 void uv__pipe_shutdown(uv_loop_t* loop, uv_pipe_t* handle, uv_shutdown_t* req);
138 void uv__process_pipe_read_req(uv_loop_t* loop, uv_pipe_t* handle,
140 void uv__process_pipe_write_req(uv_loop_t* loop, uv_pipe_t* handle,
142 void uv__process_pipe_accept_req(uv_loop_t* loop, uv_pipe_t* handl
[all...]
H A Dstream.c41 err = uv__pipe_listen((uv_pipe_t*)stream, backlog, cb); in uv_listen()
60 err = uv__pipe_accept((uv_pipe_t*)server, client); in uv_accept()
81 err = uv__pipe_read_start((uv_pipe_t*)handle, alloc_cb, read_cb); in uv__read_start()
104 uv__pipe_read_stop((uv_pipe_t*) handle); in uv_read_stop()
133 loop, req, (uv_pipe_t*) handle, bufs, nbufs, NULL, cb); in uv_write()
159 if (handle->type != UV_NAMED_PIPE || !((uv_pipe_t*) handle)->ipc) { in uv_write2()
166 loop, req, (uv_pipe_t*) handle, bufs, nbufs, send_handle, cb); in uv_write2()
224 uv__pipe_shutdown(loop, (uv_pipe_t*) handle, req); in uv_shutdown()
/third_party/libuv/src/win/
H A Dinternal.h124 uv_pipe_t* parent_pipe, HANDLE* child_pipe_ptr, unsigned int flags);
126 int uv__pipe_listen(uv_pipe_t* handle, int backlog, uv_connection_cb cb);
127 int uv__pipe_accept(uv_pipe_t* server, uv_stream_t* client);
128 int uv__pipe_read_start(uv_pipe_t* handle, uv_alloc_cb alloc_cb,
130 void uv__pipe_read_stop(uv_pipe_t* handle);
133 uv_pipe_t* handle,
138 void uv__pipe_shutdown(uv_loop_t* loop, uv_pipe_t* handle, uv_shutdown_t* req);
140 void uv__process_pipe_read_req(uv_loop_t* loop, uv_pipe_t* handle,
142 void uv__process_pipe_write_req(uv_loop_t* loop, uv_pipe_t* handle,
144 void uv__process_pipe_accept_req(uv_loop_t* loop, uv_pipe_t* handl
[all...]
H A Dpipe.c93 static void eof_timer_init(uv_pipe_t* pipe);
94 static void eof_timer_start(uv_pipe_t* pipe);
95 static void eof_timer_stop(uv_pipe_t* pipe);
97 static void eof_timer_destroy(uv_pipe_t* pipe);
114 int uv_pipe_init(uv_loop_t* loop, uv_pipe_t* handle, int ipc) { in uv_pipe_init()
131 static void uv__pipe_connection_init(uv_pipe_t* handle) { in uv__pipe_connection_init()
197 static void close_pipe(uv_pipe_t* pipe) { in close_pipe()
390 uv_pipe_t* parent_pipe, HANDLE* child_pipe_ptr, unsigned int flags) { in uv__create_stdio_pipe_pair()
459 uv_pipe_t* handle, in uv__set_pipe_handle()
536 static int pipe_alloc_accept(uv_loop_t* loop, uv_pipe_t* handl
[all...]
H A Dstream.c41 err = uv__pipe_listen((uv_pipe_t*)stream, backlog, cb); in uv_listen()
60 err = uv__pipe_accept((uv_pipe_t*)server, client); in uv_accept()
81 err = uv__pipe_read_start((uv_pipe_t*)handle, alloc_cb, read_cb); in uv__read_start()
104 uv__pipe_read_stop((uv_pipe_t*) handle); in uv_read_stop()
133 loop, req, (uv_pipe_t*) handle, bufs, nbufs, NULL, cb); in uv_write()
159 if (handle->type != UV_NAMED_PIPE || !((uv_pipe_t*) handle)->ipc) { in uv_write2()
166 loop, req, (uv_pipe_t*) handle, bufs, nbufs, send_handle, cb); in uv_write2()
223 uv__pipe_shutdown(loop, (uv_pipe_t*) handle, req); in uv_shutdown()
/third_party/node/deps/uv/src/unix/
H A Dpipe.c34 int uv_pipe_init(uv_loop_t* loop, uv_pipe_t* handle, int ipc) { in uv_pipe_init()
44 int uv_pipe_bind(uv_pipe_t* handle, const char* name) { in uv_pipe_bind()
112 int uv__pipe_listen(uv_pipe_t* handle, int backlog, uv_connection_cb cb) { in uv__pipe_listen()
138 void uv__pipe_close(uv_pipe_t* handle) { in uv__pipe_close()
155 int uv_pipe_open(uv_pipe_t* handle, uv_file fd) { in uv_pipe_open()
192 uv_pipe_t* handle, in uv_pipe_connect()
258 static int uv__pipe_getsockpeername(const uv_pipe_t* handle, in uv__pipe_getsockpeername()
302 int uv_pipe_getsockname(const uv_pipe_t* handle, char* buffer, size_t* size) { in uv_pipe_getsockname()
307 int uv_pipe_getpeername(const uv_pipe_t* handle, char* buffer, size_t* size) { in uv_pipe_getpeername()
312 void uv_pipe_pending_instances(uv_pipe_t* handl
[all...]
/third_party/libuv/src/unix/
H A Dpipe.c46 int uv_pipe_init(uv_loop_t* loop, uv_pipe_t* handle, int ipc) { in uv_pipe_init()
56 int uv_pipe_bind(uv_pipe_t* handle, const char* name) { in uv_pipe_bind()
61 int uv_pipe_bind2(uv_pipe_t* handle, in uv_pipe_bind2()
146 int uv__pipe_listen(uv_pipe_t* handle, int backlog, uv_connection_cb cb) { in uv__pipe_listen()
172 void uv__pipe_close(uv_pipe_t* handle) { in uv__pipe_close()
189 int uv_pipe_open(uv_pipe_t* handle, uv_file fd) { in uv_pipe_open()
226 uv_pipe_t* handle, in uv_pipe_connect()
249 uv_pipe_t* handle, in uv_pipe_connect2()
343 static int uv__pipe_getsockpeername(const uv_pipe_t* handle, in uv__pipe_getsockpeername()
387 int uv_pipe_getsockname(const uv_pipe_t* handl
[all...]
/third_party/libuv/test/
H A Dtest-ipc-send-recv.c29 void spawn_helper(uv_pipe_t* channel,
38 uv_pipe_t pipe;
44 uv_pipe_t channel;
56 uv_pipe_t listen;
57 uv_pipe_t channel;
92 uv_pipe_t* pipe; in recv_cb()
98 pipe = (uv_pipe_t*) handle; in recv_cb()
305 uv_pipe_t* pipe; in read_cb()
319 pipe = (uv_pipe_t*) handle; in read_cb()
H A Dtest-pipe-bind-error.c46 uv_pipe_t server1, server2; in TEST_IMPL()
77 uv_pipe_t server; in TEST_IMPL()
98 uv_pipe_t server; in TEST_IMPL()
123 uv_pipe_t server; in TEST_IMPL()
143 uv_pipe_t server; in TEST_IMPL()
167 uv_pipe_t pipe; in TEST_IMPL()
H A Dtest-pipe-connect-multiple.c35 uv_pipe_t pipe_handle;
39 static uv_pipe_t server_handle;
41 static uv_pipe_t connections[NUM_CLIENTS];
46 uv_pipe_t* conn; in connection_cb()
112 uv_pipe_t* conn; in connection_cb2()
H A Dtest-pipe-sendmsg.c38 static uv_pipe_t incoming[4];
76 uv_pipe_t* p; in read_cb()
77 uv_pipe_t* inc; in read_cb()
81 p = (uv_pipe_t*) handle; in read_cb()
108 uv_pipe_t p; in TEST_IMPL()
H A Dtest-pipe-close-stdout-read-stdin.c61 uv_pipe_t stdin_pipe; in TEST_IMPL()
86 r = uv_pipe_init(uv_default_loop(), (uv_pipe_t *)&stdin_pipe, 0); in TEST_IMPL()
89 r = uv_pipe_open((uv_pipe_t *)&stdin_pipe, 0); in TEST_IMPL()
H A Dtest-stdio-over-pipes.c37 static uv_pipe_t in;
38 static uv_pipe_t out;
176 static uv_pipe_t stdin_pipe1;
177 static uv_pipe_t stdout_pipe1;
178 static uv_pipe_t stdin_pipe2;
179 static uv_pipe_t stdout_pipe2;
H A Dbenchmark-multi-accept.c29 uv_pipe_t pipe;
51 uv_pipe_t ipc_pipe;
62 uv_pipe_t ipc_pipe;
122 ASSERT_OK(uv_pipe_init(loop, (uv_pipe_t*) &pc->peer_handle, 1)); in ipc_connection_cb()
179 uv_pipe_t* ipc_pipe; in ipc_read_cb()
181 ipc_pipe = (uv_pipe_t*) handle; in ipc_read_cb()
190 ASSERT_OK(uv_pipe_init(loop, (uv_pipe_t*) ctx->server_handle, 0)); in ipc_read_cb()
303 ASSERT_OK(uv_pipe_init(server_handle->loop, (uv_pipe_t*) storage, 0)); in sv_connection_cb()
H A Dtest-ipc-heavy-traffic-deadlock-bug.c28 void spawn_helper(uv_pipe_t* channel,
134 uv_pipe_t pipe; in TEST_IMPL()
145 uv_pipe_t pipe; in ipc_helper_heavy_traffic_deadlock_bug()
H A Dbenchmark-pump.c50 static uv_pipe_t pipeServer;
77 static uv_pipe_t pipe_write_handles[MAX_WRITE_HANDLES];
247 uv_pipe_t* pipe; in maybe_connect_some()
289 stream = (uv_stream_t*)malloc(sizeof(uv_pipe_t)); in connection_cb()
290 r = uv_pipe_init(loop, (uv_pipe_t*)stream, 0); in connection_cb()
H A Dtest-pipe-server-close.c29 static uv_pipe_t pipe_client;
30 static uv_pipe_t pipe_server;
H A Dtest-pipe-connect-error.c62 uv_pipe_t client; in TEST_IMPL()
82 uv_pipe_t client; in TEST_IMPL()
H A Dtest-ipc.c28 static uv_pipe_t channel;
147 uv_pipe_t* pipe; in on_read()
151 pipe = (uv_pipe_t*) handle; in on_read()
217 uv_pipe_t* pipe; in on_read_listen_after_bound_twice()
220 pipe = (uv_pipe_t*) handle; in on_read_listen_after_bound_twice()
280 void spawn_helper(uv_pipe_t* channel, in spawn_helper()
355 uv_pipe_t* pipe; in on_read_connection()
358 pipe = (uv_pipe_t*) handle; in on_read_connection()
H A Dtest-spawn.c285 uv_pipe_t out; in TEST_IMPL()
585 uv_pipe_t out; in TEST_IMPL()
586 uv_pipe_t in; in TEST_IMPL()
628 uv_pipe_t pipe; in TEST_IMPL()
788 uv_pipe_t out; in TEST_IMPL()
857 uv_pipe_t in, out, err; in TEST_IMPL()
916 uv_pipe_t in, out; in TEST_IMPL()
963 uv_pipe_t in, out; in TEST_IMPL()
1009 uv_pipe_t in; in TEST_IMPL()
1097 uv_pipe_t ou in TEST_IMPL()
[all...]
/third_party/libuv/docs/code/pipe-echo-server/
H A Dmain.c60 uv_pipe_t *client = (uv_pipe_t*) malloc(sizeof(uv_pipe_t)); in on_new_connection()
79 uv_pipe_t server; in main()
/third_party/libuv/docs/code/multi-echo-server/
H A Dworker.c9 uv_pipe_t queue;
59 uv_pipe_t *pipe = (uv_pipe_t*) q; in on_new_connection()
/third_party/libuv/docs/code/uvtee/
H A Dmain.c14 uv_pipe_t stdin_pipe;
15 uv_pipe_t stdout_pipe;
16 uv_pipe_t file_pipe;
/third_party/node/src/
H A Dconnection_wrap.cc119 template ConnectionWrap<PipeWrap, uv_pipe_t>::ConnectionWrap(
129 template void ConnectionWrap<PipeWrap, uv_pipe_t>::OnConnection(
135 template void ConnectionWrap<PipeWrap, uv_pipe_t>::AfterConnect(

Completed in 14 milliseconds

123