]> git.saurik.com Git - apple/xnu.git/blobdiff - osfmk/kern/clock.c
projects / apple / xnu.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
xnu-792.22.5.tar.gz
[apple/xnu.git] / osfmk / kern / clock.c
diff --git a/osfmk/kern/clock.c b/osfmk/kern/clock.c
index 1aab8196c4fa819191d095ad963e71fa15345725..b9d0a075baa9da9c1fd2ff7e1252e105533335b7 100644 (file)
--- a/osfmk/kern/clock.c
+++ b/osfmk/kern/clock.c
@@ -1,862 +1,755 @@
 /*
 /*
- * Copyright (c) 2000 Apple Computer, Inc. All rights reserved.
+ * Copyright (c) 2000-2005 Apple Computer, Inc. All rights reserved.
  *
  *
- * @APPLE_LICENSE_HEADER_START@
+ * @APPLE_OSREFERENCE_LICENSE_HEADER_START@
  * 
  * 
- * The contents of this file constitute Original Code as defined in and
- * are subject to the Apple Public Source License Version 1.1 (the
- * "License").  You may not use this file except in compliance with the
- * License.  Please obtain a copy of the License at
- * http://www.apple.com/publicsource and read it before using this file.
+ * This file contains Original Code and/or Modifications of Original Code
+ * as defined in and that are subject to the Apple Public Source License
+ * Version 2.0 (the 'License'). You may not use this file except in
+ * compliance with the License. The rights granted to you under the License
+ * may not be used to create, or enable the creation or redistribution of,
+ * unlawful or unlicensed copies of an Apple operating system, or to
+ * circumvent, violate, or enable the circumvention or violation of, any
+ * terms of an Apple operating system software license agreement.
  * 
  * 
- * This Original Code and all software distributed under the License are
- * distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY KIND, EITHER
+ * Please obtain a copy of the License at
+ * http://www.opensource.apple.com/apsl/ and read it before using this file.
+ * 
+ * The Original Code and all software distributed under the License are
+ * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
  * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
  * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
  * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
  * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
- * FITNESS FOR A PARTICULAR PURPOSE OR NON-INFRINGEMENT.  Please see the
- * License for the specific language governing rights and limitations
- * under the License.
+ * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
+ * Please see the License for the specific language governing rights and
+ * limitations under the License.
  * 
  * 
- * @APPLE_LICENSE_HEADER_END@
+ * @APPLE_OSREFERENCE_LICENSE_HEADER_END@
  */
 /*
  * @OSF_COPYRIGHT@
  */
 /*
  */
 /*
  * @OSF_COPYRIGHT@
  */
 /*
- *     File:           kern/clock.c
- *     Purpose:        Routines for the creation and use of kernel
- *                     alarm clock services. This file and the ipc
- *                     routines in kern/ipc_clock.c constitute the
- *                     machine-independent clock service layer.
  */
 
  */
 
-#include <cpus.h>
-#include <mach_host.h>
+#include <mach/mach_types.h>
 
 
-#include <mach/boolean.h>
-#include <mach/processor_info.h>
-#include <mach/vm_param.h>
-#include <machine/mach_param.h>
-#include <kern/cpu_number.h>
-#include <kern/misc_protos.h>
 #include <kern/lock.h>
 #include <kern/lock.h>
-#include <kern/host.h>
 #include <kern/spl.h>
 #include <kern/spl.h>
+#include <kern/sched_prim.h>
 #include <kern/thread.h>
 #include <kern/thread.h>
-#include <kern/thread_swap.h>
-#include <kern/ipc_host.h>
 #include <kern/clock.h>
 #include <kern/clock.h>
-#include <kern/zalloc.h>
-#include <ipc/ipc_port.h>
+#include <kern/host_notify.h>
+
+#include <IOKit/IOPlatformExpert.h>
+
+#include <machine/commpage.h>
 
 
-#include <mach/mach_syscalls.h>
-#include <mach/clock_reply.h>
+#include <mach/mach_traps.h>
 #include <mach/mach_time.h>
 
 #include <mach/mach_time.h>
 
-#include <kern/mk_timer.h>
+decl_simple_lock_data(static,clock_lock)
 
 /*
 
 /*
- * Exported interface
+ *     Time of day (calendar) variables.
+ *
+ *     Algorithm:
+ *
+ *     TOD <- (seconds + epoch, fraction) <- CONV(current absolute time + offset)
+ *
+ *     where CONV converts absolute time units into seconds and a fraction.
  */
  */
-
-#include <mach/clock_server.h>
-#include <mach/mach_host_server.h>
-
-/* local data declarations */
-decl_simple_lock_data(static,ClockLock)                /* clock system synchronization */
-static struct  zone            *alarm_zone;    /* zone for user alarms */
-static struct  alarm           *alrmfree;              /* alarm free list pointer */
-static struct  alarm           *alrmdone;              /* alarm done list pointer */
-static long                                    alrm_seqno;             /* uniquely identifies alarms */
-static thread_call_data_t      alarm_deliver;
-
-/* backwards compatibility */
-int             hz = HZ;                /* GET RID OF THIS !!! */
-int             tick = (1000000 / HZ);  /* GET RID OF THIS !!! */
-
-/* external declarations */
-extern struct clock    clock_list[];
-extern int             clock_count;
-
-/* local clock subroutines */
-static
-void   flush_alarms(
-                       clock_t                 clock);
-
-static
-void   post_alarm(
-                       clock_t                 clock,
-                       alarm_t                 alarm);
-
-static
-int            check_time(
-                       alarm_type_t    alarm_type,
-                       mach_timespec_t *alarm_time,
-                       mach_timespec_t *clock_time);
-
-static
-void   clock_alarm_deliver(
-                       thread_call_param_t             p0,
-                       thread_call_param_t             p1);
+static struct clock_calend {
+       uint64_t                        epoch;
+       uint64_t                        offset;
+}                                      clock_calend;
 
 /*
 
 /*
- *     Macros to lock/unlock clock system.
+ *     Calendar adjustment variables and values.
  */
  */
