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
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
|
// $Id$
// ============================================================================
//
// = LIBRARY
// examples
//
// = FILENAME
// test_mutex.cpp
//
// = DESCRIPTION
//
// = AUTHOR
// Tim Harrison
//
// ============================================================================
#include "ace/Get_Opt.h"
#include "ace/Local_Tokens.h"
#include "ace/Remote_Tokens.h"
#include "ace/Thread.h"
#include "ace/Thread_Manager.h"
#if defined (ACE_HAS_THREADS) && defined (ACE_HAS_THREADS_LIBRARY)
ACE_RCSID(mutex, test_mutex, "$Id$")
static ACE_Token_Proxy *mutex;
static int remote_mutexes = 0;
static const char *server_host = ACE_DEFAULT_SERVER_HOST;
static int server_port = ACE_DEFAULT_SERVER_PORT;
static int iterations = 100;
static int spawn_count = 2;
static void *
run_test (void *)
{
int count = iterations;
// test recursive acquisition of a global proxy
while (count--)
{
if (mutex->acquire () == -1)
{
ACE_ERROR ((LM_ERROR, "(%t) %p acquire failed\n","test_mutex"));
return (void *) -1;
}
// mutex->acquire ();
if (mutex->renew () == -1)
{
ACE_ERROR ((LM_ERROR, "(%t) %p renew failed\n","test_mutex"));
return (void *) -1;
}
if (mutex->release () == -1)
{
ACE_ERROR ((LM_ERROR, "(%t) %p release failed\n","test_mutex"));
return (void *) -1;
}
// mutex->release ();
}
return 0;
}
static int
parse_args (int argc, char *argv[])
{
ACE_LOG_MSG->open (argv[0]);
ACE_Get_Opt get_opt (argc, argv, "t:uh:p:n:", 1);
for (int c; (c = get_opt ()) != -1; )
{
switch (c)
{
case 't':
spawn_count = ACE_OS::atoi (get_opt.opt_arg ());
break;
case 'h': // specify the host machine on which the server is running
server_host = get_opt.opt_arg ();
remote_mutexes = 1;
break;
case 'p': // specify the port on which the server is running
server_port = ACE_OS::atoi (get_opt.opt_arg ());
remote_mutexes = 1;
break;
case 'n': // specify the port on which the server is running
iterations = ACE_OS::atoi (get_opt.opt_arg ());
break;
case 'u':
default:
ACE_ERROR_RETURN ((LM_ERROR,
"%n:\n"
"[-h <remote host>]\n"
"[-p <remote port>]\n"
"[-n <iterations>]\n"
"[-t <threads>]\n"
"[-h <remote host>]\n"
"[-p <remote port>]\n", 1), -1);
/* NOTREACHED */
}
}
return 0;
}
int
main (int argc, char *argv[])
{
ACE_Thread_Manager thread_mgr;
if (parse_args (argc, argv) == -1)
return -1;
if (remote_mutexes)
{
ACE_Remote_Mutex::set_server_address (ACE_INET_Addr (server_port, server_host));
mutex = new ACE_Remote_Mutex ("Remote TOKEN", 0, 1);
}
else
{
mutex = new ACE_Local_Mutex ("Local TOKEN", 0, 1);
}
if (thread_mgr.spawn_n (spawn_count,
ACE_THR_FUNC (run_test),
0,
THR_BOUND) == -1)
ACE_ERROR_RETURN ((LM_DEBUG, "%p\n", "spawn"), -1);
thread_mgr.wait ();
return 0;
}
#else
int main (int, char *[])
{
ACE_ERROR_RETURN ((LM_ERROR, "you must have threads to run this test program\n"), -1);
}
#endif /* ACE_HAS_THREADS */
|
