/** Test Valgrind's interception of the Linux syscalls timerfd_create(),
* timerfd_gettime() and timerfd_settime().
*
* This is a modified version of
* timerfd-test2 by Davide Libenzi (test app for timerfd)
* Copyright (C) 2007 Davide Libenzi <davidel@xmailserver.org>
* Modified for inclusion in Valgrind.
* Copyright (C) 2008 Bart Van Assche <bvanassche@acm.org>
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*
* See also http://www.xmailserver.org/timerfd-test2.c
*/
#define _GNU_SOURCE
#include "../../../config.h"
#include <errno.h>
#include <fcntl.h>
#include <poll.h>
#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <unistd.h>
#if defined(HAVE_SYS_SIGNAL_H)
#include <sys/signal.h>
#endif
#if defined(HAVE_SYS_SYSCALL_H)
#include <sys/syscall.h>
#endif
#if defined(HAVE_SYS_TIME_H)
#include <sys/time.h>
#endif
#if defined(HAVE_SYS_TYPES_H)
#include <sys/types.h>
#endif
/*
* timerfd_* system call numbers introduced in 2.6.23. These constants are
* not yet in the glibc 2.7 headers, that is why they are defined here.
*/
#ifndef __NR_timerfd_create
#if defined(__x86_64__)
#define __NR_timerfd_create 283
#elif defined(__i386__)
#define __NR_timerfd_create 322
#elif defined(__powerpc__)
#define __NR_timerfd_create 306
#elif defined(__s390x__)
#define __NR_timerfd_create 319
#else
#error Cannot detect your architecture!
#endif
#endif
#ifndef __NR_timerfd_settime
#if defined(__x86_64__)
#define __NR_timerfd_settime 286
#define __NR_timerfd_gettime 287
#elif defined(__i386__)
#define __NR_timerfd_settime 325
#define __NR_timerfd_gettime 326
#elif defined(__powerpc__)
#define __NR_timerfd_settime 311
#define __NR_timerfd_gettime 312
#elif defined(__s390x__)
#define __NR_timerfd_settime 320
#define __NR_timerfd_gettime 321
#else
#error Cannot detect your architecture!
#endif
#endif
/* Definitions from include/linux/timerfd.h */
#define TFD_TIMER_ABSTIME (1 << 0)
struct tmr_type
{
int id;
char const *name;
};
#if defined(HAVE_CLOCK_GETTIME)
unsigned long long getustime(int clockid)
{
struct timespec tp;
if (clock_gettime((clockid_t) clockid, &tp))
{
perror("clock_gettime");
return 0;
}
return 1000000ULL * tp.tv_sec + tp.tv_nsec / 1000;
}
#else
unsigned long long getustime(int clockid)
{
fprintf(stderr, "error: clock_gettime\n");
return 0;
}
#endif
void set_timespec(struct timespec *tmr, unsigned long long ustime)
{
tmr->tv_sec = (time_t) (ustime / 1000000ULL);
tmr->tv_nsec = (long) (1000ULL * (ustime % 1000000ULL));
}
int timerfd_create(int clockid, int flags)
{
return syscall(__NR_timerfd_create, clockid, flags);
}
int timerfd_settime(int ufc, int flags, const struct itimerspec *utmr,
struct itimerspec *otmr)
{
return syscall(__NR_timerfd_settime, ufc, flags, utmr, otmr);
}
int timerfd_gettime(int ufc, struct itimerspec *otmr)
{
return syscall(__NR_timerfd_gettime, ufc, otmr);
}
long waittmr(int tfd, int timeo)
{
u_int64_t ticks;
struct pollfd pfd;
pfd.fd = tfd;
pfd.events = POLLIN;
pfd.revents = 0;
if (poll(&pfd, 1, timeo) < 0)
{
perror("poll");
return -1;
}
if ((pfd.revents & POLLIN) == 0)
{
fprintf(stderr, "no ticks happened\n");
return -1;
}
if (read(tfd, &ticks, sizeof(ticks)) != sizeof(ticks))
{
perror("timerfd read");
return -1;
}
return ticks;
}
int main(int ac, char **av)
{
int i, tfd;
long ticks;
unsigned long long tnow, ttmr;
u_int64_t uticks;
struct itimerspec tmr;
struct tmr_type clks[] =
{
#if defined(HAVE_CLOCK_MONOTONIC)
{ CLOCK_MONOTONIC, "CLOCK MONOTONIC" },
#endif
{ CLOCK_REALTIME, "CLOCK REALTIME" },
};
for (i = 0; i < sizeof(clks) / sizeof(clks[0]); i++)
{
fprintf(stderr, "\n\n---------------------------------------\n");
fprintf(stderr, "| testing %s\n", clks[i].name);
fprintf(stderr, "---------------------------------------\n\n");
fprintf(stderr, "relative timer test (at 500 ms) ...\n");
set_timespec(&tmr.it_value, 500 * 1000);
set_timespec(&tmr.it_interval, 0);
tnow = getustime(clks[i].id);
if ((tfd = timerfd_create(clks[i].id, 0)) == -1)
{
perror("timerfd_create");
return 1;
}
if (timerfd_settime(tfd, 0, &tmr, NULL))
{
perror("timerfd_settime");
return 1;
}
fprintf(stderr, "waiting timer ...\n");
ticks = waittmr(tfd, -1);
ttmr = getustime(clks[i].id);
if (ticks <= 0)
fprintf(stderr, "whooops! no timer showed up!\n");
else
fprintf(stderr, "got timer ticks (%ld) after %.1f s\n",
ticks, (ttmr - tnow) * 1e-6);
fprintf(stderr, "absolute timer test (at 500 ms) ...\n");
tnow = getustime(clks[i].id);
set_timespec(&tmr.it_value, tnow + 500 * 1000);
set_timespec(&tmr.it_interval, 0);
if (timerfd_settime(tfd, TFD_TIMER_ABSTIME, &tmr, NULL))
{
perror("timerfd_settime");
return 1;
}
fprintf(stderr, "waiting timer ...\n");
ticks = waittmr(tfd, -1);
ttmr = getustime(clks[i].id);
if (ticks <= 0)
fprintf(stderr, "whooops! no timer showed up!\n");
else
fprintf(stderr, "got timer ticks (%ld) after %.1f s\n",
ticks, (ttmr - tnow) * 1e-6);
fprintf(stderr, "sequential timer test (100 ms clock) ...\n");
tnow = getustime(clks[i].id);
set_timespec(&tmr.it_value, tnow + 100 * 1000);
set_timespec(&tmr.it_interval, 100 * 1000);
if (timerfd_settime(tfd, TFD_TIMER_ABSTIME, &tmr, NULL))
{
perror("timerfd_settime");
return 1;
}
fprintf(stderr, "sleeping one second ...\n");
sleep(1);
if (timerfd_gettime(tfd, &tmr))
{
perror("timerfd_gettime");
return 1;
}
fprintf(stderr, "timerfd_gettime returned:\n"
"\tit_value = %.1f it_interval = %.1f\n",
tmr.it_value.tv_sec + 1e-9 * tmr.it_value.tv_nsec,
tmr.it_interval.tv_sec + 1e-9 * tmr.it_interval.tv_nsec);
fprintf(stderr, "sleeping 1 second ...\n");
sleep(1);
fprintf(stderr, "waiting timer ...\n");
ticks = waittmr(tfd, -1);
ttmr = getustime(clks[i].id);
if (ticks <= 0)
fprintf(stderr, "whooops! no timer showed up!\n");
else
{
const double delta = (ttmr - tnow) * 1e-6;
if (19 <= ticks && ticks <= 55 && 1.9 < delta && delta < 5.5)
fprintf(stderr, "got about 20 timer ticks after about 2s\n");
else
fprintf(stderr, "got timer ticks (%ld) after %.2f s\n", ticks, delta);
}
fprintf(stderr, "O_NONBLOCK test ...\n");
tnow = getustime(clks[i].id);
set_timespec(&tmr.it_value, 100 * 1000);
set_timespec(&tmr.it_interval, 0);
if (timerfd_settime(tfd, 0, &tmr, NULL))
{
perror("timerfd_settime");
return 1;
}
#if 0
fprintf(stderr, "timerfd = %d\n", tfd);
#endif
fprintf(stderr, "waiting timer (flush the single tick) ...\n");
ticks = waittmr(tfd, -1);
ttmr = getustime(clks[i].id);
if (ticks <= 0)
fprintf(stderr, "whooops! no timer showed up!\n");
else
fprintf(stderr, "got timer ticks (%ld) after %.1f s\n",
ticks, (ttmr - tnow) * 1e-6);
fcntl(tfd, F_SETFL, fcntl(tfd, F_GETFL, 0) | O_NONBLOCK);
if (read(tfd, &uticks, sizeof(uticks)) > 0)
fprintf(stderr, "whooops! timer ticks not zero when should have been\n");
else if (errno != EAGAIN)
fprintf(stderr, "whooops! bad errno value (%d = '%s')!\n",
errno, strerror(errno));
else
fprintf(stderr, "success\n");
fcntl(tfd, F_SETFL, fcntl(tfd, F_GETFL, 0) & ~O_NONBLOCK);
close(tfd);
}
return 0;
}