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
|
/* GStreamer
* Copyright (C) <2009> Wim Taymans <wim taymans at gmail dot com>
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Library General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Library General Public License for more details.
*
* You should have received a copy of the GNU Library General Public
* License along with this library; if not, write to the
* Free Software Foundation, Inc., 59 Temple Place - Suite 330,
* Boston, MA 02111-1307, USA.
*/
#include <stdio.h>
#include <stdlib.h>
#include <gst/gst.h>
#include <gst/glib-compat-private.h>
#define MAX_THREADS 100
static gboolean running = TRUE;
static gint count = 0;
static void *
run_test (void *user_data)
{
gint prev;
GstClock *sysclock = GST_CLOCK_CAST (user_data);
while (running) {
gst_clock_get_time (sysclock);
prev = g_atomic_int_add (&count, 1);
if (prev == G_MAXINT)
g_warning ("overflow");
}
g_thread_exit (NULL);
return NULL;
}
gint
main (gint argc, gchar * argv[])
{
GThread *threads[MAX_THREADS];
gint num_threads;
gint t;
GstClock *sysclock;
gst_init (&argc, &argv);
if (argc != 2) {
g_print ("usage: %s <num_threads>\n", argv[0]);
exit (-1);
}
num_threads = atoi (argv[1]);
if (num_threads <= 0 || num_threads > MAX_THREADS) {
g_print ("number of threads must be between 0 and %d\n", MAX_THREADS);
exit (-2);
}
sysclock = gst_system_clock_obtain ();
for (t = 0; t < num_threads; t++) {
GError *error = NULL;
threads[t] = g_thread_try_new ("clockstresstest", run_test,
sysclock, &error);
if (error) {
printf ("ERROR: g_thread_create() %s\n", error->message);
exit (-1);
}
}
printf ("main(): Created %d threads.\n", t);
/* run for 5 seconds */
g_usleep (G_USEC_PER_SEC * 5);
printf ("main(): Stopping threads...\n");
running = FALSE;
for (t = 0; t < num_threads; t++) {
g_thread_join (threads[t]);
}
g_print ("performed %d get_time operations\n", count);
gst_object_unref (sysclock);
return 0;
}
|
