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
|
// $Id$
#include "orbsvcs/CosNamingC.h"
#include "orbsvcs/FtRtecEventChannelAdminC.h"
#include "orbsvcs/Event_Utilities.h"
#include "PushConsumer.h"
#include "ace/Get_Opt.h"
#include "orbsvcs/FtRtEvent/Utils/resolve_init.h"
#include "orbsvcs/FtRtEvent/Utils/FTEC_Gateway.h"
/// include this file to statically linked with FT ORB
#include "orbsvcs/FaultTolerance/FT_ClientService_Activate.h"
/// include this file to statically linked with Transaction Depth
#include "orbsvcs/FtRtEvent/ClientORB/FTRT_ClientORB_Loader.h"
ACE_RCSID (FtRtEvent,
PushConsumer,
"$Id$")
CORBA::ORB_var orb;
auto_ptr<TAO_FTRTEC::FTEC_Gateway> gateway;
RtecEventChannelAdmin::EventChannel_ptr
get_event_channel(int argc, ACE_TCHAR** argv ACE_ENV_ARG_DECL)
{
FtRtecEventChannelAdmin::EventChannel_var channel;
ACE_Get_Opt get_opt (argc, argv, ACE_LIB_TEXT("hi:n"));
int opt;
int use_gateway = 1;
while ((opt = get_opt ()) != EOF)
{
switch (opt)
{
case 'i':
{
CORBA::Object_var obj = orb->string_to_object(get_opt.opt_arg ()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN(0);
channel = FtRtecEventChannelAdmin::EventChannel::_narrow(obj.in()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN(0);
}
break;
case 'n':
use_gateway = 0;
break;
case 'h':
case '?':
ACE_DEBUG((LM_DEBUG,
ACE_LIB_TEXT("Usage: %s ")
ACE_LIB_TEXT("-i ftrt_eventchannel_ior\n")
ACE_LIB_TEXT("-n do not use gateway\n")
ACE_LIB_TEXT("\n"),
argv[0]));
return 0;
}
}
if (CORBA::is_nil(channel.in()))
{
CosNaming::Name name(1);
name.length(1);
name[0].id = CORBA::string_dup("FT_EventService");
CosNaming::NamingContext_var naming_context =
resolve_init<CosNaming::NamingContext>(orb.in(), "NameService"
ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN(0);
channel = resolve<FtRtecEventChannelAdmin::EventChannel>(naming_context.in(),
name
ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN(0);
}
if (use_gateway)
{
ACE_AUTO_PTR_RESET (gateway, new TAO_FTRTEC::FTEC_Gateway(orb.in(), channel.in()), TAO_FTRTEC::FTEC_Gateway);
return gateway->_this(ACE_ENV_SINGLE_ARG_PARAMETER);
}
else
return channel._retn();
}
int main(int argc, ACE_TCHAR** argv)
{
ACE_TRY_NEW_ENV {
orb = CORBA::ORB_init(argc, argv, ""
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
RtecEventChannelAdmin::EventChannel_var channel
= get_event_channel(argc, argv ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
if (CORBA::is_nil(channel.in()))
ACE_ERROR_RETURN((LM_ERROR, "Cannot Find FT_EventService\n"), -1);
PortableServer::POA_var poa =
resolve_init<PortableServer::POA>(orb.in(), "RootPOA"
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
PortableServer::POAManager_var mgr = poa->the_POAManager(ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
mgr->activate(ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
PushConsumer_impl push_consumer_impl(orb.in());
RtecEventChannelAdmin::ConsumerAdmin_var consumer_admin =
channel->for_consumers(ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
RtecEventChannelAdmin::ProxyPushSupplier_var supplier =
consumer_admin->obtain_push_supplier(ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
RtecEventChannelAdmin::ConsumerQOS qos;
qos.is_gateway = 1;
qos.dependencies.length(1);
RtecEventComm::EventHeader& h0 =
qos.dependencies[0].event.header;
h0.type = ACE_ES_EVENT_UNDEFINED; // first free event type
h0.source = ACE_ES_EVENT_SOURCE_ANY;
RtecEventComm::PushConsumer_var push_consumer =
push_consumer_impl._this();
supplier->connect_push_consumer(push_consumer.in(),
qos ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
orb->run(ACE_ENV_SINGLE_ARG_PARAMETER);
}
ACE_CATCHANY {
ACE_PRINT_EXCEPTION(ACE_ANY_EXCEPTION, "A CORBA Exception occurred.");
return -1;
}
ACE_ENDTRY;
return 0;
}
|
