| 479 | } |
| 480 | |
| 481 | int DCPS_IR_Participant::find_topic_reference(OpenDDS::DCPS::GUID_t topicId, |
| 482 | DCPS_IR_Topic*& topic) |
| 483 | { |
| 484 | DCPS_IR_Topic_Map::iterator where = this->topicRefs_.find(topicId); |
| 485 | |
| 486 | if (where != this->topicRefs_.end()) { |
| 487 | topic = where->second; |
| 488 | |
| 489 | if (OpenDDS::DCPS::DCPS_debug_level > 0) { |
| 490 | OpenDDS::DCPS::RepoIdConverter part_converter(id_); |
| 491 | OpenDDS::DCPS::RepoIdConverter topic_converter(topicId); |
| 492 | ACE_DEBUG((LM_DEBUG, |
| 493 | ACE_TEXT("(%P|%t) DCPS_IR_Participant::find_topic_reference: ") |
| 494 | ACE_TEXT("participant %C found topic %C at %x.\n"), |
| 495 | std::string(part_converter).c_str(), |
| 496 | std::string(topic_converter).c_str(), |
| 497 | topic)); |
| 498 | } |
| 499 | |
| 500 | return 0; |
| 501 | |
| 502 | } else { |
| 503 | OpenDDS::DCPS::RepoIdConverter part_converter(id_); |
| 504 | OpenDDS::DCPS::RepoIdConverter topic_converter(topicId); |
| 505 | ACE_ERROR((LM_ERROR, |
| 506 | ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Participant::find_topic_reference: ") |
| 507 | ACE_TEXT("participant %C unable to find topic %C.\n"), |
| 508 | std::string(part_converter).c_str(), |
| 509 | std::string(topic_converter).c_str())); |
| 510 | topic = 0; |
| 511 | return -1; |
| 512 | } |
| 513 | } |
| 514 | |
| 515 | void DCPS_IR_Participant::remove_all_dependents(CORBA::Boolean notify_lost) |
| 516 | { |
no test coverage detected