use rdwri()

[unix-history] / usr / src / sys / kern / kern_clock.c

diff --git a/usr/src/sys/kern/kern_clock.c b/usr/src/sys/kern/kern_clock.c
index 055698f..fe0dfc6 100644 (file)
--- a/usr/src/sys/kern/kern_clock.c
+++ b/usr/src/sys/kern/kern_clock.c
@@ -1,4 +1,4 @@
-/*     kern_clock.c    4.23    81/07/09        */
+/*     kern_clock.c    4.36    82/08/22        */

 
 #include "../h/param.h"
 #include "../h/systm.h"
 
 #include "../h/param.h"
 #include "../h/systm.h"


@@ -17,10 +17,18 @@
 #include "../h/mtpr.h"
 #include "../h/clock.h"
 #include "../h/cpu.h"
 #include "../h/mtpr.h"
 #include "../h/clock.h"
 #include "../h/cpu.h"

+#include "../h/protosw.h"
+#include "../h/socket.h"
+#include "../net/if.h"
+#ifdef MUSH
+#include "../h/quota.h"
+#include "../h/share.h"
+#endif

 
 #include "bk.h"
 #include "dh.h"
 #include "dz.h"
 
 #include "bk.h"
 #include "dh.h"
 #include "dz.h"

+#include "ps.h"

 
 /*
  * Hardclock is called straight from
 
 /*
  * Hardclock is called straight from


@@ -45,6 +53,22 @@
  * interrupts compressed into one (due to excessive interrupt load),
  * but that hardclock interrupts should never be lost.
  */
  * interrupts compressed into one (due to excessive interrupt load),
  * but that hardclock interrupts should never be lost.
  */

+#ifdef GPROF
+extern int profiling;
+extern char *s_lowpc;
+extern u_long s_textsize;
+extern u_short *kcount;
+#endif
+
+/*
+ * Protoslow is like lbolt, but for slow protocol timeouts, counting
+ * up to (hz/PR_SLOWHZ), then causing a pfslowtimo().
+ * Protofast is like lbolt, but for fast protocol timeouts, counting
+ * up to (hz/PR_FASTHZ), then causing a pffasttimo().
+ */
+int    protoslow;
+int    protofast;
+int    ifnetslow;

 
 /*ARGSUSED*/
 hardclock(pc, ps)
 
 /*ARGSUSED*/
 hardclock(pc, ps)


@@ -53,12 +77,20 @@ hardclock(pc, ps)
        register struct callout *p1;
        register struct proc *pp;
        register int s, cpstate;
        register struct callout *p1;
        register struct proc *pp;
        register int s, cpstate;

+       extern double avenrun[];

 
        /*
         * reprime clock
         */
        clkreld();
 
 
        /*
         * reprime clock
         */
        clkreld();
 

+#if NPS > 0
+       /*
+        * sync referesh of picture system
+        */
+       psextsync(pc, ps);
+#endif
+

        /*
         * update callout times
         */
        /*
         * update callout times
         */


@@ -97,10 +129,16 @@ hardclock(pc, ps)
                else
                        cpstate = CP_USER;
        } else {
                else
                        cpstate = CP_USER;
        } else {

+#ifdef GPROF
+               int k = pc - s_lowpc;
+               if (profiling < 2 && k < s_textsize)
+                       kcount[k / sizeof (*kcount)]++;
+#endif

                cpstate = CP_SYS;
                cpstate = CP_SYS;

-               if (noproc)
-                       cpstate = CP_IDLE;
-               else
+               if (noproc) {
+                       if ((ps&PSL_IPL) != 0)
+                               cpstate = CP_IDLE;
+               } else

                        u.u_vm.vm_stime++;
        }
        cp_time[cpstate]++;
                        u.u_vm.vm_stime++;
        }
        cp_time[cpstate]++;


@@ -115,6 +153,11 @@ hardclock(pc, ps)
                pp->p_cpticks++;
                if(++pp->p_cpu == 0)
                        pp->p_cpu--;
                pp->p_cpticks++;
                if(++pp->p_cpu == 0)
                        pp->p_cpu--;