-#define LOCK_CLOCK(s)                  \
-       s = splclock();                 \
-       simple_lock(&ClockLock);
+#define calend_adjperiod       (NSEC_PER_SEC / 100)    /* adjustment period, ns */
+#define calend_adjskew         (40 * NSEC_PER_USEC)    /* "standard" skew, ns / period */
+#define        calend_adjbig           (NSEC_PER_SEC)                  /* use 10x skew above adjbig ns */
 
 
-#define UNLOCK_CLOCK(s)                        \
-       simple_unlock(&ClockLock);      \
-       splx(s);
+static uint64_t                        calend_adjstart;                /* Absolute time value for start of this adjustment period */
+static uint32_t                        calend_adjoffset;               /* Absolute time offset for this adjustment period as absolute value */
+
+static int32_t                 calend_adjdelta;                /* Nanosecond time delta for this adjustment period */
+static int64_t                 calend_adjtotal;                /* Nanosecond remaining total adjustment */
+
+static uint64_t                        calend_adjdeadline;             /* Absolute time value for next adjustment period */
+static uint32_t                        calend_adjinterval;             /* Absolute time interval of adjustment period */
+
+static timer_call_data_t       calend_adjcall;
+static uint32_t                                calend_adjactive;
+
+static uint32_t                calend_set_adjustment(
+                                               int32_t                 *secs,
+                                               int32_t                 *microsecs);
+
+static void                    calend_adjust_call(void);
+static uint32_t                calend_adjust(void);
+
+static thread_call_data_t      calend_wakecall;
+
+extern void    IOKitResetTime(void);
+
+static uint64_t                clock_boottime;                         /* Seconds boottime epoch */
+
+#define TIME_ADD(rsecs, secs, rfrac, frac, unit)       \
+MACRO_BEGIN                                                                                    \
+       if (((rfrac) += (frac)) >= (unit)) {                    \
+               (rfrac) -= (unit);                                                      \
+               (rsecs) += 1;                                                           \
+       }                                                                                               \
+       (rsecs) += (secs);                                                              \
+MACRO_END
+
+#define TIME_SUB(rsecs, secs, rfrac, frac, unit)       \
+MACRO_BEGIN                                                                                    \
+       if ((int32_t)((rfrac) -= (frac)) < 0) {                 \
+               (rfrac) += (unit);                                                      \
+               (rsecs) -= 1;                                                           \
+       }                                                                                               \
+       (rsecs) -= (secs);                                                              \
+MACRO_END
 
 /*
 
 /*
- * Configure the clock system. (Not sure if we need this,
- * as separate from clock_init()).
+ *     clock_config:
+ *
+ *     Called once at boot to configure the clock subsystem.
  */
 void
 clock_config(void)
 {
  */
 void
 clock_config(void)
 {
-       clock_t                 clock;
-       register int    i;
+       simple_lock_init(&clock_lock, 0);
+
+       timer_call_setup(&calend_adjcall, (timer_call_func_t)calend_adjust_call, NULL);
+       thread_call_setup(&calend_wakecall, (thread_call_func_t)IOKitResetTime, NULL);
 
 
-       if (cpu_number() != master_cpu)
-               panic("clock_config");
+       clock_oldconfig();
 
        /*
 
        /*
-        * Configure clock devices.
+        * Initialize the timer callouts.
         */
         */
-       simple_lock_init(&ClockLock, ETAP_MISC_CLOCK);
-       for (i = 0; i < clock_count; i++) {
-               clock = &clock_list[i];
-               if (clock->cl_ops) {
-                       if ((*clock->cl_ops->c_config)() == 0)
-                               clock->cl_ops = 0;
-               }
-       }
-
-       /* start alarm sequence numbers at 0 */
-       alrm_seqno = 0;
+       timer_call_initialize();
 }
 
 /*
 }
 
 /*
- * Initialize the clock system.
+ *     clock_init:
+ *
+ *     Called on a processor each time started.
  */
 void
 clock_init(void)
 {
  */
 void
 clock_init(void)
 {
-       clock_t                 clock;
-       register int    i;
-
-       /*
-        * Initialize basic clock structures.
-        */
-       for (i = 0; i < clock_count; i++) {
-               clock = &clock_list[i];
-               if (clock->cl_ops)
-                       (*clock->cl_ops->c_init)();
-       }
+       clock_oldinit();
 }
 
 /*
 }
 
 /*
- * Initialize the clock ipc service facility.
+ *     clock_timebase_init:
+ *
+ *     Called by machine dependent code
+ *     to initialize areas dependent on the
+ *     timebase value.  May be called multiple
+ *     times during start up.
  */
 void
  */
 void
-clock_service_create(void)
+clock_timebase_init(void)
 {
 {
-       clock_t                 clock;
-       register int    i;
-
-       mk_timer_initialize();
-
-       /*
-        * Initialize ipc clock services.
-        */
-       for (i = 0; i < clock_count; i++) {
-               clock = &clock_list[i];
-               if (clock->cl_ops) {
-                       ipc_clock_init(clock);
-                       ipc_clock_enable(clock);
-               }
-       }
+       uint64_t        abstime;
 
 
-       /*
-        * Initialize clock service alarms.
-        */
-       i = sizeof(struct alarm);
-       alarm_zone = zinit(i, (4096/i)*i, 10*i, "alarms");
+       nanoseconds_to_absolutetime(calend_adjperiod, &abstime);
+       calend_adjinterval = abstime;
 
 
-       /*
-        * Initialize the clock alarm delivery mechanism.
-        */
-       thread_call_setup(&alarm_deliver, clock_alarm_deliver, NULL);
+       sched_timebase_init();
 }
 
 /*
 }
 
 /*
- * Get the service port on a clock.
+ *     mach_timebase_info_trap:
+ *
+ *     User trap returns timebase constant.
  */
 kern_return_t
  */
 kern_return_t
-host_get_clock_service(
-       host_t                  host,
-       clock_id_t              clock_id,
-       clock_t                 *clock)         /* OUT */
+mach_timebase_info_trap(
+       struct mach_timebase_info_trap_args *args)
 {
 {
-       if (host == HOST_NULL || clock_id < 0 || clock_id >= clock_count) {
-               *clock = CLOCK_NULL;
-               return (KERN_INVALID_ARGUMENT);
-       }
+       mach_vm_address_t                       out_info_addr = args->info;
+       mach_timebase_info_data_t       info;
 
 
-       *clock = &clock_list[clock_id];
-       if ((*clock)->cl_ops == 0)
-               return (KERN_FAILURE);
-       return (KERN_SUCCESS);
-}
+       clock_timebase_info(&info);
 
 
-/*
- * Get the control port on a clock.
- */
-kern_return_t
-host_get_clock_control(
-       host_priv_t             host_priv,
-       clock_id_t              clock_id,
-       clock_t                 *clock)         /* OUT */
-{
-       if (host_priv == HOST_PRIV_NULL || clock_id < 0 || clock_id >= clock_count) {
-               *clock = CLOCK_NULL;
-               return (KERN_INVALID_ARGUMENT);
-       }
+       copyout((void *)&info, out_info_addr, sizeof (info));
 
 
-       *clock = &clock_list[clock_id];
-       if ((*clock)->cl_ops == 0)
-               return (KERN_FAILURE);
        return (KERN_SUCCESS);
 }
 
 /*
        return (KERN_SUCCESS);
 }
 
 /*
- * Get the current clock time.
+ *     Calendar routines.
  */
  */
-kern_return_t
-clock_get_time(
-       clock_t                 clock,
-       mach_timespec_t *cur_time)      /* OUT */
-{
-       if (clock == CLOCK_NULL)
-               return (KERN_INVALID_ARGUMENT);
-       return ((*clock->cl_ops->c_gettime)(cur_time));
-}
 
 /*
 
 /*
- * Get clock attributes.
+ *     clock_get_calendar_microtime:
+ *
+ *     Returns the current calendar value,
+ *     microseconds as the fraction.
  */
  */
-kern_return_t
-clock_get_attributes(
-       clock_t                                 clock,
-       clock_flavor_t                  flavor,
-       clock_attr_t                    attr,           /* OUT */
-       mach_msg_type_number_t  *count)         /* IN/OUT */
+void
+clock_get_calendar_microtime(
+       uint32_t                        *secs,
+       uint32_t                        *microsecs)
 {
 {
-       kern_return_t   (*getattr)(
-                                               clock_flavor_t                  flavor,
-                                               clock_attr_t                    attr,
-                                               mach_msg_type_number_t  *count);
-
-       if (clock == CLOCK_NULL)
-               return (KERN_INVALID_ARGUMENT);
-       if (getattr = clock->cl_ops->c_getattr)
-               return((*getattr)(flavor, attr, count));
-       else
-               return (KERN_FAILURE);
-}
+       uint64_t                now;
+       spl_t                   s;
 
 
-/*
- * Set the current clock time.
- */
-kern_return_t
-clock_set_time(
-       clock_t                 clock,
-       mach_timespec_t new_time)
-{
-       mach_timespec_t *clock_time;
-       kern_return_t   (*settime)(
-                                               mach_timespec_t         *clock_time);
-
-       if (clock == CLOCK_NULL)
-               return (KERN_INVALID_ARGUMENT);
-       if ((settime = clock->cl_ops->c_settime) == 0)
-               return (KERN_FAILURE);
-       clock_time = &new_time;
-       if (BAD_MACH_TIMESPEC(clock_time))
-               return (KERN_INVALID_VALUE);
+       s = splclock();
+       simple_lock(&clock_lock);
 
 
-       /*
-        * Flush all outstanding alarms.
-        */
-       flush_alarms(clock);
+       now = mach_absolute_time();
 
 
-       /*
-        * Set the new time.
-        */
-       return ((*settime)(clock_time));
+       if (calend_adjdelta < 0) {
+               uint32_t        t32;
+
+               if (now > calend_adjstart) {
+                       t32 = now - calend_adjstart;
+
+                       if (t32 > calend_adjoffset)
+                               now -= calend_adjoffset;
+                       else
+                               now = calend_adjstart;
+               }
+       }
+
+       now += clock_calend.offset;
+
+       absolutetime_to_microtime(now, secs, microsecs);
+
+       *secs += clock_calend.epoch;
+
+       simple_unlock(&clock_lock);
+       splx(s);
 }
 
 /*
 }
 
 /*
- * Set the clock alarm resolution.
+ *     clock_get_calendar_nanotime:
+ *
+ *     Returns the current calendar value,
+ *     nanoseconds as the fraction.
+ *
+ *     Since we do not have an interface to
+ *     set the calendar with resolution greater
+ *     than a microsecond, we honor that here.
  */
  */
-kern_return_t
-clock_set_attributes(
-       clock_t                                 clock,
-       clock_flavor_t                  flavor,
-       clock_attr_t                    attr,
-       mach_msg_type_number_t  count)
+void
+clock_get_calendar_nanotime(
+       uint32_t                        *secs,
+       uint32_t                        *nanosecs)
 {
 {
-       kern_return_t   (*setattr)(
-                                               clock_flavor_t                  flavor,
-                                               clock_attr_t                    attr,
-                                               mach_msg_type_number_t  count);
-
-       if (clock == CLOCK_NULL)
-               return (KERN_INVALID_ARGUMENT);
-       if (setattr = clock->cl_ops->c_setattr)
-               return ((*setattr)(flavor, attr, count));
-       else
-               return (KERN_FAILURE);
+       uint64_t                now;
+       spl_t                   s;
+
+       s = splclock();
+       simple_lock(&clock_lock);
+
+       now = mach_absolute_time();
+
+       if (calend_adjdelta < 0) {
+               uint32_t        t32;
+
+               if (now > calend_adjstart) {
+                       t32 = now - calend_adjstart;
+
+                       if (t32 > calend_adjoffset)
+                               now -= calend_adjoffset;
+                       else
+                               now = calend_adjstart;
+               }
+       }
+
+       now += clock_calend.offset;
+
+       absolutetime_to_microtime(now, secs, nanosecs);
+       *nanosecs *= NSEC_PER_USEC;
+
+       *secs += clock_calend.epoch;
+
+       simple_unlock(&clock_lock);
+       splx(s);
 }
 
 /*
 }
 
 /*
- * Setup a clock alarm.
+ *     clock_gettimeofday:
+ *
+ *     Kernel interface for commpage implementation of
+ *     gettimeofday() syscall.
+ *
+ *     Returns the current calendar value, and updates the
+ *     commpage info as appropriate.  Because most calls to
+ *     gettimeofday() are handled in user mode by the commpage,
+ *     this routine should be used infrequently.
  */
  */
-kern_return_t
-clock_alarm(
-       clock_t                                 clock,
-       alarm_type_t                    alarm_type,
-       mach_timespec_t                 alarm_time,
-       ipc_port_t                              alarm_port,
-       mach_msg_type_name_t    alarm_port_type)
+void
+clock_gettimeofday(
+       uint32_t                        *secs,
+       uint32_t                        *microsecs)
 {
 {
-       alarm_t                                 alarm;
-       mach_timespec_t                 clock_time;
-       int                                             chkstat;
-       kern_return_t                   reply_code;
-       spl_t                                   s;
-
-       if (clock == CLOCK_NULL)
-               return (KERN_INVALID_ARGUMENT);
-       if (clock->cl_ops->c_setalrm == 0)
-               return (KERN_FAILURE);
-       if (IP_VALID(alarm_port) == 0)
-               return (KERN_INVALID_CAPABILITY);
+       uint64_t                now;
+       spl_t                   s;
 
 
-       /*
-        * Check alarm parameters. If parameters are invalid,
-        * send alarm message immediately.
-        */
-       (*clock->cl_ops->c_gettime)(&clock_time);
-       chkstat = check_time(alarm_type, &alarm_time, &clock_time);
-       if (chkstat <= 0) {
-               reply_code = (chkstat < 0 ? KERN_INVALID_VALUE : KERN_SUCCESS);
-               clock_alarm_reply(alarm_port, alarm_port_type,
-                                 reply_code, alarm_type, clock_time);
-               return (KERN_SUCCESS);
+       s = splclock();
+       simple_lock(&clock_lock);
+
+       now = mach_absolute_time();
+
+       if (calend_adjdelta >= 0) {
+               clock_gettimeofday_set_commpage(now, clock_calend.epoch, clock_calend.offset, secs, microsecs);
        }
        }
+       else {
+               uint32_t        t32;
 
 
-       /*
-        * Get alarm and add to clock alarm list.
-        */
+               if (now > calend_adjstart) {
+                       t32 = now - calend_adjstart;
+
+                       if (t32 > calend_adjoffset)
+                               now -= calend_adjoffset;
+                       else
+                               now = calend_adjstart;
+               }
 
 
-       LOCK_CLOCK(s);
-       if ((alarm = alrmfree) == 0) {
-               UNLOCK_CLOCK(s);
-               alarm = (alarm_t) zalloc(alarm_zone);
-               if (alarm == 0)
-                       return (KERN_RESOURCE_SHORTAGE);
-               LOCK_CLOCK(s);
+               now += clock_calend.offset;
+
+               absolutetime_to_microtime(now, secs, microsecs);
+
+               *secs += clock_calend.epoch;
        }
        }
-       else
-               alrmfree = alarm->al_next;
-
-       alarm->al_status = ALARM_CLOCK;
-       alarm->al_time = alarm_time;
-       alarm->al_type = alarm_type;
-       alarm->al_port = alarm_port;
-       alarm->al_port_type = alarm_port_type;
-       alarm->al_clock = clock;
-       alarm->al_seqno = alrm_seqno++;
-       post_alarm(clock, alarm);
-       UNLOCK_CLOCK(s);
 
 
-       return (KERN_SUCCESS);
+       simple_unlock(&clock_lock);
+       splx(s);
 }
 
 /*
 }
 
 /*
- * Sleep on a clock. System trap. User-level libmach clock_sleep
- * interface call takes a mach_timespec_t sleep_time argument which it
- * converts to sleep_sec and sleep_nsec arguments which are then
- * passed to clock_sleep_trap.
+ *     clock_set_calendar_microtime:
+ *
+ *     Sets the current calendar value by
+ *     recalculating the epoch and offset
+ *     from the system clock.
+ *
+ *     Also adjusts the boottime to keep the
+ *     value consistent, writes the new
+ *     calendar value to the platform clock,
+ *     and sends calendar change notifications.
  */
  */
-kern_return_t
-clock_sleep_trap(
-       mach_port_name_t        clock_name,
-       sleep_type_t            sleep_type,
-       int                                     sleep_sec,
-       int                                     sleep_nsec,
-       mach_timespec_t         *wakeup_time)
+void
+clock_set_calendar_microtime(
+       uint32_t                        secs,
+       uint32_t                        microsecs)
 {
 {
-       clock_t                         clock;
-       mach_timespec_t         swtime;
-       kern_return_t           rvalue;
+       uint32_t                sys, microsys;
+       uint32_t                newsecs;
+       spl_t                   s;
+
+       newsecs = (microsecs < 500*USEC_PER_SEC)?
+                                               secs: secs + 1;
+
+       s = splclock();
+       simple_lock(&clock_lock);
+
+    commpage_set_timestamp(0,0,0);
 
        /*
 
        /*
-        * Convert the trap parameters.
+        *      Calculate the new calendar epoch based on
+        *      the new value and the system clock.
         */
         */
-       if (clock_name != MACH_PORT_NULL)
-               clock = port_name_to_clock(clock_name);
-       else
-               clock = &clock_list[SYSTEM_CLOCK];
+       clock_get_system_microtime(&sys, &microsys);
+       TIME_SUB(secs, sys, microsecs, microsys, USEC_PER_SEC);
 
 
-       swtime.tv_sec  = sleep_sec;
-       swtime.tv_nsec = sleep_nsec;
+       /*
+        *      Adjust the boottime based on the delta.
+        */
+       clock_boottime += secs - clock_calend.epoch;
 
        /*
 
        /*
-        * Call the actual clock_sleep routine.
+        *      Set the new calendar epoch.
         */
         */
-       rvalue = clock_sleep_internal(clock, sleep_type, &swtime);
+       clock_calend.epoch = secs;
+       nanoseconds_to_absolutetime((uint64_t)microsecs * NSEC_PER_USEC, &clock_calend.offset);
 
        /*
 
        /*
-        * Return current time as wakeup time.
+        *      Cancel any adjustment in progress.
         */
         */
-       if (rvalue != KERN_INVALID_ARGUMENT && rvalue != KERN_FAILURE) {
-               copyout((char *)&swtime, (char *)wakeup_time,
-                       sizeof(mach_timespec_t));
-       }
-       return (rvalue);
-}      
+       calend_adjdelta = calend_adjtotal = 0;
+
+       simple_unlock(&clock_lock);
+
+       /*
+        *      Set the new value for the platform clock.
+        */
+       PESetGMTTimeOfDay(newsecs);
+
+       splx(s);
+
+       /*
+        *      Send host notifications.
+        */
+       host_notify_calendar_change();
+}
 
 /*
 
 /*
- * Kernel internally callable clock sleep routine. The calling
- * thread is suspended until the requested sleep time is reached.
+ *     clock_initialize_calendar:
+ *
+ *     Set the calendar and related clocks
+ *     from the platform clock at boot or
+ *     wake event.
+ *
+ *     Also sends host notifications.
  */
  */
-kern_return_t
-clock_sleep_internal(
-       clock_t                         clock,
-       sleep_type_t            sleep_type,
-       mach_timespec_t         *sleep_time)
+void
+clock_initialize_calendar(void)
 {
 {
-       alarm_t                         alarm;
-       mach_timespec_t         clock_time;
-       kern_return_t           rvalue;
-       int                                     chkstat;
-       spl_t                           s;
+       uint32_t                sys, microsys;
+       uint32_t                microsecs = 0, secs = PEGetGMTTimeOfDay();
+       spl_t                   s;
 
 
-       if (clock == CLOCK_NULL)
-               return (KERN_INVALID_ARGUMENT);
-       if (clock->cl_ops->c_setalrm == 0)
-               return (KERN_FAILURE);
+       s = splclock();
+       simple_lock(&clock_lock);
 
 
-       /*
-        * Check sleep parameters. If parameters are invalid
-        * return an error, otherwise post alarm request.
-        */
-       (*clock->cl_ops->c_gettime)(&clock_time);
+    commpage_set_timestamp(0,0,0);
 
 
-       chkstat = check_time(sleep_type, sleep_time, &clock_time);
-       if (chkstat < 0)
-               return (KERN_INVALID_VALUE);
-       rvalue = KERN_SUCCESS;
-       if (chkstat > 0) {
+       if ((int32_t)secs >= (int32_t)clock_boottime) {
                /*
                /*
-                * Get alarm and add to clock alarm list.
+                *      Initialize the boot time based on the platform clock.
                 */
                 */
+               if (clock_boottime == 0)
+                       clock_boottime = secs;
 
 
-               LOCK_CLOCK(s);
-               if ((alarm = alrmfree) == 0) {
-                       UNLOCK_CLOCK(s);
-                       alarm = (alarm_t) zalloc(alarm_zone);
-                       if (alarm == 0)
-                               return (KERN_RESOURCE_SHORTAGE);
-                       LOCK_CLOCK(s);
-               }
-               else
-                       alrmfree = alarm->al_next;
-
-               alarm->al_time = *sleep_time;
-               alarm->al_status = ALARM_SLEEP;
-               post_alarm(clock, alarm);
+               /*
+                *      Calculate the new calendar epoch based on
+                *      the platform clock and the system clock.
+                */
+               clock_get_system_microtime(&sys, &microsys);
+               TIME_SUB(secs, sys, microsecs, microsys, USEC_PER_SEC);
 
                /*
 
                /*
-                * Wait for alarm to occur.
+                *      Set the new calendar epoch.
                 */
                 */
-               assert_wait((event_t)alarm, THREAD_ABORTSAFE);
-               UNLOCK_CLOCK(s);
-               /* should we force spl(0) at this point? */
-               thread_block((void (*)(void)) 0);
-               /* we should return here at ipl0 */
+               clock_calend.epoch = secs;
+               nanoseconds_to_absolutetime((uint64_t)microsecs * NSEC_PER_USEC, &clock_calend.offset);
 
                /*
 
                /*
-                * Note if alarm expired normally or whether it
-                * was aborted. If aborted, delete alarm from
-                * clock alarm list. Return alarm to free list.
+                *       Cancel any adjustment in progress.
                 */
                 */
-               LOCK_CLOCK(s);
-               if (alarm->al_status != ALARM_DONE) {
-                       /* This means we were interrupted and that
-                          thread->wait_result != THREAD_AWAKENED. */
-                       if ((alarm->al_prev)->al_next = alarm->al_next)
-                               (alarm->al_next)->al_prev = alarm->al_prev;
-                       rvalue = KERN_ABORTED;
-               }
-               *sleep_time = alarm->al_time;
-               alarm->al_status = ALARM_FREE;
-               alarm->al_next = alrmfree;
-               alrmfree = alarm;
-               UNLOCK_CLOCK(s);
+               calend_adjdelta = calend_adjtotal = 0;
        }
        }
-       else
-               *sleep_time = clock_time;
 
 
-       return (rvalue);
+       simple_unlock(&clock_lock);
+       splx(s);
+
+       /*
+        *      Send host notifications.
+        */
+       host_notify_calendar_change();
 }
 
 /*
 }
 
 /*
- * CLOCK INTERRUPT SERVICE ROUTINES.
+ *     clock_get_boottime_nanotime:
+ *
+ *     Return the boottime, used by sysctl.
  */
  */
+void
+clock_get_boottime_nanotime(
+       uint32_t                        *secs,
+       uint32_t                        *nanosecs)
+{
+       *secs = clock_boottime;
+       *nanosecs = 0;
+}
 
 /*
 
 /*
- * Service clock alarm interrupts. Called from machine dependent
- * layer at splclock(). The clock_id argument specifies the clock,
- * and the clock_time argument gives that clock's current time.
+ *     clock_adjtime:
+ *
+ *     Interface to adjtime() syscall.
+ *
+ *     Calculates adjustment variables and
+ *     initiates adjustment.
  */
 void
  */
 void
-clock_alarm_intr(
-       clock_id_t                      clock_id,
-       mach_timespec_t         *clock_time)
+clock_adjtime(
+       int32_t         *secs,
+       int32_t         *microsecs)
 {
 {
-       clock_t                         clock;
-       register alarm_t        alrm1;
-       register alarm_t        alrm2;
-       mach_timespec_t         *alarm_time;
-       spl_t                           s;
+       uint32_t        interval;
+       spl_t           s;
 
 
-       clock = &clock_list[clock_id];
+       s = splclock();
+       simple_lock(&clock_lock);
 
 
-       /*
-        * Update clock alarm list. All alarms that are due are moved
-        * to the alarmdone list to be serviced by the alarm_thread.
-        */
+       interval = calend_set_adjustment(secs, microsecs);
+       if (interval != 0) {
+               calend_adjdeadline = mach_absolute_time() + interval;
+               if (!timer_call_enter(&calend_adjcall, calend_adjdeadline))
+                       calend_adjactive++;
+       }
+       else
+       if (timer_call_cancel(&calend_adjcall))
+               calend_adjactive--;
 
 
-       LOCK_CLOCK(s);
-       alrm1 = (alarm_t) &clock->cl_alarm;
-       while (alrm2 = alrm1->al_next) {
-               alarm_time = &alrm2->al_time;
-               if (CMP_MACH_TIMESPEC(alarm_time, clock_time) > 0)
-                       break;
+       simple_unlock(&clock_lock);
+       splx(s);
+}
 
 
-               /*
-                * Alarm has expired, so remove it from the
-                * clock alarm list.
-                */  
-               if (alrm1->al_next = alrm2->al_next)
-                       (alrm1->al_next)->al_prev = alrm1;
+static uint32_t
+calend_set_adjustment(
+       int32_t                         *secs,
+       int32_t                         *microsecs)
+{
+       uint64_t                now, t64;
+       int64_t                 total, ototal;
+       uint32_t                interval = 0;
 
 
-               /*
-                * If a clock_sleep() alarm, wakeup the thread
-                * which issued the clock_sleep() call.
-                */
-               if (alrm2->al_status == ALARM_SLEEP) {
-                       alrm2->al_next = 0;
-                       alrm2->al_status = ALARM_DONE;
-                       alrm2->al_time = *clock_time;
-                       thread_wakeup((event_t)alrm2);
-               }
+       total = (int64_t)*secs * NSEC_PER_SEC + *microsecs * NSEC_PER_USEC;
 
 
-               /*
-                * If a clock_alarm() alarm, place the alarm on
-                * the alarm done list and schedule the alarm
-                * delivery mechanism.
-                */
+    commpage_set_timestamp(0,0,0);
+
+       now = mach_absolute_time();
+
+       ototal = calend_adjtotal;
+
+       if (total != 0) {
+               int32_t         delta = calend_adjskew;
+
+               if (total > 0) {
+                       if (total > calend_adjbig)
+                               delta *= 10;
+                       if (delta > total)
+                               delta = total;
+
+                       nanoseconds_to_absolutetime((uint64_t)delta, &t64);
+                       calend_adjoffset = t64;
+               }
                else {
                else {
-                       assert(alrm2->al_status == ALARM_CLOCK);
-                       if (alrm2->al_next = alrmdone)
-                               alrmdone->al_prev = alrm2;
-                       else
-                               thread_call_enter(&alarm_deliver);
-                       alrm2->al_prev = (alarm_t) &alrmdone;
-                       alrmdone = alrm2;
-                       alrm2->al_status = ALARM_DONE;
-                       alrm2->al_time = *clock_time;
+                       if (total < -calend_adjbig)
+                               delta *= 10;
+                       delta = -delta;
+                       if (delta < total)
+                               delta = total;
+
+                       calend_adjstart = now;
+
+                       nanoseconds_to_absolutetime((uint64_t)-delta, &t64);
+                       calend_adjoffset = t64;
                }
                }
+
+               calend_adjtotal = total;
+               calend_adjdelta = delta;
+
+               interval = calend_adjinterval;
        }
        }
+       else
+               calend_adjdelta = calend_adjtotal = 0;
 
 
-       /*
-        * Setup the clock dependent layer to deliver another
-        * interrupt for the next pending alarm.
-        */
-       if (alrm2)
-               (*clock->cl_ops->c_setalrm)(alarm_time);
-       UNLOCK_CLOCK(s);
-}
+       if (ototal != 0) {
+               *secs = ototal / NSEC_PER_SEC;
+               *microsecs = (ototal % NSEC_PER_SEC) / NSEC_PER_USEC;
+       }
+       else
+               *secs = *microsecs = 0;
 
 
-/*
- * ALARM DELIVERY ROUTINES.
- */
+       return (interval);
+}
 
 static void
 
 static void
-clock_alarm_deliver(
-       thread_call_param_t             p0,
-       thread_call_param_t             p1)
+calend_adjust_call(void)
 {
 {
-       register alarm_t        alrm;
-       kern_return_t           code;
-       spl_t                           s;
-
-       LOCK_CLOCK(s);
-       while (alrm = alrmdone) {
-               if (alrmdone = alrm->al_next)
-                       alrmdone->al_prev = (alarm_t) &alrmdone;
-               UNLOCK_CLOCK(s);
-
-               code = (alrm->al_status == ALARM_DONE? KERN_SUCCESS: KERN_ABORTED);
-               if (alrm->al_port != IP_NULL) {
-                       /* Deliver message to designated port */
-                       if (IP_VALID(alrm->al_port)) {
-                               clock_alarm_reply(alrm->al_port, alrm->al_port_type, code,
-                                                                                               alrm->al_type, alrm->al_time);
-                       }
-
-                       LOCK_CLOCK(s);
-                       alrm->al_status = ALARM_FREE;
-                       alrm->al_next = alrmfree;
-                       alrmfree = alrm;
+       uint32_t        interval;
+       spl_t           s;
+
+       s = splclock();
+       simple_lock(&clock_lock);
+
+       if (--calend_adjactive == 0) {
+               interval = calend_adjust();
+               if (interval != 0) {
+                       clock_deadline_for_periodic_event(interval, mach_absolute_time(),
+                                                                                                                               &calend_adjdeadline);
+
+                       if (!timer_call_enter(&calend_adjcall, calend_adjdeadline))
+                               calend_adjactive++;
                }
                }
-               else
-                       panic("clock_alarm_deliver");
        }
 
        }
 
-       UNLOCK_CLOCK(s);
+       simple_unlock(&clock_lock);
+       splx(s);
 }
 
 }
 
-/*
- * CLOCK PRIVATE SERVICING SUBROUTINES.
- */
-
-/*
- * Flush all pending alarms on a clock. All alarms
- * are activated and timestamped correctly, so any
- * programs waiting on alarms/threads will proceed
- * with accurate information.
- */
-static
-void
-flush_alarms(
-       clock_t                         clock)
+static uint32_t
+calend_adjust(void)
 {
 {
-       register alarm_t        alrm1, alrm2;
-       spl_t                           s;
+       uint64_t                now, t64;
+       int32_t                 delta;
+       uint32_t                interval = 0;
 
 
-       /*
-        * Flush all outstanding alarms.
-        */
-       LOCK_CLOCK(s);
-       alrm1 = (alarm_t) &clock->cl_alarm;
-       while (alrm2 = alrm1->al_next) {
-               /*
-                * Remove alarm from the clock alarm list.
-                */  
-               if (alrm1->al_next = alrm2->al_next)
-                       (alrm1->al_next)->al_prev = alrm1;
+    commpage_set_timestamp(0,0,0);
 
 
-               /*
-                * If a clock_sleep() alarm, wakeup the thread
-                * which issued the clock_sleep() call.
-                */
-               if (alrm2->al_status == ALARM_SLEEP) {
-                       alrm2->al_next = 0;
-                       thread_wakeup((event_t)alrm2);
+       now = mach_absolute_time();
+
+       delta = calend_adjdelta;
+
+       if (delta > 0) {
+               clock_calend.offset += calend_adjoffset;
+
+               calend_adjtotal -= delta;
+               if (delta > calend_adjtotal) {
+                       calend_adjdelta = delta = calend_adjtotal;
+
+                       nanoseconds_to_absolutetime((uint64_t)delta, &t64);
+                       calend_adjoffset = t64;
                }
                }
-               else {
-                       /*
-                        * If a clock_alarm() alarm, place the alarm on
-                        * the alarm done list and wakeup the dedicated
-                        * kernel alarm_thread to service the alarm.
-                        */
-                       assert(alrm2->al_status == ALARM_CLOCK);
-                       if (alrm2->al_next = alrmdone)
-                               alrmdone->al_prev = alrm2;
-                       else
-                               thread_wakeup((event_t)&alrmdone);
-                       alrm2->al_prev = (alarm_t) &alrmdone;
-                       alrmdone = alrm2;
+       }
+       else
+       if (delta < 0) {
+               clock_calend.offset -= calend_adjoffset;
+
+               calend_adjtotal -= delta;
+               if (delta < calend_adjtotal) {
+                       calend_adjdelta = delta = calend_adjtotal;
+
+                       nanoseconds_to_absolutetime((uint64_t)-delta, &t64);
+                       calend_adjoffset = t64;
                }
                }
+
+               if (calend_adjdelta != 0)
+                       calend_adjstart = now;
        }
        }
-       UNLOCK_CLOCK(s);
+
+       if (calend_adjdelta != 0)
+               interval = calend_adjinterval;
+
+       return (interval);
 }
 
 /*
 }
 
 /*
- * Post an alarm on a clock's active alarm list. The alarm is
- * inserted in time-order into the clock's active alarm list.
- * Always called from within a LOCK_CLOCK() code section.
+ *     clock_wakeup_calendar:
+ *
+ *     Interface to power management, used
+ *     to initiate the reset of the calendar
+ *     on wake from sleep event.
  */
  */
-static
 void
 void
-post_alarm(
-       clock_t                         clock,
-       alarm_t                         alarm)
+clock_wakeup_calendar(void)
 {
 {
-       register alarm_t        alrm1, alrm2;
-       mach_timespec_t         *alarm_time;
-       mach_timespec_t         *queue_time;
-
-       /*
-        * Traverse alarm list until queue time is greater
-        * than alarm time, then insert alarm.
-        */
-       alarm_time = &alarm->al_time;
-       alrm1 = (alarm_t) &clock->cl_alarm;
-       while (alrm2 = alrm1->al_next) {
-               queue_time = &alrm2->al_time;
-               if (CMP_MACH_TIMESPEC(queue_time, alarm_time) > 0)
-                       break;
-               alrm1 = alrm2;
-       }
-       alrm1->al_next = alarm;
-       alarm->al_next = alrm2;
-       alarm->al_prev = alrm1;
-       if (alrm2)
-               alrm2->al_prev  = alarm;
-
-       /*
-        * If the inserted alarm is the 'earliest' alarm,
-        * reset the device layer alarm time accordingly.
-        */
-       if (clock->cl_alarm.al_next == alarm)
-               (*clock->cl_ops->c_setalrm)(alarm_time);
+       thread_call_enter(&calend_wakecall);
 }
 
 /*
 }
 
 /*
- * Check the validity of 'alarm_time' and 'alarm_type'. If either
- * argument is invalid, return a negative value. If the 'alarm_time'
- * is now, return a 0 value. If the 'alarm_time' is in the future,
- * return a positive value.
+ *     Wait / delay routines.
  */
  */
-static
-int
-check_time(
-       alarm_type_t            alarm_type,
-       mach_timespec_t         *alarm_time,
-       mach_timespec_t         *clock_time)
+static void
+mach_wait_until_continue(
+       __unused void   *parameter,
+       wait_result_t   wresult)
 {
 {
-       int                                     result;
+       thread_syscall_return((wresult == THREAD_INTERRUPTED)? KERN_ABORTED: KERN_SUCCESS);
+       /*NOTREACHED*/
+}
 
 
-       if (BAD_ALRMTYPE(alarm_type))
-               return (-1);
-       if (BAD_MACH_TIMESPEC(alarm_time))
-               return (-1);
-       if ((alarm_type & ALRMTYPE) == TIME_RELATIVE)
-               ADD_MACH_TIMESPEC(alarm_time, clock_time);
+kern_return_t
+mach_wait_until_trap(
+       struct mach_wait_until_trap_args        *args)
+{
+       uint64_t                deadline = args->deadline;
+       wait_result_t   wresult;
 
 
-       result = CMP_MACH_TIMESPEC(alarm_time, clock_time);
+       wresult = assert_wait_deadline((event_t)mach_wait_until_trap, THREAD_ABORTSAFE, deadline);
+       if (wresult == THREAD_WAITING)
+               wresult = thread_block(mach_wait_until_continue);
 
 
-       return ((result >= 0)? result: 0);
+       return ((wresult == THREAD_INTERRUPTED)? KERN_ABORTED: KERN_SUCCESS);
 }
 
 }
 
-mach_timespec_t
-clock_get_system_value(void)
+void
+clock_delay_until(
+       uint64_t                deadline)
 {
 {
-       clock_t                         clock = &clock_list[SYSTEM_CLOCK];
-       mach_timespec_t         value;
+       uint64_t                now = mach_absolute_time();
+
+       if (now >= deadline)
+               return;
 
 
-       (void) (*clock->cl_ops->c_gettime)(&value);
+       if (    (deadline - now) < (8 * sched_cswtime)  ||
+                       get_preemption_level() != 0                             ||
+                       ml_get_interrupts_enabled() == FALSE    )
+               machine_delay_until(deadline);
+       else {
+               assert_wait_deadline((event_t)clock_delay_until, THREAD_UNINT, deadline - sched_cswtime);
 
 
-       return value;
+               thread_block(THREAD_CONTINUE_NULL);
+       }
 }
 
 }
 
-mach_timespec_t
-clock_get_calendar_value(void)
+void
+delay_for_interval(
+       uint32_t                interval,
+       uint32_t                scale_factor)
 {
 {
-       clock_t                         clock = &clock_list[CALENDAR_CLOCK];
-       mach_timespec_t         value = MACH_TIMESPEC_ZERO;
+       uint64_t                end;
 
 
-       (void) (*clock->cl_ops->c_gettime)(&value);
+       clock_interval_to_deadline(interval, scale_factor, &end);
 
 
-       return value;
+       clock_delay_until(end);
 }
 
 void
 }
 
 void
-clock_set_calendar_value(
-       mach_timespec_t         value)
+delay(
+       int             usec)
 {
 {
-       clock_t                         clock = &clock_list[CALENDAR_CLOCK];
-
-       (void) (*clock->cl_ops->c_settime)(&value);
+       delay_for_interval((usec < 0)? -usec: usec, NSEC_PER_USEC);
 }
 
 }
 
+/*
+ *     Miscellaneous routines.
+ */
 void
 void
-clock_deadline_for_periodic_event(
-       uint64_t                        interval,
-       uint64_t                        abstime,
-       uint64_t                        *deadline)
+clock_interval_to_deadline(
+       uint32_t                        interval,
+       uint32_t                        scale_factor,
+       uint64_t                        *result)
 {
 {
-       assert(interval != 0);
+       uint64_t        abstime;
 
 
-       *deadline += interval;
-
-       if (*deadline <= abstime) {
-               *deadline = abstime;
-               clock_get_uptime(&abstime);
-               *deadline += interval;
+       clock_interval_to_absolutetime_interval(interval, scale_factor, &abstime);
 
 
-               if (*deadline <= abstime) {
-                       *deadline = abstime;
-                       *deadline += interval;
-               }
-       }
+       *result = mach_absolute_time() + abstime;
 }
 
 void
 }
 
 void
-mk_timebase_info(
-       uint32_t                        *delta,
-       uint32_t                        *abs_to_ns_numer,
-       uint32_t                        *abs_to_ns_denom,
-       uint32_t                        *proc_to_abs_numer,
-       uint32_t                        *proc_to_abs_denom)
+clock_absolutetime_interval_to_deadline(
+       uint64_t                        abstime,
+       uint64_t                        *result)
 {
 {
-       mach_timebase_info_data_t       info;
-       uint32_t                                        one = 1;
-
-       clock_timebase_info(&info);
-
-       copyout((void *)&one, (void *)delta, sizeof (uint32_t));
-
-       copyout((void *)&info.numer, (void *)abs_to_ns_numer, sizeof (uint32_t));
-       copyout((void *)&info.denom, (void *)abs_to_ns_denom, sizeof (uint32_t));
-
-       copyout((void *)&one, (void *)proc_to_abs_numer, sizeof (uint32_t));
-       copyout((void *)&one, (void *)proc_to_abs_denom, sizeof (uint32_t));
+       *result = mach_absolute_time() + abstime;
 }
 
 }
 
-kern_return_t
-mach_timebase_info(
-       mach_timebase_info_t    out_info)
+void
+clock_get_uptime(
+       uint64_t        *result)
 {
 {
-       mach_timebase_info_data_t       info;
-
-       clock_timebase_info(&info);
-
-       copyout((void *)&info, (void *)out_info, sizeof (info));
-
-       return (KERN_SUCCESS);
+       *result = mach_absolute_time();
 }
 
 }
 
-kern_return_t
-mach_wait_until(
-       uint64_t                deadline)
+void
+clock_deadline_for_periodic_event(
+       uint64_t                        interval,
+       uint64_t                        abstime,
+       uint64_t                        *deadline)
 {
 {
-       int                             wait_result;
+       assert(interval != 0);
 
 
-       assert_wait((event_t)&mach_wait_until, THREAD_ABORTSAFE);
-       thread_set_timer_deadline(deadline);
-       wait_result = thread_block((void (*)) 0);
-       if (wait_result != THREAD_TIMED_OUT)
-               thread_cancel_timer();
+       *deadline += interval;
+
+       if (*deadline <= abstime) {
+               *deadline = abstime + interval;
+               abstime = mach_absolute_time();
 
 
-       return ((wait_result == THREAD_INTERRUPTED)? KERN_ABORTED: KERN_SUCCESS);
+               if (*deadline <= abstime)
+                       *deadline = abstime + interval;
+       }
 }
 }
mirror of XNU