Lines Matching defs:handle
46 int uv_pipe_init(uv_loop_t* loop, uv_pipe_t* handle, int ipc) {
47 uv__stream_init(loop, (uv_stream_t*)handle, UV_NAMED_PIPE);
48 handle->shutdown_req = NULL;
49 handle->connect_req = NULL;
50 handle->pipe_fname = NULL;
51 handle->ipc = ipc;
56 int uv_pipe_bind(uv_pipe_t* handle, const char* name) {
57 return uv_pipe_bind2(handle, name, strlen(name), 0);
61 int uv_pipe_bind2(uv_pipe_t* handle,
94 if (uv__stream_fd(handle) >= 0)
97 if (uv__is_closing(handle))
135 handle->flags |= UV_HANDLE_BOUND;
136 handle->pipe_fname = pipe_fname; /* NULL or a copy of |name| */
137 handle->io_watcher.fd = sockfd;
146 int uv__pipe_listen(uv_pipe_t* handle, int backlog, uv_connection_cb cb) {
147 if (uv__stream_fd(handle) == -1)
150 if (handle->ipc)
162 if (listen(uv__stream_fd(handle), backlog))
165 handle->connection_cb = cb;
166 handle->io_watcher.cb = uv__server_io;
167 uv__io_start(handle->loop, &handle->io_watcher, POLLIN);
172 void uv__pipe_close(uv_pipe_t* handle) {
173 if (handle->pipe_fname) {
180 unlink(handle->pipe_fname);
181 uv__free((void*)handle->pipe_fname);
182 handle->pipe_fname = NULL;
185 uv__stream_close((uv_stream_t*)handle);
189 int uv_pipe_open(uv_pipe_t* handle, uv_file fd) {
195 if (uv__fd_exists(handle->loop, fd))
210 err = uv__stream_try_select((uv_stream_t*) handle, &fd);
221 return uv__stream_open((uv_stream_t*)handle, fd, flags);
226 uv_pipe_t* handle,
231 err = uv_pipe_connect2(req, handle, name, strlen(name), 0, cb);
234 handle->delayed_error = err;
235 handle->connect_req = req;
237 uv__req_init(handle->loop, req, UV_CONNECT);
238 req->handle = (uv_stream_t*) handle;
243 uv__io_feed(handle->loop, &handle->io_watcher);
249 uv_pipe_t* handle,
280 new_sock = (uv__stream_fd(handle) == -1);
286 handle->io_watcher.fd = err;
299 r = connect(uv__stream_fd(handle), (struct sockaddr*)&saddr, addrlen);
318 err = uv__stream_open((uv_stream_t*)handle,
319 uv__stream_fd(handle),
324 uv__io_start(handle->loop, &handle->io_watcher, POLLOUT);
327 handle->delayed_error = err;
328 handle->connect_req = req;
330 uv__req_init(handle->loop, req, UV_CONNECT);
331 req->handle = (uv_stream_t*) handle;
337 uv__io_feed(handle->loop, &handle->io_watcher);
343 static int uv__pipe_getsockpeername(const uv_pipe_t* handle,
353 err = uv__getsockpeername((const uv_handle_t*) handle,
387 int uv_pipe_getsockname(const uv_pipe_t* handle, char* buffer, size_t* size) {
388 return uv__pipe_getsockpeername(handle, getsockname, buffer, size);
392 int uv_pipe_getpeername(const uv_pipe_t* handle, char* buffer, size_t* size) {
393 return uv__pipe_getsockpeername(handle, getpeername, buffer, size);
397 void uv_pipe_pending_instances(uv_pipe_t* handle, int count) {
401 int uv_pipe_pending_count(uv_pipe_t* handle) {
404 if (!handle->ipc)
407 if (handle->accepted_fd == -1)
410 if (handle->queued_fds == NULL)
413 queued_fds = handle->queued_fds;
418 uv_handle_type uv_pipe_pending_type(uv_pipe_t* handle) {
419 if (!handle->ipc)
422 if (handle->accepted_fd == -1)
425 return uv_guess_handle(handle->accepted_fd);
429 int uv_pipe_chmod(uv_pipe_t* handle, int mode) {
436 if (handle == NULL || uv__stream_fd(handle) == -1)
446 r = uv_pipe_getsockname(handle, NULL, &name_len);
454 r = uv_pipe_getsockname(handle, name_buffer, &name_len);