mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-19 14:56:36 +00:00
Code Issues 1 Projects Releases Wiki Activity

tests: systemclock: scale stress test threads according to number of cpus

Browse source 
Scale the number of threads used in the stress tests according to
the number of cores/cpus. We want some contention, but we also
don't want too much contention, as some operating systems are
better at handling 100 threads running wild on a single core
than others.
This commit is contained in:
Tim-Philipp Müller 2018-01-11 18:39:50 +00:00
parent 5feff26624
commit db0c54c5c8
1 changed files with 14 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
tests/check/gst/gstsystemclock.c
View file

@ -827,10 +827,13 @@ unschedule_thread_func (gpointer data)
GST_START_TEST (test_stress_cleanup_unschedule) GST_START_TEST (test_stress_cleanup_unschedule)
{ {
WaitUnscheduleData data[50]; WaitUnscheduleData *data;
gint i; gint i, num;
for (i = 0; i < G_N_ELEMENTS (data); i++) { num = g_get_num_processors () * 6;
data = g_newa (WaitUnscheduleData, num);
for (i = 0; i < num; i++) {
WaitUnscheduleData *d = &data[i]; WaitUnscheduleData *d = &data[i];
/* Don't unschedule waits with positive offsets in order to trigger /* Don't unschedule waits with positive offsets in order to trigger
@ -854,7 +857,7 @@ GST_START_TEST (test_stress_cleanup_unschedule)
g_usleep (G_USEC_PER_SEC); g_usleep (G_USEC_PER_SEC);
/* Stop and free test data */ /* Stop and free test data */
for (i = 0; i < G_N_ELEMENTS (data); i++) { for (i = 0; i < num; i++) {
WaitUnscheduleData *d = &data[i]; WaitUnscheduleData *d = &data[i];
d->running = FALSE; d->running = FALSE;
g_thread_join (d->thread_wait); g_thread_join (d->thread_wait);
@ -868,10 +871,13 @@ GST_END_TEST;
GST_START_TEST (test_stress_reschedule) GST_START_TEST (test_stress_reschedule)
{ {
WaitUnscheduleData data[50]; WaitUnscheduleData *data;
gint i; gint i, num;
for (i = 0; i < G_N_ELEMENTS (data); i++) { num = g_get_num_processors () * 6;
data = g_newa (WaitUnscheduleData, num);
for (i = 0; i < num; i++) {
WaitUnscheduleData *d = &data[i]; WaitUnscheduleData *d = &data[i];
/* Try to unschedule all waits */ /* Try to unschedule all waits */
@ -893,7 +899,7 @@ GST_START_TEST (test_stress_reschedule)
g_usleep (G_USEC_PER_SEC); g_usleep (G_USEC_PER_SEC);
/* Stop and free test data */ /* Stop and free test data */
for (i = 0; i < G_N_ELEMENTS (data); i++) { for (i = 0; i < num; i++) {
WaitUnscheduleData *d = &data[i]; WaitUnscheduleData *d = &data[i];
d->running = FALSE; d->running = FALSE;
g_thread_join (d->thread_wait); g_thread_join (d->thread_wait);