h3_socket.c¶

Functions¶

	Name
apr_status_t	h3_socket_open(apr_port_t port, apr_pool_t * pool, int * out_fd)
void	h3_socket_close(int fd)

Defines¶

	Name
	H3_STATUS_IS_EADDRINUSE(s)

Functions Documentation¶

function h3_socket_open¶

apr_status_t h3_socket_open(
    apr_port_t port,
    apr_pool_t * pool,
    int * out_fd
)

Parameters:

port Port to bind; 0 lets the OS pick.
pool Pool used for the underlying apr_socket_t lifetime.
out_fd Out parameter: the resulting OS-level fd (suitable for SSL_set_fd on OpenSSL QUIC).

Return: APR_SUCCESS, APR_EAGAIN if the port is already bound, or another APR error code.

Open a non-blocking IPv6 dual-stack UDP socket and bind it to the given port. Sets SO_REUSEADDR; on non-Windows also tries SO_REUSEPORT so multiple children can share the port.

function h3_socket_close¶

void h3_socket_close(
    int fd
)

Parameters:

fd The OS-level fd to close.

Close a UDP socket previously returned by h3_socket_open. Safe to call with a negative fd (no-op).

Macros Documentation¶

define H3_STATUS_IS_EADDRINUSE¶

#define H3_STATUS_IS_EADDRINUSE(
    s
)
((s) == APR_FROM_OS_ERROR(EADDRINUSE))

Source code¶

/*
 * Copyright (c) 2026 The mod_http3 Project Authors. All rights reserved.
 *
 * SPDX-License-Identifier: Apache-2.0
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include <apr_portable.h>
#include <unistd.h>

#if defined(_WIN32)
    #include <winsock2.h>
    #define H3_STATUS_IS_EADDRINUSE(s) ((s) == APR_FROM_OS_ERROR(WSAEADDRINUSE))
#else
    #include <errno.h>
    #define H3_STATUS_IS_EADDRINUSE(s) ((s) == APR_FROM_OS_ERROR(EADDRINUSE))
#endif

#include "h3_check.h"
#include "h3_socket.h"

apr_status_t h3_socket_open(apr_port_t port, apr_pool_t* pool, int* out_fd)
{
    CHECK(pool);
    CHECK(out_fd);
    apr_socket_t* sock = NULL;
    apr_status_t rv = apr_socket_create(&sock, APR_INET6, SOCK_DGRAM, APR_PROTO_UDP, pool);
    if (rv != APR_SUCCESS)
    {
        ap_log_perror(APLOG_MARK, APLOG_ERR, 0, pool, "h3_socket_open: apr_socket_create failed");
        return rv;
    }
    apr_socket_opt_set(sock, APR_IPV6_V6ONLY, 0);
    apr_sockaddr_t* addr = NULL;
    rv = apr_sockaddr_info_get(&addr, NULL, APR_INET6, port, 0, pool);
    if (rv != APR_SUCCESS)
    {
        apr_socket_close(sock);
        ap_log_perror(APLOG_MARK, APLOG_ERR, 0, pool, "h3_socket_open: apr_sockaddr_info_get failed");
        return rv;
    }
    rv = apr_socket_bind(sock, addr);
    if (rv != APR_SUCCESS)
    {
        apr_socket_close(sock);
        if (H3_STATUS_IS_EADDRINUSE(rv))
        {
            ap_log_perror(APLOG_MARK, APLOG_DEBUG, 0, pool, "bind(%d) skipped (port already owned)", (int)port);
            return APR_EAGAIN;
        }
        ap_log_perror(APLOG_MARK, APLOG_ERR, 0, pool, "bind(%d) failed", (int)port);
        return rv;
    }
    rv = apr_socket_timeout_set(sock, 0);
    if (rv != APR_SUCCESS)
    {
        apr_socket_close(sock);
        ap_log_perror(APLOG_MARK, APLOG_ERR, 0, pool, "set nonblocking on %d failed", (int)port);
        return rv;
    }
    apr_os_sock_t os_sock;
    rv = apr_os_sock_get(&os_sock, sock);
    if (rv != APR_SUCCESS)
    {
        apr_socket_close(sock);
        ap_log_perror(APLOG_MARK, APLOG_ERR, 0, pool, "h3_socket_open: apr_os_sock_get failed");
        return rv;
    }
    *out_fd = (int)os_sock;
    return APR_SUCCESS;
}

void h3_socket_close(int fd)
{
    if (fd >= 0)
    {
#if defined(_WIN32)
        closesocket(fd);
#else
        close(fd);
#endif
    }
}