]>
code.delx.au - pulseaudio/blob - src/tests/rtstutter.c
4 This file is part of PulseAudio.
6 Copyright 2008 Lennart Poettering
8 PulseAudio is free software; you can redistribute it and/or modify
9 it under the terms of the GNU Lesser General Public License as
10 published by the Free Software Foundation; either version 2 of the
11 License, or (at your option) any later version.
13 PulseAudio is distributed in the hope that it will be useful, but
14 WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16 General Public License for more details.
18 You should have received a copy of the GNU Lesser General Public
19 License along with PulseAudio; if not, write to the Free Software
20 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
36 #include <pulse/timeval.h>
37 #include <pulse/gccmacro.h>
39 #include <pulsecore/log.h>
40 #include <pulsecore/macro.h>
42 static int msec_lower
, msec_upper
;
44 static void* work(void *p
) PA_GCC_NORETURN
;
46 static void* work(void *p
) {
48 struct sched_param param
;
50 pa_log_notice("CPU%i: Created thread.", PA_PTR_TO_INT(p
));
52 memset(¶m
, 0, sizeof(param
));
53 param
.sched_priority
= 12;
54 pa_assert_se(pthread_setschedparam(pthread_self(), SCHED_FIFO
, ¶m
) == 0);
57 CPU_SET(PA_PTR_TO_INT(p
), &mask
);
58 pa_assert_se(pthread_setaffinity_np(pthread_self(), sizeof(mask
), &mask
) == 0);
61 struct timespec now
, end
;
64 pa_log_notice("CPU%i: Sleeping for 1s", PA_PTR_TO_INT(p
));
67 pa_assert_se(clock_gettime(CLOCK_REALTIME
, &end
) == 0);
70 (uint64_t) ((((double) rand())*(msec_upper
-msec_lower
)*PA_NSEC_PER_MSEC
)/RAND_MAX
) +
71 (uint64_t) (msec_lower
*PA_NSEC_PER_MSEC
);
73 pa_log_notice("CPU%i: Freezing for %ims", PA_PTR_TO_INT(p
), (int) (nsec
/PA_NSEC_PER_MSEC
));
75 end
.tv_sec
+= nsec
/ PA_NSEC_PER_SEC
;
76 end
.tv_nsec
+= nsec
% PA_NSEC_PER_SEC
;
78 while ((pa_usec_t
) end
.tv_nsec
> PA_NSEC_PER_SEC
) {
80 end
.tv_nsec
-= PA_NSEC_PER_SEC
;
84 pa_assert_se(clock_gettime(CLOCK_REALTIME
, &now
) == 0);
85 } while (now
.tv_sec
< end
.tv_sec
||
86 (now
.tv_sec
== end
.tv_sec
&& now
.tv_nsec
< end
.tv_nsec
));
90 int main(int argc
, char*argv
[]) {
96 msec_lower
= atoi(argv
[1]);
97 msec_upper
= atoi(argv
[2]);
98 } else if (argc
>= 2) {
100 msec_upper
= atoi(argv
[1]);
106 pa_assert(msec_upper
> 0);
107 pa_assert(msec_upper
>= msec_lower
);
109 pa_log_notice("Creating random latencies in the range of %ims to %ims.", msec_lower
, msec_upper
);
111 for (n
= 1; n
< sysconf(_SC_NPROCESSORS_CONF
); n
++) {
113 pa_assert_se(pthread_create(&t
, NULL
, work
, PA_INT_TO_PTR(n
)) == 0);
116 work(PA_INT_TO_PTR(0));