mirror of
https://github.com/troglobit/libuev.git
synced 2026-10-23 11:24:34 +00:00
Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
de89b6647d | ||
|
|
7eee63e5eb | ||
|
|
c780b82929 | ||
|
|
cccaabfad5 | ||
|
|
6d33c56d0f | ||
|
|
6ae98d135c | ||
|
|
d3e5900f73 | ||
|
|
2ff15101ae | ||
|
|
04d9e1c80a | ||
|
|
0674fb8db4 | ||
|
|
c4ac2eae5d | ||
|
|
951f959549 | ||
|
|
a2900279f6 | ||
|
|
f9c9f24afb | ||
|
|
ab05f71bbc | ||
|
|
856546f4c7 | ||
|
|
748ebc998c | ||
|
|
0e97bfdc5a |
No files matched your search
@@ -312,7 +312,7 @@ int main(void)
|
|||||||
uev_t watcher;
|
uev_t watcher;
|
||||||
uev_ctx_t ctx;
|
uev_ctx_t ctx;
|
||||||
|
|
||||||
fd = open("/dev/input/js1", O_RDONLY, O_NONBLOCK);
|
fd = open("/dev/input/js0", O_RDONLY, O_NONBLOCK);
|
||||||
if (fd < 0)
|
if (fd < 0)
|
||||||
errx(errno, "Cannot find a joystick attached.");
|
errx(errno, "Cannot find a joystick attached.");
|
||||||
|
|
||||||
|
|||||||
+33
-1
@@ -3,6 +3,36 @@ Change Log
|
|||||||
|
|
||||||
All notable changes to the project are documented in this file.
|
All notable changes to the project are documented in this file.
|
||||||
|
|
||||||
|
|
||||||
|
[v2.1.3][] - 2018-09-06
|
||||||
|
-----------------------
|
||||||
|
|
||||||
|
### Changes
|
||||||
|
- Update joystick example, use first device, `/dev/input/js0`
|
||||||
|
- Minor refactor of `uev_exit()`, use `_SAFE` macros to traverse
|
||||||
|
list of watchers instead of `while()`
|
||||||
|
- New API test to verify that `uev_exit()` terminates properly
|
||||||
|
- Make `uev_signal_stop()` idempotent
|
||||||
|
|
||||||
|
### Fixes
|
||||||
|
- Let `uev_timer_stop()` call `close()` on the timerfd directly, do not
|
||||||
|
call `uev_timer_set()` since that may cause lockups or hangs
|
||||||
|
|
||||||
|
|
||||||
|
[v2.1.2][] - 2018-02-27
|
||||||
|
-----------------------
|
||||||
|
|
||||||
|
### Changes
|
||||||
|
- Minor refactor of event loop after fixing the nasty use-after-free bug
|
||||||
|
in v2.1.1. Code can now be collapsed and noticeably simplified
|
||||||
|
|
||||||
|
### Fixes
|
||||||
|
- Issue #17: Check if `AM_PROG_AR` macro exists before calling it, fixes
|
||||||
|
problem building libuEv on systems with older autoconf + automake.
|
||||||
|
Patch by Markus Svilans
|
||||||
|
- Fix minor issue with unit tests, return result of test not event loop
|
||||||
|
|
||||||
|
|
||||||
[v2.1.1][] - 2018-01-28
|
[v2.1.1][] - 2018-01-28
|
||||||
-----------------------
|
-----------------------
|
||||||
|
|
||||||
@@ -336,7 +366,9 @@ v0.0.1 - 2012-03-17
|
|||||||
Lua users mailing list.
|
Lua users mailing list.
|
||||||
|
|
||||||
|
|
||||||
[UNRELEASED]: https://github.com/troglobit/libuev/compare/v2.1.1...HEAD
|
[UNRELEASED]: https://github.com/troglobit/libuev/compare/v2.1.3...HEAD
|
||||||
|
[v2.1.3]: https://github.com/troglobit/libuev/compare/v2.1.2...v2.1.3
|
||||||
|
[v2.1.2]: https://github.com/troglobit/libuev/compare/v2.1.1...v2.1.2
|
||||||
[v2.1.1]: https://github.com/troglobit/libuev/compare/v2.1.0...v2.1.1
|
[v2.1.1]: https://github.com/troglobit/libuev/compare/v2.1.0...v2.1.1
|
||||||
[v2.1.0]: https://github.com/troglobit/libuev/compare/v2.0.0...v2.1.0
|
[v2.1.0]: https://github.com/troglobit/libuev/compare/v2.0.0...v2.1.0
|
||||||
[v2.0.0]: https://github.com/troglobit/libuev/compare/v1.6.0...v2.0.0
|
[v2.0.0]: https://github.com/troglobit/libuev/compare/v1.6.0...v2.0.0
|
||||||
|
|||||||
+2
-2
@@ -1,4 +1,4 @@
|
|||||||
AC_INIT(libuev, 2.1.1, https://github.com/troglobit/libuev/issues)
|
AC_INIT(libuev, 2.1.3, https://github.com/troglobit/libuev/issues)
|
||||||
AM_INIT_AUTOMAKE([1.11 foreign no-dist-gzip dist-xz])
|
AM_INIT_AUTOMAKE([1.11 foreign no-dist-gzip dist-xz])
|
||||||
AM_SILENT_RULES([yes])
|
AM_SILENT_RULES([yes])
|
||||||
|
|
||||||
@@ -8,7 +8,7 @@ AC_CONFIG_FILES([Makefile src/libuev.pc src/Makefile examples/Makefile tests/Mak
|
|||||||
AC_CONFIG_MACRO_DIR([m4])
|
AC_CONFIG_MACRO_DIR([m4])
|
||||||
|
|
||||||
AC_PROG_CC
|
AC_PROG_CC
|
||||||
AM_PROG_AR
|
m4_ifdef([AM_PROG_AR], [AM_PROG_AR])
|
||||||
LT_INIT
|
LT_INIT
|
||||||
|
|
||||||
# Optional features
|
# Optional features
|
||||||
|
|||||||
Vendored
+21
@@ -1,3 +1,24 @@
|
|||||||
|
libuev (2.1.3) unstable; urgency=medium
|
||||||
|
|
||||||
|
* Minor bugfix release
|
||||||
|
- Updated joystick example, use first joystick, /dev/input/js0
|
||||||
|
- Use LIST_FOREACH_SAFE() instead of while() in uev_exit()
|
||||||
|
- New API test for uev_exit()
|
||||||
|
- Don't call uev_timer_set() when stopping a timer, may cause lockups
|
||||||
|
- Return OK immediately if a signal watcher is already stopped
|
||||||
|
* Packaging fixes: libuev.so symlink goes in -dev package
|
||||||
|
-- Joachim Nilsson <troglobit@gmail.com> Thu, 06 Sep 2018 22:01:24 +0200
|
||||||
|
|
||||||
|
libuev (2.1.2) unstable; urgency=medium
|
||||||
|
|
||||||
|
* Minor bugfix release
|
||||||
|
- Fix #17: build problem on systems with too old autoconf + automake
|
||||||
|
- Fix unit tests, return result of test not result of event loop
|
||||||
|
- Refactor/simplify/collapse main event loop code after fixes in v2.1.1
|
||||||
|
* Fix minor packaging issues
|
||||||
|
|
||||||
|
-- Joachim Nilsson <troglobit@gmail.com> Tue, 27 Feb 2018 00:05:32 +0100
|
||||||
|
|
||||||
libuev (2.1.1) unstable; urgency=medium
|
libuev (2.1.1) unstable; urgency=medium
|
||||||
|
|
||||||
* Minor bugfix release
|
* Minor bugfix release
|
||||||
|
|||||||
Vendored
+3
-5
@@ -1,6 +1,4 @@
|
|||||||
usr/include/uev/uev.h
|
usr/include/uev/*.h
|
||||||
usr/include/uev/private.h
|
usr/lib/*/libuev.a
|
||||||
usr/include/uev/queue.h
|
usr/lib/*/libuev.so
|
||||||
usr/lib/*/lib*.a
|
|
||||||
usr/lib/*/lib*.so
|
|
||||||
usr/lib/*/pkgconfig/lib*.pc
|
usr/lib/*/pkgconfig/lib*.pc
|
||||||
+1
-1
@@ -78,7 +78,7 @@ int main(void)
|
|||||||
uev_t js1_watcher;
|
uev_t js1_watcher;
|
||||||
uev_ctx_t ctx;
|
uev_ctx_t ctx;
|
||||||
|
|
||||||
fd = open("/dev/input/js1", O_RDONLY, O_NONBLOCK);
|
fd = open("/dev/input/js0", O_RDONLY, O_NONBLOCK);
|
||||||
if (fd < 0)
|
if (fd < 0)
|
||||||
errx(errno, "Cannot find a joystick attached.");
|
errx(errno, "Cannot find a joystick attached.");
|
||||||
|
|
||||||
|
|||||||
+1
-1
@@ -2,7 +2,7 @@ lib_LTLIBRARIES = libuev.la
|
|||||||
libuev_la_SOURCES = uev.c io.c timer.c signal.c cron.c
|
libuev_la_SOURCES = uev.c io.c timer.c signal.c cron.c
|
||||||
libuev_la_CPPFLAGS = -D_GNU_SOURCE -D_TIME_BITS=64
|
libuev_la_CPPFLAGS = -D_GNU_SOURCE -D_TIME_BITS=64
|
||||||
libuev_la_CFLAGS = -W -Wall -Wextra
|
libuev_la_CFLAGS = -W -Wall -Wextra
|
||||||
libuev_la_LDFLAGS = $(AM_LDFLAGS) -version-info 2:1:0
|
libuev_la_LDFLAGS = $(AM_LDFLAGS) -version-info 2:2:0
|
||||||
|
|
||||||
noinst_PROGRAMS = bench
|
noinst_PROGRAMS = bench
|
||||||
bench_CPPFLAGS = -D_GNU_SOURCE
|
bench_CPPFLAGS = -D_GNU_SOURCE
|
||||||
|
|||||||
@@ -140,6 +140,9 @@ int uev_signal_start(uev_t *w)
|
|||||||
*/
|
*/
|
||||||
int uev_signal_stop(uev_t *w)
|
int uev_signal_stop(uev_t *w)
|
||||||
{
|
{
|
||||||
|
if (!_uev_watcher_active(w))
|
||||||
|
return 0;
|
||||||
|
|
||||||
if (_uev_watcher_stop(w))
|
if (_uev_watcher_stop(w))
|
||||||
return -1;
|
return -1;
|
||||||
|
|
||||||
|
|||||||
@@ -170,17 +170,12 @@ int uev_timer_start(uev_t *w)
|
|||||||
*/
|
*/
|
||||||
int uev_timer_stop(uev_t *w)
|
int uev_timer_stop(uev_t *w)
|
||||||
{
|
{
|
||||||
/* Check if already stopped in uev_run() after cb() or _init() */
|
|
||||||
if (!_uev_watcher_active(w))
|
if (!_uev_watcher_active(w))
|
||||||
return 0;
|
return 0;
|
||||||
|
|
||||||
/* Stop kernel timer */
|
|
||||||
uev_timer_set(w, 0, 0);
|
|
||||||
|
|
||||||
if (_uev_watcher_stop(w))
|
if (_uev_watcher_stop(w))
|
||||||
return -1;
|
return -1;
|
||||||
|
|
||||||
/* Close timerfd, will have to be reopened again on reset */
|
|
||||||
close(w->fd);
|
close(w->fd);
|
||||||
w->fd = -1;
|
w->fd = -1;
|
||||||
|
|
||||||
|
|||||||
@@ -203,14 +203,14 @@ int uev_init(uev_ctx_t *ctx)
|
|||||||
*/
|
*/
|
||||||
int uev_exit(uev_ctx_t *ctx)
|
int uev_exit(uev_ctx_t *ctx)
|
||||||
{
|
{
|
||||||
|
uev_t *w, *next;
|
||||||
|
|
||||||
if (!ctx) {
|
if (!ctx) {
|
||||||
errno = EINVAL;
|
errno = EINVAL;
|
||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
|
|
||||||
while (!LIST_EMPTY(&ctx->watchers)) {
|
LIST_FOREACH_SAFE(w, &ctx->watchers, link, next) {
|
||||||
uev_t *w = LIST_FIRST(&ctx->watchers);
|
|
||||||
|
|
||||||
/* Remove from internal list */
|
/* Remove from internal list */
|
||||||
LIST_REMOVE(w, link);
|
LIST_REMOVE(w, link);
|
||||||
|
|
||||||
@@ -233,6 +233,7 @@ int uev_exit(uev_ctx_t *ctx)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
LIST_INIT(&ctx->watchers);
|
||||||
ctx->running = 0;
|
ctx->running = 0;
|
||||||
close(ctx->fd);
|
close(ctx->fd);
|
||||||
ctx->fd = -1;
|
ctx->fd = -1;
|
||||||
@@ -347,6 +348,8 @@ int uev_run(uev_ctx_t *ctx, int flags)
|
|||||||
|
|
||||||
if (!w->u.t.period)
|
if (!w->u.t.period)
|
||||||
w->u.t.timeout = 0;
|
w->u.t.timeout = 0;
|
||||||
|
if (!w->u.t.timeout)
|
||||||
|
uev_timer_stop(w);
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case UEV_CRON_TYPE:
|
case UEV_CRON_TYPE:
|
||||||
@@ -362,16 +365,9 @@ int uev_run(uev_ctx_t *ctx, int flags)
|
|||||||
w->u.c.when = 0;
|
w->u.c.when = 0;
|
||||||
else
|
else
|
||||||
w->u.c.when += w->u.c.interval;
|
w->u.c.when += w->u.c.interval;
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (UEV_CRON_TYPE == w->type) {
|
|
||||||
if (!w->u.c.when)
|
if (!w->u.c.when)
|
||||||
uev_timer_stop(w);
|
uev_timer_stop(w);
|
||||||
}
|
break;
|
||||||
if (UEV_TIMER_TYPE == w->type) {
|
|
||||||
if (!w->u.t.timeout)
|
|
||||||
uev_timer_stop(w);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
|||||||
@@ -1,6 +1,7 @@
|
|||||||
*.trs
|
*.trs
|
||||||
*.log
|
*.log
|
||||||
active
|
active
|
||||||
|
api
|
||||||
complete
|
complete
|
||||||
cronrun
|
cronrun
|
||||||
signal
|
signal
|
||||||
|
|||||||
@@ -3,6 +3,7 @@ CLEANFILES = *~ *.trs *.log
|
|||||||
|
|
||||||
TESTS =
|
TESTS =
|
||||||
TESTS += active
|
TESTS += active
|
||||||
|
TESTS += api
|
||||||
TESTS += complete
|
TESTS += complete
|
||||||
TESTS += cronrun
|
TESTS += cronrun
|
||||||
TESTS += signal
|
TESTS += signal
|
||||||
|
|||||||
@@ -30,6 +30,9 @@ static void cb(uev_t *w, void *UNUSED(arg), int events)
|
|||||||
fail_unless(!uev_timer_active(&timer2));
|
fail_unless(!uev_timer_active(&timer2));
|
||||||
fail_unless(!uev_cron_active(&cron2));
|
fail_unless(!uev_cron_active(&cron2));
|
||||||
|
|
||||||
|
/* Restart timer and see if we fail in uev_exit() */
|
||||||
|
uev_timer_start(&timer2);
|
||||||
|
|
||||||
uev_exit(w->ctx);
|
uev_exit(w->ctx);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -52,3 +55,10 @@ int main(void)
|
|||||||
|
|
||||||
return uev_run(&ctx, 0);
|
return uev_run(&ctx, 0);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Local Variables:
|
||||||
|
* indent-tabs-mode: t
|
||||||
|
* c-file-style: "linux"
|
||||||
|
* End:
|
||||||
|
*/
|
||||||
+34
@@ -0,0 +1,34 @@
|
|||||||
|
#include "check.h"
|
||||||
|
|
||||||
|
uev_t timer, file;
|
||||||
|
int counter = 10;
|
||||||
|
|
||||||
|
static void cb(uev_t *w, void *UNUSED(arg), int events)
|
||||||
|
{
|
||||||
|
if (UEV_ERROR == events)
|
||||||
|
fprintf(stderr, "timer watcher failed, ignoring ...\n");
|
||||||
|
|
||||||
|
if (counter--)
|
||||||
|
return;
|
||||||
|
|
||||||
|
uev_exit(w->ctx);
|
||||||
|
}
|
||||||
|
|
||||||
|
int main(void)
|
||||||
|
{
|
||||||
|
uev_ctx_t ctx;
|
||||||
|
FILE *fp;
|
||||||
|
|
||||||
|
uev_init(&ctx);
|
||||||
|
uev_timer_init(&ctx, &timer, cb, NULL, 100, 100);
|
||||||
|
|
||||||
|
fp = fopen("/dev/one", "r");
|
||||||
|
if (fp)
|
||||||
|
uev_io_init(&ctx, &file, cb, NULL, fileno(fp), UEV_READ);
|
||||||
|
|
||||||
|
uev_run(&ctx, 0);
|
||||||
|
|
||||||
|
uev_exit(&ctx); /* Should not hang event loop, troglobit/uftpd#16 */
|
||||||
|
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
+4
-4
@@ -82,7 +82,7 @@ static void pipe_read_cb(uev_t *w, void UNUSED(*arg), int events)
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Kick watchdog */
|
/* Kick watchdog */
|
||||||
if (watchdog)
|
if (watchdog)
|
||||||
uev_timer_set(watchdog, 1000, 0);
|
uev_timer_set(watchdog, 1000, 0);
|
||||||
|
|
||||||
@@ -112,9 +112,9 @@ static void pipe_write_cb(uev_t *w, void *arg, int UNUSED(events))
|
|||||||
|
|
||||||
/* Here we *must* use out, not w->fd, since we're a timer callback */
|
/* Here we *must* use out, not w->fd, since we're a timer callback */
|
||||||
if (write(out, msg, my->counter) < 0) {
|
if (write(out, msg, my->counter) < 0) {
|
||||||
perror("\nFailed writing to pipe");
|
perror("\nFailed writing to pipe");
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
// fprintf(stderr, "WRITE %.*s %d\n", my->counter, msg, my->counter);
|
// fprintf(stderr, "WRITE %.*s %d\n", my->counter, msg, my->counter);
|
||||||
fprintf(stderr, "%d ", my->counter);
|
fprintf(stderr, "%d ", my->counter);
|
||||||
|
|||||||
+9
-2
@@ -28,6 +28,7 @@
|
|||||||
#define TIMEOUT 2
|
#define TIMEOUT 2
|
||||||
#define INTERVAL 2
|
#define INTERVAL 2
|
||||||
|
|
||||||
|
int result = -1;
|
||||||
struct timeval tv;
|
struct timeval tv;
|
||||||
|
|
||||||
static void cron_job(uev_t *w, void *UNUSED(arg), int events)
|
static void cron_job(uev_t *w, void *UNUSED(arg), int events)
|
||||||
@@ -45,12 +46,15 @@ static void cron_job(uev_t *w, void *UNUSED(arg), int events)
|
|||||||
printf("Cron job HELO %s", ctime(&now.tv_sec));
|
printf("Cron job HELO %s", ctime(&now.tv_sec));
|
||||||
fail_unless(now.tv_sec == tv.tv_sec);
|
fail_unless(now.tv_sec == tv.tv_sec);
|
||||||
|
|
||||||
if (!laps--)
|
if (!laps--) {
|
||||||
|
result = 0;
|
||||||
uev_exit(w->ctx);
|
uev_exit(w->ctx);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
int main(void)
|
int main(void)
|
||||||
{
|
{
|
||||||
|
int rc;
|
||||||
uev_t cron_watcher;
|
uev_t cron_watcher;
|
||||||
uev_ctx_t ctx;
|
uev_ctx_t ctx;
|
||||||
time_t when, interval;
|
time_t when, interval;
|
||||||
@@ -66,7 +70,10 @@ int main(void)
|
|||||||
interval = INTERVAL;
|
interval = INTERVAL;
|
||||||
uev_cron_init(&ctx, &cron_watcher, cron_job, NULL, when, interval);
|
uev_cron_init(&ctx, &cron_watcher, cron_job, NULL, when, interval);
|
||||||
|
|
||||||
return uev_run(&ctx, 0);
|
rc = uev_run(&ctx, 0);
|
||||||
|
fail_unless(result == 0);
|
||||||
|
|
||||||
|
return rc;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
+13
-13
@@ -63,7 +63,7 @@ static int callback(arg_t *arg, int event, void *foo)
|
|||||||
printf("child: segfaulting failed!\n");
|
printf("child: segfaulting failed!\n");
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
return 42;
|
return 42;
|
||||||
}
|
}
|
||||||
|
|
||||||
static void sigsegv_cb(uev_t *UNUSED(w), void *UNUSED(arg), int UNUSED(events))
|
static void sigsegv_cb(uev_t *UNUSED(w), void *UNUSED(arg), int UNUSED(events))
|
||||||
@@ -74,27 +74,27 @@ static void sigsegv_cb(uev_t *UNUSED(w), void *UNUSED(arg), int UNUSED(events))
|
|||||||
|
|
||||||
static void sigchld_cb(uev_t *UNUSED(w), void *UNUSED(arg), int UNUSED(events))
|
static void sigchld_cb(uev_t *UNUSED(w), void *UNUSED(arg), int UNUSED(events))
|
||||||
{
|
{
|
||||||
pid_t pid = waitpid(-1, NULL, WNOHANG);
|
pid_t pid = waitpid(-1, NULL, WNOHANG);
|
||||||
|
|
||||||
if (-1 != pid)
|
if (-1 != pid)
|
||||||
warnx("PID %d exited, bye.", pid);
|
warnx("PID %d exited, bye.", pid);
|
||||||
}
|
}
|
||||||
|
|
||||||
static void work_cb(uev_t *UNUSED(w), void *arg, int UNUSED(events))
|
static void work_cb(uev_t *UNUSED(w), void *arg, int UNUSED(events))
|
||||||
{
|
{
|
||||||
int status = 0;
|
int status = 0;
|
||||||
pid_t pid;
|
pid_t pid;
|
||||||
|
|
||||||
pid = fork();
|
pid = fork();
|
||||||
if (-1 == pid)
|
if (-1 == pid)
|
||||||
err(1, "fork");
|
err(1, "fork");
|
||||||
if (!pid) {
|
if (!pid) {
|
||||||
status = callback(arg, 6137, NULL);
|
status = callback(arg, 6137, NULL);
|
||||||
exit(status);
|
exit(status);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (waitpid(pid, &status, 0) == -1)
|
if (waitpid(pid, &status, 0) == -1)
|
||||||
err(1, "waitpid");
|
err(1, "waitpid");
|
||||||
|
|
||||||
if (WIFEXITED(status))
|
if (WIFEXITED(status))
|
||||||
printf("Child exited normally => %d\n", WEXITSTATUS(status));
|
printf("Child exited normally => %d\n", WEXITSTATUS(status));
|
||||||
@@ -108,7 +108,7 @@ static void work_cb(uev_t *UNUSED(w), void *arg, int UNUSED(events))
|
|||||||
|
|
||||||
static void exit_cb(uev_t *w, void *UNUSED(arg), int UNUSED(events))
|
static void exit_cb(uev_t *w, void *UNUSED(arg), int UNUSED(events))
|
||||||
{
|
{
|
||||||
printf("Process deadline reached, exiting!\n");
|
printf("Process deadline reached, exiting!\n");
|
||||||
uev_exit(w->ctx);
|
uev_exit(w->ctx);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
+15
-1
@@ -3,6 +3,8 @@
|
|||||||
#include <sys/time.h>
|
#include <sys/time.h>
|
||||||
|
|
||||||
#define TIMEOUT 2 /* 2 sec */
|
#define TIMEOUT 2 /* 2 sec */
|
||||||
|
|
||||||
|
int result = -1;
|
||||||
struct timeval start;
|
struct timeval start;
|
||||||
|
|
||||||
static void cb(uev_t *w, void *UNUSED(arg), int events)
|
static void cb(uev_t *w, void *UNUSED(arg), int events)
|
||||||
@@ -15,11 +17,13 @@ static void cb(uev_t *w, void *UNUSED(arg), int events)
|
|||||||
gettimeofday(&now, NULL);
|
gettimeofday(&now, NULL);
|
||||||
fail_unless(now.tv_sec == start.tv_sec + TIMEOUT);
|
fail_unless(now.tv_sec == start.tv_sec + TIMEOUT);
|
||||||
|
|
||||||
|
result = 0;
|
||||||
uev_exit(w->ctx);
|
uev_exit(w->ctx);
|
||||||
}
|
}
|
||||||
|
|
||||||
int main(void)
|
int main(void)
|
||||||
{
|
{
|
||||||
|
int rc;
|
||||||
uev_t w;
|
uev_t w;
|
||||||
uev_ctx_t ctx;
|
uev_ctx_t ctx;
|
||||||
|
|
||||||
@@ -27,5 +31,15 @@ int main(void)
|
|||||||
uev_timer_init(&ctx, &w, cb, NULL, TIMEOUT * 1000, 0);
|
uev_timer_init(&ctx, &w, cb, NULL, TIMEOUT * 1000, 0);
|
||||||
gettimeofday(&start, NULL);
|
gettimeofday(&start, NULL);
|
||||||
|
|
||||||
return uev_run(&ctx, 0);
|
rc = uev_run(&ctx, 0);
|
||||||
|
fail_unless(result == 0);
|
||||||
|
|
||||||
|
return rc;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Local Variables:
|
||||||
|
* indent-tabs-mode: t
|
||||||
|
* c-file-style: "linux"
|
||||||
|
* End:
|
||||||
|
*/
|
||||||
Reference in new issue
Block a user