Go to the documentation of this file.00001 
00002 
00003 
00004 
00005 
00006 
00007 
00008 
00009 
00010 
00011 
00012 
00013 
00014 
00015 
00016 
00017 
00018 
00019 
00020 
00021 
00022 
00023 
00024 
00025 
00026 
00027 
00028 
00029 
00030 
00031 
00032 
00033 
00034 
00035 
00036 
00037 
00038 
00039 
00040 
00041 
00042 
00043 
00044 
00045 
00046 
00047 
00048 
00049 
00050 
00051 
00052 
00053 
00054 
00055 
00056 
00057 
00058 
00059 
00060 
00061 
00062 
00063 
00064 
00065 
00066 
00067 
00068 
00069 #include "ServiceI.h"
00070 
00071 using namespace RTT;
00072 using namespace RTT::detail;
00073 
00074 
00075 RTT_corba_CService_i::RTT_corba_CService_i ( RTT::Service::shared_ptr service, PortableServer::POA_ptr poa)
00076     : RTT_corba_CConfigurationInterface_i( service.get(), PortableServer::POA::_duplicate( poa) ), 
00077       RTT_corba_COperationInterface_i( service.get(), PortableServer::POA::_duplicate( poa) ),
00078       RTT::corba::CDataFlowInterface_i( service.get(), PortableServer::POA::_duplicate( poa) ),
00079       mpoa(poa), mservice(service)
00080 {
00081 }
00082 
00083 
00084 RTT_corba_CService_i::~RTT_corba_CService_i (void)
00085 {
00086 }
00087 
00088 PortableServer::POA_ptr RTT_corba_CService_i::_default_POA()
00089 {
00090     return PortableServer::POA::_duplicate(mpoa);
00091 }
00092 
00093 char * RTT_corba_CService_i::getName (
00094     void)
00095 {
00096     return CORBA::string_dup( mservice->getName().c_str() );
00097 }
00098 
00099 char * RTT_corba_CService_i::getServiceDescription (
00100     void)
00101 {
00102     return CORBA::string_dup( mservice->doc().c_str() );
00103 }
00104 
00105 ::RTT::corba::CService::CProviderNames * RTT_corba_CService_i::getProviderNames (
00106     void)
00107 {
00108     Service::ProviderNames names = mservice->getProviderNames();
00109     ::RTT::corba::CService::CProviderNames_var result = new ::RTT::corba::CService::CProviderNames();
00110     result->length( names.size() );
00111     for (unsigned int i=0; i != names.size(); ++i )
00112         result[i] = CORBA::string_dup( names[i].c_str() );
00113 
00114     return result._retn();
00115 }
00116 
00117 ::RTT::corba::CService_ptr RTT_corba_CService_i::getService (
00118     const char * service_name)
00119 {
00120     Service::shared_ptr provider = mservice->getService(service_name);
00121     if ( !provider )
00122         return RTT::corba::CService::_nil();
00123 
00124     
00125     for(Servants::iterator it = mservs.begin(); it != mservs.end(); ++it) {
00126         CORBA::String_var sname = it->first->getName();
00127         if ( sname.in() == service_name )
00128                 return  RTT::corba::CService::_duplicate( it->first.in() );
00129     }
00130     
00131     
00132     RTT_corba_CService_i* serv_i;
00133     RTT::corba::CService_var serv;
00134     serv_i = new RTT_corba_CService_i( provider, mpoa );
00135     serv = serv_i->activate_this();
00136     mservs.push_back( std::pair<RTT::corba::CService_var,PortableServer::ServantBase_var>( RTT::corba::CService::_duplicate(serv.in()), serv_i ) );
00137     
00138     return RTT::corba::CService::_duplicate( serv.in() );
00139 }
00140 
00141 ::CORBA::Boolean RTT_corba_CService_i::hasService (
00142     const char * name)
00143 {
00144     return mservice->hasService( name );
00145 }