Mercurial

comparison third_party/libuv/src/win/internal.h @ 160:948de3f54cea

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
[ThirdParty] Added libuv
author June Park <parkjune1995@gmail.com>
date Wed, 14 Jan 2026 19:39:52 -0800
parents
children
comparison
equal deleted inserted replaced
159:05cf9467a1c3 160:948de3f54cea
1 /* Copyright Joyent, Inc. and other Node contributors. All rights reserved.
2 *
3 * Permission is hereby granted, free of charge, to any person obtaining a copy
4 * of this software and associated documentation files (the "Software"), to
5 * deal in the Software without restriction, including without limitation the
6 * rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
7 * sell copies of the Software, and to permit persons to whom the Software is
8 * furnished to do so, subject to the following conditions:
9 *
10 * The above copyright notice and this permission notice shall be included in
11 * all copies or substantial portions of the Software.
12 *
13 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
14 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
15 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
16 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
17 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
18 * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
19 * IN THE SOFTWARE.
20 */
21
22 #ifndef UV_WIN_INTERNAL_H_
23 #define UV_WIN_INTERNAL_H_
24
25 #include "uv.h"
26 #include "../uv-common.h"
27
28 #include "uv/tree.h"
29 #include "winapi.h"
30 #include "winsock.h"
31
32 #ifdef _MSC_VER
33 # define INLINE __inline
34 # define UV_THREAD_LOCAL __declspec( thread )
35 #else
36 # define INLINE inline
37 # define UV_THREAD_LOCAL __thread
38 #endif
39
40
41 #ifdef _DEBUG
42
43 extern UV_THREAD_LOCAL int uv__crt_assert_enabled;
44
45 #define UV_BEGIN_DISABLE_CRT_ASSERT() \
46 { \
47 int uv__saved_crt_assert_enabled = uv__crt_assert_enabled; \
48 uv__crt_assert_enabled = FALSE;
49
50
51 #define UV_END_DISABLE_CRT_ASSERT() \
52 uv__crt_assert_enabled = uv__saved_crt_assert_enabled; \
53 }
54
55 #else
56 #define UV_BEGIN_DISABLE_CRT_ASSERT()
57 #define UV_END_DISABLE_CRT_ASSERT()
58 #endif
59
60 /*
61 * TCP
62 */
63
64 typedef enum {
65 UV__IPC_SOCKET_XFER_NONE = 0,
66 UV__IPC_SOCKET_XFER_TCP_CONNECTION,
67 UV__IPC_SOCKET_XFER_TCP_SERVER
68 } uv__ipc_socket_xfer_type_t;
69
70 typedef struct {
71 WSAPROTOCOL_INFOW socket_info;
72 uint32_t delayed_error;
73 } uv__ipc_socket_xfer_info_t;
74
75 int uv__tcp_listen(uv_tcp_t* handle, int backlog, uv_connection_cb cb);
76 int uv__tcp_accept(uv_tcp_t* server, uv_tcp_t* client);
77 int uv__tcp_read_start(uv_tcp_t* handle, uv_alloc_cb alloc_cb,
78 uv_read_cb read_cb);
79 int uv__tcp_write(uv_loop_t* loop, uv_write_t* req, uv_tcp_t* handle,
80 const uv_buf_t bufs[], unsigned int nbufs, uv_write_cb cb);
81 int uv__tcp_try_write(uv_tcp_t* handle, const uv_buf_t bufs[],
82 unsigned int nbufs);
83
84 void uv__process_tcp_read_req(uv_loop_t* loop, uv_tcp_t* handle, uv_req_t* req);
85 void uv__process_tcp_write_req(uv_loop_t* loop, uv_tcp_t* handle,
86 uv_write_t* req);
87 void uv__process_tcp_accept_req(uv_loop_t* loop, uv_tcp_t* handle,
88 uv_req_t* req);
89 void uv__process_tcp_connect_req(uv_loop_t* loop, uv_tcp_t* handle,
90 uv_connect_t* req);
91 void uv__process_tcp_shutdown_req(uv_loop_t* loop,
92 uv_tcp_t* stream,
93 uv_shutdown_t* req);
94
95 void uv__tcp_close(uv_loop_t* loop, uv_tcp_t* tcp);
96 void uv__tcp_endgame(uv_loop_t* loop, uv_tcp_t* handle);
97
98 int uv__tcp_xfer_export(uv_tcp_t* handle,
99 int pid,
100 uv__ipc_socket_xfer_type_t* xfer_type,
101 uv__ipc_socket_xfer_info_t* xfer_info);
102 int uv__tcp_xfer_import(uv_tcp_t* tcp,
103 uv__ipc_socket_xfer_type_t xfer_type,
104 uv__ipc_socket_xfer_info_t* xfer_info);
105
106
107 /*
108 * UDP
109 */
110 void uv__process_udp_recv_req(uv_loop_t* loop, uv_udp_t* handle, uv_req_t* req);
111 void uv__process_udp_send_req(uv_loop_t* loop, uv_udp_t* handle,
112 uv_udp_send_t* req);
113
114 void uv__udp_close(uv_loop_t* loop, uv_udp_t* handle);
115 void uv__udp_endgame(uv_loop_t* loop, uv_udp_t* handle);
116
117
118 /*
119 * Pipes
120 */
121 int uv__create_stdio_pipe_pair(uv_loop_t* loop,
122 uv_pipe_t* parent_pipe, HANDLE* child_pipe_ptr, unsigned int flags);
123
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,
127 uv_read_cb read_cb);
128 void uv__pipe_read_stop(uv_pipe_t* handle);
129 int uv__pipe_write(uv_loop_t* loop,
130 uv_write_t* req,
131 uv_pipe_t* handle,
132 const uv_buf_t bufs[],
133 size_t nbufs,
134 uv_stream_t* send_handle,
135 uv_write_cb cb);
136 void uv__pipe_shutdown(uv_loop_t* loop, uv_pipe_t* handle, uv_shutdown_t* req);
137
138 void uv__process_pipe_read_req(uv_loop_t* loop, uv_pipe_t* handle,
139 uv_req_t* req);
140 void uv__process_pipe_write_req(uv_loop_t* loop, uv_pipe_t* handle,
141 uv_write_t* req);
142 void uv__process_pipe_accept_req(uv_loop_t* loop, uv_pipe_t* handle,
143 uv_req_t* raw_req);
144 void uv__process_pipe_connect_req(uv_loop_t* loop, uv_pipe_t* handle,
145 uv_connect_t* req);
146 void uv__process_pipe_shutdown_req(uv_loop_t* loop, uv_pipe_t* handle,
147 uv_shutdown_t* req);
148
149 void uv__pipe_close(uv_loop_t* loop, uv_pipe_t* handle);
150 void uv__pipe_endgame(uv_loop_t* loop, uv_pipe_t* handle);
151
152
153 /*
154 * TTY
155 */
156 void uv__console_init(void);
157
158 int uv__tty_read_start(uv_tty_t* handle, uv_alloc_cb alloc_cb,
159 uv_read_cb read_cb);
160 int uv__tty_read_stop(uv_tty_t* handle);
161 int uv__tty_write(uv_loop_t* loop, uv_write_t* req, uv_tty_t* handle,
162 const uv_buf_t bufs[], unsigned int nbufs, uv_write_cb cb);
163 int uv__tty_try_write(uv_tty_t* handle, const uv_buf_t bufs[],
164 unsigned int nbufs);
165 void uv__tty_close(uv_tty_t* handle);
166
167 void uv__process_tty_read_req(uv_loop_t* loop, uv_tty_t* handle,
168 uv_req_t* req);
169 void uv__process_tty_write_req(uv_loop_t* loop, uv_tty_t* handle,
170 uv_write_t* req);
171 #define uv__process_tty_accept_req(loop, handle, req) abort()
172 #define uv__process_tty_connect_req(loop, handle, req) abort()
173 void uv__process_tty_shutdown_req(uv_loop_t* loop,
174 uv_tty_t* stream,
175 uv_shutdown_t* req);
176 void uv__tty_endgame(uv_loop_t* loop, uv_tty_t* handle);
177
178
179 /*
180 * Poll watchers
181 */
182 void uv__process_poll_req(uv_loop_t* loop, uv_poll_t* handle,
183 uv_req_t* req);
184
185 int uv__poll_close(uv_loop_t* loop, uv_poll_t* handle);
186 void uv__poll_endgame(uv_loop_t* loop, uv_poll_t* handle);
187
188
189 /*
190 * Loop watchers
191 */
192 void uv__loop_watcher_endgame(uv_loop_t* loop, uv_handle_t* handle);
193
194 void uv__prepare_invoke(uv_loop_t* loop);
195 void uv__check_invoke(uv_loop_t* loop);
196 void uv__idle_invoke(uv_loop_t* loop);
197
198 void uv__once_init(void);
199
200
201 /*
202 * Async watcher
203 */
204 void uv__async_close(uv_loop_t* loop, uv_async_t* handle);
205 void uv__async_endgame(uv_loop_t* loop, uv_async_t* handle);
206
207 void uv__process_async_wakeup_req(uv_loop_t* loop, uv_async_t* handle,
208 uv_req_t* req);
209
210
211 /*
212 * Signal watcher
213 */
214 void uv__signals_init(void);
215 int uv__signal_dispatch(int signum);
216
217 void uv__signal_close(uv_loop_t* loop, uv_signal_t* handle);
218 void uv__signal_endgame(uv_loop_t* loop, uv_signal_t* handle);
219
220 void uv__process_signal_req(uv_loop_t* loop, uv_signal_t* handle,
221 uv_req_t* req);
222
223
224 /*
225 * Spawn
226 */
227 void uv__process_proc_exit(uv_loop_t* loop, uv_process_t* handle);
228 void uv__process_close(uv_loop_t* loop, uv_process_t* handle);
229 void uv__process_endgame(uv_loop_t* loop, uv_process_t* handle);
230
231
232 /*
233 * FS
234 */
235 void uv__fs_init(void);
236
237
238 /*
239 * FS Event
240 */
241 void uv__process_fs_event_req(uv_loop_t* loop, uv_req_t* req,
242 uv_fs_event_t* handle);
243 void uv__fs_event_close(uv_loop_t* loop, uv_fs_event_t* handle);
244 void uv__fs_event_endgame(uv_loop_t* loop, uv_fs_event_t* handle);
245
246
247 /*
248 * Stat poller.
249 */
250 void uv__fs_poll_endgame(uv_loop_t* loop, uv_fs_poll_t* handle);
251
252
253 /*
254 * Utilities.
255 */
256 void uv__util_init(void);
257
258 uint64_t uv__hrtime(unsigned int scale);
259 __declspec(noreturn) void uv_fatal_error(const int errorno, const char* syscall);
260 int uv__convert_utf16_to_utf8(const WCHAR* utf16, size_t utf16len, char** utf8);
261 int uv__copy_utf16_to_utf8(const WCHAR* utf16, size_t utf16len, char* utf8, size_t *size);
262 int uv__convert_utf8_to_utf16(const char* utf8, WCHAR** utf16);
263
264 typedef int (WINAPI *uv__peersockfunc)(SOCKET, struct sockaddr*, int*);
265
266 int uv__getsockpeername(const uv_handle_t* handle,
267 uv__peersockfunc func,
268 struct sockaddr* name,
269 int* namelen,
270 int delayed_error);
271
272 int uv__random_rtlgenrandom(void* buf, size_t buflen);
273
274
275 /*
276 * Process stdio handles.
277 */
278 int uv__stdio_create(uv_loop_t* loop,
279 const uv_process_options_t* options,
280 BYTE** buffer_ptr);
281 void uv__stdio_destroy(BYTE* buffer);
282 void uv__stdio_noinherit(BYTE* buffer);
283 int uv__stdio_verify(BYTE* buffer, WORD size);
284 WORD uv__stdio_size(BYTE* buffer);
285 HANDLE uv__stdio_handle(BYTE* buffer, int fd);
286
287
288 /*
289 * Winapi and ntapi utility functions
290 */
291 void uv__winapi_init(void);
292
293
294 /*
295 * Winsock utility functions
296 */
297 void uv__winsock_init(void);
298
299 int uv__ntstatus_to_winsock_error(NTSTATUS status);
300
301 BOOL uv__get_acceptex_function(SOCKET socket, LPFN_ACCEPTEX* target);
302 BOOL uv__get_connectex_function(SOCKET socket, LPFN_CONNECTEX* target);
303
304 int WSAAPI uv__wsarecv_workaround(SOCKET socket, WSABUF* buffers,
305 DWORD buffer_count, DWORD* bytes, DWORD* flags, WSAOVERLAPPED *overlapped,
306 LPWSAOVERLAPPED_COMPLETION_ROUTINE completion_routine);
307 int WSAAPI uv__wsarecvfrom_workaround(SOCKET socket, WSABUF* buffers,
308 DWORD buffer_count, DWORD* bytes, DWORD* flags, struct sockaddr* addr,
309 int* addr_len, WSAOVERLAPPED *overlapped,
310 LPWSAOVERLAPPED_COMPLETION_ROUTINE completion_routine);
311
312 int WSAAPI uv__msafd_poll(SOCKET socket, AFD_POLL_INFO* info_in,
313 AFD_POLL_INFO* info_out, OVERLAPPED* overlapped);
314
315 /* Whether there are any non-IFS LSPs stacked on TCP */
316 extern int uv_tcp_non_ifs_lsp_ipv4;
317 extern int uv_tcp_non_ifs_lsp_ipv6;
318
319 /* Ip address used to bind to any port at any interface */
320 extern struct sockaddr_in uv_addr_ip4_any_;
321 extern struct sockaddr_in6 uv_addr_ip6_any_;
322
323 /*
324 * Wake all loops with fake message
325 */
326 void uv__wake_all_loops(void);
327
328 /*
329 * Init system wake-up detection
330 */
331 void uv__init_detect_system_wakeup(void);
332
333 int uv_translate_write_sys_error(int sys_errno);
334
335 #endif /* UV_WIN_INTERNAL_H_ */