+#ifdef MUSH
+               pp->p_quota->q_cost += (pp->p_nice > NZERO ?
+                   (shconsts.sc_tic * ((2*NZERO)-pp->p_nice)) / NZERO :
+                   shconsts.sc_tic) * (((int)avenrun[0]+2)/3);
+#endif

                if(pp->p_cpu % 4 == 0) {
                        (void) setpri(pp);
                        if (pp->p_pri >= PUSER)
                if(pp->p_cpu % 4 == 0) {
                        (void) setpri(pp);
                        if (pp->p_pri >= PUSER)


@@ -125,6 +168,12 @@ hardclock(pc, ps)
         * Time moves on.
         */
        ++lbolt;
         * Time moves on.
         */
        ++lbolt;

+
+       /*
+        * Time moves on for protocols.
+        */
+       --protoslow; --protofast; --ifnetslow;
+

 #if VAX780
        /*
         * On 780's, impelement a fast UBA watcher,
 #if VAX780
        /*
         * On 780's, impelement a fast UBA watcher,


@@ -168,6 +217,14 @@ double     avenrun[];
  */
 double ccpu = 0.95122942450071400909;          /* exp(-1/20) */
 
  */
 double ccpu = 0.95122942450071400909;          /* exp(-1/20) */
 

+#ifdef MELB
+/*
+ * Automatic niceness rate & max constants
+ */
+#define        MAXNICE (8 + NZERO)     /* maximum auto nice value */
+#define        NFACT   (40 * hz)       /* nice++ every 40 secs cpu+sys time */
+#endif
+

 /*
  * Software clock interrupt.
  * This routine runs at lower priority than device interrupts.
 /*
  * Software clock interrupt.
  * This routine runs at lower priority than device interrupts.


@@ -188,8 +245,10 @@ softclock(pc, ps)
        if (panicstr == 0) {
                for (;;) {
                        s = spl7();
        if (panicstr == 0) {
                for (;;) {
                        s = spl7();

-                       if ((p1 = calltodo.c_next) == 0 || p1->c_time > 0)
+                       if ((p1 = calltodo.c_next) == 0 || p1->c_time > 0) {
+                               splx(s);

                                break;
                                break;

+                       }

                        calltodo.c_next = p1->c_next;
                        arg = p1->c_arg;
                        func = p1->c_func;
                        calltodo.c_next = p1->c_next;
                        arg = p1->c_arg;
                        func = p1->c_func;


@@ -203,13 +262,11 @@ softclock(pc, ps)
        /*
         * Drain silos.
         */
        /*
         * Drain silos.
         */

-#if NBK > 0

 #if NDH > 0
        s = spl5(); dhtimer(); splx(s);
 #endif
 #if NDZ > 0
        s = spl5(); dztimer(); splx(s);
 #if NDH > 0
        s = spl5(); dhtimer(); splx(s);
 #endif
 #if NDZ > 0
        s = spl5(); dztimer(); splx(s);

-#endif

 #endif
 
        /*
 #endif
 
        /*


@@ -236,6 +293,22 @@ softclock(pc, ps)
                aston();
        }
 
                aston();
        }
 

+       /*
+        * Run network slow and fast timeouts.
+        */
+       if (protofast <= 0) {
+               protofast = hz / PR_FASTHZ;
+               pffasttimo();
+       }
+       if (protoslow <= 0) {
+               protoslow = hz / PR_SLOWHZ;
+               pfslowtimo();
+       }
+       if (ifnetslow <= 0) {
+               ifnetslow = hz / IFNET_SLOWHZ;
+               if_slowtimo();
+       }
+

        /*
         * Lightning bolt every second:
         *      sleep timeouts
        /*
         * Lightning bolt every second:
         *      sleep timeouts


@@ -261,8 +334,9 @@ softclock(pc, ps)
                 * really want to run this code several times,
                 * so squish out all multiples of hz here.
                 */
                 * really want to run this code several times,
                 * so squish out all multiples of hz here.
                 */

-               time += lbolt / hz;
-               lbolt %= hz;
+               s = spl6();
+               time += lbolt / hz; lbolt %= hz;
+               splx(s);

 
                /*
                 * Wakeup lightning bolt sleepers.
 
                /*
                 * Wakeup lightning bolt sleepers.


@@ -278,6 +352,14 @@ softclock(pc, ps)
                 */
                for (pp = proc; pp < procNPROC; pp++)
                if (pp->p_stat && pp->p_stat!=SZOMB) {
                 */
                for (pp = proc; pp < procNPROC; pp++)
                if (pp->p_stat && pp->p_stat!=SZOMB) {

+#ifdef MUSH
+                       /*
+                        * Charge process for memory in use
+                        */
+                       if (pp->p_quota->q_uid)
+                               pp->p_quota->q_cost +=
+                                   shconsts.sc_click * pp->p_rssize;
+#endif

                        /*
                         * Increase resident time, to max of 127 seconds
                         * (it is kept in a character.)  For
                        /*
                         * Increase resident time, to max of 127 seconds
                         * (it is kept in a character.)  For


@@ -338,8 +420,13 @@ softclock(pc, ps)
                         * is in the range 0 to 255, to fit in a character.
                         */
                        pp->p_cpticks = 0;
                         * is in the range 0 to 255, to fit in a character.
                         */
                        pp->p_cpticks = 0;

+#ifdef MUSH
+                       a = ave((pp->p_cpu & 0377), avenrun[0]*nrscale) +
+                            pp->p_nice - NZERO + pp->p_quota->q_nice;
+#else

                        a = ave((pp->p_cpu & 0377), avenrun[0]*nrscale) +
                             pp->p_nice - NZERO;
                        a = ave((pp->p_cpu & 0377), avenrun[0]*nrscale) +
                             pp->p_nice - NZERO;

+#endif

                        if (a < 0)
                                a = 0;
                        if (a > 255)
                        if (a < 0)
                                a = 0;
                        if (a > 255)


@@ -393,6 +480,30 @@ softclock(pc, ps)
                if (bclnlist != NULL)
                        wakeup((caddr_t)&proc[2]);
 
                if (bclnlist != NULL)
                        wakeup((caddr_t)&proc[2]);
 

+#ifdef MELB
+               /*
+                * If a process was running, see if time to make it nicer
+                */
+               if (!noproc) {
+                       pp = u.u_procp;
+                       if (pp->p_uid
+#ifdef MUSH
+                               && !(pp->p_flag & SLOGIN)
+#else
+                                    /* this is definitely not good enough */
+                               && (pp->p_pid != pp->p_pgrp || pp->p_ppid != 1)
+#endif
+                               && (u.u_vm.vm_utime + u.u_vm.vm_stime) >
+                                       (pp->p_nice-NZERO+1)*NFACT
+                               && pp->p_nice >= NZERO
+                               && pp->p_nice < MAXNICE
+                       ) {
+                               pp->p_nice++;
+                               (void) setpri(pp);
+                               pp->p_pri = pp->p_usrpri;
+                       }
+               }
+#else

                /*
                 * If the trap occurred from usermode,
                 * then check to see if it has now been
                /*
                 * If the trap occurred from usermode,
                 * then check to see if it has now been


@@ -408,6 +519,7 @@ softclock(pc, ps)
                        (void) setpri(pp);
                        pp->p_pri = pp->p_usrpri;
                }
                        (void) setpri(pp);
                        pp->p_pri = pp->p_usrpri;
                }

+#endif

        }
        /*
         * If trapped user-mode, give it a profiling tick.
        }
        /*
         * If trapped user-mode, give it a profiling tick.


@@ -463,3 +575,31 @@ timeout(fun, arg, tim)
                p2->c_time -= t;
        splx(s);
 }
                p2->c_time -= t;
        splx(s);
 }

+
+#ifdef notdef
+/*
+ * untimeout is called to remove a function timeout call
+ * from the callout structure.
+ */
+untimeout (fun, arg)
+       int (*fun)();
+       caddr_t arg;
+{
+
+       register struct callout *p1, *p2;
+       register int s;
+
+       s = spl7();
+       for (p1 = &calltodo; (p2 = p1->c_next) != 0; p1 = p2) {
+               if (p2->c_func == fun && p2->c_arg == arg) {
+                       if (p2->c_next)
+                               p2->c_next->c_time += p2->c_time;
+                       p1->c_next = p2->c_next;
+                       p2->c_next = callfree;
+                       callfree = p2;
+                       break;
+               }
+       }
+       splx(s);
+}
+#endif