| 509 | } |
| 510 | |
| 511 | void |
| 512 | StaticEndpointManager::reader_exists(const GUID_t& readerid, const GUID_t& writerid) |
| 513 | { |
| 514 | ACE_GUARD(ACE_Thread_Mutex, g, lock_); |
| 515 | LocalPublicationMap::const_iterator lp_pos = local_publications_.find(writerid); |
| 516 | EndpointRegistry::ReaderMapType::const_iterator reader_pos = registry_.reader_map.find(readerid); |
| 517 | if (lp_pos != local_publications_.end() && |
| 518 | reader_pos != registry_.reader_map.end()) { |
| 519 | DataWriterCallbacks_rch dwr = lp_pos->second.publication_.lock(); |
| 520 | if (dwr) { |
| 521 | const ReaderAssociation ra = |
| 522 | {reader_pos->second.trans_info, TransportLocator(), 0, readerid, reader_pos->second.subscriber_qos, reader_pos->second.qos, |
| 523 | "", "", DDS::StringSeq(), DDS::OctetSeq(), {0, 0}}; |
| 524 | dwr->add_association(ra, true); |
| 525 | } |
| 526 | } |
| 527 | } |
| 528 | |
| 529 | void |
| 530 | StaticEndpointManager::reader_does_not_exist(const GUID_t& readerid, const GUID_t& writerid) |