Home | History | Annotate | Line # | Download | only in kern
kern_clock.c revision 1.74.2.8
      1  1.74.2.8   nathanw /*	$NetBSD: kern_clock.c,v 1.74.2.8 2002/07/12 01:40:13 nathanw Exp $	*/
      2      1.52   thorpej 
      3      1.52   thorpej /*-
      4      1.52   thorpej  * Copyright (c) 2000 The NetBSD Foundation, Inc.
      5      1.52   thorpej  * All rights reserved.
      6      1.52   thorpej  *
      7      1.52   thorpej  * This code is derived from software contributed to The NetBSD Foundation
      8      1.52   thorpej  * by Jason R. Thorpe of the Numerical Aerospace Simulation Facility,
      9      1.52   thorpej  * NASA Ames Research Center.
     10      1.52   thorpej  *
     11      1.52   thorpej  * Redistribution and use in source and binary forms, with or without
     12      1.52   thorpej  * modification, are permitted provided that the following conditions
     13      1.52   thorpej  * are met:
     14      1.52   thorpej  * 1. Redistributions of source code must retain the above copyright
     15      1.52   thorpej  *    notice, this list of conditions and the following disclaimer.
     16      1.52   thorpej  * 2. Redistributions in binary form must reproduce the above copyright
     17      1.52   thorpej  *    notice, this list of conditions and the following disclaimer in the
     18      1.52   thorpej  *    documentation and/or other materials provided with the distribution.
     19      1.52   thorpej  * 3. All advertising materials mentioning features or use of this software
     20      1.52   thorpej  *    must display the following acknowledgement:
     21      1.52   thorpej  *	This product includes software developed by the NetBSD
     22      1.52   thorpej  *	Foundation, Inc. and its contributors.
     23      1.52   thorpej  * 4. Neither the name of The NetBSD Foundation nor the names of its
     24      1.52   thorpej  *    contributors may be used to endorse or promote products derived
     25      1.52   thorpej  *    from this software without specific prior written permission.
     26      1.52   thorpej  *
     27      1.52   thorpej  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     28      1.52   thorpej  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     29      1.52   thorpej  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     30      1.52   thorpej  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     31      1.52   thorpej  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     32      1.52   thorpej  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     33      1.52   thorpej  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     34      1.52   thorpej  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     35      1.52   thorpej  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     36      1.52   thorpej  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     37      1.52   thorpej  * POSSIBILITY OF SUCH DAMAGE.
     38      1.52   thorpej  */
     39      1.19       cgd 
     40      1.19       cgd /*-
     41      1.19       cgd  * Copyright (c) 1982, 1986, 1991, 1993
     42      1.19       cgd  *	The Regents of the University of California.  All rights reserved.
     43      1.19       cgd  * (c) UNIX System Laboratories, Inc.
     44      1.19       cgd  * All or some portions of this file are derived from material licensed
     45      1.19       cgd  * to the University of California by American Telephone and Telegraph
     46      1.19       cgd  * Co. or Unix System Laboratories, Inc. and are reproduced herein with
     47      1.19       cgd  * the permission of UNIX System Laboratories, Inc.
     48      1.19       cgd  *
     49      1.19       cgd  * Redistribution and use in source and binary forms, with or without
     50      1.19       cgd  * modification, are permitted provided that the following conditions
     51      1.19       cgd  * are met:
     52      1.19       cgd  * 1. Redistributions of source code must retain the above copyright
     53      1.19       cgd  *    notice, this list of conditions and the following disclaimer.
     54      1.19       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     55      1.19       cgd  *    notice, this list of conditions and the following disclaimer in the
     56      1.19       cgd  *    documentation and/or other materials provided with the distribution.
     57      1.19       cgd  * 3. All advertising materials mentioning features or use of this software
     58      1.19       cgd  *    must display the following acknowledgement:
     59      1.19       cgd  *	This product includes software developed by the University of
     60      1.19       cgd  *	California, Berkeley and its contributors.
     61      1.19       cgd  * 4. Neither the name of the University nor the names of its contributors
     62      1.19       cgd  *    may be used to endorse or promote products derived from this software
     63      1.19       cgd  *    without specific prior written permission.
     64      1.19       cgd  *
     65      1.19       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     66      1.19       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     67      1.19       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     68      1.19       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     69      1.19       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     70      1.19       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     71      1.19       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     72      1.19       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     73      1.19       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     74      1.19       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     75      1.19       cgd  * SUCH DAMAGE.
     76      1.19       cgd  *
     77      1.19       cgd  *	@(#)kern_clock.c	8.5 (Berkeley) 1/21/94
     78      1.19       cgd  */
     79  1.74.2.4   nathanw 
     80  1.74.2.4   nathanw #include <sys/cdefs.h>
     81  1.74.2.8   nathanw __KERNEL_RCSID(0, "$NetBSD: kern_clock.c,v 1.74.2.8 2002/07/12 01:40:13 nathanw Exp $");
     82      1.44  jonathan 
     83  1.74.2.3   nathanw #include "opt_callout.h"
     84      1.44  jonathan #include "opt_ntp.h"
     85      1.19       cgd 
     86      1.19       cgd #include <sys/param.h>
     87      1.19       cgd #include <sys/systm.h>
     88      1.19       cgd #include <sys/dkstat.h>
     89      1.19       cgd #include <sys/callout.h>
     90      1.19       cgd #include <sys/kernel.h>
     91      1.19       cgd #include <sys/proc.h>
     92      1.19       cgd #include <sys/resourcevar.h>
     93      1.25  christos #include <sys/signalvar.h>
     94      1.26  christos #include <sys/sysctl.h>
     95      1.27  jonathan #include <sys/timex.h>
     96      1.45      ross #include <sys/sched.h>
     97  1.74.2.5   nathanw #include <sys/time.h>
     98  1.74.2.3   nathanw #ifdef CALLWHEEL_STATS
     99  1.74.2.3   nathanw #include <sys/device.h>
    100  1.74.2.3   nathanw #endif
    101      1.19       cgd 
    102      1.19       cgd #include <machine/cpu.h>
    103      1.74   thorpej #ifdef __HAVE_GENERIC_SOFT_INTERRUPTS
    104      1.74   thorpej #include <machine/intr.h>
    105      1.74   thorpej #endif
    106      1.25  christos 
    107      1.19       cgd #ifdef GPROF
    108      1.19       cgd #include <sys/gmon.h>
    109      1.19       cgd #endif
    110      1.19       cgd 
    111      1.19       cgd /*
    112      1.19       cgd  * Clock handling routines.
    113      1.19       cgd  *
    114      1.19       cgd  * This code is written to operate with two timers that run independently of
    115      1.19       cgd  * each other.  The main clock, running hz times per second, is used to keep
    116      1.19       cgd  * track of real time.  The second timer handles kernel and user profiling,
    117      1.19       cgd  * and does resource use estimation.  If the second timer is programmable,
    118      1.19       cgd  * it is randomized to avoid aliasing between the two clocks.  For example,
    119      1.19       cgd  * the randomization prevents an adversary from always giving up the cpu
    120      1.19       cgd  * just before its quantum expires.  Otherwise, it would never accumulate
    121      1.19       cgd  * cpu ticks.  The mean frequency of the second timer is stathz.
    122      1.19       cgd  *
    123      1.19       cgd  * If no second timer exists, stathz will be zero; in this case we drive
    124      1.19       cgd  * profiling and statistics off the main clock.  This WILL NOT be accurate;
    125      1.19       cgd  * do not do it unless absolutely necessary.
    126      1.19       cgd  *
    127      1.19       cgd  * The statistics clock may (or may not) be run at a higher rate while
    128      1.19       cgd  * profiling.  This profile clock runs at profhz.  We require that profhz
    129      1.19       cgd  * be an integral multiple of stathz.
    130      1.19       cgd  *
    131      1.19       cgd  * If the statistics clock is running fast, it must be divided by the ratio
    132      1.19       cgd  * profhz/stathz for statistics.  (For profiling, every tick counts.)
    133      1.19       cgd  */
    134      1.19       cgd 
    135      1.27  jonathan #ifdef NTP	/* NTP phase-locked loop in kernel */
    136      1.27  jonathan /*
    137      1.27  jonathan  * Phase/frequency-lock loop (PLL/FLL) definitions
    138      1.27  jonathan  *
    139      1.27  jonathan  * The following variables are read and set by the ntp_adjtime() system
    140      1.27  jonathan  * call.
    141      1.27  jonathan  *
    142      1.27  jonathan  * time_state shows the state of the system clock, with values defined
    143      1.27  jonathan  * in the timex.h header file.
    144      1.27  jonathan  *
    145      1.27  jonathan  * time_status shows the status of the system clock, with bits defined
    146      1.27  jonathan  * in the timex.h header file.
    147      1.27  jonathan  *
    148      1.27  jonathan  * time_offset is used by the PLL/FLL to adjust the system time in small
    149      1.27  jonathan  * increments.
    150      1.27  jonathan  *
    151      1.27  jonathan  * time_constant determines the bandwidth or "stiffness" of the PLL.
    152      1.27  jonathan  *
    153      1.27  jonathan  * time_tolerance determines maximum frequency error or tolerance of the
    154      1.27  jonathan  * CPU clock oscillator and is a property of the architecture; however,
    155      1.27  jonathan  * in principle it could change as result of the presence of external
    156      1.27  jonathan  * discipline signals, for instance.
    157      1.27  jonathan  *
    158      1.27  jonathan  * time_precision is usually equal to the kernel tick variable; however,
    159      1.27  jonathan  * in cases where a precision clock counter or external clock is
    160      1.27  jonathan  * available, the resolution can be much less than this and depend on
    161      1.27  jonathan  * whether the external clock is working or not.
    162      1.27  jonathan  *
    163      1.27  jonathan  * time_maxerror is initialized by a ntp_adjtime() call and increased by
    164      1.27  jonathan  * the kernel once each second to reflect the maximum error bound
    165      1.27  jonathan  * growth.
    166      1.27  jonathan  *
    167      1.27  jonathan  * time_esterror is set and read by the ntp_adjtime() call, but
    168      1.27  jonathan  * otherwise not used by the kernel.
    169      1.27  jonathan  */
    170      1.27  jonathan int time_state = TIME_OK;	/* clock state */
    171      1.27  jonathan int time_status = STA_UNSYNC;	/* clock status bits */
    172      1.27  jonathan long time_offset = 0;		/* time offset (us) */
    173      1.27  jonathan long time_constant = 0;		/* pll time constant */
    174      1.27  jonathan long time_tolerance = MAXFREQ;	/* frequency tolerance (scaled ppm) */
    175      1.27  jonathan long time_precision = 1;	/* clock precision (us) */
    176      1.27  jonathan long time_maxerror = MAXPHASE;	/* maximum error (us) */
    177      1.27  jonathan long time_esterror = MAXPHASE;	/* estimated error (us) */
    178      1.27  jonathan 
    179      1.27  jonathan /*
    180      1.27  jonathan  * The following variables establish the state of the PLL/FLL and the
    181      1.27  jonathan  * residual time and frequency offset of the local clock. The scale
    182      1.27  jonathan  * factors are defined in the timex.h header file.
    183      1.27  jonathan  *
    184      1.27  jonathan  * time_phase and time_freq are the phase increment and the frequency
    185      1.27  jonathan  * increment, respectively, of the kernel time variable.
    186      1.27  jonathan  *
    187      1.27  jonathan  * time_freq is set via ntp_adjtime() from a value stored in a file when
    188      1.27  jonathan  * the synchronization daemon is first started. Its value is retrieved
    189      1.27  jonathan  * via ntp_adjtime() and written to the file about once per hour by the
    190      1.27  jonathan  * daemon.
    191      1.27  jonathan  *
    192      1.27  jonathan  * time_adj is the adjustment added to the value of tick at each timer
    193      1.27  jonathan  * interrupt and is recomputed from time_phase and time_freq at each
    194      1.27  jonathan  * seconds rollover.
    195      1.27  jonathan  *
    196      1.27  jonathan  * time_reftime is the second's portion of the system time at the last
    197      1.27  jonathan  * call to ntp_adjtime(). It is used to adjust the time_freq variable
    198      1.27  jonathan  * and to increase the time_maxerror as the time since last update
    199      1.27  jonathan  * increases.
    200      1.27  jonathan  */
    201      1.27  jonathan long time_phase = 0;		/* phase offset (scaled us) */
    202      1.27  jonathan long time_freq = 0;		/* frequency offset (scaled ppm) */
    203      1.27  jonathan long time_adj = 0;		/* tick adjust (scaled 1 / hz) */
    204      1.27  jonathan long time_reftime = 0;		/* time at last adjustment (s) */
    205      1.27  jonathan 
    206      1.27  jonathan #ifdef PPS_SYNC
    207      1.27  jonathan /*
    208      1.27  jonathan  * The following variables are used only if the kernel PPS discipline
    209      1.27  jonathan  * code is configured (PPS_SYNC). The scale factors are defined in the
    210      1.27  jonathan  * timex.h header file.
    211      1.27  jonathan  *
    212      1.27  jonathan  * pps_time contains the time at each calibration interval, as read by
    213      1.27  jonathan  * microtime(). pps_count counts the seconds of the calibration
    214      1.27  jonathan  * interval, the duration of which is nominally pps_shift in powers of
    215      1.27  jonathan  * two.
    216      1.27  jonathan  *
    217      1.27  jonathan  * pps_offset is the time offset produced by the time median filter
    218      1.27  jonathan  * pps_tf[], while pps_jitter is the dispersion (jitter) measured by
    219      1.27  jonathan  * this filter.
    220      1.27  jonathan  *
    221      1.27  jonathan  * pps_freq is the frequency offset produced by the frequency median
    222      1.27  jonathan  * filter pps_ff[], while pps_stabil is the dispersion (wander) measured
    223      1.27  jonathan  * by this filter.
    224      1.27  jonathan  *
    225      1.27  jonathan  * pps_usec is latched from a high resolution counter or external clock
    226      1.27  jonathan  * at pps_time. Here we want the hardware counter contents only, not the
    227      1.27  jonathan  * contents plus the time_tv.usec as usual.
    228      1.27  jonathan  *
    229      1.27  jonathan  * pps_valid counts the number of seconds since the last PPS update. It
    230      1.27  jonathan  * is used as a watchdog timer to disable the PPS discipline should the
    231      1.27  jonathan  * PPS signal be lost.
    232      1.27  jonathan  *
    233      1.27  jonathan  * pps_glitch counts the number of seconds since the beginning of an
    234      1.27  jonathan  * offset burst more than tick/2 from current nominal offset. It is used
    235      1.27  jonathan  * mainly to suppress error bursts due to priority conflicts between the
    236      1.27  jonathan  * PPS interrupt and timer interrupt.
    237      1.27  jonathan  *
    238      1.27  jonathan  * pps_intcnt counts the calibration intervals for use in the interval-
    239      1.27  jonathan  * adaptation algorithm. It's just too complicated for words.
    240      1.27  jonathan  */
    241      1.27  jonathan struct timeval pps_time;	/* kernel time at last interval */
    242      1.27  jonathan long pps_tf[] = {0, 0, 0};	/* pps time offset median filter (us) */
    243      1.27  jonathan long pps_offset = 0;		/* pps time offset (us) */
    244      1.27  jonathan long pps_jitter = MAXTIME;	/* time dispersion (jitter) (us) */
    245      1.27  jonathan long pps_ff[] = {0, 0, 0};	/* pps frequency offset median filter */
    246      1.27  jonathan long pps_freq = 0;		/* frequency offset (scaled ppm) */
    247      1.27  jonathan long pps_stabil = MAXFREQ;	/* frequency dispersion (scaled ppm) */
    248      1.27  jonathan long pps_usec = 0;		/* microsec counter at last interval */
    249      1.27  jonathan long pps_valid = PPS_VALID;	/* pps signal watchdog counter */
    250      1.27  jonathan int pps_glitch = 0;		/* pps signal glitch counter */
    251      1.27  jonathan int pps_count = 0;		/* calibration interval counter (s) */
    252      1.27  jonathan int pps_shift = PPS_SHIFT;	/* interval duration (s) (shift) */
    253      1.27  jonathan int pps_intcnt = 0;		/* intervals at current duration */
    254      1.27  jonathan 
    255      1.27  jonathan /*
    256      1.27  jonathan  * PPS signal quality monitors
    257      1.27  jonathan  *
    258      1.27  jonathan  * pps_jitcnt counts the seconds that have been discarded because the
    259      1.27  jonathan  * jitter measured by the time median filter exceeds the limit MAXTIME
    260      1.27  jonathan  * (100 us).
    261      1.27  jonathan  *
    262      1.27  jonathan  * pps_calcnt counts the frequency calibration intervals, which are
    263      1.27  jonathan  * variable from 4 s to 256 s.
    264      1.27  jonathan  *
    265      1.27  jonathan  * pps_errcnt counts the calibration intervals which have been discarded
    266      1.27  jonathan  * because the wander exceeds the limit MAXFREQ (100 ppm) or where the
    267      1.27  jonathan  * calibration interval jitter exceeds two ticks.
    268      1.27  jonathan  *
    269      1.27  jonathan  * pps_stbcnt counts the calibration intervals that have been discarded
    270      1.27  jonathan  * because the frequency wander exceeds the limit MAXFREQ / 4 (25 us).
    271      1.27  jonathan  */
    272      1.27  jonathan long pps_jitcnt = 0;		/* jitter limit exceeded */
    273      1.27  jonathan long pps_calcnt = 0;		/* calibration intervals */
    274      1.27  jonathan long pps_errcnt = 0;		/* calibration errors */
    275      1.27  jonathan long pps_stbcnt = 0;		/* stability limit exceeded */
    276      1.27  jonathan #endif /* PPS_SYNC */
    277      1.27  jonathan 
    278      1.27  jonathan #ifdef EXT_CLOCK
    279      1.27  jonathan /*
    280      1.27  jonathan  * External clock definitions
    281      1.27  jonathan  *
    282      1.27  jonathan  * The following definitions and declarations are used only if an
    283      1.27  jonathan  * external clock is configured on the system.
    284      1.27  jonathan  */
    285      1.27  jonathan #define CLOCK_INTERVAL 30	/* CPU clock update interval (s) */
    286      1.27  jonathan 
    287      1.27  jonathan /*
    288      1.27  jonathan  * The clock_count variable is set to CLOCK_INTERVAL at each PPS
    289      1.27  jonathan  * interrupt and decremented once each second.
    290      1.27  jonathan  */
    291      1.27  jonathan int clock_count = 0;		/* CPU clock counter */
    292      1.27  jonathan 
    293      1.27  jonathan #ifdef HIGHBALL
    294      1.27  jonathan /*
    295      1.27  jonathan  * The clock_offset and clock_cpu variables are used by the HIGHBALL
    296      1.27  jonathan  * interface. The clock_offset variable defines the offset between
    297      1.27  jonathan  * system time and the HIGBALL counters. The clock_cpu variable contains
    298      1.27  jonathan  * the offset between the system clock and the HIGHBALL clock for use in
    299      1.27  jonathan  * disciplining the kernel time variable.
    300      1.27  jonathan  */
    301      1.27  jonathan extern struct timeval clock_offset; /* Highball clock offset */
    302      1.27  jonathan long clock_cpu = 0;		/* CPU clock adjust */
    303      1.27  jonathan #endif /* HIGHBALL */
    304      1.27  jonathan #endif /* EXT_CLOCK */
    305      1.27  jonathan #endif /* NTP */
    306      1.27  jonathan 
    307      1.27  jonathan 
    308      1.19       cgd /*
    309      1.19       cgd  * Bump a timeval by a small number of usec's.
    310      1.19       cgd  */
    311      1.19       cgd #define BUMPTIME(t, usec) { \
    312      1.55  augustss 	volatile struct timeval *tp = (t); \
    313      1.55  augustss 	long us; \
    314      1.19       cgd  \
    315      1.19       cgd 	tp->tv_usec = us = tp->tv_usec + (usec); \
    316      1.19       cgd 	if (us >= 1000000) { \
    317      1.19       cgd 		tp->tv_usec = us - 1000000; \
    318      1.19       cgd 		tp->tv_sec++; \
    319      1.19       cgd 	} \
    320      1.19       cgd }
    321      1.19       cgd 
    322      1.19       cgd int	stathz;
    323      1.19       cgd int	profhz;
    324  1.74.2.2   nathanw int	schedhz;
    325      1.19       cgd int	profprocs;
    326      1.52   thorpej int	softclock_running;		/* 1 => softclock() is running */
    327      1.70  sommerfe static int psdiv;			/* prof => stat divider */
    328      1.22       cgd int	psratio;			/* ratio: prof / stat */
    329      1.22       cgd int	tickfix, tickfixinterval;	/* used if tick not really integral */
    330      1.34    briggs #ifndef NTP
    331      1.39       cgd static int tickfixcnt;			/* accumulated fractional error */
    332      1.34    briggs #else
    333      1.27  jonathan int	fixtick;			/* used by NTP for same */
    334      1.31   mycroft int	shifthz;
    335      1.31   mycroft #endif
    336      1.19       cgd 
    337      1.48  christos /*
    338      1.48  christos  * We might want ldd to load the both words from time at once.
    339      1.48  christos  * To succeed we need to be quadword aligned.
    340      1.48  christos  * The sparc already does that, and that it has worked so far is a fluke.
    341      1.48  christos  */
    342      1.48  christos volatile struct	timeval time  __attribute__((__aligned__(__alignof__(quad_t))));
    343      1.19       cgd volatile struct	timeval mono_time;
    344      1.19       cgd 
    345      1.19       cgd /*
    346      1.52   thorpej  * The callout mechanism is based on the work of Adam M. Costello and
    347      1.52   thorpej  * George Varghese, published in a technical report entitled "Redesigning
    348      1.52   thorpej  * the BSD Callout and Timer Facilities", and Justin Gibbs's subsequent
    349      1.52   thorpej  * integration into FreeBSD, modified for NetBSD by Jason R. Thorpe.
    350      1.52   thorpej  *
    351      1.52   thorpej  * The original work on the data structures used in this implementation
    352      1.52   thorpej  * was published by G. Varghese and A. Lauck in the paper "Hashed and
    353      1.52   thorpej  * Hierarchical Timing Wheels: Data Structures for the Efficient
    354      1.52   thorpej  * Implementation of a Timer Facility" in the Proceedings of the 11th
    355      1.52   thorpej  * ACM Annual Symposium on Operating System Principles, Austin, Texas,
    356      1.52   thorpej  * November 1987.
    357      1.52   thorpej  */
    358      1.52   thorpej struct callout_queue *callwheel;
    359      1.52   thorpej int	callwheelsize, callwheelbits, callwheelmask;
    360      1.52   thorpej 
    361      1.52   thorpej static struct callout *nextsoftcheck;	/* next callout to be checked */
    362      1.52   thorpej 
    363      1.52   thorpej #ifdef CALLWHEEL_STATS
    364  1.74.2.3   nathanw int	     *callwheel_sizes;		/* per-bucket length count */
    365  1.74.2.3   nathanw struct evcnt callwheel_collisions;	/* number of hash collisions */
    366  1.74.2.3   nathanw struct evcnt callwheel_maxlength;	/* length of the longest hash chain */
    367  1.74.2.3   nathanw struct evcnt callwheel_count;		/* # callouts currently */
    368  1.74.2.3   nathanw struct evcnt callwheel_established;	/* # callouts established */
    369  1.74.2.3   nathanw struct evcnt callwheel_fired;		/* # callouts that fired */
    370  1.74.2.3   nathanw struct evcnt callwheel_disestablished;	/* # callouts disestablished */
    371  1.74.2.3   nathanw struct evcnt callwheel_changed;		/* # callouts changed */
    372  1.74.2.3   nathanw struct evcnt callwheel_softclocks;	/* # times softclock() called */
    373  1.74.2.3   nathanw struct evcnt callwheel_softchecks;	/* # checks per softclock() */
    374  1.74.2.3   nathanw struct evcnt callwheel_softempty;	/* # empty buckets seen */
    375  1.74.2.3   nathanw struct evcnt callwheel_hintworked;	/* # times hint saved scan */
    376      1.52   thorpej #endif /* CALLWHEEL_STATS */
    377      1.52   thorpej 
    378      1.52   thorpej /*
    379      1.52   thorpej  * This value indicates the number of consecutive callouts that
    380      1.52   thorpej  * will be checked before we allow interrupts to have a chance
    381      1.52   thorpej  * again.
    382      1.52   thorpej  */
    383      1.52   thorpej #ifndef MAX_SOFTCLOCK_STEPS
    384      1.52   thorpej #define	MAX_SOFTCLOCK_STEPS	100
    385      1.52   thorpej #endif
    386      1.52   thorpej 
    387      1.64   thorpej struct simplelock callwheel_slock;
    388      1.64   thorpej 
    389      1.64   thorpej #define	CALLWHEEL_LOCK(s)						\
    390      1.64   thorpej do {									\
    391      1.64   thorpej 	s = splclock();							\
    392      1.64   thorpej 	simple_lock(&callwheel_slock);					\
    393      1.64   thorpej } while (0)
    394      1.64   thorpej 
    395      1.64   thorpej #define	CALLWHEEL_UNLOCK(s)						\
    396      1.64   thorpej do {									\
    397      1.64   thorpej 	simple_unlock(&callwheel_slock);				\
    398      1.64   thorpej 	splx(s);							\
    399      1.64   thorpej } while (0)
    400      1.64   thorpej 
    401      1.64   thorpej static void callout_stop_locked(struct callout *);
    402      1.64   thorpej 
    403      1.52   thorpej /*
    404      1.66   thorpej  * These are both protected by callwheel_lock.
    405      1.66   thorpej  * XXX SHOULD BE STATIC!!
    406      1.66   thorpej  */
    407      1.66   thorpej u_int64_t hardclock_ticks, softclock_ticks;
    408      1.66   thorpej 
    409      1.73   thorpej #ifdef __HAVE_GENERIC_SOFT_INTERRUPTS
    410      1.73   thorpej void	softclock(void *);
    411      1.73   thorpej void	*softclock_si;
    412      1.73   thorpej #endif
    413      1.73   thorpej 
    414      1.66   thorpej /*
    415      1.19       cgd  * Initialize clock frequencies and start both clocks running.
    416      1.19       cgd  */
    417      1.19       cgd void
    418      1.63   thorpej initclocks(void)
    419      1.19       cgd {
    420      1.55  augustss 	int i;
    421      1.19       cgd 
    422      1.73   thorpej #ifdef __HAVE_GENERIC_SOFT_INTERRUPTS
    423      1.73   thorpej 	softclock_si = softintr_establish(IPL_SOFTCLOCK, softclock, NULL);
    424      1.73   thorpej 	if (softclock_si == NULL)
    425      1.73   thorpej 		panic("initclocks: unable to register softclock intr");
    426      1.73   thorpej #endif
    427      1.73   thorpej 
    428      1.19       cgd 	/*
    429      1.19       cgd 	 * Set divisors to 1 (normal case) and let the machine-specific
    430      1.19       cgd 	 * code do its bit.
    431      1.19       cgd 	 */
    432      1.70  sommerfe 	psdiv = 1;
    433      1.19       cgd 	cpu_initclocks();
    434      1.19       cgd 
    435      1.19       cgd 	/*
    436      1.70  sommerfe 	 * Compute profhz/stathz/rrticks, and fix profhz if needed.
    437      1.19       cgd 	 */
    438      1.19       cgd 	i = stathz ? stathz : hz;
    439      1.19       cgd 	if (profhz == 0)
    440      1.19       cgd 		profhz = i;
    441      1.19       cgd 	psratio = profhz / i;
    442      1.70  sommerfe 	rrticks = hz / 10;
    443      1.31   mycroft 
    444      1.31   mycroft #ifdef NTP
    445      1.31   mycroft 	switch (hz) {
    446      1.57   mycroft 	case 1:
    447      1.57   mycroft 		shifthz = SHIFT_SCALE - 0;
    448      1.57   mycroft 		break;
    449      1.57   mycroft 	case 2:
    450      1.57   mycroft 		shifthz = SHIFT_SCALE - 1;
    451      1.57   mycroft 		break;
    452      1.57   mycroft 	case 4:
    453      1.57   mycroft 		shifthz = SHIFT_SCALE - 2;
    454      1.57   mycroft 		break;
    455      1.57   mycroft 	case 8:
    456      1.57   mycroft 		shifthz = SHIFT_SCALE - 3;
    457      1.57   mycroft 		break;
    458      1.57   mycroft 	case 16:
    459      1.57   mycroft 		shifthz = SHIFT_SCALE - 4;
    460      1.57   mycroft 		break;
    461      1.57   mycroft 	case 32:
    462      1.57   mycroft 		shifthz = SHIFT_SCALE - 5;
    463      1.57   mycroft 		break;
    464      1.31   mycroft 	case 60:
    465      1.31   mycroft 	case 64:
    466      1.31   mycroft 		shifthz = SHIFT_SCALE - 6;
    467      1.31   mycroft 		break;
    468      1.31   mycroft 	case 96:
    469      1.31   mycroft 	case 100:
    470      1.31   mycroft 	case 128:
    471      1.31   mycroft 		shifthz = SHIFT_SCALE - 7;
    472      1.31   mycroft 		break;
    473      1.31   mycroft 	case 256:
    474      1.31   mycroft 		shifthz = SHIFT_SCALE - 8;
    475      1.41       tls 		break;
    476      1.41       tls 	case 512:
    477      1.41       tls 		shifthz = SHIFT_SCALE - 9;
    478      1.31   mycroft 		break;
    479      1.43      ross 	case 1000:
    480      1.31   mycroft 	case 1024:
    481      1.31   mycroft 		shifthz = SHIFT_SCALE - 10;
    482      1.31   mycroft 		break;
    483      1.57   mycroft 	case 1200:
    484      1.57   mycroft 	case 2048:
    485      1.57   mycroft 		shifthz = SHIFT_SCALE - 11;
    486      1.57   mycroft 		break;
    487      1.57   mycroft 	case 4096:
    488      1.57   mycroft 		shifthz = SHIFT_SCALE - 12;
    489      1.57   mycroft 		break;
    490      1.57   mycroft 	case 8192:
    491      1.57   mycroft 		shifthz = SHIFT_SCALE - 13;
    492      1.57   mycroft 		break;
    493      1.57   mycroft 	case 16384:
    494      1.57   mycroft 		shifthz = SHIFT_SCALE - 14;
    495      1.57   mycroft 		break;
    496      1.57   mycroft 	case 32768:
    497      1.57   mycroft 		shifthz = SHIFT_SCALE - 15;
    498      1.57   mycroft 		break;
    499      1.57   mycroft 	case 65536:
    500      1.57   mycroft 		shifthz = SHIFT_SCALE - 16;
    501      1.57   mycroft 		break;
    502      1.31   mycroft 	default:
    503      1.31   mycroft 		panic("weird hz");
    504      1.50  sommerfe 	}
    505      1.50  sommerfe 	if (fixtick == 0) {
    506      1.52   thorpej 		/*
    507      1.52   thorpej 		 * Give MD code a chance to set this to a better
    508      1.52   thorpej 		 * value; but, if it doesn't, we should.
    509      1.52   thorpej 		 */
    510      1.50  sommerfe 		fixtick = (1000000 - (hz*tick));
    511      1.31   mycroft 	}
    512      1.31   mycroft #endif
    513      1.19       cgd }
    514      1.19       cgd 
    515      1.19       cgd /*
    516      1.19       cgd  * The real-time timer, interrupting hz times per second.
    517      1.19       cgd  */
    518      1.19       cgd void
    519      1.63   thorpej hardclock(struct clockframe *frame)
    520      1.19       cgd {
    521  1.74.2.1   nathanw 	struct lwp *l;
    522      1.55  augustss 	struct proc *p;
    523      1.55  augustss 	int delta;
    524      1.19       cgd 	extern int tickdelta;
    525      1.19       cgd 	extern long timedelta;
    526      1.70  sommerfe 	struct cpu_info *ci = curcpu();
    527      1.30   mycroft #ifdef NTP
    528      1.55  augustss 	int time_update;
    529      1.55  augustss 	int ltemp;
    530      1.29  christos #endif
    531      1.19       cgd 
    532  1.74.2.7   nathanw 	l = curlwp;
    533  1.74.2.1   nathanw 	if (l) {
    534  1.74.2.1   nathanw 		p = l->l_proc;
    535      1.19       cgd 		/*
    536      1.19       cgd 		 * Run current process's virtual and profile time, as needed.
    537      1.19       cgd 		 */
    538      1.19       cgd 		if (CLKF_USERMODE(frame) &&
    539  1.74.2.5   nathanw 		    p->p_timers && p->p_timers[ITIMER_VIRTUAL] &&
    540  1.74.2.5   nathanw 		    timerisset(&p->p_timers[ITIMER_VIRTUAL]->pt_time.it_value) &&
    541  1.74.2.5   nathanw 		    (itimerdecr(&p->p_timers[ITIMER_VIRTUAL]->pt_time, tick) == 0))
    542      1.19       cgd 			psignal(p, SIGVTALRM);
    543  1.74.2.5   nathanw 		if (p->p_timers && p->p_timers[ITIMER_PROF] &&
    544  1.74.2.5   nathanw 		    timerisset(&p->p_timers[ITIMER_PROF]->pt_time.it_value) &&
    545  1.74.2.5   nathanw 		    (itimerdecr(&p->p_timers[ITIMER_PROF]->pt_time, tick) == 0))
    546      1.19       cgd 			psignal(p, SIGPROF);
    547      1.19       cgd 	}
    548      1.19       cgd 
    549      1.19       cgd 	/*
    550      1.19       cgd 	 * If no separate statistics clock is available, run it from here.
    551      1.19       cgd 	 */
    552      1.19       cgd 	if (stathz == 0)
    553      1.19       cgd 		statclock(frame);
    554      1.70  sommerfe 	if ((--ci->ci_schedstate.spc_rrticks) <= 0)
    555      1.71  sommerfe 		roundrobin(ci);
    556      1.70  sommerfe 
    557      1.60   thorpej #if defined(MULTIPROCESSOR)
    558      1.60   thorpej 	/*
    559      1.60   thorpej 	 * If we are not the primary CPU, we're not allowed to do
    560      1.60   thorpej 	 * any more work.
    561      1.60   thorpej 	 */
    562      1.70  sommerfe 	if (CPU_IS_PRIMARY(ci) == 0)
    563      1.60   thorpej 		return;
    564      1.60   thorpej #endif
    565      1.60   thorpej 
    566      1.19       cgd 	/*
    567      1.22       cgd 	 * Increment the time-of-day.  The increment is normally just
    568      1.22       cgd 	 * ``tick''.  If the machine is one which has a clock frequency
    569      1.22       cgd 	 * such that ``hz'' would not divide the second evenly into
    570      1.22       cgd 	 * milliseconds, a periodic adjustment must be applied.  Finally,
    571      1.22       cgd 	 * if we are still adjusting the time (see adjtime()),
    572      1.22       cgd 	 * ``tickdelta'' may also be added in.
    573      1.19       cgd 	 */
    574      1.22       cgd 	delta = tick;
    575      1.27  jonathan 
    576      1.27  jonathan #ifndef NTP
    577      1.22       cgd 	if (tickfix) {
    578      1.39       cgd 		tickfixcnt += tickfix;
    579      1.24       cgd 		if (tickfixcnt >= tickfixinterval) {
    580      1.39       cgd 			delta++;
    581      1.39       cgd 			tickfixcnt -= tickfixinterval;
    582      1.22       cgd 		}
    583      1.22       cgd 	}
    584      1.27  jonathan #endif /* !NTP */
    585      1.27  jonathan 	/* Imprecise 4bsd adjtime() handling */
    586      1.22       cgd 	if (timedelta != 0) {
    587      1.38       cgd 		delta += tickdelta;
    588      1.19       cgd 		timedelta -= tickdelta;
    589      1.19       cgd 	}
    590      1.27  jonathan 
    591      1.27  jonathan #ifdef notyet
    592      1.27  jonathan 	microset();
    593      1.27  jonathan #endif
    594      1.27  jonathan 
    595      1.27  jonathan #ifndef NTP
    596      1.27  jonathan 	BUMPTIME(&time, delta);		/* XXX Now done using NTP code below */
    597      1.27  jonathan #endif
    598      1.19       cgd 	BUMPTIME(&mono_time, delta);
    599      1.27  jonathan 
    600      1.31   mycroft #ifdef NTP
    601      1.30   mycroft 	time_update = delta;
    602      1.27  jonathan 
    603      1.27  jonathan 	/*
    604      1.27  jonathan 	 * Compute the phase adjustment. If the low-order bits
    605      1.27  jonathan 	 * (time_phase) of the update overflow, bump the high-order bits
    606      1.27  jonathan 	 * (time_update).
    607      1.27  jonathan 	 */
    608      1.27  jonathan 	time_phase += time_adj;
    609      1.27  jonathan 	if (time_phase <= -FINEUSEC) {
    610      1.27  jonathan 		ltemp = -time_phase >> SHIFT_SCALE;
    611      1.27  jonathan 		time_phase += ltemp << SHIFT_SCALE;
    612      1.27  jonathan 		time_update -= ltemp;
    613      1.31   mycroft 	} else if (time_phase >= FINEUSEC) {
    614      1.27  jonathan 		ltemp = time_phase >> SHIFT_SCALE;
    615      1.27  jonathan 		time_phase -= ltemp << SHIFT_SCALE;
    616      1.27  jonathan 		time_update += ltemp;
    617      1.27  jonathan 	}
    618      1.27  jonathan 
    619      1.27  jonathan #ifdef HIGHBALL
    620      1.27  jonathan 	/*
    621      1.27  jonathan 	 * If the HIGHBALL board is installed, we need to adjust the
    622      1.27  jonathan 	 * external clock offset in order to close the hardware feedback
    623      1.27  jonathan 	 * loop. This will adjust the external clock phase and frequency
    624      1.27  jonathan 	 * in small amounts. The additional phase noise and frequency
    625      1.27  jonathan 	 * wander this causes should be minimal. We also need to
    626      1.27  jonathan 	 * discipline the kernel time variable, since the PLL is used to
    627      1.27  jonathan 	 * discipline the external clock. If the Highball board is not
    628      1.27  jonathan 	 * present, we discipline kernel time with the PLL as usual. We
    629      1.27  jonathan 	 * assume that the external clock phase adjustment (time_update)
    630      1.27  jonathan 	 * and kernel phase adjustment (clock_cpu) are less than the
    631      1.27  jonathan 	 * value of tick.
    632      1.27  jonathan 	 */
    633      1.27  jonathan 	clock_offset.tv_usec += time_update;
    634      1.27  jonathan 	if (clock_offset.tv_usec >= 1000000) {
    635      1.27  jonathan 		clock_offset.tv_sec++;
    636      1.27  jonathan 		clock_offset.tv_usec -= 1000000;
    637      1.27  jonathan 	}
    638      1.27  jonathan 	if (clock_offset.tv_usec < 0) {
    639      1.27  jonathan 		clock_offset.tv_sec--;
    640      1.27  jonathan 		clock_offset.tv_usec += 1000000;
    641      1.27  jonathan 	}
    642      1.27  jonathan 	time.tv_usec += clock_cpu;
    643      1.27  jonathan 	clock_cpu = 0;
    644      1.27  jonathan #else
    645      1.27  jonathan 	time.tv_usec += time_update;
    646      1.27  jonathan #endif /* HIGHBALL */
    647      1.27  jonathan 
    648      1.27  jonathan 	/*
    649      1.27  jonathan 	 * On rollover of the second the phase adjustment to be used for
    650      1.27  jonathan 	 * the next second is calculated. Also, the maximum error is
    651      1.27  jonathan 	 * increased by the tolerance. If the PPS frequency discipline
    652      1.27  jonathan 	 * code is present, the phase is increased to compensate for the
    653      1.27  jonathan 	 * CPU clock oscillator frequency error.
    654      1.27  jonathan 	 *
    655      1.27  jonathan  	 * On a 32-bit machine and given parameters in the timex.h
    656      1.27  jonathan 	 * header file, the maximum phase adjustment is +-512 ms and
    657      1.27  jonathan 	 * maximum frequency offset is a tad less than) +-512 ppm. On a
    658      1.27  jonathan 	 * 64-bit machine, you shouldn't need to ask.
    659      1.27  jonathan 	 */
    660      1.27  jonathan 	if (time.tv_usec >= 1000000) {
    661      1.27  jonathan 		time.tv_usec -= 1000000;
    662      1.27  jonathan 		time.tv_sec++;
    663      1.27  jonathan 		time_maxerror += time_tolerance >> SHIFT_USEC;
    664      1.27  jonathan 
    665      1.27  jonathan 		/*
    666      1.27  jonathan 		 * Leap second processing. If in leap-insert state at
    667      1.27  jonathan 		 * the end of the day, the system clock is set back one
    668      1.27  jonathan 		 * second; if in leap-delete state, the system clock is
    669      1.27  jonathan 		 * set ahead one second. The microtime() routine or
    670      1.27  jonathan 		 * external clock driver will insure that reported time
    671      1.27  jonathan 		 * is always monotonic. The ugly divides should be
    672      1.27  jonathan 		 * replaced.
    673      1.27  jonathan 		 */
    674      1.27  jonathan 		switch (time_state) {
    675      1.31   mycroft 		case TIME_OK:
    676      1.27  jonathan 			if (time_status & STA_INS)
    677      1.27  jonathan 				time_state = TIME_INS;
    678      1.27  jonathan 			else if (time_status & STA_DEL)
    679      1.27  jonathan 				time_state = TIME_DEL;
    680      1.27  jonathan 			break;
    681      1.27  jonathan 
    682      1.31   mycroft 		case TIME_INS:
    683      1.27  jonathan 			if (time.tv_sec % 86400 == 0) {
    684      1.27  jonathan 				time.tv_sec--;
    685      1.27  jonathan 				time_state = TIME_OOP;
    686      1.27  jonathan 			}
    687      1.27  jonathan 			break;
    688      1.27  jonathan 
    689      1.31   mycroft 		case TIME_DEL:
    690      1.27  jonathan 			if ((time.tv_sec + 1) % 86400 == 0) {
    691      1.27  jonathan 				time.tv_sec++;
    692      1.27  jonathan 				time_state = TIME_WAIT;
    693      1.27  jonathan 			}
    694      1.27  jonathan 			break;
    695      1.27  jonathan 
    696      1.31   mycroft 		case TIME_OOP:
    697      1.27  jonathan 			time_state = TIME_WAIT;
    698      1.27  jonathan 			break;
    699      1.27  jonathan 
    700      1.31   mycroft 		case TIME_WAIT:
    701      1.27  jonathan 			if (!(time_status & (STA_INS | STA_DEL)))
    702      1.27  jonathan 				time_state = TIME_OK;
    703      1.31   mycroft 			break;
    704      1.27  jonathan 		}
    705      1.27  jonathan 
    706      1.27  jonathan 		/*
    707      1.27  jonathan 		 * Compute the phase adjustment for the next second. In
    708      1.27  jonathan 		 * PLL mode, the offset is reduced by a fixed factor
    709      1.27  jonathan 		 * times the time constant. In FLL mode the offset is
    710      1.27  jonathan 		 * used directly. In either mode, the maximum phase
    711      1.27  jonathan 		 * adjustment for each second is clamped so as to spread
    712      1.27  jonathan 		 * the adjustment over not more than the number of
    713      1.27  jonathan 		 * seconds between updates.
    714      1.27  jonathan 		 */
    715      1.27  jonathan 		if (time_offset < 0) {
    716      1.27  jonathan 			ltemp = -time_offset;
    717      1.27  jonathan 			if (!(time_status & STA_FLL))
    718      1.27  jonathan 				ltemp >>= SHIFT_KG + time_constant;
    719      1.27  jonathan 			if (ltemp > (MAXPHASE / MINSEC) << SHIFT_UPDATE)
    720      1.27  jonathan 				ltemp = (MAXPHASE / MINSEC) <<
    721      1.27  jonathan 				    SHIFT_UPDATE;
    722      1.27  jonathan 			time_offset += ltemp;
    723      1.31   mycroft 			time_adj = -ltemp << (shifthz - SHIFT_UPDATE);
    724      1.31   mycroft 		} else if (time_offset > 0) {
    725      1.27  jonathan 			ltemp = time_offset;
    726      1.27  jonathan 			if (!(time_status & STA_FLL))
    727      1.27  jonathan 				ltemp >>= SHIFT_KG + time_constant;
    728      1.27  jonathan 			if (ltemp > (MAXPHASE / MINSEC) << SHIFT_UPDATE)
    729      1.27  jonathan 				ltemp = (MAXPHASE / MINSEC) <<
    730      1.27  jonathan 				    SHIFT_UPDATE;
    731      1.27  jonathan 			time_offset -= ltemp;
    732      1.31   mycroft 			time_adj = ltemp << (shifthz - SHIFT_UPDATE);
    733      1.31   mycroft 		} else
    734      1.31   mycroft 			time_adj = 0;
    735      1.27  jonathan 
    736      1.27  jonathan 		/*
    737      1.27  jonathan 		 * Compute the frequency estimate and additional phase
    738      1.27  jonathan 		 * adjustment due to frequency error for the next
    739      1.27  jonathan 		 * second. When the PPS signal is engaged, gnaw on the
    740      1.27  jonathan 		 * watchdog counter and update the frequency computed by
    741      1.27  jonathan 		 * the pll and the PPS signal.
    742      1.27  jonathan 		 */
    743      1.27  jonathan #ifdef PPS_SYNC
    744      1.27  jonathan 		pps_valid++;
    745      1.27  jonathan 		if (pps_valid == PPS_VALID) {
    746      1.27  jonathan 			pps_jitter = MAXTIME;
    747      1.27  jonathan 			pps_stabil = MAXFREQ;
    748      1.27  jonathan 			time_status &= ~(STA_PPSSIGNAL | STA_PPSJITTER |
    749      1.27  jonathan 			    STA_PPSWANDER | STA_PPSERROR);
    750      1.27  jonathan 		}
    751      1.27  jonathan 		ltemp = time_freq + pps_freq;
    752      1.27  jonathan #else
    753      1.27  jonathan 		ltemp = time_freq;
    754      1.27  jonathan #endif /* PPS_SYNC */
    755      1.27  jonathan 
    756      1.27  jonathan 		if (ltemp < 0)
    757      1.31   mycroft 			time_adj -= -ltemp >> (SHIFT_USEC - shifthz);
    758      1.27  jonathan 		else
    759      1.31   mycroft 			time_adj += ltemp >> (SHIFT_USEC - shifthz);
    760      1.31   mycroft 		time_adj += (long)fixtick << shifthz;
    761      1.27  jonathan 
    762      1.27  jonathan 		/*
    763      1.27  jonathan 		 * When the CPU clock oscillator frequency is not a
    764      1.31   mycroft 		 * power of 2 in Hz, shifthz is only an approximate
    765      1.31   mycroft 		 * scale factor.
    766      1.46   mycroft 		 *
    767      1.46   mycroft 		 * To determine the adjustment, you can do the following:
    768      1.46   mycroft 		 *   bc -q
    769      1.46   mycroft 		 *   scale=24
    770      1.46   mycroft 		 *   obase=2
    771      1.46   mycroft 		 *   idealhz/realhz
    772      1.46   mycroft 		 * where `idealhz' is the next higher power of 2, and `realhz'
    773      1.57   mycroft 		 * is the actual value.  You may need to factor this result
    774      1.57   mycroft 		 * into a sequence of 2 multipliers to get better precision.
    775      1.46   mycroft 		 *
    776      1.46   mycroft 		 * Likewise, the error can be calculated with (e.g. for 100Hz):
    777      1.46   mycroft 		 *   bc -q
    778      1.46   mycroft 		 *   scale=24
    779      1.57   mycroft 		 *   ((1+2^-2+2^-5)*(1-2^-10)*realhz-idealhz)/idealhz
    780      1.57   mycroft 		 * (and then multiply by 1000000 to get ppm).
    781      1.27  jonathan 		 */
    782      1.31   mycroft 		switch (hz) {
    783      1.58   mycroft 		case 60:
    784      1.58   mycroft 			/* A factor of 1.000100010001 gives about 15ppm
    785      1.58   mycroft 			   error. */
    786      1.58   mycroft 			if (time_adj < 0) {
    787      1.58   mycroft 				time_adj -= (-time_adj >> 4);
    788      1.58   mycroft 				time_adj -= (-time_adj >> 8);
    789      1.58   mycroft 			} else {
    790      1.58   mycroft 				time_adj += (time_adj >> 4);
    791      1.58   mycroft 				time_adj += (time_adj >> 8);
    792      1.58   mycroft 			}
    793      1.58   mycroft 			break;
    794      1.58   mycroft 
    795      1.31   mycroft 		case 96:
    796      1.56   mycroft 			/* A factor of 1.0101010101 gives about 244ppm error. */
    797      1.46   mycroft 			if (time_adj < 0) {
    798      1.46   mycroft 				time_adj -= (-time_adj >> 2);
    799      1.46   mycroft 				time_adj -= (-time_adj >> 4) + (-time_adj >> 8);
    800      1.46   mycroft 			} else {
    801      1.46   mycroft 				time_adj += (time_adj >> 2);
    802      1.46   mycroft 				time_adj += (time_adj >> 4) + (time_adj >> 8);
    803      1.46   mycroft 			}
    804      1.46   mycroft 			break;
    805      1.46   mycroft 
    806      1.31   mycroft 		case 100:
    807      1.56   mycroft 			/* A factor of 1.010001111010111 gives about 1ppm
    808      1.56   mycroft 			   error. */
    809      1.56   mycroft 			if (time_adj < 0) {
    810      1.46   mycroft 				time_adj -= (-time_adj >> 2) + (-time_adj >> 5);
    811      1.56   mycroft 				time_adj += (-time_adj >> 10);
    812      1.56   mycroft 			} else {
    813      1.46   mycroft 				time_adj += (time_adj >> 2) + (time_adj >> 5);
    814      1.56   mycroft 				time_adj -= (time_adj >> 10);
    815      1.56   mycroft 			}
    816      1.43      ross 			break;
    817      1.46   mycroft 
    818      1.43      ross 		case 1000:
    819      1.56   mycroft 			/* A factor of 1.000001100010100001 gives about 50ppm
    820      1.56   mycroft 			   error. */
    821      1.56   mycroft 			if (time_adj < 0) {
    822      1.56   mycroft 				time_adj -= (-time_adj >> 6) + (-time_adj >> 11);
    823      1.56   mycroft 				time_adj -= (-time_adj >> 7);
    824      1.56   mycroft 			} else {
    825      1.56   mycroft 				time_adj += (time_adj >> 6) + (time_adj >> 11);
    826      1.56   mycroft 				time_adj += (time_adj >> 7);
    827      1.56   mycroft 			}
    828      1.56   mycroft 			break;
    829      1.56   mycroft 
    830      1.56   mycroft 		case 1200:
    831      1.56   mycroft 			/* A factor of 1.1011010011100001 gives about 64ppm
    832      1.56   mycroft 			   error. */
    833      1.56   mycroft 			if (time_adj < 0) {
    834      1.56   mycroft 				time_adj -= (-time_adj >> 1) + (-time_adj >> 6);
    835      1.56   mycroft 				time_adj -= (-time_adj >> 3) + (-time_adj >> 10);
    836      1.56   mycroft 			} else {
    837      1.56   mycroft 				time_adj += (time_adj >> 1) + (time_adj >> 6);
    838      1.56   mycroft 				time_adj += (time_adj >> 3) + (time_adj >> 10);
    839      1.56   mycroft 			}
    840      1.31   mycroft 			break;
    841      1.27  jonathan 		}
    842      1.27  jonathan 
    843      1.27  jonathan #ifdef EXT_CLOCK
    844      1.27  jonathan 		/*
    845      1.27  jonathan 		 * If an external clock is present, it is necessary to
    846      1.27  jonathan 		 * discipline the kernel time variable anyway, since not
    847      1.27  jonathan 		 * all system components use the microtime() interface.
    848      1.27  jonathan 		 * Here, the time offset between the external clock and
    849      1.27  jonathan 		 * kernel time variable is computed every so often.
    850      1.27  jonathan 		 */
    851      1.27  jonathan 		clock_count++;
    852      1.27  jonathan 		if (clock_count > CLOCK_INTERVAL) {
    853      1.27  jonathan 			clock_count = 0;
    854      1.27  jonathan 			microtime(&clock_ext);
    855      1.27  jonathan 			delta.tv_sec = clock_ext.tv_sec - time.tv_sec;
    856      1.27  jonathan 			delta.tv_usec = clock_ext.tv_usec -
    857      1.27  jonathan 			    time.tv_usec;
    858      1.27  jonathan 			if (delta.tv_usec < 0)
    859      1.27  jonathan 				delta.tv_sec--;
    860      1.27  jonathan 			if (delta.tv_usec >= 500000) {
    861      1.27  jonathan 				delta.tv_usec -= 1000000;
    862      1.27  jonathan 				delta.tv_sec++;
    863      1.27  jonathan 			}
    864      1.27  jonathan 			if (delta.tv_usec < -500000) {
    865      1.27  jonathan 				delta.tv_usec += 1000000;
    866      1.27  jonathan 				delta.tv_sec--;
    867      1.27  jonathan 			}
    868      1.27  jonathan 			if (delta.tv_sec > 0 || (delta.tv_sec == 0 &&
    869      1.27  jonathan 			    delta.tv_usec > MAXPHASE) ||
    870      1.27  jonathan 			    delta.tv_sec < -1 || (delta.tv_sec == -1 &&
    871      1.27  jonathan 			    delta.tv_usec < -MAXPHASE)) {
    872      1.27  jonathan 				time = clock_ext;
    873      1.27  jonathan 				delta.tv_sec = 0;
    874      1.27  jonathan 				delta.tv_usec = 0;
    875      1.27  jonathan 			}
    876      1.27  jonathan #ifdef HIGHBALL
    877      1.27  jonathan 			clock_cpu = delta.tv_usec;
    878      1.27  jonathan #else /* HIGHBALL */
    879      1.27  jonathan 			hardupdate(delta.tv_usec);
    880      1.27  jonathan #endif /* HIGHBALL */
    881      1.27  jonathan 		}
    882      1.27  jonathan #endif /* EXT_CLOCK */
    883      1.27  jonathan 	}
    884      1.27  jonathan 
    885      1.31   mycroft #endif /* NTP */
    886      1.19       cgd 
    887      1.19       cgd 	/*
    888      1.19       cgd 	 * Process callouts at a very low cpu priority, so we don't keep the
    889      1.19       cgd 	 * relatively high clock interrupt priority any longer than necessary.
    890      1.19       cgd 	 */
    891      1.66   thorpej 	simple_lock(&callwheel_slock);	/* already at splclock() */
    892      1.66   thorpej 	hardclock_ticks++;
    893  1.74.2.3   nathanw 	if (! TAILQ_EMPTY(&callwheel[hardclock_ticks & callwheelmask].cq_q)) {
    894      1.66   thorpej 		simple_unlock(&callwheel_slock);
    895      1.19       cgd 		if (CLKF_BASEPRI(frame)) {
    896      1.19       cgd 			/*
    897      1.19       cgd 			 * Save the overhead of a software interrupt;
    898      1.52   thorpej 			 * it will happen as soon as we return, so do
    899      1.52   thorpej 			 * it now.
    900      1.52   thorpej 			 *
    901      1.52   thorpej 			 * NOTE: If we're at ``base priority'', softclock()
    902      1.52   thorpej 			 * was not already running.
    903      1.19       cgd 			 */
    904      1.65   thorpej 			spllowersoftclock();
    905      1.69   thorpej 			KERNEL_LOCK(LK_CANRECURSE|LK_EXCLUSIVE);
    906      1.73   thorpej 			softclock(NULL);
    907      1.69   thorpej 			KERNEL_UNLOCK();
    908      1.73   thorpej 		} else {
    909      1.73   thorpej #ifdef __HAVE_GENERIC_SOFT_INTERRUPTS
    910      1.73   thorpej 			softintr_schedule(softclock_si);
    911      1.73   thorpej #else
    912      1.19       cgd 			setsoftclock();
    913      1.73   thorpej #endif
    914      1.73   thorpej 		}
    915      1.67   thorpej 		return;
    916      1.52   thorpej 	} else if (softclock_running == 0 &&
    917      1.66   thorpej 		   (softclock_ticks + 1) == hardclock_ticks) {
    918      1.52   thorpej 		softclock_ticks++;
    919      1.66   thorpej 	}
    920      1.67   thorpej 	simple_unlock(&callwheel_slock);
    921      1.19       cgd }
    922      1.19       cgd 
    923      1.19       cgd /*
    924      1.19       cgd  * Software (low priority) clock interrupt.
    925      1.19       cgd  * Run periodic events from timeout queue.
    926      1.19       cgd  */
    927      1.19       cgd /*ARGSUSED*/
    928      1.19       cgd void
    929      1.73   thorpej softclock(void *v)
    930      1.19       cgd {
    931      1.52   thorpej 	struct callout_queue *bucket;
    932      1.52   thorpej 	struct callout *c;
    933      1.63   thorpej 	void (*func)(void *);
    934      1.52   thorpej 	void *arg;
    935      1.52   thorpej 	int s, idx;
    936      1.52   thorpej 	int steps = 0;
    937      1.19       cgd 
    938      1.64   thorpej 	CALLWHEEL_LOCK(s);
    939      1.64   thorpej 
    940      1.52   thorpej 	softclock_running = 1;
    941      1.52   thorpej 
    942      1.52   thorpej #ifdef CALLWHEEL_STATS
    943  1.74.2.3   nathanw 	callwheel_softclocks.ev_count++;
    944      1.52   thorpej #endif
    945      1.52   thorpej 
    946      1.52   thorpej 	while (softclock_ticks != hardclock_ticks) {
    947      1.52   thorpej 		softclock_ticks++;
    948      1.52   thorpej 		idx = (int)(softclock_ticks & callwheelmask);
    949      1.52   thorpej 		bucket = &callwheel[idx];
    950  1.74.2.3   nathanw 		c = TAILQ_FIRST(&bucket->cq_q);
    951  1.74.2.3   nathanw 		if (c == NULL) {
    952  1.74.2.3   nathanw #ifdef CALLWHEEL_STATS
    953  1.74.2.3   nathanw 			callwheel_softempty.ev_count++;
    954  1.74.2.3   nathanw #endif
    955  1.74.2.3   nathanw 			continue;
    956  1.74.2.3   nathanw 		}
    957  1.74.2.3   nathanw 		if (softclock_ticks < bucket->cq_hint) {
    958      1.52   thorpej #ifdef CALLWHEEL_STATS
    959  1.74.2.3   nathanw 			callwheel_hintworked.ev_count++;
    960      1.52   thorpej #endif
    961  1.74.2.3   nathanw 			continue;
    962  1.74.2.3   nathanw 		}
    963  1.74.2.3   nathanw 		bucket->cq_hint = UQUAD_MAX;
    964      1.52   thorpej 		while (c != NULL) {
    965      1.52   thorpej #ifdef CALLWHEEL_STATS
    966  1.74.2.3   nathanw 			callwheel_softchecks.ev_count++;
    967      1.52   thorpej #endif
    968      1.52   thorpej 			if (c->c_time != softclock_ticks) {
    969  1.74.2.3   nathanw 				if (c->c_time < bucket->cq_hint)
    970  1.74.2.3   nathanw 					bucket->cq_hint = c->c_time;
    971      1.52   thorpej 				c = TAILQ_NEXT(c, c_link);
    972      1.52   thorpej 				if (++steps >= MAX_SOFTCLOCK_STEPS) {
    973      1.52   thorpej 					nextsoftcheck = c;
    974      1.52   thorpej 					/* Give interrupts a chance. */
    975      1.64   thorpej 					CALLWHEEL_UNLOCK(s);
    976      1.64   thorpej 					CALLWHEEL_LOCK(s);
    977      1.52   thorpej 					c = nextsoftcheck;
    978      1.52   thorpej 					steps = 0;
    979      1.52   thorpej 				}
    980      1.52   thorpej 			} else {
    981      1.52   thorpej 				nextsoftcheck = TAILQ_NEXT(c, c_link);
    982  1.74.2.3   nathanw 				TAILQ_REMOVE(&bucket->cq_q, c, c_link);
    983      1.52   thorpej #ifdef CALLWHEEL_STATS
    984      1.52   thorpej 				callwheel_sizes[idx]--;
    985  1.74.2.3   nathanw 				callwheel_fired.ev_count++;
    986  1.74.2.3   nathanw 				callwheel_count.ev_count--;
    987      1.52   thorpej #endif
    988      1.52   thorpej 				func = c->c_func;
    989      1.52   thorpej 				arg = c->c_arg;
    990      1.52   thorpej 				c->c_func = NULL;
    991      1.52   thorpej 				c->c_flags &= ~CALLOUT_PENDING;
    992      1.64   thorpej 				CALLWHEEL_UNLOCK(s);
    993      1.52   thorpej 				(*func)(arg);
    994      1.64   thorpej 				CALLWHEEL_LOCK(s);
    995      1.52   thorpej 				steps = 0;
    996      1.52   thorpej 				c = nextsoftcheck;
    997      1.52   thorpej 			}
    998      1.52   thorpej 		}
    999  1.74.2.3   nathanw 		if (TAILQ_EMPTY(&bucket->cq_q))
   1000  1.74.2.3   nathanw 			bucket->cq_hint = UQUAD_MAX;
   1001      1.19       cgd 	}
   1002      1.52   thorpej 	nextsoftcheck = NULL;
   1003      1.52   thorpej 	softclock_running = 0;
   1004      1.64   thorpej 	CALLWHEEL_UNLOCK(s);
   1005      1.51   thorpej }
   1006      1.51   thorpej 
   1007      1.51   thorpej /*
   1008      1.54     enami  * callout_setsize:
   1009      1.52   thorpej  *
   1010      1.54     enami  *	Determine how many callwheels are necessary and
   1011      1.54     enami  *	set hash mask.  Called from allocsys().
   1012      1.51   thorpej  */
   1013      1.51   thorpej void
   1014      1.63   thorpej callout_setsize(void)
   1015      1.51   thorpej {
   1016      1.52   thorpej 
   1017      1.52   thorpej 	for (callwheelsize = 1; callwheelsize < ncallout; callwheelsize <<= 1)
   1018      1.52   thorpej 		/* loop */ ;
   1019      1.52   thorpej 	callwheelmask = callwheelsize - 1;
   1020      1.52   thorpej }
   1021      1.52   thorpej 
   1022      1.52   thorpej /*
   1023      1.54     enami  * callout_startup:
   1024      1.52   thorpej  *
   1025      1.52   thorpej  *	Initialize the callwheel buckets.
   1026      1.52   thorpej  */
   1027      1.52   thorpej void
   1028      1.63   thorpej callout_startup(void)
   1029      1.52   thorpej {
   1030      1.51   thorpej 	int i;
   1031      1.51   thorpej 
   1032  1.74.2.3   nathanw 	for (i = 0; i < callwheelsize; i++) {
   1033  1.74.2.3   nathanw 		callwheel[i].cq_hint = UQUAD_MAX;
   1034  1.74.2.3   nathanw 		TAILQ_INIT(&callwheel[i].cq_q);
   1035  1.74.2.3   nathanw 	}
   1036      1.64   thorpej 
   1037      1.64   thorpej 	simple_lock_init(&callwheel_slock);
   1038  1.74.2.3   nathanw 
   1039  1.74.2.3   nathanw #ifdef CALLWHEEL_STATS
   1040  1.74.2.3   nathanw 	evcnt_attach_dynamic(&callwheel_collisions, EVCNT_TYPE_MISC,
   1041  1.74.2.3   nathanw 	    NULL, "callwheel", "collisions");
   1042  1.74.2.3   nathanw 	evcnt_attach_dynamic(&callwheel_maxlength, EVCNT_TYPE_MISC,
   1043  1.74.2.3   nathanw 	    NULL, "callwheel", "maxlength");
   1044  1.74.2.3   nathanw 	evcnt_attach_dynamic(&callwheel_count, EVCNT_TYPE_MISC,
   1045  1.74.2.3   nathanw 	    NULL, "callwheel", "count");
   1046  1.74.2.3   nathanw 	evcnt_attach_dynamic(&callwheel_established, EVCNT_TYPE_MISC,
   1047  1.74.2.3   nathanw 	    NULL, "callwheel", "established");
   1048  1.74.2.3   nathanw 	evcnt_attach_dynamic(&callwheel_fired, EVCNT_TYPE_MISC,
   1049  1.74.2.3   nathanw 	    NULL, "callwheel", "fired");
   1050  1.74.2.3   nathanw 	evcnt_attach_dynamic(&callwheel_disestablished, EVCNT_TYPE_MISC,
   1051  1.74.2.3   nathanw 	    NULL, "callwheel", "disestablished");
   1052  1.74.2.3   nathanw 	evcnt_attach_dynamic(&callwheel_changed, EVCNT_TYPE_MISC,
   1053  1.74.2.3   nathanw 	    NULL, "callwheel", "changed");
   1054  1.74.2.3   nathanw 	evcnt_attach_dynamic(&callwheel_softclocks, EVCNT_TYPE_MISC,
   1055  1.74.2.3   nathanw 	    NULL, "callwheel", "softclocks");
   1056  1.74.2.3   nathanw 	evcnt_attach_dynamic(&callwheel_softempty, EVCNT_TYPE_MISC,
   1057  1.74.2.3   nathanw 	    NULL, "callwheel", "softempty");
   1058  1.74.2.3   nathanw 	evcnt_attach_dynamic(&callwheel_hintworked, EVCNT_TYPE_MISC,
   1059  1.74.2.3   nathanw 	    NULL, "callwheel", "hintworked");
   1060  1.74.2.3   nathanw #endif /* CALLWHEEL_STATS */
   1061      1.19       cgd }
   1062      1.19       cgd 
   1063      1.19       cgd /*
   1064      1.52   thorpej  * callout_init:
   1065      1.19       cgd  *
   1066      1.52   thorpej  *	Initialize a callout structure so that it can be used
   1067      1.52   thorpej  *	by callout_reset() and callout_stop().
   1068      1.52   thorpej  */
   1069      1.52   thorpej void
   1070      1.63   thorpej callout_init(struct callout *c)
   1071      1.52   thorpej {
   1072      1.52   thorpej 
   1073      1.52   thorpej 	memset(c, 0, sizeof(*c));
   1074      1.52   thorpej }
   1075      1.52   thorpej 
   1076      1.52   thorpej /*
   1077      1.52   thorpej  * callout_reset:
   1078      1.19       cgd  *
   1079      1.52   thorpej  *	Establish or change a timeout.
   1080      1.19       cgd  */
   1081      1.19       cgd void
   1082      1.63   thorpej callout_reset(struct callout *c, int ticks, void (*func)(void *), void *arg)
   1083      1.19       cgd {
   1084      1.52   thorpej 	struct callout_queue *bucket;
   1085      1.52   thorpej 	int s;
   1086      1.19       cgd 
   1087      1.19       cgd 	if (ticks <= 0)
   1088      1.19       cgd 		ticks = 1;
   1089      1.19       cgd 
   1090      1.64   thorpej 	CALLWHEEL_LOCK(s);
   1091      1.19       cgd 
   1092      1.52   thorpej 	/*
   1093      1.52   thorpej 	 * If this callout's timer is already running, cancel it
   1094      1.52   thorpej 	 * before we modify it.
   1095      1.52   thorpej 	 */
   1096      1.52   thorpej 	if (c->c_flags & CALLOUT_PENDING) {
   1097      1.64   thorpej 		callout_stop_locked(c);	/* Already locked */
   1098      1.52   thorpej #ifdef CALLWHEEL_STATS
   1099  1.74.2.3   nathanw 		callwheel_changed.ev_count++;
   1100      1.52   thorpej #endif
   1101      1.52   thorpej 	}
   1102      1.52   thorpej 
   1103      1.52   thorpej 	c->c_arg = arg;
   1104      1.52   thorpej 	c->c_func = func;
   1105      1.52   thorpej 	c->c_flags = CALLOUT_ACTIVE | CALLOUT_PENDING;
   1106      1.52   thorpej 	c->c_time = hardclock_ticks + ticks;
   1107      1.52   thorpej 
   1108      1.52   thorpej 	bucket = &callwheel[c->c_time & callwheelmask];
   1109      1.52   thorpej 
   1110      1.52   thorpej #ifdef CALLWHEEL_STATS
   1111  1.74.2.3   nathanw 	if (! TAILQ_EMPTY(&bucket->cq_q))
   1112  1.74.2.3   nathanw 		callwheel_collisions.ev_count++;
   1113      1.52   thorpej #endif
   1114      1.52   thorpej 
   1115  1.74.2.3   nathanw 	TAILQ_INSERT_TAIL(&bucket->cq_q, c, c_link);
   1116  1.74.2.3   nathanw 	if (c->c_time < bucket->cq_hint)
   1117  1.74.2.3   nathanw 		bucket->cq_hint = c->c_time;
   1118      1.52   thorpej 
   1119      1.52   thorpej #ifdef CALLWHEEL_STATS
   1120  1.74.2.3   nathanw 	callwheel_count.ev_count++;
   1121  1.74.2.3   nathanw 	callwheel_established.ev_count++;
   1122  1.74.2.3   nathanw 	if (++callwheel_sizes[c->c_time & callwheelmask] >
   1123  1.74.2.3   nathanw 	    callwheel_maxlength.ev_count)
   1124  1.74.2.3   nathanw 		callwheel_maxlength.ev_count =
   1125      1.52   thorpej 		    callwheel_sizes[c->c_time & callwheelmask];
   1126      1.52   thorpej #endif
   1127      1.52   thorpej 
   1128      1.64   thorpej 	CALLWHEEL_UNLOCK(s);
   1129      1.19       cgd }
   1130      1.19       cgd 
   1131      1.52   thorpej /*
   1132      1.64   thorpej  * callout_stop_locked:
   1133      1.52   thorpej  *
   1134      1.64   thorpej  *	Disestablish a timeout.  Callwheel is locked.
   1135      1.52   thorpej  */
   1136      1.64   thorpej static void
   1137      1.64   thorpej callout_stop_locked(struct callout *c)
   1138      1.19       cgd {
   1139  1.74.2.3   nathanw 	struct callout_queue *bucket;
   1140      1.52   thorpej 
   1141      1.52   thorpej 	/*
   1142      1.52   thorpej 	 * Don't attempt to delete a callout that's not on the queue.
   1143      1.52   thorpej 	 */
   1144      1.52   thorpej 	if ((c->c_flags & CALLOUT_PENDING) == 0) {
   1145      1.52   thorpej 		c->c_flags &= ~CALLOUT_ACTIVE;
   1146      1.52   thorpej 		return;
   1147      1.52   thorpej 	}
   1148      1.52   thorpej 
   1149      1.52   thorpej 	c->c_flags &= ~(CALLOUT_ACTIVE | CALLOUT_PENDING);
   1150      1.52   thorpej 
   1151      1.52   thorpej 	if (nextsoftcheck == c)
   1152      1.52   thorpej 		nextsoftcheck = TAILQ_NEXT(c, c_link);
   1153      1.52   thorpej 
   1154  1.74.2.3   nathanw 	bucket = &callwheel[c->c_time & callwheelmask];
   1155  1.74.2.3   nathanw 	TAILQ_REMOVE(&bucket->cq_q, c, c_link);
   1156  1.74.2.3   nathanw 	if (TAILQ_EMPTY(&bucket->cq_q))
   1157  1.74.2.3   nathanw 		bucket->cq_hint = UQUAD_MAX;
   1158      1.52   thorpej #ifdef CALLWHEEL_STATS
   1159  1.74.2.3   nathanw 	callwheel_count.ev_count--;
   1160  1.74.2.3   nathanw 	callwheel_disestablished.ev_count++;
   1161      1.52   thorpej 	callwheel_sizes[c->c_time & callwheelmask]--;
   1162      1.52   thorpej #endif
   1163      1.52   thorpej 
   1164      1.52   thorpej 	c->c_func = NULL;
   1165      1.64   thorpej }
   1166      1.64   thorpej 
   1167      1.64   thorpej /*
   1168      1.64   thorpej  * callout_stop:
   1169      1.64   thorpej  *
   1170      1.64   thorpej  *	Disestablish a timeout.  Callwheel is unlocked.  This is
   1171      1.64   thorpej  *	the standard entry point.
   1172      1.64   thorpej  */
   1173      1.64   thorpej void
   1174      1.64   thorpej callout_stop(struct callout *c)
   1175      1.64   thorpej {
   1176      1.64   thorpej 	int s;
   1177      1.52   thorpej 
   1178      1.64   thorpej 	CALLWHEEL_LOCK(s);
   1179      1.64   thorpej 	callout_stop_locked(c);
   1180      1.64   thorpej 	CALLWHEEL_UNLOCK(s);
   1181      1.52   thorpej }
   1182      1.52   thorpej 
   1183      1.52   thorpej #ifdef CALLWHEEL_STATS
   1184      1.52   thorpej /*
   1185      1.52   thorpej  * callout_showstats:
   1186      1.52   thorpej  *
   1187      1.52   thorpej  *	Display callout statistics.  Call it from DDB.
   1188      1.52   thorpej  */
   1189      1.52   thorpej void
   1190      1.63   thorpej callout_showstats(void)
   1191      1.52   thorpej {
   1192      1.52   thorpej 	u_int64_t curticks;
   1193      1.52   thorpej 	int s;
   1194      1.52   thorpej 
   1195      1.52   thorpej 	s = splclock();
   1196      1.52   thorpej 	curticks = softclock_ticks;
   1197      1.19       cgd 	splx(s);
   1198      1.52   thorpej 
   1199      1.52   thorpej 	printf("Callwheel statistics:\n");
   1200  1.74.2.3   nathanw 	printf("\tCallouts currently queued: %llu\n",
   1201  1.74.2.3   nathanw 	    (long long) callwheel_count.ev_count);
   1202  1.74.2.3   nathanw 	printf("\tCallouts established: %llu\n",
   1203  1.74.2.3   nathanw 	    (long long) callwheel_established.ev_count);
   1204  1.74.2.3   nathanw 	printf("\tCallouts disestablished: %llu\n",
   1205  1.74.2.3   nathanw 	    (long long) callwheel_disestablished.ev_count);
   1206  1.74.2.3   nathanw 	if (callwheel_changed.ev_count != 0)
   1207  1.74.2.3   nathanw 		printf("\t\tOf those, %llu were changes\n",
   1208  1.74.2.3   nathanw 		    (long long) callwheel_changed.ev_count);
   1209  1.74.2.3   nathanw 	printf("\tCallouts that fired: %llu\n",
   1210  1.74.2.3   nathanw 	    (long long) callwheel_fired.ev_count);
   1211      1.52   thorpej 	printf("\tNumber of buckets: %d\n", callwheelsize);
   1212  1.74.2.3   nathanw 	printf("\tNumber of hash collisions: %llu\n",
   1213  1.74.2.3   nathanw 	    (long long) callwheel_collisions.ev_count);
   1214  1.74.2.3   nathanw 	printf("\tMaximum hash chain length: %llu\n",
   1215  1.74.2.3   nathanw 	    (long long) callwheel_maxlength.ev_count);
   1216      1.52   thorpej 	printf("\tSoftclocks: %llu, Softchecks: %llu\n",
   1217  1.74.2.3   nathanw 	    (long long) callwheel_softclocks.ev_count,
   1218  1.74.2.3   nathanw 	    (long long) callwheel_softchecks.ev_count);
   1219  1.74.2.3   nathanw 	printf("\t\tEmpty buckets seen: %llu\n",
   1220  1.74.2.3   nathanw 	    (long long) callwheel_softempty.ev_count);
   1221  1.74.2.3   nathanw 	printf("\t\tTimes hint saved scan: %llu\n",
   1222  1.74.2.3   nathanw 	    (long long) callwheel_hintworked.ev_count);
   1223      1.19       cgd }
   1224      1.52   thorpej #endif
   1225      1.19       cgd 
   1226      1.19       cgd /*
   1227      1.52   thorpej  * Compute number of hz until specified time.  Used to compute second
   1228      1.52   thorpej  * argument to callout_reset() from an absolute time.
   1229      1.19       cgd  */
   1230      1.19       cgd int
   1231      1.63   thorpej hzto(struct timeval *tv)
   1232      1.19       cgd {
   1233      1.62   thorpej 	unsigned long ticks;
   1234      1.62   thorpej 	long sec, usec;
   1235      1.19       cgd 	int s;
   1236      1.19       cgd 
   1237      1.19       cgd 	/*
   1238      1.62   thorpej 	 * If the number of usecs in the whole seconds part of the time
   1239      1.62   thorpej 	 * difference fits in a long, then the total number of usecs will
   1240      1.62   thorpej 	 * fit in an unsigned long.  Compute the total and convert it to
   1241      1.62   thorpej 	 * ticks, rounding up and adding 1 to allow for the current tick
   1242      1.62   thorpej 	 * to expire.  Rounding also depends on unsigned long arithmetic
   1243      1.62   thorpej 	 * to avoid overflow.
   1244      1.19       cgd 	 *
   1245      1.62   thorpej 	 * Otherwise, if the number of ticks in the whole seconds part of
   1246      1.62   thorpej 	 * the time difference fits in a long, then convert the parts to
   1247      1.62   thorpej 	 * ticks separately and add, using similar rounding methods and
   1248      1.62   thorpej 	 * overflow avoidance.  This method would work in the previous
   1249      1.62   thorpej 	 * case, but it is slightly slower and assume that hz is integral.
   1250      1.62   thorpej 	 *
   1251      1.62   thorpej 	 * Otherwise, round the time difference down to the maximum
   1252      1.62   thorpej 	 * representable value.
   1253      1.62   thorpej 	 *
   1254      1.62   thorpej 	 * If ints are 32-bit, then the maximum value for any timeout in
   1255      1.62   thorpej 	 * 10ms ticks is 248 days.
   1256      1.19       cgd 	 */
   1257      1.40   mycroft 	s = splclock();
   1258      1.19       cgd 	sec = tv->tv_sec - time.tv_sec;
   1259      1.62   thorpej 	usec = tv->tv_usec - time.tv_usec;
   1260      1.62   thorpej 	splx(s);
   1261      1.62   thorpej 
   1262      1.62   thorpej 	if (usec < 0) {
   1263      1.62   thorpej 		sec--;
   1264      1.62   thorpej 		usec += 1000000;
   1265      1.62   thorpej 	}
   1266      1.62   thorpej 
   1267      1.62   thorpej 	if (sec < 0 || (sec == 0 && usec <= 0)) {
   1268      1.62   thorpej 		/*
   1269      1.62   thorpej 		 * Would expire now or in the past.  Return 0 ticks.
   1270      1.62   thorpej 		 * This is different from the legacy hzto() interface,
   1271      1.62   thorpej 		 * and callers need to check for it.
   1272      1.62   thorpej 		 */
   1273      1.62   thorpej 		ticks = 0;
   1274      1.62   thorpej 	} else if (sec <= (LONG_MAX / 1000000))
   1275      1.62   thorpej 		ticks = (((sec * 1000000) + (unsigned long)usec + (tick - 1))
   1276      1.62   thorpej 		    / tick) + 1;
   1277      1.62   thorpej 	else if (sec <= (LONG_MAX / hz))
   1278      1.62   thorpej 		ticks = (sec * hz) +
   1279      1.62   thorpej 		    (((unsigned long)usec + (tick - 1)) / tick) + 1;
   1280      1.19       cgd 	else
   1281      1.62   thorpej 		ticks = LONG_MAX;
   1282      1.62   thorpej 
   1283      1.62   thorpej 	if (ticks > INT_MAX)
   1284      1.62   thorpej 		ticks = INT_MAX;
   1285      1.62   thorpej 
   1286      1.62   thorpej 	return ((int)ticks);
   1287      1.19       cgd }
   1288      1.19       cgd 
   1289      1.19       cgd /*
   1290      1.19       cgd  * Start profiling on a process.
   1291      1.19       cgd  *
   1292      1.19       cgd  * Kernel profiling passes proc0 which never exits and hence
   1293      1.19       cgd  * keeps the profile clock running constantly.
   1294      1.19       cgd  */
   1295      1.19       cgd void
   1296      1.63   thorpej startprofclock(struct proc *p)
   1297      1.19       cgd {
   1298      1.19       cgd 
   1299      1.19       cgd 	if ((p->p_flag & P_PROFIL) == 0) {
   1300      1.19       cgd 		p->p_flag |= P_PROFIL;
   1301      1.70  sommerfe 		if (++profprocs == 1 && stathz != 0)
   1302      1.70  sommerfe 			psdiv = psratio;
   1303      1.19       cgd 	}
   1304      1.19       cgd }
   1305      1.19       cgd 
   1306      1.19       cgd /*
   1307      1.19       cgd  * Stop profiling on a process.
   1308      1.19       cgd  */
   1309      1.19       cgd void
   1310      1.63   thorpej stopprofclock(struct proc *p)
   1311      1.19       cgd {
   1312      1.19       cgd 
   1313      1.19       cgd 	if (p->p_flag & P_PROFIL) {
   1314      1.19       cgd 		p->p_flag &= ~P_PROFIL;
   1315      1.70  sommerfe 		if (--profprocs == 0 && stathz != 0)
   1316      1.70  sommerfe 			psdiv = 1;
   1317      1.19       cgd 	}
   1318      1.19       cgd }
   1319      1.19       cgd 
   1320      1.19       cgd /*
   1321      1.19       cgd  * Statistics clock.  Grab profile sample, and if divider reaches 0,
   1322      1.19       cgd  * do process and kernel statistics.
   1323      1.19       cgd  */
   1324      1.19       cgd void
   1325      1.63   thorpej statclock(struct clockframe *frame)
   1326      1.19       cgd {
   1327      1.19       cgd #ifdef GPROF
   1328      1.55  augustss 	struct gmonparam *g;
   1329      1.68       eeh 	intptr_t i;
   1330      1.19       cgd #endif
   1331      1.60   thorpej 	struct cpu_info *ci = curcpu();
   1332      1.60   thorpej 	struct schedstate_percpu *spc = &ci->ci_schedstate;
   1333  1.74.2.1   nathanw 	struct lwp *l;
   1334      1.55  augustss 	struct proc *p;
   1335      1.19       cgd 
   1336      1.70  sommerfe 	/*
   1337      1.70  sommerfe 	 * Notice changes in divisor frequency, and adjust clock
   1338      1.70  sommerfe 	 * frequency accordingly.
   1339      1.70  sommerfe 	 */
   1340      1.70  sommerfe 	if (spc->spc_psdiv != psdiv) {
   1341      1.70  sommerfe 		spc->spc_psdiv = psdiv;
   1342      1.70  sommerfe 		spc->spc_pscnt = psdiv;
   1343      1.70  sommerfe 		if (psdiv == 1) {
   1344      1.70  sommerfe 			setstatclockrate(stathz);
   1345      1.70  sommerfe 		} else {
   1346      1.70  sommerfe 			setstatclockrate(profhz);
   1347      1.70  sommerfe 		}
   1348      1.70  sommerfe 	}
   1349  1.74.2.7   nathanw 	l = curlwp;
   1350  1.74.2.1   nathanw 	p = (l ? l->l_proc : 0);
   1351      1.19       cgd 	if (CLKF_USERMODE(frame)) {
   1352      1.19       cgd 		if (p->p_flag & P_PROFIL)
   1353      1.72   mycroft 			addupc_intr(p, CLKF_PC(frame));
   1354      1.70  sommerfe 		if (--spc->spc_pscnt > 0)
   1355      1.19       cgd 			return;
   1356      1.19       cgd 		/*
   1357      1.19       cgd 		 * Came from user mode; CPU was in user state.
   1358      1.19       cgd 		 * If this process is being profiled record the tick.
   1359      1.19       cgd 		 */
   1360      1.19       cgd 		p->p_uticks++;
   1361      1.19       cgd 		if (p->p_nice > NZERO)
   1362      1.60   thorpej 			spc->spc_cp_time[CP_NICE]++;
   1363      1.19       cgd 		else
   1364      1.60   thorpej 			spc->spc_cp_time[CP_USER]++;
   1365      1.19       cgd 	} else {
   1366      1.19       cgd #ifdef GPROF
   1367      1.19       cgd 		/*
   1368      1.19       cgd 		 * Kernel statistics are just like addupc_intr, only easier.
   1369      1.19       cgd 		 */
   1370      1.19       cgd 		g = &_gmonparam;
   1371      1.19       cgd 		if (g->state == GMON_PROF_ON) {
   1372      1.19       cgd 			i = CLKF_PC(frame) - g->lowpc;
   1373      1.19       cgd 			if (i < g->textsize) {
   1374      1.19       cgd 				i /= HISTFRACTION * sizeof(*g->kcount);
   1375      1.19       cgd 				g->kcount[i]++;
   1376      1.19       cgd 			}
   1377      1.19       cgd 		}
   1378      1.19       cgd #endif
   1379  1.74.2.1   nathanw #ifdef LWP_PC
   1380      1.72   mycroft 		if (p && p->p_flag & P_PROFIL)
   1381  1.74.2.1   nathanw 			addupc_intr(p, LWP_PC(l));
   1382      1.72   mycroft #endif
   1383      1.70  sommerfe 		if (--spc->spc_pscnt > 0)
   1384      1.19       cgd 			return;
   1385      1.19       cgd 		/*
   1386      1.19       cgd 		 * Came from kernel mode, so we were:
   1387      1.19       cgd 		 * - handling an interrupt,
   1388      1.19       cgd 		 * - doing syscall or trap work on behalf of the current
   1389      1.19       cgd 		 *   user process, or
   1390      1.19       cgd 		 * - spinning in the idle loop.
   1391      1.19       cgd 		 * Whichever it is, charge the time as appropriate.
   1392      1.19       cgd 		 * Note that we charge interrupts to the current process,
   1393      1.19       cgd 		 * regardless of whether they are ``for'' that process,
   1394      1.19       cgd 		 * so that we know how much of its real time was spent
   1395      1.19       cgd 		 * in ``non-process'' (i.e., interrupt) work.
   1396      1.19       cgd 		 */
   1397      1.19       cgd 		if (CLKF_INTR(frame)) {
   1398      1.19       cgd 			if (p != NULL)
   1399      1.19       cgd 				p->p_iticks++;
   1400      1.60   thorpej 			spc->spc_cp_time[CP_INTR]++;
   1401      1.19       cgd 		} else if (p != NULL) {
   1402      1.19       cgd 			p->p_sticks++;
   1403      1.60   thorpej 			spc->spc_cp_time[CP_SYS]++;
   1404      1.19       cgd 		} else
   1405      1.60   thorpej 			spc->spc_cp_time[CP_IDLE]++;
   1406      1.19       cgd 	}
   1407      1.70  sommerfe 	spc->spc_pscnt = psdiv;
   1408      1.19       cgd 
   1409  1.74.2.1   nathanw 	if (l != NULL) {
   1410      1.45      ross 		++p->p_cpticks;
   1411      1.45      ross 		/*
   1412      1.60   thorpej 		 * If no separate schedclock is provided, call it here
   1413      1.60   thorpej 		 * at ~~12-25 Hz, ~~16 Hz is best
   1414      1.45      ross 		 */
   1415      1.60   thorpej 		if (schedhz == 0)
   1416      1.60   thorpej 			if ((++ci->ci_schedstate.spc_schedticks & 3) == 0)
   1417  1.74.2.1   nathanw 				schedclock(l);
   1418      1.19       cgd 	}
   1419      1.19       cgd }
   1420      1.27  jonathan 
   1421      1.27  jonathan 
   1422      1.27  jonathan #ifdef NTP	/* NTP phase-locked loop in kernel */
   1423      1.27  jonathan 
   1424      1.27  jonathan /*
   1425      1.27  jonathan  * hardupdate() - local clock update
   1426      1.27  jonathan  *
   1427      1.27  jonathan  * This routine is called by ntp_adjtime() to update the local clock
   1428      1.27  jonathan  * phase and frequency. The implementation is of an adaptive-parameter,
   1429      1.27  jonathan  * hybrid phase/frequency-lock loop (PLL/FLL). The routine computes new
   1430      1.27  jonathan  * time and frequency offset estimates for each call. If the kernel PPS
   1431      1.27  jonathan  * discipline code is configured (PPS_SYNC), the PPS signal itself
   1432      1.27  jonathan  * determines the new time offset, instead of the calling argument.
   1433      1.27  jonathan  * Presumably, calls to ntp_adjtime() occur only when the caller
   1434      1.27  jonathan  * believes the local clock is valid within some bound (+-128 ms with
   1435      1.27  jonathan  * NTP). If the caller's time is far different than the PPS time, an
   1436      1.27  jonathan  * argument will ensue, and it's not clear who will lose.
   1437      1.27  jonathan  *
   1438      1.27  jonathan  * For uncompensated quartz crystal oscillatores and nominal update
   1439      1.27  jonathan  * intervals less than 1024 s, operation should be in phase-lock mode
   1440      1.27  jonathan  * (STA_FLL = 0), where the loop is disciplined to phase. For update
   1441      1.27  jonathan  * intervals greater than thiss, operation should be in frequency-lock
   1442      1.27  jonathan  * mode (STA_FLL = 1), where the loop is disciplined to frequency.
   1443      1.27  jonathan  *
   1444      1.27  jonathan  * Note: splclock() is in effect.
   1445      1.27  jonathan  */
   1446      1.27  jonathan void
   1447      1.63   thorpej hardupdate(long offset)
   1448      1.27  jonathan {
   1449      1.27  jonathan 	long ltemp, mtemp;
   1450      1.27  jonathan 
   1451      1.27  jonathan 	if (!(time_status & STA_PLL) && !(time_status & STA_PPSTIME))
   1452      1.27  jonathan 		return;
   1453      1.27  jonathan 	ltemp = offset;
   1454      1.27  jonathan #ifdef PPS_SYNC
   1455      1.27  jonathan 	if (time_status & STA_PPSTIME && time_status & STA_PPSSIGNAL)
   1456      1.27  jonathan 		ltemp = pps_offset;
   1457      1.27  jonathan #endif /* PPS_SYNC */
   1458      1.27  jonathan 
   1459      1.27  jonathan 	/*
   1460      1.27  jonathan 	 * Scale the phase adjustment and clamp to the operating range.
   1461      1.27  jonathan 	 */
   1462      1.27  jonathan 	if (ltemp > MAXPHASE)
   1463      1.27  jonathan 		time_offset = MAXPHASE << SHIFT_UPDATE;
   1464      1.27  jonathan 	else if (ltemp < -MAXPHASE)
   1465      1.27  jonathan 		time_offset = -(MAXPHASE << SHIFT_UPDATE);
   1466      1.27  jonathan 	else
   1467      1.27  jonathan 		time_offset = ltemp << SHIFT_UPDATE;
   1468      1.27  jonathan 
   1469      1.27  jonathan 	/*
   1470      1.27  jonathan 	 * Select whether the frequency is to be controlled and in which
   1471      1.27  jonathan 	 * mode (PLL or FLL). Clamp to the operating range. Ugly
   1472      1.27  jonathan 	 * multiply/divide should be replaced someday.
   1473      1.27  jonathan 	 */
   1474      1.27  jonathan 	if (time_status & STA_FREQHOLD || time_reftime == 0)
   1475      1.27  jonathan 		time_reftime = time.tv_sec;
   1476      1.27  jonathan 	mtemp = time.tv_sec - time_reftime;
   1477      1.27  jonathan 	time_reftime = time.tv_sec;
   1478      1.27  jonathan 	if (time_status & STA_FLL) {
   1479      1.27  jonathan 		if (mtemp >= MINSEC) {
   1480      1.27  jonathan 			ltemp = ((time_offset / mtemp) << (SHIFT_USEC -
   1481      1.27  jonathan 			    SHIFT_UPDATE));
   1482      1.27  jonathan 			if (ltemp < 0)
   1483      1.27  jonathan 				time_freq -= -ltemp >> SHIFT_KH;
   1484      1.27  jonathan 			else
   1485      1.27  jonathan 				time_freq += ltemp >> SHIFT_KH;
   1486      1.27  jonathan 		}
   1487      1.27  jonathan 	} else {
   1488      1.27  jonathan 		if (mtemp < MAXSEC) {
   1489      1.27  jonathan 			ltemp *= mtemp;
   1490      1.27  jonathan 			if (ltemp < 0)
   1491      1.27  jonathan 				time_freq -= -ltemp >> (time_constant +
   1492      1.27  jonathan 				    time_constant + SHIFT_KF -
   1493      1.27  jonathan 				    SHIFT_USEC);
   1494      1.27  jonathan 			else
   1495      1.27  jonathan 				time_freq += ltemp >> (time_constant +
   1496      1.27  jonathan 				    time_constant + SHIFT_KF -
   1497      1.27  jonathan 				    SHIFT_USEC);
   1498      1.27  jonathan 		}
   1499      1.27  jonathan 	}
   1500      1.27  jonathan 	if (time_freq > time_tolerance)
   1501      1.27  jonathan 		time_freq = time_tolerance;
   1502      1.27  jonathan 	else if (time_freq < -time_tolerance)
   1503      1.27  jonathan 		time_freq = -time_tolerance;
   1504      1.27  jonathan }
   1505      1.27  jonathan 
   1506      1.27  jonathan #ifdef PPS_SYNC
   1507      1.27  jonathan /*
   1508      1.27  jonathan  * hardpps() - discipline CPU clock oscillator to external PPS signal
   1509      1.27  jonathan  *
   1510      1.27  jonathan  * This routine is called at each PPS interrupt in order to discipline
   1511      1.27  jonathan  * the CPU clock oscillator to the PPS signal. It measures the PPS phase
   1512      1.27  jonathan  * and leaves it in a handy spot for the hardclock() routine. It
   1513      1.27  jonathan  * integrates successive PPS phase differences and calculates the
   1514      1.27  jonathan  * frequency offset. This is used in hardclock() to discipline the CPU
   1515      1.27  jonathan  * clock oscillator so that intrinsic frequency error is cancelled out.
   1516      1.27  jonathan  * The code requires the caller to capture the time and hardware counter
   1517      1.27  jonathan  * value at the on-time PPS signal transition.
   1518      1.27  jonathan  *
   1519      1.27  jonathan  * Note that, on some Unix systems, this routine runs at an interrupt
   1520      1.27  jonathan  * priority level higher than the timer interrupt routine hardclock().
   1521      1.27  jonathan  * Therefore, the variables used are distinct from the hardclock()
   1522      1.27  jonathan  * variables, except for certain exceptions: The PPS frequency pps_freq
   1523      1.27  jonathan  * and phase pps_offset variables are determined by this routine and
   1524      1.27  jonathan  * updated atomically. The time_tolerance variable can be considered a
   1525      1.27  jonathan  * constant, since it is infrequently changed, and then only when the
   1526      1.27  jonathan  * PPS signal is disabled. The watchdog counter pps_valid is updated
   1527      1.27  jonathan  * once per second by hardclock() and is atomically cleared in this
   1528      1.27  jonathan  * routine.
   1529      1.27  jonathan  */
   1530      1.27  jonathan void
   1531      1.63   thorpej hardpps(struct timeval *tvp,		/* time at PPS */
   1532      1.63   thorpej 	long usec			/* hardware counter at PPS */)
   1533      1.27  jonathan {
   1534      1.27  jonathan 	long u_usec, v_usec, bigtick;
   1535      1.27  jonathan 	long cal_sec, cal_usec;
   1536      1.27  jonathan 
   1537      1.27  jonathan 	/*
   1538      1.27  jonathan 	 * An occasional glitch can be produced when the PPS interrupt
   1539      1.27  jonathan 	 * occurs in the hardclock() routine before the time variable is
   1540      1.27  jonathan 	 * updated. Here the offset is discarded when the difference
   1541      1.27  jonathan 	 * between it and the last one is greater than tick/2, but not
   1542      1.27  jonathan 	 * if the interval since the first discard exceeds 30 s.
   1543      1.27  jonathan 	 */
   1544      1.27  jonathan 	time_status |= STA_PPSSIGNAL;
   1545      1.27  jonathan 	time_status &= ~(STA_PPSJITTER | STA_PPSWANDER | STA_PPSERROR);
   1546      1.27  jonathan 	pps_valid = 0;
   1547      1.27  jonathan 	u_usec = -tvp->tv_usec;
   1548      1.27  jonathan 	if (u_usec < -500000)
   1549      1.27  jonathan 		u_usec += 1000000;
   1550      1.27  jonathan 	v_usec = pps_offset - u_usec;
   1551      1.27  jonathan 	if (v_usec < 0)
   1552      1.27  jonathan 		v_usec = -v_usec;
   1553      1.27  jonathan 	if (v_usec > (tick >> 1)) {
   1554      1.27  jonathan 		if (pps_glitch > MAXGLITCH) {
   1555      1.27  jonathan 			pps_glitch = 0;
   1556      1.27  jonathan 			pps_tf[2] = u_usec;
   1557      1.27  jonathan 			pps_tf[1] = u_usec;
   1558      1.27  jonathan 		} else {
   1559      1.27  jonathan 			pps_glitch++;
   1560      1.27  jonathan 			u_usec = pps_offset;
   1561      1.27  jonathan 		}
   1562      1.27  jonathan 	} else
   1563      1.27  jonathan 		pps_glitch = 0;
   1564      1.27  jonathan 
   1565      1.27  jonathan 	/*
   1566      1.27  jonathan 	 * A three-stage median filter is used to help deglitch the pps
   1567      1.27  jonathan 	 * time. The median sample becomes the time offset estimate; the
   1568      1.27  jonathan 	 * difference between the other two samples becomes the time
   1569      1.27  jonathan 	 * dispersion (jitter) estimate.
   1570      1.27  jonathan 	 */
   1571      1.27  jonathan 	pps_tf[2] = pps_tf[1];
   1572      1.27  jonathan 	pps_tf[1] = pps_tf[0];
   1573      1.27  jonathan 	pps_tf[0] = u_usec;
   1574      1.27  jonathan 	if (pps_tf[0] > pps_tf[1]) {
   1575      1.27  jonathan 		if (pps_tf[1] > pps_tf[2]) {
   1576      1.27  jonathan 			pps_offset = pps_tf[1];		/* 0 1 2 */
   1577      1.27  jonathan 			v_usec = pps_tf[0] - pps_tf[2];
   1578      1.27  jonathan 		} else if (pps_tf[2] > pps_tf[0]) {
   1579      1.27  jonathan 			pps_offset = pps_tf[0];		/* 2 0 1 */
   1580      1.27  jonathan 			v_usec = pps_tf[2] - pps_tf[1];
   1581      1.27  jonathan 		} else {
   1582      1.27  jonathan 			pps_offset = pps_tf[2];		/* 0 2 1 */
   1583      1.27  jonathan 			v_usec = pps_tf[0] - pps_tf[1];
   1584      1.27  jonathan 		}
   1585      1.27  jonathan 	} else {
   1586      1.27  jonathan 		if (pps_tf[1] < pps_tf[2]) {
   1587      1.27  jonathan 			pps_offset = pps_tf[1];		/* 2 1 0 */
   1588      1.27  jonathan 			v_usec = pps_tf[2] - pps_tf[0];
   1589      1.27  jonathan 		} else  if (pps_tf[2] < pps_tf[0]) {
   1590      1.27  jonathan 			pps_offset = pps_tf[0];		/* 1 0 2 */
   1591      1.27  jonathan 			v_usec = pps_tf[1] - pps_tf[2];
   1592      1.27  jonathan 		} else {
   1593      1.27  jonathan 			pps_offset = pps_tf[2];		/* 1 2 0 */
   1594      1.27  jonathan 			v_usec = pps_tf[1] - pps_tf[0];
   1595      1.27  jonathan 		}
   1596      1.27  jonathan 	}
   1597      1.27  jonathan 	if (v_usec > MAXTIME)
   1598      1.27  jonathan 		pps_jitcnt++;
   1599      1.27  jonathan 	v_usec = (v_usec << PPS_AVG) - pps_jitter;
   1600      1.27  jonathan 	if (v_usec < 0)
   1601      1.27  jonathan 		pps_jitter -= -v_usec >> PPS_AVG;
   1602      1.27  jonathan 	else
   1603      1.27  jonathan 		pps_jitter += v_usec >> PPS_AVG;
   1604      1.27  jonathan 	if (pps_jitter > (MAXTIME >> 1))
   1605      1.27  jonathan 		time_status |= STA_PPSJITTER;
   1606      1.27  jonathan 
   1607      1.27  jonathan 	/*
   1608      1.27  jonathan 	 * During the calibration interval adjust the starting time when
   1609      1.27  jonathan 	 * the tick overflows. At the end of the interval compute the
   1610      1.27  jonathan 	 * duration of the interval and the difference of the hardware
   1611      1.27  jonathan 	 * counters at the beginning and end of the interval. This code
   1612      1.27  jonathan 	 * is deliciously complicated by the fact valid differences may
   1613      1.27  jonathan 	 * exceed the value of tick when using long calibration
   1614      1.27  jonathan 	 * intervals and small ticks. Note that the counter can be
   1615      1.27  jonathan 	 * greater than tick if caught at just the wrong instant, but
   1616      1.27  jonathan 	 * the values returned and used here are correct.
   1617      1.27  jonathan 	 */
   1618      1.27  jonathan 	bigtick = (long)tick << SHIFT_USEC;
   1619      1.27  jonathan 	pps_usec -= pps_freq;
   1620      1.27  jonathan 	if (pps_usec >= bigtick)
   1621      1.27  jonathan 		pps_usec -= bigtick;
   1622      1.27  jonathan 	if (pps_usec < 0)
   1623      1.27  jonathan 		pps_usec += bigtick;
   1624      1.27  jonathan 	pps_time.tv_sec++;
   1625      1.27  jonathan 	pps_count++;
   1626      1.27  jonathan 	if (pps_count < (1 << pps_shift))
   1627      1.27  jonathan 		return;
   1628      1.27  jonathan 	pps_count = 0;
   1629      1.27  jonathan 	pps_calcnt++;
   1630      1.27  jonathan 	u_usec = usec << SHIFT_USEC;
   1631      1.27  jonathan 	v_usec = pps_usec - u_usec;
   1632      1.27  jonathan 	if (v_usec >= bigtick >> 1)
   1633      1.27  jonathan 		v_usec -= bigtick;
   1634      1.27  jonathan 	if (v_usec < -(bigtick >> 1))
   1635      1.27  jonathan 		v_usec += bigtick;
   1636      1.27  jonathan 	if (v_usec < 0)
   1637      1.27  jonathan 		v_usec = -(-v_usec >> pps_shift);
   1638      1.27  jonathan 	else
   1639      1.27  jonathan 		v_usec = v_usec >> pps_shift;
   1640      1.27  jonathan 	pps_usec = u_usec;
   1641      1.27  jonathan 	cal_sec = tvp->tv_sec;
   1642      1.27  jonathan 	cal_usec = tvp->tv_usec;
   1643      1.27  jonathan 	cal_sec -= pps_time.tv_sec;
   1644      1.27  jonathan 	cal_usec -= pps_time.tv_usec;
   1645      1.27  jonathan 	if (cal_usec < 0) {
   1646      1.27  jonathan 		cal_usec += 1000000;
   1647      1.27  jonathan 		cal_sec--;
   1648      1.27  jonathan 	}
   1649      1.27  jonathan 	pps_time = *tvp;
   1650      1.27  jonathan 
   1651      1.27  jonathan 	/*
   1652      1.27  jonathan 	 * Check for lost interrupts, noise, excessive jitter and
   1653      1.27  jonathan 	 * excessive frequency error. The number of timer ticks during
   1654      1.27  jonathan 	 * the interval may vary +-1 tick. Add to this a margin of one
   1655      1.27  jonathan 	 * tick for the PPS signal jitter and maximum frequency
   1656      1.27  jonathan 	 * deviation. If the limits are exceeded, the calibration
   1657      1.27  jonathan 	 * interval is reset to the minimum and we start over.
   1658      1.27  jonathan 	 */
   1659      1.27  jonathan 	u_usec = (long)tick << 1;
   1660      1.27  jonathan 	if (!((cal_sec == -1 && cal_usec > (1000000 - u_usec))
   1661      1.27  jonathan 	    || (cal_sec == 0 && cal_usec < u_usec))
   1662      1.27  jonathan 	    || v_usec > time_tolerance || v_usec < -time_tolerance) {
   1663      1.27  jonathan 		pps_errcnt++;
   1664      1.27  jonathan 		pps_shift = PPS_SHIFT;
   1665      1.27  jonathan 		pps_intcnt = 0;
   1666      1.27  jonathan 		time_status |= STA_PPSERROR;
   1667      1.27  jonathan 		return;
   1668      1.27  jonathan 	}
   1669      1.27  jonathan 
   1670      1.27  jonathan 	/*
   1671      1.27  jonathan 	 * A three-stage median filter is used to help deglitch the pps
   1672      1.27  jonathan 	 * frequency. The median sample becomes the frequency offset
   1673      1.27  jonathan 	 * estimate; the difference between the other two samples
   1674      1.27  jonathan 	 * becomes the frequency dispersion (stability) estimate.
   1675      1.27  jonathan 	 */
   1676      1.27  jonathan 	pps_ff[2] = pps_ff[1];
   1677      1.27  jonathan 	pps_ff[1] = pps_ff[0];
   1678      1.27  jonathan 	pps_ff[0] = v_usec;
   1679      1.27  jonathan 	if (pps_ff[0] > pps_ff[1]) {
   1680      1.27  jonathan 		if (pps_ff[1] > pps_ff[2]) {
   1681      1.27  jonathan 			u_usec = pps_ff[1];		/* 0 1 2 */
   1682      1.27  jonathan 			v_usec = pps_ff[0] - pps_ff[2];
   1683      1.27  jonathan 		} else if (pps_ff[2] > pps_ff[0]) {
   1684      1.27  jonathan 			u_usec = pps_ff[0];		/* 2 0 1 */
   1685      1.27  jonathan 			v_usec = pps_ff[2] - pps_ff[1];
   1686      1.27  jonathan 		} else {
   1687      1.27  jonathan 			u_usec = pps_ff[2];		/* 0 2 1 */
   1688      1.27  jonathan 			v_usec = pps_ff[0] - pps_ff[1];
   1689      1.27  jonathan 		}
   1690      1.27  jonathan 	} else {
   1691      1.27  jonathan 		if (pps_ff[1] < pps_ff[2]) {
   1692      1.27  jonathan 			u_usec = pps_ff[1];		/* 2 1 0 */
   1693      1.27  jonathan 			v_usec = pps_ff[2] - pps_ff[0];
   1694      1.27  jonathan 		} else  if (pps_ff[2] < pps_ff[0]) {
   1695      1.27  jonathan 			u_usec = pps_ff[0];		/* 1 0 2 */
   1696      1.27  jonathan 			v_usec = pps_ff[1] - pps_ff[2];
   1697      1.27  jonathan 		} else {
   1698      1.27  jonathan 			u_usec = pps_ff[2];		/* 1 2 0 */
   1699      1.27  jonathan 			v_usec = pps_ff[1] - pps_ff[0];
   1700      1.27  jonathan 		}
   1701      1.27  jonathan 	}
   1702      1.27  jonathan 
   1703      1.27  jonathan 	/*
   1704      1.27  jonathan 	 * Here the frequency dispersion (stability) is updated. If it
   1705      1.27  jonathan 	 * is less than one-fourth the maximum (MAXFREQ), the frequency
   1706      1.27  jonathan 	 * offset is updated as well, but clamped to the tolerance. It
   1707      1.27  jonathan 	 * will be processed later by the hardclock() routine.
   1708      1.27  jonathan 	 */
   1709      1.27  jonathan 	v_usec = (v_usec >> 1) - pps_stabil;
   1710      1.27  jonathan 	if (v_usec < 0)
   1711      1.27  jonathan 		pps_stabil -= -v_usec >> PPS_AVG;
   1712      1.27  jonathan 	else
   1713      1.27  jonathan 		pps_stabil += v_usec >> PPS_AVG;
   1714      1.27  jonathan 	if (pps_stabil > MAXFREQ >> 2) {
   1715      1.27  jonathan 		pps_stbcnt++;
   1716      1.27  jonathan 		time_status |= STA_PPSWANDER;
   1717      1.27  jonathan 		return;
   1718      1.27  jonathan 	}
   1719      1.27  jonathan 	if (time_status & STA_PPSFREQ) {
   1720      1.27  jonathan 		if (u_usec < 0) {
   1721      1.27  jonathan 			pps_freq -= -u_usec >> PPS_AVG;
   1722      1.27  jonathan 			if (pps_freq < -time_tolerance)
   1723      1.27  jonathan 				pps_freq = -time_tolerance;
   1724      1.27  jonathan 			u_usec = -u_usec;
   1725      1.27  jonathan 		} else {
   1726      1.27  jonathan 			pps_freq += u_usec >> PPS_AVG;
   1727      1.27  jonathan 			if (pps_freq > time_tolerance)
   1728      1.27  jonathan 				pps_freq = time_tolerance;
   1729      1.27  jonathan 		}
   1730      1.27  jonathan 	}
   1731      1.27  jonathan 
   1732      1.27  jonathan 	/*
   1733      1.27  jonathan 	 * Here the calibration interval is adjusted. If the maximum
   1734      1.27  jonathan 	 * time difference is greater than tick / 4, reduce the interval
   1735      1.27  jonathan 	 * by half. If this is not the case for four consecutive
   1736      1.27  jonathan 	 * intervals, double the interval.
   1737      1.27  jonathan 	 */
   1738      1.27  jonathan 	if (u_usec << pps_shift > bigtick >> 2) {
   1739      1.27  jonathan 		pps_intcnt = 0;
   1740      1.27  jonathan 		if (pps_shift > PPS_SHIFT)
   1741      1.27  jonathan 			pps_shift--;
   1742      1.27  jonathan 	} else if (pps_intcnt >= 4) {
   1743      1.27  jonathan 		pps_intcnt = 0;
   1744      1.27  jonathan 		if (pps_shift < PPS_SHIFTMAX)
   1745      1.27  jonathan 			pps_shift++;
   1746      1.27  jonathan 	} else
   1747      1.27  jonathan 		pps_intcnt++;
   1748      1.27  jonathan }
   1749      1.27  jonathan #endif /* PPS_SYNC */
   1750      1.27  jonathan #endif /* NTP  */
   1751      1.27  jonathan 
   1752      1.19       cgd /*
   1753      1.19       cgd  * Return information about system clocks.
   1754      1.19       cgd  */
   1755      1.25  christos int
   1756      1.63   thorpej sysctl_clockrate(void *where, size_t *sizep)
   1757      1.19       cgd {
   1758      1.19       cgd 	struct clockinfo clkinfo;
   1759      1.19       cgd 
   1760      1.19       cgd 	/*
   1761      1.19       cgd 	 * Construct clockinfo structure.
   1762      1.19       cgd 	 */
   1763      1.20   mycroft 	clkinfo.tick = tick;
   1764      1.20   mycroft 	clkinfo.tickadj = tickadj;
   1765      1.19       cgd 	clkinfo.hz = hz;
   1766      1.19       cgd 	clkinfo.profhz = profhz;
   1767      1.19       cgd 	clkinfo.stathz = stathz ? stathz : hz;
   1768      1.19       cgd 	return (sysctl_rdstruct(where, sizep, NULL, &clkinfo, sizeof(clkinfo)));
   1769      1.19       cgd }
   1770