Compare commits
1 Commits
f545be725d
...
c++
| Author | SHA1 | Date | |
|---|---|---|---|
|
ddb3a60dcc
|
@@ -1,32 +0,0 @@
|
|||||||
# clang-format is fairly limited, and these rules are approximate:
|
|
||||||
# - array initializers can get terribly mangled with clang-format 12.0,
|
|
||||||
# - sometimes it still aligns with space characters,
|
|
||||||
# - struct name NL { NL ... NL } NL name; is unachievable.
|
|
||||||
BasedOnStyle: GNU
|
|
||||||
ColumnLimit: 80
|
|
||||||
IndentWidth: 4
|
|
||||||
TabWidth: 4
|
|
||||||
UseTab: ForContinuationAndIndentation
|
|
||||||
BreakBeforeBraces: Allman
|
|
||||||
SpaceAfterCStyleCast: true
|
|
||||||
AlignAfterOpenBracket: DontAlign
|
|
||||||
AlignOperands: DontAlign
|
|
||||||
AlignConsecutiveMacros: Consecutive
|
|
||||||
AllowAllArgumentsOnNextLine: false
|
|
||||||
AllowAllParametersOfDeclarationOnNextLine: false
|
|
||||||
IndentGotoLabels: false
|
|
||||||
|
|
||||||
# IncludeCategories has some potential, but it may also break the build.
|
|
||||||
# Note that the documentation says the value should be "Never".
|
|
||||||
SortIncludes: false
|
|
||||||
|
|
||||||
# This is a compromise, it generally works out aesthetically better.
|
|
||||||
BinPackArguments: false
|
|
||||||
|
|
||||||
# Unfortunately, this can't be told to align to column 40 or so.
|
|
||||||
SpacesBeforeTrailingComments: 2
|
|
||||||
|
|
||||||
# liberty-specific macro body wrappers.
|
|
||||||
MacroBlockBegin: "BLOCK_START"
|
|
||||||
MacroBlockEnd: "BLOCK_END"
|
|
||||||
ForEachMacros: ["LIST_FOR_EACH"]
|
|
||||||
2
.gitignore
vendored
2
.gitignore
vendored
@@ -7,5 +7,3 @@
|
|||||||
/liberty.files
|
/liberty.files
|
||||||
/liberty.creator*
|
/liberty.creator*
|
||||||
/liberty.includes
|
/liberty.includes
|
||||||
/liberty.cflags
|
|
||||||
/liberty.cxxflags
|
|
||||||
|
|||||||
@@ -1,12 +1,12 @@
|
|||||||
project (liberty C)
|
project (liberty C)
|
||||||
cmake_minimum_required (VERSION 2.8.12)
|
cmake_minimum_required (VERSION 2.8.5)
|
||||||
|
|
||||||
# Moar warnings
|
# Moar warnings
|
||||||
if ("${CMAKE_C_COMPILER_ID}" MATCHES "GNU" OR CMAKE_COMPILER_IS_GNUCC)
|
if ("${CMAKE_C_COMPILER_ID}" MATCHES "GNU" OR CMAKE_COMPILER_IS_GNUCC)
|
||||||
# -Wunused-function is pretty annoying here, as everything is static
|
# -Wunused-function is pretty annoying here, as everything is static
|
||||||
set (wdisabled "-Wno-unused-function")
|
set (wdisabled "-Wno-unused-function -Wno-implicit-fallthrough")
|
||||||
set (CMAKE_C_FLAGS "${CMAKE_C_FLAGS} -std=c99 -Wall -Wextra ${wdisabled}")
|
set (CMAKE_C_FLAGS "${CMAKE_C_FLAGS} -std=c99 -Wall -Wextra ${wdisabled}")
|
||||||
endif ()
|
endif ("${CMAKE_C_COMPILER_ID}" MATCHES "GNU" OR CMAKE_COMPILER_IS_GNUCC)
|
||||||
|
|
||||||
# Dependencies
|
# Dependencies
|
||||||
set (CMAKE_MODULE_PATH ${PROJECT_SOURCE_DIR}/cmake)
|
set (CMAKE_MODULE_PATH ${PROJECT_SOURCE_DIR}/cmake)
|
||||||
@@ -16,9 +16,11 @@ find_package (PkgConfig REQUIRED)
|
|||||||
pkg_check_modules (libssl REQUIRED libssl libcrypto)
|
pkg_check_modules (libssl REQUIRED libssl libcrypto)
|
||||||
|
|
||||||
if ("${CMAKE_SYSTEM_NAME}" MATCHES "BSD")
|
if ("${CMAKE_SYSTEM_NAME}" MATCHES "BSD")
|
||||||
|
include_directories (/usr/local/include)
|
||||||
|
link_directories (/usr/local/lib)
|
||||||
# Our POSIX version macros make these undefined
|
# Our POSIX version macros make these undefined
|
||||||
add_definitions (-D__BSD_VISIBLE=1 -D_BSD_SOURCE=1)
|
add_definitions (-D__BSD_VISIBLE=1 -D_BSD_SOURCE=1)
|
||||||
endif ()
|
endif ("${CMAKE_SYSTEM_NAME}" MATCHES "BSD")
|
||||||
|
|
||||||
set (common_libraries ${libssl_LIBRARIES})
|
set (common_libraries ${libssl_LIBRARIES})
|
||||||
include_directories (${libssl_INCLUDE_DIRS})
|
include_directories (${libssl_INCLUDE_DIRS})
|
||||||
@@ -30,25 +32,15 @@ foreach (extra iconv rt)
|
|||||||
find_library (extra_lib_${extra} ${extra})
|
find_library (extra_lib_${extra} ${extra})
|
||||||
if (extra_lib_${extra})
|
if (extra_lib_${extra})
|
||||||
list (APPEND common_libraries ${extra})
|
list (APPEND common_libraries ${extra})
|
||||||
endif ()
|
endif (extra_lib_${extra})
|
||||||
endforeach ()
|
endforeach (extra)
|
||||||
|
|
||||||
# Build some unit tests
|
# Build some unit tests
|
||||||
include_directories (${PROJECT_SOURCE_DIR})
|
include_directories (${PROJECT_SOURCE_DIR})
|
||||||
enable_testing ()
|
enable_testing ()
|
||||||
set (tests liberty proto)
|
foreach (name liberty proto)
|
||||||
|
|
||||||
pkg_check_modules (libpulse libpulse)
|
|
||||||
if (libpulse_FOUND)
|
|
||||||
list (APPEND tests pulse)
|
|
||||||
list (APPEND common_libraries ${libpulse_LIBRARIES})
|
|
||||||
include_directories (${libpulse_INCLUDE_DIRS})
|
|
||||||
link_directories (${libpulse_LIBRARY_DIRS})
|
|
||||||
endif ()
|
|
||||||
|
|
||||||
foreach (name ${tests})
|
|
||||||
add_executable (test-${name} tests/${name}.c ${common_sources})
|
add_executable (test-${name} tests/${name}.c ${common_sources})
|
||||||
add_threads (test-${name})
|
add_threads (test-${name})
|
||||||
target_link_libraries (test-${name} ${common_libraries})
|
target_link_libraries (test-${name} ${common_libraries})
|
||||||
add_test (NAME test-${name} COMMAND test-${name})
|
add_test (NAME test-${name} COMMAND test-${name})
|
||||||
endforeach ()
|
endforeach (name)
|
||||||
|
|||||||
2
LICENSE
2
LICENSE
@@ -1,4 +1,4 @@
|
|||||||
Copyright (c) 2014 - 2022, Přemysl Eric Janouch <p@janouch.name>
|
Copyright (c) 2014 - 2020, Přemysl Eric Janouch <p@janouch.name>
|
||||||
|
|
||||||
Permission to use, copy, modify, and/or distribute this software for any
|
Permission to use, copy, modify, and/or distribute this software for any
|
||||||
purpose with or without fee is hereby granted.
|
purpose with or without fee is hereby granted.
|
||||||
|
|||||||
@@ -148,7 +148,7 @@ irc_free_message (struct irc_message *msg)
|
|||||||
|
|
||||||
static void
|
static void
|
||||||
irc_process_buffer (struct str *buf,
|
irc_process_buffer (struct str *buf,
|
||||||
void (*callback) (const struct irc_message *, const char *, void *),
|
void (*callback)(const struct irc_message *, const char *, void *),
|
||||||
void *user_data)
|
void *user_data)
|
||||||
{
|
{
|
||||||
char *start = buf->str, *end = start + buf->len;
|
char *start = buf->str, *end = start + buf->len;
|
||||||
@@ -507,7 +507,7 @@ http_parse_upgrade (const char *upgrade, struct http_protocol **out)
|
|||||||
case HTTP_T_WHITESPACE:
|
case HTTP_T_WHITESPACE:
|
||||||
break;
|
break;
|
||||||
case HTTP_T_TOKEN:
|
case HTTP_T_TOKEN:
|
||||||
proto = xcalloc (1, sizeof *proto);
|
proto = (struct http_protocol *) xcalloc (1, sizeof *proto);
|
||||||
proto->name = xstrdup (t.string.str);
|
proto->name = xstrdup (t.string.str);
|
||||||
LIST_APPEND_WITH_TAIL (list, tail, proto);
|
LIST_APPEND_WITH_TAIL (list, tail, proto);
|
||||||
state = STATE_SLASH;
|
state = STATE_SLASH;
|
||||||
@@ -1002,7 +1002,7 @@ fcgi_nv_parser_push (struct fcgi_nv_parser *self, const void *data, size_t len)
|
|||||||
if (self->input.len < self->name_len)
|
if (self->input.len < self->name_len)
|
||||||
return;
|
return;
|
||||||
|
|
||||||
self->name = xmalloc (self->name_len + 1);
|
self->name = (char *) xmalloc (self->name_len + 1);
|
||||||
self->name[self->name_len] = '\0';
|
self->name[self->name_len] = '\0';
|
||||||
memcpy (self->name, self->input.str, self->name_len);
|
memcpy (self->name, self->input.str, self->name_len);
|
||||||
str_remove_slice (&self->input, 0, self->name_len);
|
str_remove_slice (&self->input, 0, self->name_len);
|
||||||
@@ -1012,7 +1012,7 @@ fcgi_nv_parser_push (struct fcgi_nv_parser *self, const void *data, size_t len)
|
|||||||
if (self->input.len < self->value_len)
|
if (self->input.len < self->value_len)
|
||||||
return;
|
return;
|
||||||
|
|
||||||
self->value = xmalloc (self->value_len + 1);
|
self->value = (char *) xmalloc (self->value_len + 1);
|
||||||
self->value[self->value_len] = '\0';
|
self->value[self->value_len] = '\0';
|
||||||
memcpy (self->value, self->input.str, self->value_len);
|
memcpy (self->value, self->input.str, self->value_len);
|
||||||
str_remove_slice (&self->input, 0, self->value_len);
|
str_remove_slice (&self->input, 0, self->value_len);
|
||||||
@@ -1050,7 +1050,7 @@ fcgi_nv_convert (struct str_map *map, struct str *output)
|
|||||||
while (str_map_iter_next (&iter))
|
while (str_map_iter_next (&iter))
|
||||||
{
|
{
|
||||||
const char *name = iter.link->key;
|
const char *name = iter.link->key;
|
||||||
const char *value = iter.link->data;
|
const char *value = (const char *) iter.link->data;
|
||||||
size_t name_len = iter.link->key_length;
|
size_t name_len = iter.link->key_length;
|
||||||
size_t value_len = strlen (value);
|
size_t value_len = strlen (value);
|
||||||
|
|
||||||
@@ -1227,7 +1227,7 @@ ws_parser_push (struct ws_parser *self, const void *data, size_t len)
|
|||||||
self->reserved_1 = (u8 >> 6) & 1;
|
self->reserved_1 = (u8 >> 6) & 1;
|
||||||
self->reserved_2 = (u8 >> 5) & 1;
|
self->reserved_2 = (u8 >> 5) & 1;
|
||||||
self->reserved_3 = (u8 >> 4) & 1;
|
self->reserved_3 = (u8 >> 4) & 1;
|
||||||
self->opcode = u8 & 15;
|
self->opcode = (enum ws_opcode) (u8 & 15);
|
||||||
|
|
||||||
(void) msg_unpacker_u8 (&unpacker, &u8);
|
(void) msg_unpacker_u8 (&unpacker, &u8);
|
||||||
self->is_masked = (u8 >> 7) & 1;
|
self->is_masked = (u8 >> 7) & 1;
|
||||||
@@ -1321,6 +1321,7 @@ enum mpd_subsystem
|
|||||||
#define XX(a, b, c) MPD_SUBSYSTEM_ ## a = (1 << b),
|
#define XX(a, b, c) MPD_SUBSYSTEM_ ## a = (1 << b),
|
||||||
MPD_SUBSYSTEM_TABLE (XX)
|
MPD_SUBSYSTEM_TABLE (XX)
|
||||||
#undef XX
|
#undef XX
|
||||||
|
MPD_SUBSYSTEM_MAX
|
||||||
};
|
};
|
||||||
|
|
||||||
static const char *mpd_subsystem_names[] =
|
static const char *mpd_subsystem_names[] =
|
||||||
@@ -1422,9 +1423,9 @@ mpd_client_make (struct poller *poller)
|
|||||||
.socket = -1,
|
.socket = -1,
|
||||||
.read_buffer = str_make (),
|
.read_buffer = str_make (),
|
||||||
.write_buffer = str_make (),
|
.write_buffer = str_make (),
|
||||||
.data = strv_make (),
|
|
||||||
.socket_event = poller_fd_make (poller, -1),
|
.socket_event = poller_fd_make (poller, -1),
|
||||||
.timeout_timer = poller_timer_make (poller),
|
.timeout_timer = poller_timer_make (poller),
|
||||||
|
.data = strv_make (),
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -1463,7 +1464,7 @@ mpd_client_reset (struct mpd_client *self)
|
|||||||
{
|
{
|
||||||
// Get rid of all pending tasks to release resources etc.
|
// Get rid of all pending tasks to release resources etc.
|
||||||
strv_reset (&self->data);
|
strv_reset (&self->data);
|
||||||
struct mpd_response aborted = { .message_text = "Disconnected" };
|
struct mpd_response aborted = { .message_text = (char *) "Disconnected" };
|
||||||
while (self->tasks)
|
while (self->tasks)
|
||||||
mpd_client_dispatch (self, &aborted);
|
mpd_client_dispatch (self, &aborted);
|
||||||
|
|
||||||
@@ -1523,7 +1524,8 @@ mpd_client_parse_response (const char *p, struct mpd_response *response)
|
|||||||
if (errno != 0 || end == p)
|
if (errno != 0 || end == p)
|
||||||
return false;
|
return false;
|
||||||
p = end;
|
p = end;
|
||||||
if (*p++ != ']' || *p++ != ' ' || *p++ != '{' || !(end = strchr (p, '}')))
|
if (*p++ != ']' || *p++ != ' ' || *p++ != '{'
|
||||||
|
|| !(end = (char *) strchr (p, '}')))
|
||||||
return false;
|
return false;
|
||||||
|
|
||||||
response->current_command = xstrndup (p, end - p);
|
response->current_command = xstrndup (p, end - p);
|
||||||
@@ -1623,7 +1625,7 @@ mpd_client_on_ready (const struct pollfd *pfd, void *user_data)
|
|||||||
{
|
{
|
||||||
(void) pfd;
|
(void) pfd;
|
||||||
|
|
||||||
struct mpd_client *self = user_data;
|
struct mpd_client *self = (struct mpd_client *) user_data;
|
||||||
if (socket_io_try_read (self->socket, &self->read_buffer) != SOCKET_IO_OK
|
if (socket_io_try_read (self->socket, &self->read_buffer) != SOCKET_IO_OK
|
||||||
|| !mpd_client_process_input (self)
|
|| !mpd_client_process_input (self)
|
||||||
|| socket_io_try_write (self->socket, &self->write_buffer) != SOCKET_IO_OK)
|
|| socket_io_try_write (self->socket, &self->write_buffer) != SOCKET_IO_OK)
|
||||||
@@ -1675,7 +1677,8 @@ mpd_client_add_task
|
|||||||
// later flushed if an early ACK or OK arrives).
|
// later flushed if an early ACK or OK arrives).
|
||||||
hard_assert (!self->in_list);
|
hard_assert (!self->in_list);
|
||||||
|
|
||||||
struct mpd_client_task *task = xcalloc (1, sizeof *self);
|
struct mpd_client_task *task =
|
||||||
|
(struct mpd_client_task *) xcalloc (1, sizeof *self);
|
||||||
task->callback = cb;
|
task->callback = cb;
|
||||||
task->user_data = user_data;
|
task->user_data = user_data;
|
||||||
LIST_APPEND_WITH_TAIL (self->tasks, self->tasks_tail, task);
|
LIST_APPEND_WITH_TAIL (self->tasks, self->tasks_tail, task);
|
||||||
@@ -1793,7 +1796,7 @@ mpd_client_on_idle_return (const struct mpd_response *response,
|
|||||||
{
|
{
|
||||||
(void) response;
|
(void) response;
|
||||||
|
|
||||||
struct mpd_client *self = user_data;
|
struct mpd_client *self = (struct mpd_client *) user_data;
|
||||||
unsigned subsystems = 0;
|
unsigned subsystems = 0;
|
||||||
for (size_t i = 0; i < data->len; i++)
|
for (size_t i = 0; i < data->len; i++)
|
||||||
{
|
{
|
||||||
@@ -1816,7 +1819,7 @@ static void mpd_client_idle (struct mpd_client *self, unsigned subsystems);
|
|||||||
static void
|
static void
|
||||||
mpd_client_on_timeout (void *user_data)
|
mpd_client_on_timeout (void *user_data)
|
||||||
{
|
{
|
||||||
struct mpd_client *self = user_data;
|
struct mpd_client *self = (struct mpd_client *) user_data;
|
||||||
|
|
||||||
// Abort and immediately restore the current idle so that MPD doesn't
|
// Abort and immediately restore the current idle so that MPD doesn't
|
||||||
// disconnect us, even though the documentation says this won't happen.
|
// disconnect us, even though the documentation says this won't happen.
|
||||||
@@ -1884,7 +1887,7 @@ mpd_client_destroy_connector (struct mpd_client *self)
|
|||||||
static void
|
static void
|
||||||
mpd_client_on_connector_failure (void *user_data)
|
mpd_client_on_connector_failure (void *user_data)
|
||||||
{
|
{
|
||||||
struct mpd_client *self = user_data;
|
struct mpd_client *self = (struct mpd_client *) user_data;
|
||||||
mpd_client_destroy_connector (self);
|
mpd_client_destroy_connector (self);
|
||||||
mpd_client_fail (self);
|
mpd_client_fail (self);
|
||||||
}
|
}
|
||||||
@@ -1895,7 +1898,7 @@ mpd_client_on_connector_connected
|
|||||||
{
|
{
|
||||||
(void) host;
|
(void) host;
|
||||||
|
|
||||||
struct mpd_client *self = user_data;
|
struct mpd_client *self = (struct mpd_client *) user_data;
|
||||||
mpd_client_destroy_connector (self);
|
mpd_client_destroy_connector (self);
|
||||||
mpd_client_finish_connection (self, socket);
|
mpd_client_finish_connection (self, socket);
|
||||||
}
|
}
|
||||||
@@ -1939,7 +1942,8 @@ mpd_client_connect (struct mpd_client *self, const char *address,
|
|||||||
if (strchr (address, '/'))
|
if (strchr (address, '/'))
|
||||||
return mpd_client_connect_unix (self, address, e);
|
return mpd_client_connect_unix (self, address, e);
|
||||||
|
|
||||||
struct connector *connector = xmalloc (sizeof *connector);
|
struct connector *connector =
|
||||||
|
(struct connector *) xmalloc (sizeof *connector);
|
||||||
connector_init (connector, self->poller);
|
connector_init (connector, self->poller);
|
||||||
self->connector = connector;
|
self->connector = connector;
|
||||||
|
|
||||||
|
|||||||
348
liberty-pulse.c
348
liberty-pulse.c
@@ -1,348 +0,0 @@
|
|||||||
/*
|
|
||||||
* liberty-pulse.c: PulseAudio mainloop abstraction
|
|
||||||
*
|
|
||||||
* Copyright (c) 2016 - 2021, Přemysl Eric Janouch <p@janouch.name>
|
|
||||||
*
|
|
||||||
* Permission to use, copy, modify, and/or distribute this software for any
|
|
||||||
* purpose with or without fee is hereby granted.
|
|
||||||
*
|
|
||||||
* THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
|
|
||||||
* WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
|
|
||||||
* MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY
|
|
||||||
* SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
|
|
||||||
* WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION
|
|
||||||
* OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN
|
|
||||||
* CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
|
|
||||||
#include <pulse/mainloop.h>
|
|
||||||
|
|
||||||
// --- PulseAudio mainloop abstraction -----------------------------------------
|
|
||||||
|
|
||||||
struct pa_io_event
|
|
||||||
{
|
|
||||||
LIST_HEADER (pa_io_event)
|
|
||||||
|
|
||||||
pa_mainloop_api *api; ///< Parent structure
|
|
||||||
struct poller_fd fd; ///< Underlying FD event
|
|
||||||
|
|
||||||
pa_io_event_cb_t dispatch; ///< Dispatcher
|
|
||||||
pa_io_event_destroy_cb_t free; ///< Destroyer
|
|
||||||
void *user_data; ///< User data
|
|
||||||
};
|
|
||||||
|
|
||||||
struct pa_time_event
|
|
||||||
{
|
|
||||||
LIST_HEADER (pa_time_event)
|
|
||||||
|
|
||||||
pa_mainloop_api *api; ///< Parent structure
|
|
||||||
struct poller_timer timer; ///< Underlying timer event
|
|
||||||
|
|
||||||
pa_time_event_cb_t dispatch; ///< Dispatcher
|
|
||||||
pa_time_event_destroy_cb_t free; ///< Destroyer
|
|
||||||
void *user_data; ///< User data
|
|
||||||
};
|
|
||||||
|
|
||||||
struct pa_defer_event
|
|
||||||
{
|
|
||||||
LIST_HEADER (pa_defer_event)
|
|
||||||
|
|
||||||
pa_mainloop_api *api; ///< Parent structure
|
|
||||||
struct poller_idle idle; ///< Underlying idle event
|
|
||||||
|
|
||||||
pa_defer_event_cb_t dispatch; ///< Dispatcher
|
|
||||||
pa_defer_event_destroy_cb_t free; ///< Destroyer
|
|
||||||
void *user_data; ///< User data
|
|
||||||
};
|
|
||||||
|
|
||||||
struct poller_pa
|
|
||||||
{
|
|
||||||
struct poller *poller; ///< The underlying event loop
|
|
||||||
pa_io_event *io_list; ///< I/O events
|
|
||||||
pa_time_event *time_list; ///< Timer events
|
|
||||||
pa_defer_event *defer_list; ///< Deferred events
|
|
||||||
};
|
|
||||||
|
|
||||||
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
||||||
|
|
||||||
static short
|
|
||||||
poller_pa_flags_to_events (pa_io_event_flags_t flags)
|
|
||||||
{
|
|
||||||
short result = 0;
|
|
||||||
if (flags & PA_IO_EVENT_ERROR) result |= POLLERR;
|
|
||||||
if (flags & PA_IO_EVENT_HANGUP) result |= POLLHUP;
|
|
||||||
if (flags & PA_IO_EVENT_INPUT) result |= POLLIN;
|
|
||||||
if (flags & PA_IO_EVENT_OUTPUT) result |= POLLOUT;
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
|
|
||||||
static pa_io_event_flags_t
|
|
||||||
poller_pa_events_to_flags (short events)
|
|
||||||
{
|
|
||||||
pa_io_event_flags_t result = 0;
|
|
||||||
if (events & POLLERR) result |= PA_IO_EVENT_ERROR;
|
|
||||||
if (events & POLLHUP) result |= PA_IO_EVENT_HANGUP;
|
|
||||||
if (events & POLLIN) result |= PA_IO_EVENT_INPUT;
|
|
||||||
if (events & POLLOUT) result |= PA_IO_EVENT_OUTPUT;
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
|
|
||||||
static struct timeval
|
|
||||||
poller_pa_get_current_time (void)
|
|
||||||
{
|
|
||||||
struct timeval tv;
|
|
||||||
#ifdef _POSIX_TIMERS
|
|
||||||
struct timespec tp;
|
|
||||||
hard_assert (clock_gettime (CLOCK_REALTIME, &tp) != -1);
|
|
||||||
tv.tv_sec = tp.tv_sec;
|
|
||||||
tv.tv_usec = tp.tv_nsec / 1000;
|
|
||||||
#else
|
|
||||||
gettimeofday (&tv, NULL);
|
|
||||||
#endif
|
|
||||||
return tv;
|
|
||||||
}
|
|
||||||
|
|
||||||
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
||||||
|
|
||||||
static void
|
|
||||||
poller_pa_io_dispatcher (const struct pollfd *pfd, void *user_data)
|
|
||||||
{
|
|
||||||
pa_io_event *self = user_data;
|
|
||||||
self->dispatch (self->api, self,
|
|
||||||
pfd->fd, poller_pa_events_to_flags (pfd->revents), self->user_data);
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
poller_pa_io_enable (pa_io_event *self, pa_io_event_flags_t events)
|
|
||||||
{
|
|
||||||
struct poller_fd *fd = &self->fd;
|
|
||||||
if (events)
|
|
||||||
poller_fd_set (fd, poller_pa_flags_to_events (events));
|
|
||||||
else
|
|
||||||
poller_fd_reset (fd);
|
|
||||||
}
|
|
||||||
|
|
||||||
static pa_io_event *
|
|
||||||
poller_pa_io_new (pa_mainloop_api *api, int fd_, pa_io_event_flags_t events,
|
|
||||||
pa_io_event_cb_t cb, void *userdata)
|
|
||||||
{
|
|
||||||
pa_io_event *self = xcalloc (1, sizeof *self);
|
|
||||||
self->api = api;
|
|
||||||
self->dispatch = cb;
|
|
||||||
self->user_data = userdata;
|
|
||||||
|
|
||||||
struct poller_pa *data = api->userdata;
|
|
||||||
self->fd = poller_fd_make (data->poller, fd_);
|
|
||||||
self->fd.user_data = self;
|
|
||||||
self->fd.dispatcher = poller_pa_io_dispatcher;
|
|
||||||
|
|
||||||
// FIXME: under x2go PA tries to register twice for the same FD,
|
|
||||||
// which fails with our curent poller implementation;
|
|
||||||
// we could maintain a list of { poller_fd, listeners } structures;
|
|
||||||
// or maybe we're doing something wrong, which is yet to be determined
|
|
||||||
poller_pa_io_enable (self, events);
|
|
||||||
LIST_PREPEND (data->io_list, self);
|
|
||||||
return self;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
poller_pa_io_free (pa_io_event *self)
|
|
||||||
{
|
|
||||||
if (self->free)
|
|
||||||
self->free (self->api, self, self->user_data);
|
|
||||||
|
|
||||||
struct poller_pa *data = self->api->userdata;
|
|
||||||
poller_fd_reset (&self->fd);
|
|
||||||
LIST_UNLINK (data->io_list, self);
|
|
||||||
free (self);
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
poller_pa_io_set_destroy (pa_io_event *self, pa_io_event_destroy_cb_t cb)
|
|
||||||
{
|
|
||||||
self->free = cb;
|
|
||||||
}
|
|
||||||
|
|
||||||
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
||||||
|
|
||||||
static void
|
|
||||||
poller_pa_time_dispatcher (void *user_data)
|
|
||||||
{
|
|
||||||
pa_time_event *self = user_data;
|
|
||||||
// XXX: the meaning of the time argument is undocumented,
|
|
||||||
// so let's just put current Unix time in there
|
|
||||||
struct timeval now = poller_pa_get_current_time ();
|
|
||||||
self->dispatch (self->api, self, &now, self->user_data);
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
poller_pa_time_restart (pa_time_event *self, const struct timeval *tv)
|
|
||||||
{
|
|
||||||
struct poller_timer *timer = &self->timer;
|
|
||||||
if (tv)
|
|
||||||
{
|
|
||||||
struct timeval now = poller_pa_get_current_time ();
|
|
||||||
poller_timer_set (timer,
|
|
||||||
(tv->tv_sec - now.tv_sec) * 1000 +
|
|
||||||
(tv->tv_usec - now.tv_usec) / 1000);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
poller_timer_reset (timer);
|
|
||||||
}
|
|
||||||
|
|
||||||
static pa_time_event *
|
|
||||||
poller_pa_time_new (pa_mainloop_api *api, const struct timeval *tv,
|
|
||||||
pa_time_event_cb_t cb, void *userdata)
|
|
||||||
{
|
|
||||||
pa_time_event *self = xcalloc (1, sizeof *self);
|
|
||||||
self->api = api;
|
|
||||||
self->dispatch = cb;
|
|
||||||
self->user_data = userdata;
|
|
||||||
|
|
||||||
struct poller_pa *data = api->userdata;
|
|
||||||
self->timer = poller_timer_make (data->poller);
|
|
||||||
self->timer.user_data = self;
|
|
||||||
self->timer.dispatcher = poller_pa_time_dispatcher;
|
|
||||||
|
|
||||||
poller_pa_time_restart (self, tv);
|
|
||||||
LIST_PREPEND (data->time_list, self);
|
|
||||||
return self;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
poller_pa_time_free (pa_time_event *self)
|
|
||||||
{
|
|
||||||
if (self->free)
|
|
||||||
self->free (self->api, self, self->user_data);
|
|
||||||
|
|
||||||
struct poller_pa *data = self->api->userdata;
|
|
||||||
poller_timer_reset (&self->timer);
|
|
||||||
LIST_UNLINK (data->time_list, self);
|
|
||||||
free (self);
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
poller_pa_time_set_destroy (pa_time_event *self, pa_time_event_destroy_cb_t cb)
|
|
||||||
{
|
|
||||||
self->free = cb;
|
|
||||||
}
|
|
||||||
|
|
||||||
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
||||||
|
|
||||||
static void
|
|
||||||
poller_pa_defer_dispatcher (void *user_data)
|
|
||||||
{
|
|
||||||
pa_defer_event *self = user_data;
|
|
||||||
self->dispatch (self->api, self, self->user_data);
|
|
||||||
}
|
|
||||||
|
|
||||||
static pa_defer_event *
|
|
||||||
poller_pa_defer_new (pa_mainloop_api *api,
|
|
||||||
pa_defer_event_cb_t cb, void *userdata)
|
|
||||||
{
|
|
||||||
pa_defer_event *self = xcalloc (1, sizeof *self);
|
|
||||||
self->api = api;
|
|
||||||
self->dispatch = cb;
|
|
||||||
self->user_data = userdata;
|
|
||||||
|
|
||||||
struct poller_pa *data = api->userdata;
|
|
||||||
self->idle = poller_idle_make (data->poller);
|
|
||||||
self->idle.user_data = self;
|
|
||||||
self->idle.dispatcher = poller_pa_defer_dispatcher;
|
|
||||||
|
|
||||||
poller_idle_set (&self->idle);
|
|
||||||
LIST_PREPEND (data->defer_list, self);
|
|
||||||
return self;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
poller_pa_defer_enable (pa_defer_event *self, int enable)
|
|
||||||
{
|
|
||||||
struct poller_idle *idle = &self->idle;
|
|
||||||
if (enable)
|
|
||||||
poller_idle_set (idle);
|
|
||||||
else
|
|
||||||
poller_idle_reset (idle);
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
poller_pa_defer_free (pa_defer_event *self)
|
|
||||||
{
|
|
||||||
if (self->free)
|
|
||||||
self->free (self->api, self, self->user_data);
|
|
||||||
|
|
||||||
struct poller_pa *data = self->api->userdata;
|
|
||||||
poller_idle_reset (&self->idle);
|
|
||||||
LIST_UNLINK (data->defer_list, self);
|
|
||||||
free (self);
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
poller_pa_defer_set_destroy (pa_defer_event *self,
|
|
||||||
pa_defer_event_destroy_cb_t cb)
|
|
||||||
{
|
|
||||||
self->free = cb;
|
|
||||||
}
|
|
||||||
|
|
||||||
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
||||||
|
|
||||||
static void
|
|
||||||
poller_pa_quit (pa_mainloop_api *api, int retval)
|
|
||||||
{
|
|
||||||
(void) api;
|
|
||||||
(void) retval;
|
|
||||||
|
|
||||||
// This is not called from within libpulse
|
|
||||||
hard_assert (!"quitting the libpulse event loop is unimplemented");
|
|
||||||
}
|
|
||||||
|
|
||||||
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
||||||
|
|
||||||
static struct pa_mainloop_api g_poller_pa_template =
|
|
||||||
{
|
|
||||||
.io_new = poller_pa_io_new,
|
|
||||||
.io_enable = poller_pa_io_enable,
|
|
||||||
.io_free = poller_pa_io_free,
|
|
||||||
.io_set_destroy = poller_pa_io_set_destroy,
|
|
||||||
|
|
||||||
.time_new = poller_pa_time_new,
|
|
||||||
.time_restart = poller_pa_time_restart,
|
|
||||||
.time_free = poller_pa_time_free,
|
|
||||||
.time_set_destroy = poller_pa_time_set_destroy,
|
|
||||||
|
|
||||||
.defer_new = poller_pa_defer_new,
|
|
||||||
.defer_enable = poller_pa_defer_enable,
|
|
||||||
.defer_free = poller_pa_defer_free,
|
|
||||||
.defer_set_destroy = poller_pa_defer_set_destroy,
|
|
||||||
|
|
||||||
.quit = poller_pa_quit,
|
|
||||||
};
|
|
||||||
|
|
||||||
static struct pa_mainloop_api *
|
|
||||||
poller_pa_new (struct poller *self)
|
|
||||||
{
|
|
||||||
struct poller_pa *data = xcalloc (1, sizeof *data);
|
|
||||||
data->poller = self;
|
|
||||||
|
|
||||||
struct pa_mainloop_api *api = xmalloc (sizeof *api);
|
|
||||||
*api = g_poller_pa_template;
|
|
||||||
api->userdata = data;
|
|
||||||
return api;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
poller_pa_destroy (struct pa_mainloop_api *api)
|
|
||||||
{
|
|
||||||
struct poller_pa *data = api->userdata;
|
|
||||||
|
|
||||||
LIST_FOR_EACH (pa_io_event, iter, data->io_list)
|
|
||||||
poller_pa_io_free (iter);
|
|
||||||
LIST_FOR_EACH (pa_time_event, iter, data->time_list)
|
|
||||||
poller_pa_time_free (iter);
|
|
||||||
LIST_FOR_EACH (pa_defer_event, iter, data->defer_list)
|
|
||||||
poller_pa_defer_free (iter);
|
|
||||||
|
|
||||||
free (data);
|
|
||||||
free (api);
|
|
||||||
}
|
|
||||||
296
liberty.c
296
liberty.c
@@ -1,7 +1,7 @@
|
|||||||
/*
|
/*
|
||||||
* liberty.c: the ultimate C unlibrary
|
* liberty.c: the ultimate C unlibrary
|
||||||
*
|
*
|
||||||
* Copyright (c) 2014 - 2022, Přemysl Eric Janouch <p@janouch.name>
|
* Copyright (c) 2014 - 2020, Přemysl Eric Janouch <p@janouch.name>
|
||||||
*
|
*
|
||||||
* Permission to use, copy, modify, and/or distribute this software for any
|
* Permission to use, copy, modify, and/or distribute this software for any
|
||||||
* purpose with or without fee is hereby granted.
|
* purpose with or without fee is hereby granted.
|
||||||
@@ -117,7 +117,8 @@ extern char **environ;
|
|||||||
#define CONTAINER_OF(pointer, type, member) \
|
#define CONTAINER_OF(pointer, type, member) \
|
||||||
((type *) ((char *) pointer - offsetof (type, member)))
|
((type *) ((char *) pointer - offsetof (type, member)))
|
||||||
|
|
||||||
char *liberty = "They who can give up essential liberty to obtain a little "
|
const char *liberty =
|
||||||
|
"They who can give up essential liberty to obtain a little "
|
||||||
"temporary safety deserve neither liberty nor safety.";
|
"temporary safety deserve neither liberty nor safety.";
|
||||||
|
|
||||||
// --- Logging -----------------------------------------------------------------
|
// --- Logging -----------------------------------------------------------------
|
||||||
@@ -287,7 +288,7 @@ xreallocarray (void *o, size_t n, size_t m)
|
|||||||
static char *
|
static char *
|
||||||
xstrdup (const char *s)
|
xstrdup (const char *s)
|
||||||
{
|
{
|
||||||
return strcpy (xmalloc (strlen (s) + 1), s);
|
return strcpy ((char *) xmalloc (strlen (s) + 1), s);
|
||||||
}
|
}
|
||||||
|
|
||||||
static char *
|
static char *
|
||||||
@@ -297,7 +298,7 @@ xstrndup (const char *s, size_t n)
|
|||||||
if (n > size)
|
if (n > size)
|
||||||
n = size;
|
n = size;
|
||||||
|
|
||||||
char *copy = xmalloc (n + 1);
|
char *copy = (char *) xmalloc (n + 1);
|
||||||
memcpy (copy, s, n);
|
memcpy (copy, s, n);
|
||||||
copy[n] = '\0';
|
copy[n] = '\0';
|
||||||
return copy;
|
return copy;
|
||||||
@@ -310,14 +311,15 @@ xstrndup (const char *s, size_t n)
|
|||||||
#define ARRAY(type, name) type *name; size_t name ## _len, name ## _alloc;
|
#define ARRAY(type, name) type *name; size_t name ## _len, name ## _alloc;
|
||||||
#define ARRAY_INIT_SIZED(a, n) \
|
#define ARRAY_INIT_SIZED(a, n) \
|
||||||
BLOCK_START \
|
BLOCK_START \
|
||||||
(a) = xcalloc (sizeof *(a), (a ## _alloc) = (n)); \
|
(a) = (type *) xcalloc (sizeof *(a), (a ## _alloc) = (n)); \
|
||||||
(a ## _len) = 0; \
|
(a ## _len) = 0; \
|
||||||
BLOCK_END
|
BLOCK_END
|
||||||
#define ARRAY_INIT(a) ARRAY_INIT_SIZED (a, 16)
|
#define ARRAY_INIT(a) ARRAY_INIT_SIZED (a, 16)
|
||||||
#define ARRAY_RESERVE(a, n) \
|
#define ARRAY_RESERVE(a, n) \
|
||||||
BLOCK_START \
|
BLOCK_START \
|
||||||
while ((a ## _alloc) - (a ## _len) < n) \
|
while ((a ## _alloc) - (a ## _len) < n) \
|
||||||
(a) = xreallocarray ((a), sizeof *(a), (a ## _alloc) <<= 1); \
|
(a) = (type *) xreallocarray ((a), \
|
||||||
|
sizeof *(a), (a ## _alloc) <<= 1); \
|
||||||
BLOCK_END
|
BLOCK_END
|
||||||
|
|
||||||
// --- Double-linked list helpers ----------------------------------------------
|
// --- Double-linked list helpers ----------------------------------------------
|
||||||
@@ -392,7 +394,7 @@ strv_make (void)
|
|||||||
struct strv self;
|
struct strv self;
|
||||||
self.alloc = 4;
|
self.alloc = 4;
|
||||||
self.len = 0;
|
self.len = 0;
|
||||||
self.vector = xcalloc (sizeof *self.vector, self.alloc);
|
self.vector = (char **) xcalloc (sizeof *self.vector, self.alloc);
|
||||||
return self;
|
return self;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -419,7 +421,7 @@ strv_append_owned (struct strv *self, char *s)
|
|||||||
{
|
{
|
||||||
self->vector[self->len] = s;
|
self->vector[self->len] = s;
|
||||||
if (++self->len >= self->alloc)
|
if (++self->len >= self->alloc)
|
||||||
self->vector = xreallocarray (self->vector,
|
self->vector = (char **) xreallocarray (self->vector,
|
||||||
sizeof *self->vector, (self->alloc <<= 1));
|
sizeof *self->vector, (self->alloc <<= 1));
|
||||||
self->vector[self->len] = NULL;
|
self->vector[self->len] = NULL;
|
||||||
}
|
}
|
||||||
@@ -492,7 +494,7 @@ str_make (void)
|
|||||||
struct str self;
|
struct str self;
|
||||||
self.alloc = 16;
|
self.alloc = 16;
|
||||||
self.len = 0;
|
self.len = 0;
|
||||||
self.str = strcpy (xmalloc (self.alloc), "");
|
self.str = strcpy ((char *) xmalloc (self.alloc), "");
|
||||||
return self;
|
return self;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -529,7 +531,7 @@ str_reserve (struct str *self, size_t n)
|
|||||||
while (new_alloc <= self->len + n)
|
while (new_alloc <= self->len + n)
|
||||||
new_alloc <<= 1;
|
new_alloc <<= 1;
|
||||||
if (new_alloc != self->alloc)
|
if (new_alloc != self->alloc)
|
||||||
self->str = xrealloc (self->str, (self->alloc = new_alloc));
|
self->str = (char *) xrealloc (self->str, (self->alloc = new_alloc));
|
||||||
}
|
}
|
||||||
|
|
||||||
static void
|
static void
|
||||||
@@ -608,7 +610,7 @@ str_remove_slice (struct str *self, size_t start, size_t length)
|
|||||||
|
|
||||||
// Shrink the string if the allocation becomes way too large
|
// Shrink the string if the allocation becomes way too large
|
||||||
if (self->alloc >= STR_SHRINK_THRESHOLD && self->len < (self->alloc >> 2))
|
if (self->alloc >= STR_SHRINK_THRESHOLD && self->len < (self->alloc >> 2))
|
||||||
self->str = xrealloc (self->str, self->alloc >>= 2);
|
self->str = (char *) xrealloc (self->str, self->alloc >>= 2);
|
||||||
}
|
}
|
||||||
|
|
||||||
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
||||||
@@ -622,7 +624,11 @@ str_pack_u8 (struct str *self, uint8_t x)
|
|||||||
static void
|
static void
|
||||||
str_pack_u16 (struct str *self, uint16_t x)
|
str_pack_u16 (struct str *self, uint16_t x)
|
||||||
{
|
{
|
||||||
uint8_t tmp[2] = { x >> 8, x };
|
uint8_t tmp[2] =
|
||||||
|
{
|
||||||
|
(uint8_t) (x >> 8),
|
||||||
|
(uint8_t) x
|
||||||
|
};
|
||||||
str_append_data (self, tmp, sizeof tmp);
|
str_append_data (self, tmp, sizeof tmp);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -630,7 +636,13 @@ static void
|
|||||||
str_pack_u32 (struct str *self, uint32_t x)
|
str_pack_u32 (struct str *self, uint32_t x)
|
||||||
{
|
{
|
||||||
uint32_t u = x;
|
uint32_t u = x;
|
||||||
uint8_t tmp[4] = { u >> 24, u >> 16, u >> 8, u };
|
uint8_t tmp[4] =
|
||||||
|
{
|
||||||
|
(uint8_t) (u >> 24),
|
||||||
|
(uint8_t) (u >> 16),
|
||||||
|
(uint8_t) (u >> 8),
|
||||||
|
(uint8_t) u
|
||||||
|
};
|
||||||
str_append_data (self, tmp, sizeof tmp);
|
str_append_data (self, tmp, sizeof tmp);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -638,7 +650,16 @@ static void
|
|||||||
str_pack_u64 (struct str *self, uint64_t x)
|
str_pack_u64 (struct str *self, uint64_t x)
|
||||||
{
|
{
|
||||||
uint8_t tmp[8] =
|
uint8_t tmp[8] =
|
||||||
{ x >> 56, x >> 48, x >> 40, x >> 32, x >> 24, x >> 16, x >> 8, x };
|
{
|
||||||
|
(uint8_t) (x >> 56),
|
||||||
|
(uint8_t) (x >> 48),
|
||||||
|
(uint8_t) (x >> 40),
|
||||||
|
(uint8_t) (x >> 32),
|
||||||
|
(uint8_t) (x >> 24),
|
||||||
|
(uint8_t) (x >> 16),
|
||||||
|
(uint8_t) (x >> 8),
|
||||||
|
(uint8_t) x
|
||||||
|
};
|
||||||
str_append_data (self, tmp, sizeof tmp);
|
str_append_data (self, tmp, sizeof tmp);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -672,8 +693,8 @@ error_set (struct error **e, const char *message, ...)
|
|||||||
|
|
||||||
hard_assert (size >= 0);
|
hard_assert (size >= 0);
|
||||||
|
|
||||||
struct error *tmp = xmalloc (sizeof *tmp);
|
struct error *tmp = (struct error *) xmalloc (sizeof *tmp);
|
||||||
tmp->message = xmalloc (size + 1);
|
tmp->message = (char *) xmalloc (size + 1);
|
||||||
|
|
||||||
va_start (ap, message);
|
va_start (ap, message);
|
||||||
size = vsnprintf (tmp->message, size + 1, message, ap);
|
size = vsnprintf (tmp->message, size + 1, message, ap);
|
||||||
@@ -778,7 +799,7 @@ random_bytes (void *output, size_t len, struct error **e)
|
|||||||
|
|
||||||
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
||||||
|
|
||||||
static unsigned char g_siphash_key[16] = "SipHash 2-4 key!";
|
static unsigned char g_siphash_key[16] = "SipHash 2-4 key" /* \0 */;
|
||||||
|
|
||||||
static inline void
|
static inline void
|
||||||
siphash_wrapper_randomize (void)
|
siphash_wrapper_randomize (void)
|
||||||
@@ -790,7 +811,7 @@ siphash_wrapper_randomize (void)
|
|||||||
static inline uint64_t
|
static inline uint64_t
|
||||||
siphash_wrapper (const void *m, size_t len)
|
siphash_wrapper (const void *m, size_t len)
|
||||||
{
|
{
|
||||||
return siphash (g_siphash_key, m, len);
|
return siphash (g_siphash_key, (const unsigned char *) m, len);
|
||||||
}
|
}
|
||||||
|
|
||||||
// --- String hash map ---------------------------------------------------------
|
// --- String hash map ---------------------------------------------------------
|
||||||
@@ -832,7 +853,7 @@ str_map_make (str_map_free_fn free)
|
|||||||
self.len = 0;
|
self.len = 0;
|
||||||
self.free = free;
|
self.free = free;
|
||||||
self.key_xfrm = NULL;
|
self.key_xfrm = NULL;
|
||||||
self.map = xcalloc (self.alloc, sizeof *self.map);
|
self.map = (struct str_map_link **) xcalloc (self.alloc, sizeof *self.map);
|
||||||
self.shrink_lock = false;
|
self.shrink_lock = false;
|
||||||
return self;
|
return self;
|
||||||
}
|
}
|
||||||
@@ -888,7 +909,8 @@ str_map_resize (struct str_map *self, size_t new_size)
|
|||||||
size_t mask = new_size - 1;
|
size_t mask = new_size - 1;
|
||||||
|
|
||||||
self->alloc = new_size;
|
self->alloc = new_size;
|
||||||
self->map = xcalloc (self->alloc, sizeof *self->map);
|
self->map =
|
||||||
|
(struct str_map_link **) xcalloc (self->alloc, sizeof *self->map);
|
||||||
for (i = 0; i < old_size; i++)
|
for (i = 0; i < old_size; i++)
|
||||||
{
|
{
|
||||||
struct str_map_link *iter = old_map[i], *next_iter;
|
struct str_map_link *iter = old_map[i], *next_iter;
|
||||||
@@ -958,7 +980,8 @@ str_map_set_real (struct str_map *self, const char *key, void *value)
|
|||||||
|
|
||||||
// Link in a new element for the given <key, value> pair
|
// Link in a new element for the given <key, value> pair
|
||||||
size_t key_length = strlen (key);
|
size_t key_length = strlen (key);
|
||||||
struct str_map_link *link = xmalloc (sizeof *link + key_length + 1);
|
struct str_map_link *link =
|
||||||
|
(struct str_map_link *) xmalloc (sizeof *link + key_length + 1);
|
||||||
link->data = value;
|
link->data = value;
|
||||||
link->key_length = key_length;
|
link->key_length = key_length;
|
||||||
memcpy (link->key, key, key_length + 1);
|
memcpy (link->key, key, key_length + 1);
|
||||||
@@ -1161,7 +1184,7 @@ async_cancel (struct async *self)
|
|||||||
static void
|
static void
|
||||||
async_cleanup (void *user_data)
|
async_cleanup (void *user_data)
|
||||||
{
|
{
|
||||||
struct async *self = user_data;
|
struct async *self = (struct async *) user_data;
|
||||||
|
|
||||||
hard_assert (!pthread_mutex_lock (&self->manager->lock));
|
hard_assert (!pthread_mutex_lock (&self->manager->lock));
|
||||||
LIST_UNLINK (self->manager->running, self);
|
LIST_UNLINK (self->manager->running, self);
|
||||||
@@ -1177,7 +1200,7 @@ async_routine (void *user_data)
|
|||||||
{
|
{
|
||||||
// Beware that we mustn't trigger any cancellation point before we set up
|
// Beware that we mustn't trigger any cancellation point before we set up
|
||||||
// the cleanup handler, otherwise we'd need to disable it first
|
// the cleanup handler, otherwise we'd need to disable it first
|
||||||
struct async *self = user_data;
|
struct async *self = (struct async *) user_data;
|
||||||
pthread_cleanup_push (async_cleanup, self);
|
pthread_cleanup_push (async_cleanup, self);
|
||||||
|
|
||||||
self->execute (self);
|
self->execute (self);
|
||||||
@@ -1386,7 +1409,8 @@ poller_timers_make (void)
|
|||||||
struct poller_timers self;
|
struct poller_timers self;
|
||||||
self.alloc = POLLER_MIN_ALLOC;
|
self.alloc = POLLER_MIN_ALLOC;
|
||||||
self.len = 0;
|
self.len = 0;
|
||||||
self.heap = xmalloc (self.alloc * sizeof *self.heap);
|
self.heap =
|
||||||
|
(struct poller_timer **) xmalloc (self.alloc * sizeof *self.heap);
|
||||||
return self;
|
return self;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -1496,7 +1520,7 @@ poller_timers_set (struct poller_timers *self, struct poller_timer *timer)
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (self->len == self->alloc)
|
if (self->len == self->alloc)
|
||||||
self->heap = xreallocarray (self->heap,
|
self->heap = (struct poller_timer **) xreallocarray (self->heap,
|
||||||
self->alloc <<= 1, sizeof *self->heap);
|
self->alloc <<= 1, sizeof *self->heap);
|
||||||
self->heap[self->len] = timer;
|
self->heap[self->len] = timer;
|
||||||
timer->index = self->len;
|
timer->index = self->len;
|
||||||
@@ -1573,9 +1597,10 @@ poller_init (struct poller *self)
|
|||||||
|
|
||||||
self->len = 0;
|
self->len = 0;
|
||||||
self->alloc = POLLER_MIN_ALLOC;
|
self->alloc = POLLER_MIN_ALLOC;
|
||||||
self->fds = xcalloc (self->alloc, sizeof *self->fds);
|
self->fds = (struct poller_fd **) xcalloc (self->alloc, sizeof *self->fds);
|
||||||
self->dummy = xcalloc (self->alloc, sizeof *self->dummy);
|
self->dummy = (int *) xcalloc (self->alloc, sizeof *self->dummy);
|
||||||
self->revents = xcalloc (self->alloc, sizeof *self->revents);
|
self->revents = (struct epoll_event *)
|
||||||
|
xcalloc (self->alloc, sizeof *self->revents);
|
||||||
self->revents_len = 0;
|
self->revents_len = 0;
|
||||||
|
|
||||||
poller_common_init (&self->common, self);
|
poller_common_init (&self->common, self);
|
||||||
@@ -1588,7 +1613,7 @@ poller_free (struct poller *self)
|
|||||||
{
|
{
|
||||||
struct poller_fd *fd = self->fds[i];
|
struct poller_fd *fd = self->fds[i];
|
||||||
hard_assert (epoll_ctl (self->epoll_fd,
|
hard_assert (epoll_ctl (self->epoll_fd,
|
||||||
EPOLL_CTL_DEL, fd->fd, (void *) "") != -1);
|
EPOLL_CTL_DEL, fd->fd, (struct epoll_event *) "") != -1);
|
||||||
}
|
}
|
||||||
|
|
||||||
poller_common_free (&self->common);
|
poller_common_free (&self->common);
|
||||||
@@ -1608,11 +1633,11 @@ poller_ensure_space (struct poller *self)
|
|||||||
self->alloc <<= 1;
|
self->alloc <<= 1;
|
||||||
hard_assert (self->alloc != 0);
|
hard_assert (self->alloc != 0);
|
||||||
|
|
||||||
self->revents = xreallocarray
|
self->revents = (struct epoll_event *) xreallocarray
|
||||||
(self->revents, sizeof *self->revents, self->alloc);
|
(self->revents, sizeof *self->revents, self->alloc);
|
||||||
self->fds = xreallocarray
|
self->fds = (struct poller_fd **) xreallocarray
|
||||||
(self->fds, sizeof *self->fds, self->alloc);
|
(self->fds, sizeof *self->fds, self->alloc);
|
||||||
self->dummy = xreallocarray
|
self->dummy = (int *) xreallocarray
|
||||||
(self->dummy, sizeof *self->dummy, self->alloc);
|
(self->dummy, sizeof *self->dummy, self->alloc);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -1664,8 +1689,12 @@ poller_set (struct poller *self, struct poller_fd *fd)
|
|||||||
static int
|
static int
|
||||||
poller_compare_fds (const void *ax, const void *bx)
|
poller_compare_fds (const void *ax, const void *bx)
|
||||||
{
|
{
|
||||||
const struct epoll_event *ay = ax, *by = bx;
|
const struct epoll_event
|
||||||
struct poller_fd *a = ay->data.ptr, *b = by->data.ptr;
|
*ay = (const struct epoll_event *) ax,
|
||||||
|
*by = (const struct epoll_event *) bx;
|
||||||
|
struct poller_fd
|
||||||
|
*a = (struct poller_fd *) ay->data.ptr,
|
||||||
|
*b = (struct poller_fd *) by->data.ptr;
|
||||||
return a->fd - b->fd;
|
return a->fd - b->fd;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -1676,7 +1705,7 @@ poller_remove_from_dispatch (struct poller *self, const struct poller_fd *fd)
|
|||||||
return;
|
return;
|
||||||
|
|
||||||
struct epoll_event key = { .data.ptr = (void *) fd }, *fd_event;
|
struct epoll_event key = { .data.ptr = (void *) fd }, *fd_event;
|
||||||
if ((fd_event = bsearch (&key, self->revents,
|
if ((fd_event = (struct epoll_event *) bsearch (&key, self->revents,
|
||||||
self->revents_len, sizeof *self->revents, poller_compare_fds)))
|
self->revents_len, sizeof *self->revents, poller_compare_fds)))
|
||||||
{
|
{
|
||||||
fd_event->events = -1;
|
fd_event->events = -1;
|
||||||
@@ -1699,7 +1728,7 @@ poller_remove_at_index (struct poller *self, size_t index)
|
|||||||
poller_remove_from_dispatch (self, fd);
|
poller_remove_from_dispatch (self, fd);
|
||||||
if (!fd->closed)
|
if (!fd->closed)
|
||||||
hard_assert (epoll_ctl (self->epoll_fd,
|
hard_assert (epoll_ctl (self->epoll_fd,
|
||||||
EPOLL_CTL_DEL, fd->fd, (void *) "") != -1);
|
EPOLL_CTL_DEL, fd->fd, (struct epoll_event *) "") != -1);
|
||||||
|
|
||||||
if (index != --self->len)
|
if (index != --self->len)
|
||||||
{
|
{
|
||||||
@@ -1735,7 +1764,7 @@ poller_run (struct poller *self)
|
|||||||
if (revents->events == (uint32_t) -1)
|
if (revents->events == (uint32_t) -1)
|
||||||
continue;
|
continue;
|
||||||
|
|
||||||
struct poller_fd *fd = revents->data.ptr;
|
struct poller_fd *fd = (struct poller_fd *) revents->data.ptr;
|
||||||
hard_assert (fd->index != -1);
|
hard_assert (fd->index != -1);
|
||||||
|
|
||||||
struct pollfd pfd;
|
struct pollfd pfd;
|
||||||
@@ -1749,9 +1778,10 @@ poller_run (struct poller *self)
|
|||||||
self->revents_len = 0;
|
self->revents_len = 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Sort of similar to the epoll version. Let's hope Darwin isn't broken,
|
#elif defined (BSD)
|
||||||
// that'd mean reimplementing this in terms of select() just because of Crapple.
|
|
||||||
#elif defined (BSD) || defined (__APPLE__)
|
// Mac OS X's kqueue is fatally broken, or so I've been told; leaving it out.
|
||||||
|
// Otherwise this is sort of similar to the epoll version.
|
||||||
|
|
||||||
#include <sys/types.h>
|
#include <sys/types.h>
|
||||||
#include <sys/event.h>
|
#include <sys/event.h>
|
||||||
@@ -1777,8 +1807,9 @@ poller_init (struct poller *self)
|
|||||||
|
|
||||||
self->len = 0;
|
self->len = 0;
|
||||||
self->alloc = POLLER_MIN_ALLOC;
|
self->alloc = POLLER_MIN_ALLOC;
|
||||||
self->fds = xcalloc (self->alloc, sizeof *self->fds);
|
self->fds = (struct poller_fd **) xcalloc (self->alloc, sizeof *self->fds);
|
||||||
self->revents = xcalloc (self->alloc, sizeof *self->revents);
|
self->revents = (struct kevent *)
|
||||||
|
xcalloc (self->alloc, sizeof *self->revents);
|
||||||
self->revents_len = 0;
|
self->revents_len = 0;
|
||||||
poller_common_init (&self->common, self);
|
poller_common_init (&self->common, self);
|
||||||
}
|
}
|
||||||
@@ -1801,9 +1832,9 @@ poller_ensure_space (struct poller *self)
|
|||||||
self->alloc <<= 1;
|
self->alloc <<= 1;
|
||||||
hard_assert (self->alloc != 0);
|
hard_assert (self->alloc != 0);
|
||||||
|
|
||||||
self->revents = xreallocarray
|
self->revents = (struct kevent *) xreallocarray
|
||||||
(self->revents, sizeof *self->revents, self->alloc);
|
(self->revents, sizeof *self->revents, self->alloc);
|
||||||
self->fds = xreallocarray
|
self->fds = (struct poller_fd **) xreallocarray
|
||||||
(self->fds, sizeof *self->fds, self->alloc);
|
(self->fds, sizeof *self->fds, self->alloc);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -2003,8 +2034,9 @@ poller_init (struct poller *self)
|
|||||||
{
|
{
|
||||||
self->alloc = POLLER_MIN_ALLOC;
|
self->alloc = POLLER_MIN_ALLOC;
|
||||||
self->len = 0;
|
self->len = 0;
|
||||||
self->fds = xcalloc (self->alloc, sizeof *self->fds);
|
self->fds = (struct pollfd **) xcalloc (self->alloc, sizeof *self->fds);
|
||||||
self->fds_data = xcalloc (self->alloc, sizeof *self->fds_data);
|
self->fds_data = (struct poller_fd **)
|
||||||
|
xcalloc (self->alloc, sizeof *self->fds_data);
|
||||||
poller_common_init (&self->common, self);
|
poller_common_init (&self->common, self);
|
||||||
self->dispatch_next = -1;
|
self->dispatch_next = -1;
|
||||||
}
|
}
|
||||||
@@ -2024,8 +2056,9 @@ poller_ensure_space (struct poller *self)
|
|||||||
return;
|
return;
|
||||||
|
|
||||||
self->alloc <<= 1;
|
self->alloc <<= 1;
|
||||||
self->fds = xreallocarray (self->fds, sizeof *self->fds, self->alloc);
|
self->fds = (struct pollfd *)
|
||||||
self->fds_data = xreallocarray
|
xreallocarray (self->fds, sizeof *self->fds, self->alloc);
|
||||||
|
self->fds_data = (struct poller_fd **) xreallocarray
|
||||||
(self->fds_data, sizeof *self->fds_data, self->alloc);
|
(self->fds_data, sizeof *self->fds_data, self->alloc);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -2309,7 +2342,8 @@ static struct async_getaddrinfo *
|
|||||||
async_getaddrinfo (struct async_manager *manager,
|
async_getaddrinfo (struct async_manager *manager,
|
||||||
const char *host, const char *service, const struct addrinfo *hints)
|
const char *host, const char *service, const struct addrinfo *hints)
|
||||||
{
|
{
|
||||||
struct async_getaddrinfo *self = xcalloc (1, sizeof *self);
|
struct async_getaddrinfo *self =
|
||||||
|
(struct async_getaddrinfo *) xcalloc (1, sizeof *self);
|
||||||
self->async = async_make (manager);
|
self->async = async_make (manager);
|
||||||
|
|
||||||
if (host) self->host = xstrdup (host);
|
if (host) self->host = xstrdup (host);
|
||||||
@@ -2373,10 +2407,11 @@ static struct async_getnameinfo *
|
|||||||
async_getnameinfo (struct async_manager *manager,
|
async_getnameinfo (struct async_manager *manager,
|
||||||
const struct sockaddr *sa, socklen_t sa_len, int flags)
|
const struct sockaddr *sa, socklen_t sa_len, int flags)
|
||||||
{
|
{
|
||||||
struct async_getnameinfo *self = xcalloc (1, sizeof *self);
|
struct async_getnameinfo *self =
|
||||||
|
(struct async_getnameinfo *) xcalloc (1, sizeof *self);
|
||||||
self->async = async_make (manager);
|
self->async = async_make (manager);
|
||||||
|
|
||||||
self->address = memcpy (xmalloc (sa_len), sa, sa_len);
|
self->address = (struct sockaddr *) memcpy (xmalloc (sa_len), sa, sa_len);
|
||||||
self->address_len = sa_len;
|
self->address_len = sa_len;
|
||||||
self->flags = flags;
|
self->flags = flags;
|
||||||
|
|
||||||
@@ -2541,7 +2576,12 @@ struct msg_unpacker
|
|||||||
static struct msg_unpacker
|
static struct msg_unpacker
|
||||||
msg_unpacker_make (const void *data, size_t len)
|
msg_unpacker_make (const void *data, size_t len)
|
||||||
{
|
{
|
||||||
return (struct msg_unpacker) { .data = data, .len = len, .offset = 0 };
|
return (struct msg_unpacker)
|
||||||
|
{
|
||||||
|
.data = (const char *) data,
|
||||||
|
.offset = 0,
|
||||||
|
.len = len
|
||||||
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
static size_t
|
static size_t
|
||||||
@@ -2630,8 +2670,16 @@ msg_writer_flush (struct msg_writer *self, size_t *len)
|
|||||||
{
|
{
|
||||||
// Update the message length
|
// Update the message length
|
||||||
uint64_t x = self->buf.len;
|
uint64_t x = self->buf.len;
|
||||||
uint8_t tmp[8] =
|
uint8_t tmp[8] = {
|
||||||
{ x >> 56, x >> 48, x >> 40, x >> 32, x >> 24, x >> 16, x >> 8, x };
|
(uint8_t) (x >> 56),
|
||||||
|
(uint8_t) (x >> 48),
|
||||||
|
(uint8_t) (x >> 40),
|
||||||
|
(uint8_t) (x >> 32),
|
||||||
|
(uint8_t) (x >> 24),
|
||||||
|
(uint8_t) (x >> 16),
|
||||||
|
(uint8_t) (x >> 8),
|
||||||
|
(uint8_t) x
|
||||||
|
};
|
||||||
memcpy (self->buf.str, tmp, sizeof tmp);
|
memcpy (self->buf.str, tmp, sizeof tmp);
|
||||||
|
|
||||||
*len = x;
|
*len = x;
|
||||||
@@ -2747,12 +2795,16 @@ utf8_decode (const char **s, size_t len)
|
|||||||
}
|
}
|
||||||
|
|
||||||
// In the middle of a character
|
// In the middle of a character
|
||||||
// or an overlong sequence (subset, possibly MUTF-8, not supported)
|
if (sequence_len == 1)
|
||||||
if (sequence_len == 1 || *p == 0xC0 || *p == 0xC1)
|
|
||||||
return -1;
|
return -1;
|
||||||
|
|
||||||
// Check the rest of the sequence
|
// Check the rest of the sequence
|
||||||
uint32_t cp = *p++ & ~mask;
|
uint32_t cp = *p++ & ~mask;
|
||||||
|
|
||||||
|
// Overlong sequence (possibly MUTF-8, not supported)
|
||||||
|
if (!cp && sequence_len)
|
||||||
|
return -1;
|
||||||
|
|
||||||
while (sequence_len && --sequence_len)
|
while (sequence_len && --sequence_len)
|
||||||
{
|
{
|
||||||
if (p == end)
|
if (p == end)
|
||||||
@@ -2906,7 +2958,7 @@ base64_encode (const void *data, size_t len, struct str *output)
|
|||||||
const char *alphabet =
|
const char *alphabet =
|
||||||
"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";
|
"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";
|
||||||
|
|
||||||
const uint8_t *p = data;
|
const uint8_t *p = (const uint8_t *) data;
|
||||||
size_t n_groups = len / 3;
|
size_t n_groups = len / 3;
|
||||||
size_t tail = len - n_groups * 3;
|
size_t tail = len - n_groups * 3;
|
||||||
uint32_t group;
|
uint32_t group;
|
||||||
@@ -2943,10 +2995,10 @@ base64_encode (const void *data, size_t len, struct str *output)
|
|||||||
// --- Utilities ---------------------------------------------------------------
|
// --- Utilities ---------------------------------------------------------------
|
||||||
|
|
||||||
static void
|
static void
|
||||||
cstr_set (char **s, char *new)
|
cstr_set (char **s, char *new_)
|
||||||
{
|
{
|
||||||
free (*s);
|
free (*s);
|
||||||
*s = new;
|
*s = new_;
|
||||||
}
|
}
|
||||||
|
|
||||||
static void
|
static void
|
||||||
@@ -3024,7 +3076,7 @@ iconv_xstrdup (iconv_t conv, char *in, size_t in_len, size_t *out_len)
|
|||||||
char *buf, *buf_ptr;
|
char *buf, *buf_ptr;
|
||||||
size_t out_left, buf_alloc;
|
size_t out_left, buf_alloc;
|
||||||
|
|
||||||
buf = buf_ptr = xmalloc (out_left = buf_alloc = 64);
|
buf = buf_ptr = (char *) xmalloc (out_left = buf_alloc = 64);
|
||||||
|
|
||||||
char *in_ptr = in;
|
char *in_ptr = in;
|
||||||
if (in_len == (size_t) -1)
|
if (in_len == (size_t) -1)
|
||||||
@@ -3040,7 +3092,7 @@ iconv_xstrdup (iconv_t conv, char *in, size_t in_len, size_t *out_len)
|
|||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
out_left += buf_alloc;
|
out_left += buf_alloc;
|
||||||
char *new_buf = xrealloc (buf, buf_alloc <<= 1);
|
char *new_buf = (char *) xrealloc (buf, buf_alloc <<= 1);
|
||||||
buf_ptr += new_buf - buf;
|
buf_ptr += new_buf - buf;
|
||||||
buf = new_buf;
|
buf = new_buf;
|
||||||
}
|
}
|
||||||
@@ -3121,8 +3173,8 @@ lock_pid_file (const char *path, struct error **e)
|
|||||||
struct flock lock =
|
struct flock lock =
|
||||||
{
|
{
|
||||||
.l_type = F_WRLCK,
|
.l_type = F_WRLCK,
|
||||||
.l_start = 0,
|
|
||||||
.l_whence = SEEK_SET,
|
.l_whence = SEEK_SET,
|
||||||
|
.l_start = 0,
|
||||||
.l_len = 0,
|
.l_len = 0,
|
||||||
};
|
};
|
||||||
if (fcntl (fd, F_SETLK, &lock))
|
if (fcntl (fd, F_SETLK, &lock))
|
||||||
@@ -3246,7 +3298,7 @@ get_xdg_config_dirs (struct strv *out)
|
|||||||
str_free (&config_home);
|
str_free (&config_home);
|
||||||
|
|
||||||
const char *xdg_config_dirs;
|
const char *xdg_config_dirs;
|
||||||
if (!(xdg_config_dirs = getenv ("XDG_CONFIG_DIRS")) || !*xdg_config_dirs)
|
if (!(xdg_config_dirs = getenv ("XDG_CONFIG_DIRS")))
|
||||||
xdg_config_dirs = "/etc/xdg";
|
xdg_config_dirs = "/etc/xdg";
|
||||||
cstr_split (xdg_config_dirs, ":", true, out);
|
cstr_split (xdg_config_dirs, ":", true, out);
|
||||||
}
|
}
|
||||||
@@ -3271,7 +3323,7 @@ get_xdg_data_dirs (struct strv *out)
|
|||||||
str_free (&data_home);
|
str_free (&data_home);
|
||||||
|
|
||||||
const char *xdg_data_dirs;
|
const char *xdg_data_dirs;
|
||||||
if (!(xdg_data_dirs = getenv ("XDG_DATA_DIRS")) || !*xdg_data_dirs)
|
if (!(xdg_data_dirs = getenv ("XDG_DATA_DIRS")))
|
||||||
xdg_data_dirs = "/usr/local/share/:/usr/share/";
|
xdg_data_dirs = "/usr/local/share/:/usr/share/";
|
||||||
cstr_split (xdg_data_dirs, ":", true, out);
|
cstr_split (xdg_data_dirs, ":", true, out);
|
||||||
}
|
}
|
||||||
@@ -3321,7 +3373,7 @@ resolve_relative_runtime_filename (const char *filename)
|
|||||||
/// path can reside in a system-wide directory with no risk of a conflict.
|
/// path can reside in a system-wide directory with no risk of a conflict.
|
||||||
/// However, we have to take care about permissions. Do we even need this?
|
/// However, we have to take care about permissions. Do we even need this?
|
||||||
static char *
|
static char *
|
||||||
resolve_relative_runtime_template (const char *template)
|
resolve_relative_runtime_template (const char *template_)
|
||||||
{
|
{
|
||||||
struct str path = str_make ();
|
struct str path = str_make ();
|
||||||
const char *runtime_dir = getenv ("XDG_RUNTIME_DIR");
|
const char *runtime_dir = getenv ("XDG_RUNTIME_DIR");
|
||||||
@@ -3333,7 +3385,7 @@ resolve_relative_runtime_template (const char *template)
|
|||||||
else
|
else
|
||||||
str_append_printf (&path, "/tmp/%s.%d", PROGRAM_NAME, geteuid ());
|
str_append_printf (&path, "/tmp/%s.%d", PROGRAM_NAME, geteuid ());
|
||||||
|
|
||||||
str_append_printf (&path, "/%s", template);
|
str_append_printf (&path, "/%s", template_);
|
||||||
return resolve_relative_runtime_filename_finish (path);
|
return resolve_relative_runtime_filename_finish (path);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -3355,9 +3407,9 @@ try_expand_tilde (const char *filename)
|
|||||||
struct passwd pwd, *success = NULL;
|
struct passwd pwd, *success = NULL;
|
||||||
|
|
||||||
char *user = xstrndup (filename, until_slash);
|
char *user = xstrndup (filename, until_slash);
|
||||||
char *buf = xmalloc (buf_len);
|
char *buf = (char *) xmalloc (buf_len);
|
||||||
while (getpwnam_r (user, &pwd, buf, buf_len, &success) == ERANGE)
|
while (getpwnam_r (user, &pwd, buf, buf_len, &success) == ERANGE)
|
||||||
buf = xrealloc (buf, buf_len <<= 1);
|
buf = (char *) xrealloc (buf, buf_len <<= 1);
|
||||||
free (user);
|
free (user);
|
||||||
|
|
||||||
char *result = NULL;
|
char *result = NULL;
|
||||||
@@ -3433,7 +3485,7 @@ xssl_get_error (SSL *ssl, int result, const char **error_info)
|
|||||||
static regex_t *
|
static regex_t *
|
||||||
regex_compile (const char *regex, int flags, struct error **e)
|
regex_compile (const char *regex, int flags, struct error **e)
|
||||||
{
|
{
|
||||||
regex_t *re = xmalloc (sizeof *re);
|
regex_t *re = (regex_t *) xmalloc (sizeof *re);
|
||||||
int err = regcomp (re, regex, flags);
|
int err = regcomp (re, regex, flags);
|
||||||
if (!err)
|
if (!err)
|
||||||
return re;
|
return re;
|
||||||
@@ -3449,7 +3501,7 @@ regex_compile (const char *regex, int flags, struct error **e)
|
|||||||
static void
|
static void
|
||||||
regex_free (void *regex)
|
regex_free (void *regex)
|
||||||
{
|
{
|
||||||
regfree (regex);
|
regfree ((regex_t *) regex);
|
||||||
free (regex);
|
free (regex);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -3468,7 +3520,7 @@ static bool
|
|||||||
regex_cache_match (struct str_map *cache, const char *regex, int flags,
|
regex_cache_match (struct str_map *cache, const char *regex, int flags,
|
||||||
const char *s, struct error **e)
|
const char *s, struct error **e)
|
||||||
{
|
{
|
||||||
regex_t *re = str_map_find (cache, regex);
|
regex_t *re = (regex_t *) str_map_find (cache, regex);
|
||||||
if (!re)
|
if (!re)
|
||||||
{
|
{
|
||||||
re = regex_compile (regex, flags, e);
|
re = regex_compile (regex, flags, e);
|
||||||
@@ -3738,7 +3790,7 @@ opt_handler_make (int argc, char **argv,
|
|||||||
|
|
||||||
self.opts = opts;
|
self.opts = opts;
|
||||||
self.opts_len = len;
|
self.opts_len = len;
|
||||||
self.options = xcalloc (len + 1, sizeof *self.options);
|
self.options = (struct option *) xcalloc (len + 1, sizeof *self.options);
|
||||||
|
|
||||||
struct str opt_string = str_make ();
|
struct str opt_string = str_make ();
|
||||||
for (size_t i = 0; i < len; i++)
|
for (size_t i = 0; i < len; i++)
|
||||||
@@ -3916,7 +3968,7 @@ test_add_internal (struct test *self, const char *name, size_t fixture_size,
|
|||||||
hard_assert (test != NULL);
|
hard_assert (test != NULL);
|
||||||
hard_assert (name != NULL);
|
hard_assert (name != NULL);
|
||||||
|
|
||||||
struct test_unit *unit = xcalloc (1, sizeof *unit);
|
struct test_unit *unit = (struct test_unit *) xcalloc (1, sizeof *unit);
|
||||||
unit->name = xstrdup (name);
|
unit->name = xstrdup (name);
|
||||||
unit->fixture_size = fixture_size;
|
unit->fixture_size = fixture_size;
|
||||||
unit->user_data = user_data;
|
unit->user_data = user_data;
|
||||||
@@ -4069,7 +4121,8 @@ struct connector_target
|
|||||||
static struct connector_target *
|
static struct connector_target *
|
||||||
connector_target_new (void)
|
connector_target_new (void)
|
||||||
{
|
{
|
||||||
struct connector_target *self = xcalloc (1, sizeof *self);
|
struct connector_target *self =
|
||||||
|
(struct connector_target *) xcalloc (1, sizeof *self);
|
||||||
return self;
|
return self;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -4282,7 +4335,7 @@ connector_free (struct connector *self)
|
|||||||
static void
|
static void
|
||||||
connector_on_getaddrinfo (int err, struct addrinfo *results, void *user_data)
|
connector_on_getaddrinfo (int err, struct addrinfo *results, void *user_data)
|
||||||
{
|
{
|
||||||
struct connector_target *self = user_data;
|
struct connector_target *self = (struct connector_target *) user_data;
|
||||||
|
|
||||||
if (err)
|
if (err)
|
||||||
{
|
{
|
||||||
@@ -4412,13 +4465,11 @@ socket_io_try_write (int socket_fd, struct str *wb)
|
|||||||
// object = lws '{' entries endobj
|
// object = lws '{' entries endobj
|
||||||
// endobj = lws '}'
|
// endobj = lws '}'
|
||||||
//
|
//
|
||||||
// quoted = lws '"' ('\\' escape / ![\\"] char)* '"'
|
// string = lws '"' ('\\' escape / ![\\"] char)* '"'
|
||||||
// / lws '`' ![`]* '`'
|
|
||||||
// string = (quoted)+
|
|
||||||
// char = [\0-\177] # or any Unicode codepoint in the UTF-8 encoding
|
// char = [\0-\177] # or any Unicode codepoint in the UTF-8 encoding
|
||||||
// escape = [\\"abfnrtv] / [xX][0-9A-Fa-f][0-9A-Fa-f]? / [0-7][0-7]?[0-7]?
|
// escape = [\\"abfnrtv] / [xX][0-9A-Fa-f][0-9A-Fa-f]? / [0-7][0-7]?[0-7]?
|
||||||
//
|
//
|
||||||
// integer = lws [-+]? [0-9]+ # whatever strtoll() accepts on your system
|
// integer = lws '-'? [0-9]+ # whatever strtoll() accepts on your system
|
||||||
// null = lws 'null'
|
// null = lws 'null'
|
||||||
// boolean = lws 'yes' / lws 'YES' / lws 'no' / lws 'NO'
|
// boolean = lws 'yes' / lws 'YES' / lws 'no' / lws 'NO'
|
||||||
// / lws 'on' / lws 'ON' / lws 'off' / lws 'OFF'
|
// / lws 'on' / lws 'ON' / lws 'off' / lws 'OFF'
|
||||||
@@ -4537,7 +4588,8 @@ config_item_move (struct config_item *self, struct config_item *source)
|
|||||||
static struct config_item *
|
static struct config_item *
|
||||||
config_item_new (enum config_item_type type)
|
config_item_new (enum config_item_type type)
|
||||||
{
|
{
|
||||||
struct config_item *self = xcalloc (1, sizeof *self);
|
struct config_item *self =
|
||||||
|
(struct config_item *) xcalloc (1, sizeof *self);
|
||||||
self->type = type;
|
self->type = type;
|
||||||
return self;
|
return self;
|
||||||
}
|
}
|
||||||
@@ -4677,7 +4729,8 @@ config_item_get (struct config_item *self, const char *path, struct error **e)
|
|||||||
const char *key = v.vector[i];
|
const char *key = v.vector[i];
|
||||||
if (!*key)
|
if (!*key)
|
||||||
error_set (e, "empty path element");
|
error_set (e, "empty path element");
|
||||||
else if (!(self = str_map_find (&self->value.object, key)))
|
else if (!(self = (struct config_item *)
|
||||||
|
str_map_find (&self->value.object, key)))
|
||||||
error_set (e, "`%s' not found in object", key);
|
error_set (e, "`%s' not found in object", key);
|
||||||
else if (++i == v.len)
|
else if (++i == v.len)
|
||||||
result = self;
|
result = self;
|
||||||
@@ -4709,15 +4762,13 @@ config_item_write_string (struct str *output, const struct str *s)
|
|||||||
for (size_t i = 0; i < s->len; i++)
|
for (size_t i = 0; i < s->len; i++)
|
||||||
{
|
{
|
||||||
unsigned char c = s->str[i];
|
unsigned char c = s->str[i];
|
||||||
if (c == '\n') str_append (output, "\\n");
|
if (c == '\n') str_append (output, "\\n");
|
||||||
else if (c == '\r') str_append (output, "\\r");
|
else if (c == '\r') str_append (output, "\\r");
|
||||||
else if (c == '\t') str_append (output, "\\t");
|
else if (c == '\t') str_append (output, "\\t");
|
||||||
else if (c == '\\') str_append (output, "\\\\");
|
else if (c == '\\') str_append (output, "\\\\");
|
||||||
else if (c == '"') str_append (output, "\\\"");
|
else if (c == '"') str_append (output, "\\\"");
|
||||||
else if (iscntrl_ascii (c))
|
else if (c < 32) str_append_printf (output, "\\x%02x", c);
|
||||||
str_append_printf (output, "\\x%02x", c);
|
else str_append_c (output, c);
|
||||||
else
|
|
||||||
str_append_c (output, c);
|
|
||||||
}
|
}
|
||||||
str_append_c (output, '"');
|
str_append_c (output, '"');
|
||||||
}
|
}
|
||||||
@@ -4810,7 +4861,7 @@ config_item_write_object_innards
|
|||||||
|
|
||||||
struct str_map_iter iter = str_map_iter_make (&object->value.object);
|
struct str_map_iter iter = str_map_iter_make (&object->value.object);
|
||||||
struct config_item *value;
|
struct config_item *value;
|
||||||
while ((value = str_map_iter_next (&iter)))
|
while ((value = (struct config_item *) str_map_iter_next (&iter)))
|
||||||
config_item_write_kv_pair (self, iter.link->key, value);
|
config_item_write_kv_pair (self, iter.link->key, value);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -5041,10 +5092,10 @@ config_tokenizer_escape_sequence
|
|||||||
}
|
}
|
||||||
|
|
||||||
static bool
|
static bool
|
||||||
config_tokenizer_dq_string (struct config_tokenizer *self, struct str *output,
|
config_tokenizer_string
|
||||||
struct error **e)
|
(struct config_tokenizer *self, struct str *output, struct error **e)
|
||||||
{
|
{
|
||||||
unsigned char c = config_tokenizer_advance (self);
|
unsigned char c;
|
||||||
while (self->len)
|
while (self->len)
|
||||||
{
|
{
|
||||||
if ((c = config_tokenizer_advance (self)) == '"')
|
if ((c = config_tokenizer_advance (self)) == '"')
|
||||||
@@ -5058,44 +5109,6 @@ config_tokenizer_dq_string (struct config_tokenizer *self, struct str *output,
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
static bool
|
|
||||||
config_tokenizer_bt_string (struct config_tokenizer *self, struct str *output,
|
|
||||||
struct error **e)
|
|
||||||
{
|
|
||||||
unsigned char c = config_tokenizer_advance (self);
|
|
||||||
while (self->len)
|
|
||||||
{
|
|
||||||
if ((c = config_tokenizer_advance (self)) == '`')
|
|
||||||
return true;
|
|
||||||
str_append_c (output, c);
|
|
||||||
}
|
|
||||||
config_tokenizer_error (self, e, "premature end of string");
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
static bool
|
|
||||||
config_tokenizer_string (struct config_tokenizer *self, struct str *output,
|
|
||||||
struct error **e)
|
|
||||||
{
|
|
||||||
// Go-like strings, with C/AWK-like automatic concatenation
|
|
||||||
while (self->len)
|
|
||||||
{
|
|
||||||
bool ok = true;
|
|
||||||
if (isspace_ascii (*self->p) && *self->p != '\n')
|
|
||||||
config_tokenizer_advance (self);
|
|
||||||
else if (*self->p == '"')
|
|
||||||
ok = config_tokenizer_dq_string (self, output, e);
|
|
||||||
else if (*self->p == '`')
|
|
||||||
ok = config_tokenizer_bt_string (self, output, e);
|
|
||||||
else
|
|
||||||
break;
|
|
||||||
|
|
||||||
if (!ok)
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
static enum config_token
|
static enum config_token
|
||||||
config_tokenizer_next (struct config_tokenizer *self, struct error **e)
|
config_tokenizer_next (struct config_tokenizer *self, struct error **e)
|
||||||
{
|
{
|
||||||
@@ -5120,7 +5133,7 @@ config_tokenizer_next (struct config_tokenizer *self, struct error **e)
|
|||||||
return CONFIG_T_ABORT;
|
return CONFIG_T_ABORT;
|
||||||
|
|
||||||
case '"':
|
case '"':
|
||||||
case '`':
|
config_tokenizer_advance (self);
|
||||||
str_reset (&self->string);
|
str_reset (&self->string);
|
||||||
if (!config_tokenizer_string (self, &self->string, e))
|
if (!config_tokenizer_string (self, &self->string, e))
|
||||||
return CONFIG_T_ABORT;
|
return CONFIG_T_ABORT;
|
||||||
@@ -5414,11 +5427,11 @@ config_read_from_file (const char *filename, struct error **e)
|
|||||||
{
|
{
|
||||||
struct config_item *root = NULL;
|
struct config_item *root = NULL;
|
||||||
|
|
||||||
|
struct error *error = NULL;
|
||||||
struct str data = str_make ();
|
struct str data = str_make ();
|
||||||
if (!read_file (filename, &data, e))
|
if (!read_file (filename, &data, e))
|
||||||
goto end;
|
goto end;
|
||||||
|
|
||||||
struct error *error = NULL;
|
|
||||||
if (!(root = config_item_parse (data.str, data.len, false, &error)))
|
if (!(root = config_item_parse (data.str, data.len, false, &error)))
|
||||||
{
|
{
|
||||||
error_set (e, "parse error in `%s': %s", filename, error->message);
|
error_set (e, "parse error in `%s': %s", filename, error->message);
|
||||||
@@ -5438,12 +5451,12 @@ config_schema_initialize_item (struct config_schema *schema,
|
|||||||
struct error **e)
|
struct error **e)
|
||||||
{
|
{
|
||||||
hard_assert (parent->type == CONFIG_ITEM_OBJECT);
|
hard_assert (parent->type == CONFIG_ITEM_OBJECT);
|
||||||
struct config_item *item =
|
struct config_item *item = (struct config_item *)
|
||||||
str_map_find (&parent->value.object, schema->name);
|
str_map_find (&parent->value.object, schema->name);
|
||||||
|
|
||||||
|
struct error *error = NULL;
|
||||||
if (item)
|
if (item)
|
||||||
{
|
{
|
||||||
struct error *error = NULL;
|
|
||||||
item->user_data = user_data;
|
item->user_data = user_data;
|
||||||
if (config_item_validate_by_schema (item, schema, &error))
|
if (config_item_validate_by_schema (item, schema, &error))
|
||||||
goto keep_current;
|
goto keep_current;
|
||||||
@@ -5451,9 +5464,9 @@ config_schema_initialize_item (struct config_schema *schema,
|
|||||||
error_set (warning, "resetting configuration item "
|
error_set (warning, "resetting configuration item "
|
||||||
"`%s' to default: %s", schema->name, error->message);
|
"`%s' to default: %s", schema->name, error->message);
|
||||||
error_free (error);
|
error_free (error);
|
||||||
|
error = NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
struct error *error = NULL;
|
|
||||||
if (schema->default_)
|
if (schema->default_)
|
||||||
item = config_item_parse
|
item = config_item_parse
|
||||||
(schema->default_, strlen (schema->default_), true, &error);
|
(schema->default_, strlen (schema->default_), true, &error);
|
||||||
@@ -5516,7 +5529,7 @@ config_schema_call_changed (struct config_item *item)
|
|||||||
{
|
{
|
||||||
struct str_map_iter iter = str_map_iter_make (&item->value.object);
|
struct str_map_iter iter = str_map_iter_make (&item->value.object);
|
||||||
struct config_item *child;
|
struct config_item *child;
|
||||||
while ((child = str_map_iter_next (&iter)))
|
while ((child = (struct config_item *) str_map_iter_next (&iter)))
|
||||||
config_schema_call_changed (child);
|
config_schema_call_changed (child);
|
||||||
}
|
}
|
||||||
else if (item->schema && item->schema->on_change)
|
else if (item->schema && item->schema->on_change)
|
||||||
@@ -5569,7 +5582,8 @@ static void
|
|||||||
config_register_module (struct config *self,
|
config_register_module (struct config *self,
|
||||||
const char *name, config_module_load_fn loader, void *user_data)
|
const char *name, config_module_load_fn loader, void *user_data)
|
||||||
{
|
{
|
||||||
struct config_module *module = xcalloc (1, sizeof *module);
|
struct config_module *module =
|
||||||
|
(struct config_module *) xcalloc (1, sizeof *module);
|
||||||
module->name = xstrdup (name);
|
module->name = xstrdup (name);
|
||||||
module->loader = loader;
|
module->loader = loader;
|
||||||
module->user_data = user_data;
|
module->user_data = user_data;
|
||||||
@@ -5587,9 +5601,9 @@ config_load (struct config *self, struct config_item *root)
|
|||||||
|
|
||||||
struct str_map_iter iter = str_map_iter_make (&self->modules);
|
struct str_map_iter iter = str_map_iter_make (&self->modules);
|
||||||
struct config_module *module;
|
struct config_module *module;
|
||||||
while ((module = str_map_iter_next (&iter)))
|
while ((module = (struct config_module *) str_map_iter_next (&iter)))
|
||||||
{
|
{
|
||||||
struct config_item *subtree = str_map_find
|
struct config_item *subtree = (struct config_item *) str_map_find
|
||||||
(&root->value.object, module->name);
|
(&root->value.object, module->name);
|
||||||
// Silently fix inputs that only a lunatic user could create
|
// Silently fix inputs that only a lunatic user could create
|
||||||
if (!subtree || subtree->type != CONFIG_ITEM_OBJECT)
|
if (!subtree || subtree->type != CONFIG_ITEM_OBJECT)
|
||||||
|
|||||||
@@ -82,3 +82,4 @@ siphash (const unsigned char key[16], const unsigned char *m, size_t len)
|
|||||||
|
|
||||||
return v0 ^ v1 ^ v2 ^ v3;
|
return v0 ^ v1 ^ v2 ^ v3;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
/*
|
/*
|
||||||
* tests/liberty.c
|
* tests/liberty.c
|
||||||
*
|
*
|
||||||
* Copyright (c) 2015 - 2022, Přemysl Eric Janouch <p@janouch.name>
|
* Copyright (c) 2015 - 2016, Přemysl Eric Janouch <p@janouch.name>
|
||||||
*
|
*
|
||||||
* Permission to use, copy, modify, and/or distribute this software for any
|
* Permission to use, copy, modify, and/or distribute this software for any
|
||||||
* purpose with or without fee is hereby granted.
|
* purpose with or without fee is hereby granted.
|
||||||
@@ -331,12 +331,10 @@ test_utf8 (void)
|
|||||||
soft_assert (utf8_decode (&partial, 1) == -2);
|
soft_assert (utf8_decode (&partial, 1) == -2);
|
||||||
soft_assert (utf8_decode (&empty, 0) == -1);
|
soft_assert (utf8_decode (&empty, 0) == -1);
|
||||||
|
|
||||||
const char valid_1[] = "2H₂ + O₂ ⇌ 2H₂O, R = 4.7 kΩ, ⌀ 200 mm";
|
const char valid[] = "2H₂ + O₂ ⇌ 2H₂O, R = 4.7 kΩ, ⌀ 200 mm";
|
||||||
const char valid_2[] = "\xf0\x93\x82\xb9";
|
|
||||||
const char invalid_1[] = "\xf0\x90\x28\xbc";
|
const char invalid_1[] = "\xf0\x90\x28\xbc";
|
||||||
const char invalid_2[] = "\xc0\x80";
|
const char invalid_2[] = "\xc0\x80";
|
||||||
soft_assert ( utf8_validate (valid_1, sizeof valid_1));
|
soft_assert ( utf8_validate (valid, sizeof valid));
|
||||||
soft_assert ( utf8_validate (valid_2, sizeof valid_2));
|
|
||||||
soft_assert (!utf8_validate (invalid_1, sizeof invalid_1));
|
soft_assert (!utf8_validate (invalid_1, sizeof invalid_1));
|
||||||
soft_assert (!utf8_validate (invalid_2, sizeof invalid_2));
|
soft_assert (!utf8_validate (invalid_2, sizeof invalid_2));
|
||||||
|
|
||||||
@@ -649,7 +647,7 @@ static struct config_schema g_config_test[] =
|
|||||||
.default_ = "1" },
|
.default_ = "1" },
|
||||||
{ .name = "foobar",
|
{ .name = "foobar",
|
||||||
.type = CONFIG_ITEM_STRING,
|
.type = CONFIG_ITEM_STRING,
|
||||||
.default_ = "\"qux\\x01`\" \"\"`a`" },
|
.default_ = "\"qux\\x01\"" },
|
||||||
{}
|
{}
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -675,9 +673,6 @@ test_config (void)
|
|||||||
"top.bar", NULL), invalid, NULL));
|
"top.bar", NULL), invalid, NULL));
|
||||||
config_item_destroy (invalid);
|
config_item_destroy (invalid);
|
||||||
|
|
||||||
hard_assert (!strcmp ("qux\001`a",
|
|
||||||
config_item_get (config.root, "top.foobar", NULL)->value.string.str));
|
|
||||||
|
|
||||||
struct str s = str_make ();
|
struct str s = str_make ();
|
||||||
config_item_write (config.root, true, &s);
|
config_item_write (config.root, true, &s);
|
||||||
struct config_item *parsed = config_item_parse (s.str, s.len, false, NULL);
|
struct config_item *parsed = config_item_parse (s.str, s.len, false, NULL);
|
||||||
|
|||||||
127
tests/pulse.c
127
tests/pulse.c
@@ -1,127 +0,0 @@
|
|||||||
/*
|
|
||||||
* tests/pulse.c
|
|
||||||
*
|
|
||||||
* Copyright (c) 2021, Přemysl Eric Janouch <p@janouch.name>
|
|
||||||
*
|
|
||||||
* Permission to use, copy, modify, and/or distribute this software for any
|
|
||||||
* purpose with or without fee is hereby granted.
|
|
||||||
*
|
|
||||||
* THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
|
|
||||||
* WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
|
|
||||||
* MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY
|
|
||||||
* SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
|
|
||||||
* WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION
|
|
||||||
* OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN
|
|
||||||
* CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
|
|
||||||
#define PROGRAM_NAME "test"
|
|
||||||
#define PROGRAM_VERSION "0"
|
|
||||||
|
|
||||||
#define LIBERTY_WANT_POLLER
|
|
||||||
|
|
||||||
#include "../liberty.c"
|
|
||||||
#include "../liberty-pulse.c"
|
|
||||||
|
|
||||||
// --- Tests -------------------------------------------------------------------
|
|
||||||
|
|
||||||
enum
|
|
||||||
{
|
|
||||||
EVENT_IO = 1 << 0,
|
|
||||||
EVENT_TIME = 1 << 1,
|
|
||||||
EVENT_DEFER = 1 << 2,
|
|
||||||
EVENT_ALL = (1 << 3) - 1
|
|
||||||
};
|
|
||||||
|
|
||||||
static intptr_t g_events = 0;
|
|
||||||
static intptr_t g_destroys = 0;
|
|
||||||
|
|
||||||
static void
|
|
||||||
io_event_cb (pa_mainloop_api *a,
|
|
||||||
pa_io_event *e, int fd, pa_io_event_flags_t events, void *userdata)
|
|
||||||
{
|
|
||||||
(void) a; (void) e; (void) fd; (void) events;
|
|
||||||
g_events |= (intptr_t) userdata;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
io_event_destroy_cb (pa_mainloop_api *a, pa_io_event *e, void *userdata)
|
|
||||||
{
|
|
||||||
(void) a; (void) e;
|
|
||||||
g_destroys += (intptr_t) userdata;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
time_event_cb (pa_mainloop_api *a,
|
|
||||||
pa_time_event *e, const struct timeval *tv, void *userdata)
|
|
||||||
{
|
|
||||||
(void) a; (void) e; (void) tv;
|
|
||||||
g_events |= (intptr_t) userdata;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
time_event_destroy_cb (pa_mainloop_api *a, pa_time_event *e, void *userdata)
|
|
||||||
{
|
|
||||||
(void) a; (void) e;
|
|
||||||
g_destroys += (intptr_t) userdata;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
defer_event_cb (pa_mainloop_api *a, pa_defer_event *e, void *userdata)
|
|
||||||
{
|
|
||||||
(void) a; (void) e;
|
|
||||||
g_events |= (intptr_t) userdata;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
defer_event_destroy_cb (pa_mainloop_api *a, pa_defer_event *e, void *userdata)
|
|
||||||
{
|
|
||||||
(void) a; (void) e;
|
|
||||||
g_destroys += (intptr_t) userdata;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
test_pulse (void)
|
|
||||||
{
|
|
||||||
struct poller poller;
|
|
||||||
poller_init (&poller);
|
|
||||||
|
|
||||||
// Let's just get this over with, not aiming for high test coverage here
|
|
||||||
pa_mainloop_api *api = poller_pa_new (&poller);
|
|
||||||
|
|
||||||
pa_io_event *ie = api->io_new (api, STDOUT_FILENO, PA_IO_EVENT_OUTPUT,
|
|
||||||
io_event_cb, (void *) EVENT_IO);
|
|
||||||
api->io_set_destroy (ie, io_event_destroy_cb);
|
|
||||||
|
|
||||||
const struct timeval tv = poller_pa_get_current_time ();
|
|
||||||
pa_time_event *te = api->time_new (api, &tv,
|
|
||||||
time_event_cb, (void *) EVENT_TIME);
|
|
||||||
api->time_set_destroy (te, time_event_destroy_cb);
|
|
||||||
api->time_restart (te, &tv);
|
|
||||||
|
|
||||||
pa_defer_event *de = api->defer_new (api,
|
|
||||||
defer_event_cb, (void *) EVENT_DEFER);
|
|
||||||
api->defer_set_destroy (de, defer_event_destroy_cb);
|
|
||||||
api->defer_enable (api->defer_new (api,
|
|
||||||
defer_event_cb, (void *) EVENT_DEFER), false);
|
|
||||||
|
|
||||||
alarm (1);
|
|
||||||
while (g_events != EVENT_ALL)
|
|
||||||
poller_run (&poller);
|
|
||||||
|
|
||||||
poller_pa_destroy (api);
|
|
||||||
soft_assert (g_destroys == EVENT_ALL);
|
|
||||||
poller_free (&poller);
|
|
||||||
}
|
|
||||||
|
|
||||||
// --- Main --------------------------------------------------------------------
|
|
||||||
|
|
||||||
int
|
|
||||||
main (int argc, char *argv[])
|
|
||||||
{
|
|
||||||
struct test test;
|
|
||||||
test_init (&test, argc, argv);
|
|
||||||
test_add_simple (&test, "/pulse", NULL, test_pulse);
|
|
||||||
return test_run (&test);
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user