gre-ilya/libuv
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add socket type to Unix domain socket

Browse Source
This commit is contained in:
aperture-it 2026-01-06 08:25:39 +03:00
parent 91ae02a63d
commit c9fbec2c4f
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
include/uv.h
View File

@ -871,6 +871,7 @@ struct uv_pipe_s {
UV_HANDLE_FIELDS UV_HANDLE_FIELDS
UV_STREAM_FIELDS UV_STREAM_FIELDS
int ipc; /* non-zero if this pipe is used for passing handles */ int ipc; /* non-zero if this pipe is used for passing handles */
int socket_type; /* socket type from enum __socket_type */
UV_PIPE_PRIVATE_FIELDS UV_PIPE_PRIVATE_FIELDS
}; };

5
src/unix/pipe.c
View File

@ -51,6 +51,7 @@ int uv_pipe_init(uv_loop_t* loop, uv_pipe_t* handle, int ipc) {
handle->connect_req = NULL; handle->connect_req = NULL;
handle->pipe_fname = NULL; handle->pipe_fname = NULL;
handle->ipc = ipc; handle->ipc = ipc;
handle->socket_type = SOCK_STREAM;
return 0; return 0;
} }
@ -119,7 +120,7 @@ int uv_pipe_bind2(uv_pipe_t* handle,
addrlen = sizeof saddr; addrlen = sizeof saddr;
} }
err = uv__socket(AF_UNIX, SOCK_STREAM, 0); err = uv__socket(AF_UNIX, handle->socket_type, 0);
if (err < 0) if (err < 0)
goto err_socket; goto err_socket;
sockfd = err; sockfd = err;
@ -286,7 +287,7 @@ int uv_pipe_connect2(uv_connect_t* req,
new_sock = (uv__stream_fd(handle) == -1); new_sock = (uv__stream_fd(handle) == -1);
if (new_sock) { if (new_sock) {
err = uv__socket(AF_UNIX, SOCK_STREAM, 0); err = uv__socket(AF_UNIX, handle->socket_type, 0);
if (err < 0) if (err < 0)
goto out; goto out;
handle->io_watcher.fd = err; handle->io_watcher.fd = err;