Date: Mon, 16 Jul 2012 00:14:26 +0000 (UTC) From: Davide Italiano <davide@FreeBSD.org> To: src-committers@freebsd.org, svn-src-projects@freebsd.org Subject: svn commit: r238511 - projects/calloutng/sys/kern Message-ID: <201207160014.q6G0EQTm086694@svn.freebsd.org>
next in thread | raw e-mail | index | archive | help
Author: davide Date: Mon Jul 16 00:14:25 2012 New Revision: 238511 URL: http://svn.freebsd.org/changeset/base/238511 Log: Make the interval timings for EVFILT_TIMER more accurate. Differently from what happens in HEAD, here we can take advantage of the new callout(9) KPI and of the better precision allowed. Reviewed by: mav Modified: projects/calloutng/sys/kern/kern_event.c Modified: projects/calloutng/sys/kern/kern_event.c ============================================================================== --- projects/calloutng/sys/kern/kern_event.c Sun Jul 15 21:46:19 2012 (r238510) +++ projects/calloutng/sys/kern/kern_event.c Mon Jul 16 00:14:25 2012 (r238511) @@ -517,25 +517,26 @@ knote_fork(struct knlist *list, int pid) * XXX: EVFILT_TIMER should perhaps live in kern_time.c beside the * interval timer support code. */ -static int -timertoticks(intptr_t data) +static struct bintime +timer2bintime(intptr_t data) { - struct timeval tv; - int tticks; - - tv.tv_sec = data / 1000; - tv.tv_usec = (data % 1000) * 1000; - tticks = tvtohz(&tv); + struct bintime bt, pbt; - return tticks; + getbinuptime(&pbt); + bt.sec = data / 1000; + bt.frac = (data % 1000) * (uint64_t)1844674407309000LL; + bintime_add(&bt, &pbt); + return bt; } static void filt_timerexpire(void *knx) { - struct knote *kn = knx; + struct bintime bt; struct callout *calloutp; + struct knote *kn; + kn = knx; kn->kn_data++; KNOTE_ACTIVATE(kn, 0); /* XXX - handle locking */ @@ -547,9 +548,10 @@ filt_timerexpire(void *knx) * when we're delayed. */ if ((kn->kn_flags & EV_ONESHOT) != EV_ONESHOT) { + bt = timer2bintime(kn->kn_sdata); calloutp = (struct callout *)kn->kn_hook; - callout_reset_curcpu(calloutp, timertoticks(kn->kn_sdata) - 1, - filt_timerexpire, kn); + callout_reset_bt_on(calloutp, &bt, filt_timerexpire, kn, + PCPU_GET(cpuid), C_P1MS); } } @@ -559,6 +561,7 @@ filt_timerexpire(void *knx) static int filt_timerattach(struct knote *kn) { + struct bintime bt; struct callout *calloutp; atomic_add_int(&kq_ncallouts, 1); @@ -573,8 +576,9 @@ filt_timerattach(struct knote *kn) calloutp = malloc(sizeof(*calloutp), M_KQUEUE, M_WAITOK); callout_init(calloutp, CALLOUT_MPSAFE); kn->kn_hook = calloutp; - callout_reset_curcpu(calloutp, timertoticks(kn->kn_sdata), - filt_timerexpire, kn); + bt = timer2bintime(kn->kn_sdata); + callout_reset_bt_on(calloutp, &bt, filt_timerexpire, kn, + PCPU_GET(cpuid), C_P1MS); return (0); }
Want to link to this message? Use this URL: <https://mail-archive.FreeBSD.org/cgi/mid.cgi?201207160014.q6G0EQTm086694>