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
|
// $Id$
#include "RateGenC.h"
#include "ace/streams.h"
#include "ace/Get_Opt.h"
/**
* @file controller.cpp
*
* This program interact with a RateGen component, using its supported
* interface "opmode" to switch it on/off, and set the rate of the
* RateGen.
*/
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 <RateGen 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://RateGen.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;
HUDisplay::RateGen_var pulser =
HUDisplay::RateGen::_narrow (obj.in ()
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
if (CORBA::is_nil (pulser.in ()))
{
ACE_ERROR_RETURN ((LM_ERROR,
"Unable to acquire 'RateGen' objref\n"),
-1);
}
if (turn_on)
{
pulser->hertz (rate
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
ACE_DEBUG ((LM_DEBUG, "Start up the Rate Generator\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, "Rate Generator stopped\n"));
}
orb->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCHANY
{
ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
"Who is the culprit \n");
cerr << "Uncaught CORBA exception" << endl;
return 1;
}
ACE_ENDTRY;
return 0;
}
|
