mirror of https://github.com/lukechilds/node.git
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
456 lines
17 KiB
456 lines
17 KiB
/* Copyright Joyent, Inc. and other Node contributors. All rights reserved.
|
|
*
|
|
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
* of this software and associated documentation files (the "Software"), to
|
|
* deal in the Software without restriction, including without limitation the
|
|
* rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
|
|
* sell copies of the Software, and to permit persons to whom the Software is
|
|
* furnished to do so, subject to the following conditions:
|
|
*
|
|
* The above copyright notice and this permission notice shall be included in
|
|
* all copies or substantial portions of the Software.
|
|
*
|
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
|
|
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
|
|
* IN THE SOFTWARE.
|
|
*/
|
|
|
|
#ifndef _WIN32_WINNT
|
|
# define _WIN32_WINNT 0x0502
|
|
#endif
|
|
|
|
#include <process.h>
|
|
#include <stdint.h>
|
|
#include <winsock2.h>
|
|
#include <mswsock.h>
|
|
#include <ws2tcpip.h>
|
|
#include <windows.h>
|
|
#include <sys/stat.h>
|
|
|
|
#include "tree.h"
|
|
|
|
#define MAX_PIPENAME_LEN 256
|
|
|
|
/*
|
|
* Guids and typedefs for winsock extension functions
|
|
* Mingw32 doesn't have these :-(
|
|
*/
|
|
#ifndef WSAID_ACCEPTEX
|
|
# define WSAID_ACCEPTEX \
|
|
{0xb5367df1, 0xcbac, 0x11cf, \
|
|
{0x95, 0xca, 0x00, 0x80, 0x5f, 0x48, 0xa1, 0x92}}
|
|
|
|
# define WSAID_CONNECTEX \
|
|
{0x25a207b9, 0xddf3, 0x4660, \
|
|
{0x8e, 0xe9, 0x76, 0xe5, 0x8c, 0x74, 0x06, 0x3e}}
|
|
|
|
# define WSAID_GETACCEPTEXSOCKADDRS \
|
|
{0xb5367df2, 0xcbac, 0x11cf, \
|
|
{0x95, 0xca, 0x00, 0x80, 0x5f, 0x48, 0xa1, 0x92}}
|
|
|
|
# define WSAID_DISCONNECTEX \
|
|
{0x7fda2e11, 0x8630, 0x436f, \
|
|
{0xa0, 0x31, 0xf5, 0x36, 0xa6, 0xee, 0xc1, 0x57}}
|
|
|
|
# define WSAID_TRANSMITFILE \
|
|
{0xb5367df0, 0xcbac, 0x11cf, \
|
|
{0x95, 0xca, 0x00, 0x80, 0x5f, 0x48, 0xa1, 0x92}}
|
|
|
|
typedef BOOL PASCAL (*LPFN_ACCEPTEX)
|
|
(SOCKET sListenSocket,
|
|
SOCKET sAcceptSocket,
|
|
PVOID lpOutputBuffer,
|
|
DWORD dwReceiveDataLength,
|
|
DWORD dwLocalAddressLength,
|
|
DWORD dwRemoteAddressLength,
|
|
LPDWORD lpdwBytesReceived,
|
|
LPOVERLAPPED lpOverlapped);
|
|
|
|
typedef BOOL PASCAL (*LPFN_CONNECTEX)
|
|
(SOCKET s,
|
|
const struct sockaddr* name,
|
|
int namelen,
|
|
PVOID lpSendBuffer,
|
|
DWORD dwSendDataLength,
|
|
LPDWORD lpdwBytesSent,
|
|
LPOVERLAPPED lpOverlapped);
|
|
|
|
typedef void PASCAL (*LPFN_GETACCEPTEXSOCKADDRS)
|
|
(PVOID lpOutputBuffer,
|
|
DWORD dwReceiveDataLength,
|
|
DWORD dwLocalAddressLength,
|
|
DWORD dwRemoteAddressLength,
|
|
LPSOCKADDR* LocalSockaddr,
|
|
LPINT LocalSockaddrLength,
|
|
LPSOCKADDR* RemoteSockaddr,
|
|
LPINT RemoteSockaddrLength);
|
|
|
|
typedef BOOL PASCAL (*LPFN_DISCONNECTEX)
|
|
(SOCKET hSocket,
|
|
LPOVERLAPPED lpOverlapped,
|
|
DWORD dwFlags,
|
|
DWORD reserved);
|
|
|
|
typedef BOOL PASCAL (*LPFN_TRANSMITFILE)
|
|
(SOCKET hSocket,
|
|
HANDLE hFile,
|
|
DWORD nNumberOfBytesToWrite,
|
|
DWORD nNumberOfBytesPerSend,
|
|
LPOVERLAPPED lpOverlapped,
|
|
LPTRANSMIT_FILE_BUFFERS lpTransmitBuffers,
|
|
DWORD dwFlags);
|
|
|
|
typedef PVOID RTL_SRWLOCK;
|
|
typedef RTL_SRWLOCK SRWLOCK, *PSRWLOCK;
|
|
#endif
|
|
|
|
typedef int (WSAAPI* LPFN_WSARECV)
|
|
(SOCKET socket,
|
|
LPWSABUF buffers,
|
|
DWORD buffer_count,
|
|
LPDWORD bytes,
|
|
LPDWORD flags,
|
|
LPWSAOVERLAPPED overlapped,
|
|
LPWSAOVERLAPPED_COMPLETION_ROUTINE
|
|
completion_routine);
|
|
|
|
typedef int (WSAAPI* LPFN_WSARECVFROM)
|
|
(SOCKET socket,
|
|
LPWSABUF buffers,
|
|
DWORD buffer_count,
|
|
LPDWORD bytes,
|
|
LPDWORD flags,
|
|
struct sockaddr* addr,
|
|
LPINT addr_len,
|
|
LPWSAOVERLAPPED overlapped,
|
|
LPWSAOVERLAPPED_COMPLETION_ROUTINE completion_routine);
|
|
|
|
|
|
/**
|
|
* It should be possible to cast uv_buf_t[] to WSABUF[]
|
|
* see http://msdn.microsoft.com/en-us/library/ms741542(v=vs.85).aspx
|
|
*/
|
|
typedef struct uv_buf_t {
|
|
ULONG len;
|
|
char* base;
|
|
} uv_buf_t;
|
|
|
|
typedef int uv_file;
|
|
|
|
typedef HANDLE uv_thread_t;
|
|
|
|
typedef CRITICAL_SECTION uv_mutex_t;
|
|
|
|
typedef union {
|
|
/* srwlock_ has type SRWLOCK, but not all toolchains define this type in */
|
|
/* windows.h. */
|
|
SRWLOCK srwlock_;
|
|
struct {
|
|
uv_mutex_t read_mutex_;
|
|
uv_mutex_t write_mutex_;
|
|
unsigned int num_readers_;
|
|
} fallback_;
|
|
} uv_rwlock_t;
|
|
|
|
#define UV_ONCE_INIT { 0, NULL, NULL }
|
|
|
|
typedef struct uv_once_s {
|
|
unsigned char ran;
|
|
/* The actual event handle must be aligned to sizeof(HANDLE), so in */
|
|
/* practice it might overlap padding a little. */
|
|
HANDLE event;
|
|
HANDLE padding;
|
|
} uv_once_t;
|
|
|
|
/* Platform-specific definitions for uv_dlopen support. */
|
|
typedef HMODULE uv_lib_t;
|
|
#define UV_DYNAMIC FAR WINAPI
|
|
|
|
RB_HEAD(uv_timer_tree_s, uv_timer_s);
|
|
|
|
#define UV_LOOP_PRIVATE_FIELDS \
|
|
/* The loop's I/O completion port */ \
|
|
HANDLE iocp; \
|
|
/* Reference count that keeps the event loop alive */ \
|
|
int refs; \
|
|
/* The current time according to the event loop. in msecs. */ \
|
|
int64_t time; \
|
|
/* Tail of a single-linked circular queue of pending reqs. If the queue */ \
|
|
/* is empty, tail_ is NULL. If there is only one item, */ \
|
|
/* tail_->next_req == tail_ */ \
|
|
uv_req_t* pending_reqs_tail; \
|
|
/* Head of a single-linked list of closed handles */ \
|
|
uv_handle_t* endgame_handles; \
|
|
/* The head of the timers tree */ \
|
|
struct uv_timer_tree_s timers; \
|
|
/* Lists of active loop (prepare / check / idle) watchers */ \
|
|
uv_prepare_t* prepare_handles; \
|
|
uv_check_t* check_handles; \
|
|
uv_idle_t* idle_handles; \
|
|
/* This pointer will refer to the prepare/check/idle handle whose */ \
|
|
/* callback is scheduled to be called next. This is needed to allow */ \
|
|
/* safe removal from one of the lists above while that list being */ \
|
|
/* iterated over. */ \
|
|
uv_prepare_t* next_prepare_handle; \
|
|
uv_check_t* next_check_handle; \
|
|
uv_idle_t* next_idle_handle; \
|
|
ares_channel ares_chan; \
|
|
int ares_active_sockets; \
|
|
uv_timer_t ares_polling_timer; \
|
|
/* Counter to keep track of active tcp streams */ \
|
|
unsigned int active_tcp_streams; \
|
|
/* Counter to keep track of active udp streams */ \
|
|
unsigned int active_udp_streams;
|
|
|
|
#define UV_REQ_TYPE_PRIVATE \
|
|
/* TODO: remove the req suffix */ \
|
|
UV_ARES_EVENT_REQ, \
|
|
UV_ARES_CLEANUP_REQ, \
|
|
UV_GETADDRINFO_REQ, \
|
|
UV_PROCESS_EXIT, \
|
|
UV_PROCESS_CLOSE, \
|
|
UV_UDP_RECV, \
|
|
UV_FS_EVENT_REQ
|
|
|
|
#define UV_REQ_PRIVATE_FIELDS \
|
|
union { \
|
|
/* Used by I/O operations */ \
|
|
struct { \
|
|
OVERLAPPED overlapped; \
|
|
size_t queued_bytes; \
|
|
}; \
|
|
}; \
|
|
struct uv_req_s* next_req;
|
|
|
|
#define UV_WRITE_PRIVATE_FIELDS \
|
|
int ipc_header; \
|
|
uv_buf_t write_buffer; \
|
|
HANDLE event_handle; \
|
|
HANDLE wait_handle;
|
|
|
|
#define UV_CONNECT_PRIVATE_FIELDS \
|
|
/* empty */
|
|
|
|
#define UV_SHUTDOWN_PRIVATE_FIELDS \
|
|
/* empty */
|
|
|
|
#define UV_UDP_SEND_PRIVATE_FIELDS \
|
|
/* empty */
|
|
|
|
#define UV_PRIVATE_REQ_TYPES \
|
|
typedef struct uv_pipe_accept_s { \
|
|
UV_REQ_FIELDS \
|
|
HANDLE pipeHandle; \
|
|
struct uv_pipe_accept_s* next_pending; \
|
|
} uv_pipe_accept_t; \
|
|
\
|
|
typedef struct uv_tcp_accept_s { \
|
|
UV_REQ_FIELDS \
|
|
SOCKET accept_socket; \
|
|
char accept_buffer[sizeof(struct sockaddr_storage) * 2 + 32]; \
|
|
HANDLE event_handle; \
|
|
HANDLE wait_handle; \
|
|
struct uv_tcp_accept_s* next_pending; \
|
|
} uv_tcp_accept_t; \
|
|
\
|
|
typedef struct uv_read_s { \
|
|
UV_REQ_FIELDS \
|
|
HANDLE event_handle; \
|
|
HANDLE wait_handle; \
|
|
} uv_read_t;
|
|
|
|
#define uv_stream_connection_fields \
|
|
unsigned int write_reqs_pending; \
|
|
uv_shutdown_t* shutdown_req;
|
|
|
|
#define uv_stream_server_fields \
|
|
uv_connection_cb connection_cb;
|
|
|
|
#define UV_STREAM_PRIVATE_FIELDS \
|
|
unsigned int reqs_pending; \
|
|
uv_read_t read_req; \
|
|
union { \
|
|
struct { uv_stream_connection_fields }; \
|
|
struct { uv_stream_server_fields }; \
|
|
};
|
|
|
|
#define uv_tcp_server_fields \
|
|
uv_tcp_accept_t* accept_reqs; \
|
|
unsigned int processed_accepts; \
|
|
uv_tcp_accept_t* pending_accepts; \
|
|
LPFN_ACCEPTEX func_acceptex;
|
|
|
|
#define uv_tcp_connection_fields \
|
|
uv_buf_t read_buffer; \
|
|
LPFN_CONNECTEX func_connectex;
|
|
|
|
#define UV_TCP_PRIVATE_FIELDS \
|
|
SOCKET socket; \
|
|
int bind_error; \
|
|
union { \
|
|
struct { uv_tcp_server_fields }; \
|
|
struct { uv_tcp_connection_fields }; \
|
|
};
|
|
|
|
#define UV_UDP_PRIVATE_FIELDS \
|
|
SOCKET socket; \
|
|
unsigned int reqs_pending; \
|
|
uv_req_t recv_req; \
|
|
uv_buf_t recv_buffer; \
|
|
struct sockaddr_storage recv_from; \
|
|
int recv_from_len; \
|
|
uv_udp_recv_cb recv_cb; \
|
|
uv_alloc_cb alloc_cb; \
|
|
LPFN_WSARECV func_wsarecv; \
|
|
LPFN_WSARECVFROM func_wsarecvfrom;
|
|
|
|
#define uv_pipe_server_fields \
|
|
int pending_instances; \
|
|
uv_pipe_accept_t* accept_reqs; \
|
|
uv_pipe_accept_t* pending_accepts;
|
|
|
|
#define uv_pipe_connection_fields \
|
|
uv_timer_t* eof_timer; \
|
|
uv_write_t ipc_header_write_req; \
|
|
int ipc_pid; \
|
|
uint64_t remaining_ipc_rawdata_bytes; \
|
|
WSAPROTOCOL_INFOW* pending_socket_info; \
|
|
uv_write_t* non_overlapped_writes_tail;
|
|
|
|
#define UV_PIPE_PRIVATE_FIELDS \
|
|
HANDLE handle; \
|
|
wchar_t* name; \
|
|
union { \
|
|
struct { uv_pipe_server_fields }; \
|
|
struct { uv_pipe_connection_fields }; \
|
|
};
|
|
|
|
/* TODO: put the parser states in an union - TTY handles are always */
|
|
/* half-duplex so read-state can safely overlap write-state. */
|
|
#define UV_TTY_PRIVATE_FIELDS \
|
|
HANDLE handle; \
|
|
HANDLE read_line_handle; \
|
|
uv_buf_t read_line_buffer; \
|
|
HANDLE read_raw_wait; \
|
|
DWORD original_console_mode; \
|
|
/* Fields used for translating win */ \
|
|
/* keystrokes into vt100 characters */ \
|
|
char last_key[8]; \
|
|
unsigned char last_key_offset; \
|
|
unsigned char last_key_len; \
|
|
INPUT_RECORD last_input_record; \
|
|
WCHAR last_utf16_high_surrogate; \
|
|
/* utf8-to-utf16 conversion state */ \
|
|
unsigned char utf8_bytes_left; \
|
|
unsigned int utf8_codepoint; \
|
|
/* eol conversion state */ \
|
|
unsigned char previous_eol; \
|
|
/* ansi parser state */ \
|
|
unsigned char ansi_parser_state; \
|
|
unsigned char ansi_csi_argc; \
|
|
unsigned short ansi_csi_argv[4]; \
|
|
COORD saved_position; \
|
|
WORD saved_attributes;
|
|
|
|
#define UV_TIMER_PRIVATE_FIELDS \
|
|
RB_ENTRY(uv_timer_s) tree_entry; \
|
|
int64_t due; \
|
|
int64_t repeat; \
|
|
uv_timer_cb timer_cb;
|
|
|
|
#define UV_ASYNC_PRIVATE_FIELDS \
|
|
struct uv_req_s async_req; \
|
|
uv_async_cb async_cb; \
|
|
/* char to avoid alignment issues */ \
|
|
char volatile async_sent;
|
|
|
|
#define UV_PREPARE_PRIVATE_FIELDS \
|
|
uv_prepare_t* prepare_prev; \
|
|
uv_prepare_t* prepare_next; \
|
|
uv_prepare_cb prepare_cb;
|
|
|
|
#define UV_CHECK_PRIVATE_FIELDS \
|
|
uv_check_t* check_prev; \
|
|
uv_check_t* check_next; \
|
|
uv_check_cb check_cb;
|
|
|
|
#define UV_IDLE_PRIVATE_FIELDS \
|
|
uv_idle_t* idle_prev; \
|
|
uv_idle_t* idle_next; \
|
|
uv_idle_cb idle_cb;
|
|
|
|
#define UV_HANDLE_PRIVATE_FIELDS \
|
|
uv_handle_t* endgame_next; \
|
|
unsigned int flags;
|
|
|
|
#define UV_ARES_TASK_PRIVATE_FIELDS \
|
|
struct uv_req_s ares_req; \
|
|
SOCKET sock; \
|
|
HANDLE h_wait; \
|
|
WSAEVENT h_event; \
|
|
HANDLE h_close_event;
|
|
|
|
#define UV_GETADDRINFO_PRIVATE_FIELDS \
|
|
struct uv_req_s getadddrinfo_req; \
|
|
uv_getaddrinfo_cb getaddrinfo_cb; \
|
|
void* alloc; \
|
|
wchar_t* node; \
|
|
wchar_t* service; \
|
|
struct addrinfoW* hints; \
|
|
struct addrinfoW* res; \
|
|
int retcode;
|
|
|
|
#define UV_PROCESS_PRIVATE_FIELDS \
|
|
struct uv_process_exit_s { \
|
|
UV_REQ_FIELDS \
|
|
} exit_req; \
|
|
struct uv_process_close_s { \
|
|
UV_REQ_FIELDS \
|
|
} close_req; \
|
|
HANDLE child_stdio[3]; \
|
|
int exit_signal; \
|
|
DWORD spawn_errno; \
|
|
HANDLE wait_handle; \
|
|
HANDLE process_handle; \
|
|
HANDLE close_handle;
|
|
|
|
#define UV_FS_PRIVATE_FIELDS \
|
|
wchar_t* pathw; \
|
|
int flags; \
|
|
DWORD sys_errno_; \
|
|
struct _stati64 stat; \
|
|
void* arg0; \
|
|
union { \
|
|
struct { \
|
|
void* arg1; \
|
|
void* arg2; \
|
|
void* arg3; \
|
|
}; \
|
|
struct { \
|
|
ssize_t arg4; \
|
|
ssize_t arg5; \
|
|
}; \
|
|
};
|
|
|
|
#define UV_WORK_PRIVATE_FIELDS \
|
|
|
|
#define UV_FS_EVENT_PRIVATE_FIELDS \
|
|
struct uv_fs_event_req_s { \
|
|
UV_REQ_FIELDS \
|
|
} req; \
|
|
HANDLE dir_handle; \
|
|
int req_pending; \
|
|
uv_fs_event_cb cb; \
|
|
wchar_t* filew; \
|
|
wchar_t* short_filew; \
|
|
wchar_t* dirw; \
|
|
char* buffer;
|
|
|
|
int uv_utf16_to_utf8(const wchar_t* utf16Buffer, size_t utf16Size,
|
|
char* utf8Buffer, size_t utf8Size);
|
|
int uv_utf8_to_utf16(const char* utf8Buffer, wchar_t* utf16Buffer,
|
|
size_t utf16Size);
|
|
|