| 2822 | } |
| 2823 | |
| 2824 | void DataWriterImpl::transport_discovery_change() |
| 2825 | { |
| 2826 | RcHandle<DomainParticipantImpl> participant = participant_servant_.lock(); |
| 2827 | populate_connection_info(participant->get_id()); |
| 2828 | const TransportLocatorSeq& trans_conf_info = connection_info(); |
| 2829 | |
| 2830 | ACE_Guard<ACE_Recursive_Thread_Mutex> guard(lock_); |
| 2831 | const GUID_t dp_id_copy = dp_id_; |
| 2832 | const GUID_t publication_id_copy = publication_id_; |
| 2833 | const int domain_id = domain_id_; |
| 2834 | guard.release(); |
| 2835 | |
| 2836 | Discovery_rch disco = TheServiceParticipant->get_discovery(domain_id); |
| 2837 | disco->update_publication_locators(domain_id, |
| 2838 | dp_id_copy, |
| 2839 | publication_id_copy, |
| 2840 | trans_conf_info); |
| 2841 | } |
| 2842 | |
| 2843 | DDS::ReturnCode_t DataWriterImpl::setup_serialization() |
| 2844 | { |
no test coverage detected