| 25 | } |
| 26 | |
| 27 | void |
| 28 | OpenDDS::Model::Entities::registerTypes( const OPENDDS_STRING& participant, |
| 29 | const OPENDDS_STRING& transportConfig) |
| 30 | { |
| 31 | OPENDDS_QUEUE(DDS::TypeSupport_ptr)& queue = this->typeSupport_[ participant]; |
| 32 | if( queue.empty()) { |
| 33 | return; |
| 34 | } |
| 35 | |
| 36 | DDS::DomainParticipant_var p = this->participant(participant, |
| 37 | transportConfig); |
| 38 | if( !p) { |
| 39 | return; |
| 40 | } |
| 41 | |
| 42 | while( !queue.empty()) { |
| 43 | if( OpenDDS::DCPS::DCPS_debug_level>1) { |
| 44 | ACE_DEBUG((LM_DEBUG, |
| 45 | ACE_TEXT("(%P|%t) Entities::registerTypes() - ") |
| 46 | ACE_TEXT("Registering type [%C] in participant [%C].\n"), |
| 47 | CORBA::String_var(queue.front()->get_type_name()).in(), |
| 48 | participant.c_str() |
| 49 | )); |
| 50 | } |
| 51 | DDS::ReturnCode_t result = queue.front()->register_type(p, ""); |
| 52 | if (result != DDS::RETCODE_OK) { |
| 53 | ACE_ERROR((LM_ERROR, "(%P|%t) Entities::registerTypes() - " |
| 54 | "register_type returned %d\n", result)); |
| 55 | } |
| 56 | queue.pop(); |
| 57 | } |
| 58 | } |
| 59 | |
| 60 | DDS::DomainParticipant_var |
| 61 | OpenDDS::Model::Entities::participant( |
no test coverage detected