in source/windows/iocp/socket.c [83:237]
static int s_ipv4_stream_connect(
struct aws_socket *socket,
const struct aws_socket_endpoint *remote_endpoint,
struct aws_event_loop *connect_loop,
aws_socket_on_connection_result_fn *on_connection_result,
void *user_data);
static int s_ipv4_dgram_connect(
struct aws_socket *socket,
const struct aws_socket_endpoint *remote_endpoint,
struct aws_event_loop *connect_loop,
aws_socket_on_connection_result_fn *on_connection_result,
void *user_data);
static int s_ipv6_stream_connect(
struct aws_socket *socket,
const struct aws_socket_endpoint *remote_endpoint,
struct aws_event_loop *connect_loop,
aws_socket_on_connection_result_fn *on_connection_result,
void *user_data);
static int s_ipv6_dgram_connect(
struct aws_socket *socket,
const struct aws_socket_endpoint *remote_endpoint,
struct aws_event_loop *connect_loop,
aws_socket_on_connection_result_fn *on_connection_result,
void *user_data);
static int s_local_connect(
struct aws_socket *socket,
const struct aws_socket_endpoint *remote_endpoint,
struct aws_event_loop *connect_loop,
aws_socket_on_connection_result_fn *on_connection_result,
void *user_data);
static int s_tcp_start_accept(
struct aws_socket *socket,
struct aws_event_loop *accept_loop,
aws_socket_on_accept_result_fn *on_accept_result,
void *user_data);
static int s_local_start_accept(
struct aws_socket *socket,
struct aws_event_loop *accept_loop,
aws_socket_on_accept_result_fn *on_accept_result,
void *user_data);
static int s_stream_stop_accept(struct aws_socket *socket);
static int s_dgram_start_accept(
struct aws_socket *socket,
struct aws_event_loop *accept_loop,
aws_socket_on_accept_result_fn *on_accept_result,
void *user_data);
static int s_dgram_stop_accept(struct aws_socket *socket);
static int s_tcp_listen(struct aws_socket *socket, int backlog_size);
static int s_udp_listen(struct aws_socket *socket, int backlog_size);
static int s_local_listen(struct aws_socket *socket, int backlog_size);
static int s_tcp_read(struct aws_socket *socket, struct aws_byte_buf *buffer, size_t *amount_read);
static int s_local_read(struct aws_socket *socket, struct aws_byte_buf *buffer, size_t *amount_read);
static int s_dgram_read(struct aws_socket *socket, struct aws_byte_buf *buffer, size_t *amount_read);
static int s_socket_close(struct aws_socket *socket);
static int s_local_close(struct aws_socket *socket);
static int s_ipv4_stream_bind(struct aws_socket *socket, const struct aws_socket_endpoint *local_endpoint);
static int s_ipv4_dgram_bind(struct aws_socket *socket, const struct aws_socket_endpoint *local_endpoint);
static int s_ipv6_stream_bind(struct aws_socket *socket, const struct aws_socket_endpoint *local_endpoint);
static int s_ipv6_dgram_bind(struct aws_socket *socket, const struct aws_socket_endpoint *local_endpoint);
static int s_local_bind(struct aws_socket *socket, const struct aws_socket_endpoint *local_endpoint);
static int s_stream_subscribe_to_read(
struct aws_socket *socket,
aws_socket_on_readable_fn *on_readable,
void *user_data);
static int s_dgram_subscribe_to_read(
struct aws_socket *socket,
aws_socket_on_readable_fn *on_readable,
void *user_data);
static int s_determine_socket_error(int error);
/* Why build this V-table instead of doing that beautiful posix code I just read?
I'm glad you asked...... because winsock is nothing like posix and certainly not
as well thought out. There were so many branches to handle three entirely different
APIs we decided it was less painful to just have a bunch of function pointers in a table
than to want to gouge our eyes out while looking at a ridiculous number of branches. */
static struct socket_vtable vtables[3][2] = {
[AWS_SOCKET_IPV4] =
{
[AWS_SOCKET_STREAM] =
{
.connection_success = s_ipv4_stream_connection_success,
.connection_error = s_connection_error,
.connect = s_ipv4_stream_connect,
.start_accept = s_tcp_start_accept,
.stop_accept = s_stream_stop_accept,
.bind = s_ipv4_stream_bind,
.listen = s_tcp_listen,
.read = s_tcp_read,
.close = s_socket_close,
.subscribe_to_read = s_stream_subscribe_to_read,
},
[AWS_SOCKET_DGRAM] =
{
.connection_success = s_local_and_udp_connection_success,
.connection_error = s_connection_error,
.connect = s_ipv4_dgram_connect,
.start_accept = s_dgram_start_accept,
.stop_accept = s_dgram_stop_accept,
.bind = s_ipv4_dgram_bind,
.listen = s_udp_listen,
.read = s_dgram_read,
.close = s_socket_close,
.subscribe_to_read = s_dgram_subscribe_to_read,
},
},
[AWS_SOCKET_IPV6] =
{
[AWS_SOCKET_STREAM] =
{
.connection_success = s_ipv6_stream_connection_success,
.connection_error = s_connection_error,
.connect = s_ipv6_stream_connect,
.start_accept = s_tcp_start_accept,
.stop_accept = s_stream_stop_accept,
.bind = s_ipv6_stream_bind,
.listen = s_tcp_listen,
.read = s_tcp_read,
.close = s_socket_close,
.subscribe_to_read = s_stream_subscribe_to_read,
},
[AWS_SOCKET_DGRAM] =
{
.connection_success = s_local_and_udp_connection_success,
.connection_error = s_connection_error,
.connect = s_ipv6_dgram_connect,
.start_accept = s_dgram_start_accept,
.stop_accept = s_dgram_stop_accept,
.bind = s_ipv6_dgram_bind,
.listen = s_udp_listen,
.read = s_dgram_read,
.close = s_socket_close,
.subscribe_to_read = s_dgram_subscribe_to_read,
},
},
[AWS_SOCKET_LOCAL] =
{
[AWS_SOCKET_STREAM] =
{
.connection_success = s_local_and_udp_connection_success,
.connection_error = s_connection_error,
.connect = s_local_connect,
.start_accept = s_local_start_accept,
.stop_accept = s_stream_stop_accept,
.bind = s_local_bind,
.listen = s_local_listen,
.read = s_local_read,
.close = s_local_close,
.subscribe_to_read = s_stream_subscribe_to_read,
},
[AWS_SOCKET_DGRAM] = {0},
},
};