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
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
|
// $Id$
// ============================================================================
//
// = LIBRARY
// tests
//
// = FILENAME
// Reactor_Exceptions_Test.cpp
//
// = DESCRIPTION
// This is a test that makes sure the ACE_Reactor works correctly
// in the face of C++ exceptions and threads.
//
// = AUTHOR
// Luca Priorelli <lucapri@mbox.vol.it> and Douglas C. Schmidt
//
// ============================================================================
#include "ace/Service_Config.h"
#include "ace/Reactor.h"
#include "ace/SOCK_Dgram.h"
#include "test_config.h"
#if defined (ACE_HAS_EXCEPTIONS)
// Just need a simple exception class.
class Except {};
class MemoryEx : public ACE_Event_Handler, public ACE_SOCK_Dgram
{
public:
MemoryEx (const ACE_INET_Addr &local_addr);
virtual ACE_HANDLE get_handle (void) const;
virtual int handle_input (ACE_HANDLE handle);
};
MemoryEx::MemoryEx (const ACE_INET_Addr &local_addr)
: ACE_SOCK_Dgram (local_addr)
{
}
ACE_HANDLE
MemoryEx::get_handle (void) const
{
return ACE_SOCK_Dgram::get_handle ();
}
int
MemoryEx::handle_input (ACE_HANDLE)
{
char buf[BUFSIZ];
ACE_INET_Addr from_addr;
ACE_DEBUG ((LM_DEBUG, "Activity occurred on handle %d!\n",
ACE_SOCK_Dgram::get_handle ()));
ssize_t n = ACE_SOCK_Dgram::recv (buf, sizeof buf, from_addr);
if (n == -1)
ACE_ERROR ((LM_ERROR, "%p\n", "handle_input"));
else
ACE_DEBUG ((LM_DEBUG, "got buf = %s\n", buf));
#if defined (ACE_WIN32)
// Cause a Win32 structured exception.
*(char *) 0 = 0;
#else
throw Except ();
#endif
ACE_NOTREACHED(return 0);
}
class My_Reactor : public ACE_Reactor
{
public:
virtual int handle_events (ACE_Time_Value *max_wait_time)
{
int ret = 0;
try
{
ret = ACE_Reactor::handle_events (max_wait_time);
}
catch (...)
{
ACE_DEBUG ((LM_DEBUG, "(%t) caught exception\n"));
ret = -1;
// do your thing, etc.
}
return ret;
}
};
static int
worker (void)
{
ACE_NEW_THREAD;
ACE_Thread_Control tc (ACE_Thread_Manager::instance ());
ACE_Reactor::instance()->owner (ACE_OS::thr_self());
for (;;)
if (ACE_Reactor::instance()->handle_events () == -1)
ACE_ERROR_RETURN ((LM_ERROR, "(%t) error return\n"), -1);
ACE_NOTREACHED(return 0);
}
#endif /* ACE_HAS_EXCEPTIONS */
int
main (int argc, char *argv[])
{
ACE_START_TEST ("Reactor_Exceptions_Test");
#if defined (ACE_HAS_EXCEPTIONS)
My_Reactor reactor;
u_short port = argc > 1 ? ACE_OS::atoi (argv[1]) : ACE_DEFAULT_SERVER_PORT;
ACE_DEBUG ((LM_DEBUG, "Starting tracing\n"));
ACE_LOG_MSG->start_tracing ();
// ACE_Reactor::instance(new My_Reactor);
ACE_Reactor::instance (&reactor);
ACE_Thread_Manager *thr_mgr = ACE_Thread_Manager::instance ();
ACE_INET_Addr local_addr (port);
ACE_INET_Addr remote_addr (port,
"localhost");
MemoryEx ex (local_addr);
if (ACE_Reactor::instance()->register_handler
(&ex, ACE_Event_Handler::READ_MASK) == -1)
ACE_ERROR_RETURN ((LM_ERROR, "%p\n%a", "register_handler", 1), -1);
#if defined (ACE_HAS_THREADS)
thr_mgr->spawn (ACE_THR_FUNC (worker));
#else
// Need to figure out how to implement this test.
ACE_ERROR ((LM_ERROR, "threads not supported on this platform\n"));
#endif /* ACE_HAS_THREADS */
ACE_SOCK_Dgram dgram ((ACE_INET_Addr &) ACE_Addr::sap_any);
for (int i = 0; i < ACE_MAX_ITERATIONS; i++)
dgram.send ("Hello", 6, remote_addr);
thr_mgr->wait ();
ACE_DEBUG ((LM_DEBUG, "(%t) exiting main\n"));
#else
ACE_UNUSED_ARG (argc);
ACE_UNUSED_ARG (argv);
ACE_ERROR ((LM_ERROR, "C++ exceptions not supported on this platform\n"));
#endif /* ACE_HAS_EXCEPTIONS */
ACE_END_TEST;
return 0;
}
|
