Loading...
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 | /* * Copyright (c) 2000 Apple Computer, Inc. All rights reserved. * * @APPLE_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 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, * FITNESS FOR A PARTICULAR PURPOSE OR NON-INFRINGEMENT. Please see the * License for the specific language governing rights and limitations * under the License. * * @APPLE_LICENSE_HEADER_END@ */ /* * TimerElem.c * * From v01.00 04/15/90 mbs * Modified for MP, 1996 by Tuyen Nguyen * Modified, April 9, 1997 by Tuyen Nguyen for MacOSX. */ #include <sys/errno.h> #include <sys/types.h> #include <sys/param.h> #include <machine/spl.h> #include <sys/systm.h> #include <sys/kernel.h> #include <sys/proc.h> #include <sys/filedesc.h> #include <sys/fcntl.h> #include <sys/mbuf.h> #include <sys/socket.h> #include <netat/sysglue.h> #include <netat/appletalk.h> #include <netat/at_pcb.h> #include <netat/debug.h> #include <netat/adsp.h> #include <netat/adsp_internal.h> atlock_t adsptmr_lock; extern void DoTimerElem(); /* (TimerElemPtr t); * External routine called to * process each one. */ /* * InsertTimerElem * * INPUTS: * qhead Address of ptr to first item in list * t timer element to link in * vbl timer value to use * OUTPUTS: * void */ void InsertTimerElem(qhead, t, val) /* (TimerElemPtr *qhead, TimerElemPtr t, word val) */ TimerElemPtr *qhead, t; int val; { TimerElemPtr p; /* parent pointer */ TimerElemPtr n; /* current */ int s; ATDISABLE(s, adsptmr_lock); if (t->onQ) { /* * someone else beat us to the punch and put this * element back on the queue, just return in this case */ ATENABLE(s, adsptmr_lock); return; } p = (TimerElemPtr)qhead; while (n = p->link) { if (val <= n->timer) /* Do we go in front of this? */ { n->timer -= val; /* Yes, adjust his delta */ break; /* and go link us in */ } val -= n->timer; /* No, subtract off delta from our value */ p = n; } /* while */ /* It must go after item pointed to by p and in front of item * pointed to by n */ t->onQ = 1; /* we're linked in now */ p->link = t; /* parent points to us */ t->timer = val; /* this is our value */ t->link = n; /* we point to n */ ATENABLE(s, adsptmr_lock); } /* * RemoveTimerElem * * INPUTS: * qhead Address of ptr to first item in list * t timer element to link in * OUTPUTS: * void */ void RemoveTimerElem(qhead, t) /* (TimerElemPtr *qhead, TimerElemPtr t) */ TimerElemPtr *qhead, t; { TimerElemPtr p; /* parent pointer */ TimerElemPtr n; /* current */ int s; ATDISABLE(s, adsptmr_lock); if ( !t->onQ) { /* * someone else beat us to the punch and took this * element off of the queue, just return in this case */ ATENABLE(s, adsptmr_lock); return; } p = (TimerElemPtr)qhead; while (n = p->link) /* Get next item in queue */ { if (n == t) /* Is it us? */ { if (p->link = n->link) /* Link our parent to our child */ { n->link->timer += t->timer; /* and update child's timer */ } n->onQ = 0; /* Not on linked list anymore */ break; } p = n; } /* while */ ATENABLE(s, adsptmr_lock); } /* * TimerQueueTick * * INPUTS: * qhead Address of ptr to first item in list * * OUTPUTS: * void */ void TimerQueueTick(qhead) /* (TimerElemPtr *qhead) */ TimerElemPtr *qhead; { TimerElemPtr p; /* parent pointer */ TimerElemPtr n; /* current */ int s; ATDISABLE(s, adsptmr_lock); p = (TimerElemPtr)qhead; if (p->link) /* Is anything on queue? */ p->link->timer--; /* Yes, decrement by a tick */ else goto done; /* No, we're outta' here */ while ((n = p->link) && (n->timer == 0)) /* Next guy needs to be serviced */ { p->link = n->link; /* Unlink us */ n->onQ = 0; ATENABLE(s, adsptmr_lock); DoTimerElem(n); ATDISABLE(s, adsptmr_lock); p = (TimerElemPtr)qhead; } /* while */ done: ATENABLE(s, adsptmr_lock); } |