]>
code.delx.au - pulseaudio/blob - src/tests/rtstutter.c
2 This file is part of PulseAudio.
4 Copyright 2008 Lennart Poettering
6 PulseAudio is free software; you can redistribute it and/or modify
7 it under the terms of the GNU Lesser General Public License as
8 published by the Free Software Foundation; either version 2.1 of the
9 License, or (at your option) any later version.
11 PulseAudio is distributed in the hope that it will be useful, but
12 WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 General Public License for more details.
16 You should have received a copy of the GNU Lesser General Public
17 License along with PulseAudio; if not, write to the Free Software
18 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
33 #ifdef HAVE_PTHREAD_SETAFFINITY_NP
34 #if defined(__FreeBSD__)
35 #include <pthread_np.h>
36 #include <sys/param.h>
37 #include <sys/cpuset.h>
42 #include <pulse/util.h>
43 #include <pulse/timeval.h>
44 #include <pulse/gccmacro.h>
46 #include <pulsecore/log.h>
47 #include <pulsecore/macro.h>
48 #include <pulsecore/thread.h>
49 #include <pulsecore/core-util.h>
50 #include <pulsecore/core-rtclock.h>
52 static int msec_lower
, msec_upper
;
54 static void work(void *p
) PA_GCC_NORETURN
;
56 static void work(void *p
) {
58 pa_log_notice("CPU%i: Created thread.", PA_PTR_TO_UINT(p
));
62 #ifdef HAVE_PTHREAD_SETAFFINITY_NP
71 CPU_SET((size_t) PA_PTR_TO_UINT(p
), &mask
);
72 pa_assert_se(pthread_setaffinity_np(pthread_self(), sizeof(mask
), &mask
) == 0);
77 struct timeval now
, end
;
80 pa_log_notice("CPU%i: Sleeping for 1s", PA_PTR_TO_UINT(p
));
84 (uint64_t) ((((double) rand())*(double)(msec_upper
-msec_lower
)*PA_USEC_PER_MSEC
)/RAND_MAX
) +
85 (uint64_t) ((uint64_t) msec_lower
*PA_USEC_PER_MSEC
);
87 pa_log_notice("CPU%i: Freezing for %ims", PA_PTR_TO_UINT(p
), (int) (usec
/PA_USEC_PER_MSEC
));
90 pa_timeval_add(&end
, usec
);
94 } while (pa_timeval_cmp(&now
, &end
) < 0);
98 int main(int argc
, char*argv
[]) {
101 pa_log_set_level(PA_LOG_INFO
);
103 srand((unsigned) time(NULL
));
106 msec_lower
= atoi(argv
[1]);
107 msec_upper
= atoi(argv
[2]);
108 } else if (argc
>= 2) {
110 msec_upper
= atoi(argv
[1]);
116 pa_assert(msec_upper
> 0);
117 pa_assert(msec_upper
>= msec_lower
);
119 pa_log_notice("Creating random latencies in the range of %ims to %ims.", msec_lower
, msec_upper
);
121 for (n
= 1; n
< pa_ncpus(); n
++) {
122 pa_assert_se(pa_thread_new("rtstutter", work
, PA_UINT_TO_PTR(n
)));
125 work(PA_INT_TO_PTR(0));