| 92 | |
| 93 | |
| 94 | DDS::ReturnCode_t |
| 95 | RecorderImpl::cleanup() |
| 96 | { |
| 97 | |
| 98 | Discovery_rch disco = TheServiceParticipant->get_discovery(domain_id_); |
| 99 | if (!disco || !disco->remove_subscription(domain_id_, |
| 100 | participant_servant_->get_id(), |
| 101 | subscription_id_)) { |
| 102 | if (log_level >= LogLevel::Notice) { |
| 103 | ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: RecorderImpl::cleanup: " |
| 104 | "could not remove subscription from discovery\n")); |
| 105 | } |
| 106 | return DDS::RETCODE_ERROR; |
| 107 | } |
| 108 | |
| 109 | // Call remove association before unregistering the datareader from the transport, |
| 110 | // otherwise some callbacks resulted from remove_association may lost. |
| 111 | |
| 112 | remove_all_associations(); |
| 113 | |
| 114 | return DDS::RETCODE_OK; |
| 115 | } |
| 116 | |
| 117 | void RecorderImpl::init( |
| 118 | TopicDescriptionImpl* a_topic_desc, |
nothing calls this directly
no test coverage detected