128 lines
3.3 KiB
C
128 lines
3.3 KiB
C
/*
|
|
* 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);
|
|
}
|