summaryrefslogtreecommitdiff
path: root/perf/src/CosEvent/Service.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'perf/src/CosEvent/Service.cpp')
-rw-r--r--perf/src/CosEvent/Service.cpp106
1 files changed, 53 insertions, 53 deletions
diff --git a/perf/src/CosEvent/Service.cpp b/perf/src/CosEvent/Service.cpp
index 5aeb71219d3..fd6d77e1368 100644
--- a/perf/src/CosEvent/Service.cpp
+++ b/perf/src/CosEvent/Service.cpp
@@ -20,19 +20,19 @@ class EventChannel : public TAO_CEC_EventChannel
public:
EventChannel(CORBA::ORB* orb,
- const TAO_CEC_EventChannel_Attributes& attr,
- TAO_CEC_Factory* factory = 0,
- int own_factory = 0) :
- TAO_CEC_EventChannel(attr, factory, own_factory),
- _orb(CORBA::ORB::_duplicate(orb))
+ const TAO_CEC_EventChannel_Attributes& attr,
+ TAO_CEC_Factory* factory = 0,
+ int own_factory = 0) :
+ TAO_CEC_EventChannel(attr, factory, own_factory),
+ _orb(CORBA::ORB::_duplicate(orb))
{
}
void destroy(ACE_ENV_SINGLE_ARG_DECL)
- ACE_THROW_SPEC ((CORBA::SystemException))
+ ACE_THROW_SPEC ((CORBA::SystemException))
{
- TAO_CEC_EventChannel::destroy(ACE_ENV_SINGLE_ARG_PARAMETER);
- _orb->shutdown(0 ACE_ENV_ARG_PARAMETER);
+ TAO_CEC_EventChannel::destroy(ACE_ENV_SINGLE_ARG_PARAMETER);
+ _orb->shutdown(0 ACE_ENV_ARG_PARAMETER);
}
private:
@@ -48,59 +48,59 @@ main(int argc, char* argv[])
int nthreads = 1;
for(int i = 1; i < argc; i++)
{
- if(strcmp(argv[i], "-n") == 0)
- {
- nthreads = atoi(argv[++i]);
- }
+ if(strcmp(argv[i], "-n") == 0)
+ {
+ nthreads = atoi(argv[++i]);
+ }
}
ACE_DECLARE_NEW_CORBA_ENV;
ACE_TRY
{
- CORBA::ORB_var orb = CORBA::ORB_init(argc, argv, "" ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- CORBA::Object_var object = orb->resolve_initial_references("RootPOA" ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
- PortableServer::POA_var poa = PortableServer::POA::_narrow(object.in() ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
- PortableServer::POAManager_var poa_manager = poa->the_POAManager(ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_TRY_CHECK;
- poa_manager->activate(ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- TAO_CEC_EventChannel_Attributes attributes(poa.in(), poa.in());
-
- EventChannel ec_impl(orb.in(), attributes);
- ec_impl.activate(ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- CosEventChannelAdmin::EventChannel_var event_channel = ec_impl._this(ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- CORBA::String_var ior = orb->object_to_string(event_channel.in() ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- ACE_DEBUG ((LM_DEBUG, "Activated as <%s>\n", ior.in()));
-
- // If the ior_output_file exists, output the ior to it
- if(ior_output_file != 0)
- {
- FILE *output_file= ACE_OS::fopen(ior_output_file, "w");
- if(output_file == 0)
- ACE_ERROR_RETURN ((LM_ERROR, "Cannot open output file for writing IOR: %s", ior_output_file), 1);
- ACE_OS::fprintf(output_file, "%s", ior.in());
- ACE_OS::fclose(output_file);
- }
-
- WorkerThread worker(orb.in());
- worker.activate(THR_NEW_LWP | THR_JOINABLE, nthreads, 1);
- worker.thr_mgr()->wait();
+ CORBA::ORB_var orb = CORBA::ORB_init(argc, argv, "" ACE_ENV_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+
+ CORBA::Object_var object = orb->resolve_initial_references("RootPOA" ACE_ENV_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+ PortableServer::POA_var poa = PortableServer::POA::_narrow(object.in() ACE_ENV_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+ PortableServer::POAManager_var poa_manager = poa->the_POAManager(ACE_ENV_SINGLE_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+ poa_manager->activate(ACE_ENV_SINGLE_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+
+ TAO_CEC_EventChannel_Attributes attributes(poa.in(), poa.in());
+
+ EventChannel ec_impl(orb.in(), attributes);
+ ec_impl.activate(ACE_ENV_SINGLE_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+
+ CosEventChannelAdmin::EventChannel_var event_channel = ec_impl._this(ACE_ENV_SINGLE_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+
+ CORBA::String_var ior = orb->object_to_string(event_channel.in() ACE_ENV_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+
+ ACE_DEBUG ((LM_DEBUG, "Activated as <%s>\n", ior.in()));
+
+ // If the ior_output_file exists, output the ior to it
+ if(ior_output_file != 0)
+ {
+ FILE *output_file= ACE_OS::fopen(ior_output_file, "w");
+ if(output_file == 0)
+ ACE_ERROR_RETURN ((LM_ERROR, "Cannot open output file for writing IOR: %s", ior_output_file), 1);
+ ACE_OS::fprintf(output_file, "%s", ior.in());
+ ACE_OS::fclose(output_file);
+ }
+
+ WorkerThread worker(orb.in());
+ worker.activate(THR_NEW_LWP | THR_JOINABLE, nthreads, 1);
+ worker.thr_mgr()->wait();
}
ACE_CATCHANY
{
- ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "Service");
- return 1;
+ ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "Service");
+ return 1;
}
ACE_ENDTRY;
return 0;