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
|
#include "TestC.h"
#include "ace/Get_Opt.h"
#include "ace/Task.h"
class MT_Requestor : public virtual ACE_Task_Base
{
public:
MT_Requestor (Test::Middle_ptr m, CORBA::Short sec);
virtual int svc ();
private:
Test::Middle_var middle_;
CORBA::Short seconds_;
};
MT_Requestor::MT_Requestor (Test::Middle_ptr m, CORBA::Short sec)
: middle_ (Test::Middle::_duplicate (m)),
seconds_ (sec)
{
}
int
MT_Requestor::svc ()
{
int retries = 5;
while (retries-- > 0)
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("Client thread %t calling delay with %d retries\n"),
retries));
try
{
this->middle_->call_delay(seconds_);
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("Client thread %t delay succeeded\n")));
break;
}
catch (const CORBA::Exception &ex)
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("Client thread %t caught %s\n"),
ex._name()));
}
}
ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Client thread %t done\n")));
return 0;
}
const ACE_TCHAR *ior = ACE_TEXT("file://middle.ior");
bool do_shutdown = false;
CORBA::Short sec = 2;
int num_threads = 1;
int
parse_args (int argc, ACE_TCHAR *argv[])
{
ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("k:n:s:x"));
int c;
while ((c = get_opts ()) != -1)
switch (c)
{
case 'k':
ior = get_opts.opt_arg ();
break;
case 'n':
num_threads = ACE_OS::atoi (get_opts.opt_arg ());
break;
case 's':
sec = ACE_OS::atoi (get_opts.opt_arg ());
break;
case 'x':
do_shutdown = true;
break;
case '?':
default:
ACE_ERROR_RETURN ((LM_ERROR,
"usage: %s "
"-k <ior> "
"-n <threads> "
"-x "
"\n",
argv [0]),
-1);
}
// Indicates successful parsing of the command line
return 0;
}
int
ACE_TMAIN(int argc, ACE_TCHAR *argv[])
{
try
{
CORBA::ORB_var orb =
CORBA::ORB_init (argc, argv);
if (parse_args (argc, argv) != 0)
return 1;
CORBA::Object_var tmp =
orb->string_to_object(ior);
Test::Middle_var middle =
Test::Middle::_narrow(tmp.in ());
if (CORBA::is_nil (middle.in ()))
{
ACE_ERROR_RETURN ((LM_DEBUG,
"Nil Test::Middle reference <%s>\n",
ior),
1);
}
MT_Requestor requestor (middle.in(), sec);
requestor.activate (THR_NEW_LWP | THR_JOINABLE, num_threads);
requestor.wait ();
if (do_shutdown)
{
middle->shutdown();
}
orb->destroy ();
}
catch (const CORBA::Exception& ex)
{
ex._tao_print_exception ("Client main exception caught:");
return 1;
}
return 0;
}
|
