t_sleep.c revision 1.5.2.2 1 1.5.2.2 pgoyette /* $NetBSD: t_sleep.c,v 1.5.2.2 2012/11/09 20:13:25 pgoyette Exp $ */
2 1.5.2.2 pgoyette
3 1.5.2.2 pgoyette /*-
4 1.5.2.2 pgoyette * Copyright (c) 2006 Frank Kardel
5 1.5.2.2 pgoyette * All rights reserved.
6 1.5.2.2 pgoyette *
7 1.5.2.2 pgoyette * Redistribution and use in source and binary forms, with or without
8 1.5.2.2 pgoyette * modification, are permitted provided that the following conditions
9 1.5.2.2 pgoyette * are met:
10 1.5.2.2 pgoyette * 1. Redistributions of source code must retain the above copyright
11 1.5.2.2 pgoyette * notice, this list of conditions and the following disclaimer.
12 1.5.2.2 pgoyette * 2. Redistributions in binary form must reproduce the above copyright
13 1.5.2.2 pgoyette * notice, this list of conditions and the following disclaimer in the
14 1.5.2.2 pgoyette * documentation and/or other materials provided with the distribution.
15 1.5.2.2 pgoyette *
16 1.5.2.2 pgoyette * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
17 1.5.2.2 pgoyette * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
18 1.5.2.2 pgoyette * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
19 1.5.2.2 pgoyette * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
20 1.5.2.2 pgoyette * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
21 1.5.2.2 pgoyette * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
22 1.5.2.2 pgoyette * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
23 1.5.2.2 pgoyette * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
24 1.5.2.2 pgoyette * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
25 1.5.2.2 pgoyette * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
26 1.5.2.2 pgoyette * POSSIBILITY OF SUCH DAMAGE.
27 1.5.2.2 pgoyette */
28 1.5.2.2 pgoyette
29 1.5.2.2 pgoyette #include <atf-c.h>
30 1.5.2.2 pgoyette #include <errno.h>
31 1.5.2.2 pgoyette #include <poll.h>
32 1.5.2.2 pgoyette #include <stdio.h>
33 1.5.2.2 pgoyette #include <stdlib.h>
34 1.5.2.2 pgoyette #include <string.h>
35 1.5.2.2 pgoyette #include <time.h>
36 1.5.2.2 pgoyette #include <unistd.h>
37 1.5.2.2 pgoyette
38 1.5.2.2 pgoyette #include <sys/cdefs.h>
39 1.5.2.2 pgoyette #include <sys/event.h>
40 1.5.2.2 pgoyette #include <sys/signal.h>
41 1.5.2.2 pgoyette
42 1.5.2.2 pgoyette #define BILLION 1000000000LL /* nano-seconds per second */
43 1.5.2.2 pgoyette #define MILLION 1000000LL /* nano-seconds per milli-second */
44 1.5.2.2 pgoyette
45 1.5.2.2 pgoyette #define ALARM 6 /* SIGALRM after this many seconds */
46 1.5.2.2 pgoyette #define MAXSLEEP 22 /* Maximum delay in seconds */
47 1.5.2.2 pgoyette #define KEVNT_TIMEOUT 10300 /* measured in milli-seconds */
48 1.5.2.2 pgoyette #define FUZZ (40 * MILLION) /* scheduling fuzz accepted - 40 ms */
49 1.5.2.2 pgoyette
50 1.5.2.2 pgoyette /*
51 1.5.2.2 pgoyette * Timer notes
52 1.5.2.2 pgoyette *
53 1.5.2.2 pgoyette * Most tests use FUZZ as their initial delay value, but 'sleep'
54 1.5.2.2 pgoyette * starts at 1sec (since it cannot handle sub-second intervals).
55 1.5.2.2 pgoyette * Subsequent passes double the previous interval, up to MAXSLEEP.
56 1.5.2.2 pgoyette *
57 1.5.2.2 pgoyette * The current values result in 5 passes for the 'sleep' test (at 1,
58 1.5.2.2 pgoyette * 2, 4, 8, and 16 seconds) and 10 passes for the other tests (at
59 1.5.2.2 pgoyette * 0.04, 0.08, 0.16, 0.32, 0.64, 1.28, 2.56, 5.12, 10.24, and 20.48
60 1.5.2.2 pgoyette * seconds).
61 1.5.2.2 pgoyette *
62 1.5.2.2 pgoyette * The ALARM is only set if the current pass's delay is longer, and
63 1.5.2.2 pgoyette * only if the ALARM has not already been triggered.
64 1.5.2.2 pgoyette *
65 1.5.2.2 pgoyette * The 'kevent' test needs the ALARM to be set on a different pass
66 1.5.2.2 pgoyette * from when the KEVNT_TIMEOUT fires. So set ALARM to fire on the
67 1.5.2.2 pgoyette * penultimate pass, and the KEVNT_TIMEOUT on the final pass. We
68 1.5.2.2 pgoyette * set KEVNT_TIMEOUT just barely long enough to put it into the
69 1.5.2.2 pgoyette * last test pass, and set MAXSLEEP a couple seconds longer than
70 1.5.2.2 pgoyette * necessary,in order to avoid a QEMU bug which nearly doubles
71 1.5.2.2 pgoyette * some timers.
72 1.5.2.2 pgoyette */
73 1.5.2.2 pgoyette
74 1.5.2.2 pgoyette static volatile int sig;
75 1.5.2.2 pgoyette
76 1.5.2.2 pgoyette int sleeptest(int (*)(struct timespec *, struct timespec *), bool, bool);
77 1.5.2.2 pgoyette int do_nanosleep(struct timespec *, struct timespec *);
78 1.5.2.2 pgoyette int do_select(struct timespec *, struct timespec *);
79 1.5.2.2 pgoyette int do_poll(struct timespec *, struct timespec *);
80 1.5.2.2 pgoyette int do_sleep(struct timespec *, struct timespec *);
81 1.5.2.2 pgoyette int do_kevent(struct timespec *, struct timespec *);
82 1.5.2.2 pgoyette void sigalrm(int);
83 1.5.2.2 pgoyette
84 1.5.2.2 pgoyette void
85 1.5.2.2 pgoyette sigalrm(int s)
86 1.5.2.2 pgoyette {
87 1.5.2.2 pgoyette
88 1.5.2.2 pgoyette sig++;
89 1.5.2.2 pgoyette }
90 1.5.2.2 pgoyette
91 1.5.2.2 pgoyette int
92 1.5.2.2 pgoyette do_nanosleep(struct timespec *delay, struct timespec *remain)
93 1.5.2.2 pgoyette {
94 1.5.2.2 pgoyette int ret;
95 1.5.2.2 pgoyette
96 1.5.2.2 pgoyette if (nanosleep(delay, remain) == -1)
97 1.5.2.2 pgoyette ret = (errno == EINTR ? 0 : errno);
98 1.5.2.2 pgoyette else
99 1.5.2.2 pgoyette ret = 0;
100 1.5.2.2 pgoyette return ret;
101 1.5.2.2 pgoyette }
102 1.5.2.2 pgoyette
103 1.5.2.2 pgoyette int
104 1.5.2.2 pgoyette do_select(struct timespec *delay, struct timespec *remain)
105 1.5.2.2 pgoyette {
106 1.5.2.2 pgoyette int ret;
107 1.5.2.2 pgoyette struct timeval tv;
108 1.5.2.2 pgoyette
109 1.5.2.2 pgoyette TIMESPEC_TO_TIMEVAL(&tv, delay);
110 1.5.2.2 pgoyette if (select(0, NULL, NULL, NULL, &tv) == -1)
111 1.5.2.2 pgoyette ret = (errno == EINTR ? 0 : errno);
112 1.5.2.2 pgoyette else
113 1.5.2.2 pgoyette ret = 0;
114 1.5.2.2 pgoyette return ret;
115 1.5.2.2 pgoyette }
116 1.5.2.2 pgoyette
117 1.5.2.2 pgoyette int
118 1.5.2.2 pgoyette do_poll(struct timespec *delay, struct timespec *remain)
119 1.5.2.2 pgoyette {
120 1.5.2.2 pgoyette int ret;
121 1.5.2.2 pgoyette struct timeval tv;
122 1.5.2.2 pgoyette
123 1.5.2.2 pgoyette TIMESPEC_TO_TIMEVAL(&tv, delay);
124 1.5.2.2 pgoyette if (pollts(NULL, 0, delay, NULL) == -1)
125 1.5.2.2 pgoyette ret = (errno == EINTR ? 0 : errno);
126 1.5.2.2 pgoyette else
127 1.5.2.2 pgoyette ret = 0;
128 1.5.2.2 pgoyette return ret;
129 1.5.2.2 pgoyette }
130 1.5.2.2 pgoyette
131 1.5.2.2 pgoyette int
132 1.5.2.2 pgoyette do_sleep(struct timespec *delay, struct timespec *remain)
133 1.5.2.2 pgoyette {
134 1.5.2.2 pgoyette struct timeval tv;
135 1.5.2.2 pgoyette
136 1.5.2.2 pgoyette TIMESPEC_TO_TIMEVAL(&tv, delay);
137 1.5.2.2 pgoyette remain->tv_sec = sleep(delay->tv_sec);
138 1.5.2.2 pgoyette remain->tv_nsec = 0;
139 1.5.2.2 pgoyette
140 1.5.2.2 pgoyette return 0;
141 1.5.2.2 pgoyette }
142 1.5.2.2 pgoyette
143 1.5.2.2 pgoyette int
144 1.5.2.2 pgoyette do_kevent(struct timespec *delay, struct timespec *remain)
145 1.5.2.2 pgoyette {
146 1.5.2.2 pgoyette struct kevent ktimer;
147 1.5.2.2 pgoyette struct kevent kresult;
148 1.5.2.2 pgoyette int rtc, kq, kerrno;
149 1.5.2.2 pgoyette int tmo;
150 1.5.2.2 pgoyette
151 1.5.2.2 pgoyette ATF_REQUIRE_MSG((kq = kqueue()) != -1, "kqueue: %s", strerror(errno));
152 1.5.2.2 pgoyette
153 1.5.2.2 pgoyette tmo = KEVNT_TIMEOUT;
154 1.5.2.2 pgoyette
155 1.5.2.2 pgoyette /*
156 1.5.2.2 pgoyette * If we expect the KEVNT_TIMEOUT to fire, and we're running
157 1.5.2.2 pgoyette * under QEMU, make sure the delay is long enough to account
158 1.5.2.2 pgoyette * for the effects of PR kern/43997 !
159 1.5.2.2 pgoyette */
160 1.5.2.2 pgoyette if (system("cpuctl identify 0 | grep -q QEMU") == 0 &&
161 1.5.2.2 pgoyette tmo/1000 < delay->tv_sec && tmo/500 > delay->tv_sec)
162 1.5.2.2 pgoyette delay->tv_sec = MAXSLEEP;
163 1.5.2.2 pgoyette
164 1.5.2.2 pgoyette EV_SET(&ktimer, 1, EVFILT_TIMER, EV_ADD, 0, tmo, 0);
165 1.5.2.2 pgoyette
166 1.5.2.2 pgoyette rtc = kevent(kq, &ktimer, 1, &kresult, 1, delay);
167 1.5.2.2 pgoyette kerrno = errno;
168 1.5.2.2 pgoyette
169 1.5.2.2 pgoyette (void)close(kq);
170 1.5.2.2 pgoyette
171 1.5.2.2 pgoyette if (rtc == -1) {
172 1.5.2.2 pgoyette ATF_REQUIRE_MSG(kerrno == EINTR, "kevent: %s", strerror(errno));
173 1.5.2.2 pgoyette return 0;
174 1.5.2.2 pgoyette }
175 1.5.2.2 pgoyette
176 1.5.2.2 pgoyette if (delay->tv_sec * BILLION + delay->tv_nsec > tmo * MILLION)
177 1.5.2.2 pgoyette ATF_REQUIRE_MSG(rtc > 0,
178 1.5.2.2 pgoyette "kevent: KEVNT_TIMEOUT did not cause EVFILT_TIMER event");
179 1.5.2.2 pgoyette
180 1.5.2.2 pgoyette return 0;
181 1.5.2.2 pgoyette }
182 1.5.2.2 pgoyette
183 1.5.2.2 pgoyette ATF_TC(nanosleep);
184 1.5.2.2 pgoyette ATF_TC_HEAD(nanosleep, tc)
185 1.5.2.2 pgoyette {
186 1.5.2.2 pgoyette
187 1.5.2.2 pgoyette atf_tc_set_md_var(tc, "descr", "Test nanosleep(2) timing");
188 1.5.2.2 pgoyette atf_tc_set_md_var(tc, "timeout", "65");
189 1.5.2.2 pgoyette }
190 1.5.2.2 pgoyette
191 1.5.2.2 pgoyette ATF_TC_BODY(nanosleep, tc)
192 1.5.2.2 pgoyette {
193 1.5.2.2 pgoyette
194 1.5.2.2 pgoyette sleeptest(do_nanosleep, true, false);
195 1.5.2.2 pgoyette }
196 1.5.2.2 pgoyette
197 1.5.2.2 pgoyette ATF_TC(select);
198 1.5.2.2 pgoyette ATF_TC_HEAD(select, tc)
199 1.5.2.2 pgoyette {
200 1.5.2.2 pgoyette
201 1.5.2.2 pgoyette atf_tc_set_md_var(tc, "descr", "Test select(2) timing");
202 1.5.2.2 pgoyette atf_tc_set_md_var(tc, "timeout", "65");
203 1.5.2.2 pgoyette }
204 1.5.2.2 pgoyette
205 1.5.2.2 pgoyette ATF_TC_BODY(select, tc)
206 1.5.2.2 pgoyette {
207 1.5.2.2 pgoyette
208 1.5.2.2 pgoyette sleeptest(do_select, true, true);
209 1.5.2.2 pgoyette }
210 1.5.2.2 pgoyette
211 1.5.2.2 pgoyette ATF_TC(poll);
212 1.5.2.2 pgoyette ATF_TC_HEAD(poll, tc)
213 1.5.2.2 pgoyette {
214 1.5.2.2 pgoyette
215 1.5.2.2 pgoyette atf_tc_set_md_var(tc, "descr", "Test poll(2) timing");
216 1.5.2.2 pgoyette atf_tc_set_md_var(tc, "timeout", "65");
217 1.5.2.2 pgoyette }
218 1.5.2.2 pgoyette
219 1.5.2.2 pgoyette ATF_TC_BODY(poll, tc)
220 1.5.2.2 pgoyette {
221 1.5.2.2 pgoyette
222 1.5.2.2 pgoyette sleeptest(do_poll, true, true);
223 1.5.2.2 pgoyette }
224 1.5.2.2 pgoyette
225 1.5.2.2 pgoyette ATF_TC(sleep);
226 1.5.2.2 pgoyette ATF_TC_HEAD(sleep, tc)
227 1.5.2.2 pgoyette {
228 1.5.2.2 pgoyette
229 1.5.2.2 pgoyette atf_tc_set_md_var(tc, "descr", "Test sleep(3) timing");
230 1.5.2.2 pgoyette atf_tc_set_md_var(tc, "timeout", "65");
231 1.5.2.2 pgoyette }
232 1.5.2.2 pgoyette
233 1.5.2.2 pgoyette ATF_TC_BODY(sleep, tc)
234 1.5.2.2 pgoyette {
235 1.5.2.2 pgoyette
236 1.5.2.2 pgoyette sleeptest(do_sleep, false, false);
237 1.5.2.2 pgoyette }
238 1.5.2.2 pgoyette
239 1.5.2.2 pgoyette ATF_TC(kevent);
240 1.5.2.2 pgoyette ATF_TC_HEAD(kevent, tc)
241 1.5.2.2 pgoyette {
242 1.5.2.2 pgoyette
243 1.5.2.2 pgoyette atf_tc_set_md_var(tc, "descr", "Test kevent(2) timing");
244 1.5.2.2 pgoyette atf_tc_set_md_var(tc, "timeout", "65");
245 1.5.2.2 pgoyette }
246 1.5.2.2 pgoyette
247 1.5.2.2 pgoyette ATF_TC_BODY(kevent, tc)
248 1.5.2.2 pgoyette {
249 1.5.2.2 pgoyette
250 1.5.2.2 pgoyette sleeptest(do_kevent, true, true);
251 1.5.2.2 pgoyette }
252 1.5.2.2 pgoyette
253 1.5.2.2 pgoyette int
254 1.5.2.2 pgoyette sleeptest(int (*test)(struct timespec *, struct timespec *),
255 1.5.2.2 pgoyette bool subsec, bool sim_remain)
256 1.5.2.2 pgoyette {
257 1.5.2.2 pgoyette struct timespec tsa, tsb, tslp, tremain;
258 1.5.2.2 pgoyette int64_t delta1, delta2, delta3, round;
259 1.5.2.2 pgoyette
260 1.5.2.2 pgoyette sig = 0;
261 1.5.2.2 pgoyette signal(SIGALRM, sigalrm);
262 1.5.2.2 pgoyette
263 1.5.2.2 pgoyette if (subsec) {
264 1.5.2.2 pgoyette round = 1;
265 1.5.2.2 pgoyette delta3 = FUZZ;
266 1.5.2.2 pgoyette } else {
267 1.5.2.2 pgoyette round = 1000000000;
268 1.5.2.2 pgoyette delta3 = round;
269 1.5.2.2 pgoyette }
270 1.5.2.2 pgoyette
271 1.5.2.2 pgoyette tslp.tv_sec = delta3 / 1000000000;
272 1.5.2.2 pgoyette tslp.tv_nsec = delta3 % 1000000000;
273 1.5.2.2 pgoyette
274 1.5.2.2 pgoyette while (tslp.tv_sec <= MAXSLEEP) {
275 1.5.2.2 pgoyette /*
276 1.5.2.2 pgoyette * disturb sleep by signal on purpose
277 1.5.2.2 pgoyette */
278 1.5.2.2 pgoyette if (tslp.tv_sec > ALARM && sig == 0)
279 1.5.2.2 pgoyette alarm(ALARM);
280 1.5.2.2 pgoyette
281 1.5.2.2 pgoyette clock_gettime(CLOCK_REALTIME, &tsa);
282 1.5.2.2 pgoyette (*test)(&tslp, &tremain);
283 1.5.2.2 pgoyette clock_gettime(CLOCK_REALTIME, &tsb);
284 1.5.2.2 pgoyette
285 1.5.2.2 pgoyette if (sim_remain) {
286 1.5.2.2 pgoyette timespecsub(&tsb, &tsa, &tremain);
287 1.5.2.2 pgoyette timespecsub(&tslp, &tremain, &tremain);
288 1.5.2.2 pgoyette }
289 1.5.2.2 pgoyette
290 1.5.2.2 pgoyette delta1 = (int64_t)tsb.tv_sec - (int64_t)tsa.tv_sec;
291 1.5.2.2 pgoyette delta1 *= BILLION;
292 1.5.2.2 pgoyette delta1 += (int64_t)tsb.tv_nsec - (int64_t)tsa.tv_nsec;
293 1.5.2.2 pgoyette
294 1.5.2.2 pgoyette delta2 = (int64_t)tremain.tv_sec * BILLION;
295 1.5.2.2 pgoyette delta2 += (int64_t)tremain.tv_nsec;
296 1.5.2.2 pgoyette
297 1.5.2.2 pgoyette delta3 = (int64_t)tslp.tv_sec * BILLION;
298 1.5.2.2 pgoyette delta3 += (int64_t)tslp.tv_nsec - delta1 - delta2;
299 1.5.2.2 pgoyette
300 1.5.2.2 pgoyette delta3 /= round;
301 1.5.2.2 pgoyette delta3 *= round;
302 1.5.2.2 pgoyette
303 1.5.2.2 pgoyette if (delta3 > FUZZ || delta3 < -FUZZ) {
304 1.5.2.2 pgoyette if (!sim_remain &&
305 1.5.2.2 pgoyette system("cpuctl identify 0 | grep -q QEMU") == 0)
306 1.5.2.2 pgoyette atf_tc_expect_fail("Long reschedule latency "
307 1.5.2.2 pgoyette "due to PR kern/43997");
308 1.5.2.2 pgoyette
309 1.5.2.2 pgoyette atf_tc_fail("Reschedule latency %"PRId64" exceeds "
310 1.5.2.2 pgoyette "allowable fuzz %lld", delta3, FUZZ);
311 1.5.2.2 pgoyette }
312 1.5.2.2 pgoyette delta3 = (int64_t)tslp.tv_sec * 2 * BILLION;
313 1.5.2.2 pgoyette delta3 += (int64_t)tslp.tv_nsec * 2;
314 1.5.2.2 pgoyette
315 1.5.2.2 pgoyette delta3 /= round;
316 1.5.2.2 pgoyette delta3 *= round;
317 1.5.2.2 pgoyette if (delta3 < FUZZ)
318 1.5.2.2 pgoyette break;
319 1.5.2.2 pgoyette tslp.tv_sec = delta3 / BILLION;
320 1.5.2.2 pgoyette tslp.tv_nsec = delta3 % BILLION;
321 1.5.2.2 pgoyette }
322 1.5.2.2 pgoyette ATF_REQUIRE_MSG(sig == 1, "Alarm did not fire!");
323 1.5.2.2 pgoyette
324 1.5.2.2 pgoyette atf_tc_pass();
325 1.5.2.2 pgoyette }
326 1.5.2.2 pgoyette
327 1.5.2.2 pgoyette ATF_TP_ADD_TCS(tp)
328 1.5.2.2 pgoyette {
329 1.5.2.2 pgoyette ATF_TP_ADD_TC(tp, nanosleep);
330 1.5.2.2 pgoyette ATF_TP_ADD_TC(tp, select);
331 1.5.2.2 pgoyette ATF_TP_ADD_TC(tp, poll);
332 1.5.2.2 pgoyette ATF_TP_ADD_TC(tp, sleep);
333 1.5.2.2 pgoyette ATF_TP_ADD_TC(tp, kevent);
334 1.5.2.2 pgoyette
335 1.5.2.2 pgoyette return atf_no_error();
336 1.5.2.2 pgoyette }
337