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
|
//=============================================================================
/**
* @file Bug_3539_Regression_Test.cpp
*
* $Id: Bug_3539_Regression_Test.cpp 93638 2011-03-24 13:16:05Z johnnyw $
*
* This test is similar to TSS_Test but it's a bit simpler and it uses
* ACE_TSS in a main() thread. It uses TSS_Test_Errno.h.
*
*
* @author Vladimir Zykov <vz@prismtech.com>
*/
//=============================================================================
#include "test_config.h"
#include "TSS_Test_Errno.h"
#include "ace/Auto_Ptr.h"
#include "ace/TSS_T.h"
#include "ace/Thread_Manager.h"
#include "ace/Atomic_Op_T.h"
ACE_Atomic_Op<ACE_SYNCH_MUTEX, int> status;
#if defined (ACE_HAS_THREADS)
struct ObjectWithTSS
{
public:
ACE_TSS_TYPE (Errno) tss_;
};
// Static variables.
int Errno::flags_;
int Errno::created_;
int Errno::deleted_;
ACE_Thread_Mutex *Errno::lock_ = 0;
ACE_THR_FUNC_RETURN
check_tss (ObjectWithTSS *o)
{
if (0 == o)
{
ACE_ERROR ((LM_ERROR,
"Nil object."));
status = 1;
}
Errno *e = o->tss_.ts_object (0);
if (0 != e)
{
ACE_ERROR ((LM_ERROR,
"TSS should not have any value yet."));
status = 2;
}
e = ACE_TSS_GET (&o->tss_, Errno);
if (0 == e)
{
ACE_ERROR ((LM_ERROR,
"TSS should now have a value."));
status = 3;
}
return 0;
}
// This worker function is the entry point for each thread.
ACE_THR_FUNC_RETURN
worker (void *c)
{
return check_tss (reinterpret_cast<ObjectWithTSS *> (c));
}
#endif /* ACE_HAS_THREADS */
int
run_main (int, ACE_TCHAR *[])
{
ACE_START_TEST (ACE_TEXT ("Bug_3539_Regression_Test"));
#if defined (ACE_HAS_THREADS)
Errno::allocate_lock ();
const u_int threads = ACE_MAX_THREADS;
{
ObjectWithTSS *o = 0;
ACE_NEW_RETURN (o, ObjectWithTSS, 1);
ACE_Auto_Ptr<ObjectWithTSS> owner (o);
if (ACE_Thread_Manager::instance ()->spawn_n
(threads,
ACE_THR_FUNC (worker),
o,
THR_BOUND) == -1)
ACE_ERROR_RETURN ((LM_ERROR,
ACE_TEXT ("%p\n"), ACE_TEXT ("spawn_n")),
1);
check_tss (o);
ACE_Thread_Manager::instance ()->wait ();
}
Errno::deallocate_lock ();
if (Errno::created () != Errno::deleted ())
{
ACE_ERROR_RETURN ((LM_ERROR,
ACE_TEXT ("Number created (%d) ")
ACE_TEXT ("!= number deleted (%d)\n"),
Errno::created (), Errno::deleted ()),
1);
}
#else /* ACE_HAS_THREADS */
ACE_ERROR ((LM_INFO,
ACE_TEXT ("threads are not supported on this platform\n")));
#endif /* ACE_HAS_THREADS */
ACE_END_TEST;
return status.value ();
}
|
