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
|
// $Id$
/**
* @file controller.cpp
*
* This program interact with a EC component, and set the rate of the
* EC.
*/
#include "ECC.h"
#include "ace/Get_Opt.h"
#include "ace/streams.h"
const char *rategen_ior_ = 0;
int rate = 2;
int turn_on = 1;
int
parse_args (int argc, char *argv[])
{
ACE_Get_Opt get_opts (argc, argv, "k:r:of");
int c;
while ((c = get_opts ()) != -1)
{
switch (c)
{
case 'o':
turn_on = 1;
break;
case 'f':
turn_on = 0;
break;
case 'k':
rategen_ior_ = get_opts.opt_arg ();
break;
case 'r':
rate = atoi (get_opts.opt_arg ());
break;
case '?': // display help for use of the server.
default:
ACE_ERROR_RETURN ((LM_ERROR,
"usage: %s\n"
"-o (Turn on the rate generator)\n"
"-f (Turn off the rate generator)\n"
"-k <EC IOR> (default is file://rategen.ior)\n"
"-r <rate in hertz> (default is 3)\n"
"\n",
argv [0]),
-1);
break;
}
}
if (rategen_ior_ == 0)
{
rategen_ior_ = "file://ec.ior";
}
if (rate == 0)
{
rate = 3;
}
return 0;
}
int
main (int argc, char *argv[])
{
ACE_TRY_NEW_ENV
{
// Initialize orb
CORBA::ORB_var orb = CORBA::ORB_init (argc,
argv,
""
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
if (parse_args (argc, argv) != 0)
{
return -1;
}
CORBA::Object_var obj =
orb->string_to_object (rategen_ior_
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
BasicSP::EC_var pulser
= BasicSP::EC::_narrow (obj.in ()
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
if (CORBA::is_nil (pulser.in ()))
{
ACE_ERROR_RETURN ((LM_ERROR,
"Unable to acquire 'EC' objref\n"),
-1);
}
pulser->hertz (rate
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
if (turn_on)
{
pulser->hertz (rate
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
ACE_DEBUG ((LM_DEBUG, "Start up the Event services\n"));
pulser->start (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
}
else
{
pulser->stop (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
ACE_DEBUG ((LM_DEBUG, "Stop the ES\n"));
}
orb->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCHANY
{
ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
"Who is the culprit \n");
ACE_ERROR_RETURN ((LM_ERROR,
"Uncaught CORBA exception\n"),
1);
}
ACE_ENDTRY;
return 0;
}
|
