| 141 | } |
| 142 | |
| 143 | void |
| 144 | DataWriterImpl::init( |
| 145 | TopicImpl* topic_servant, |
| 146 | const DDS::DataWriterQos& qos, |
| 147 | DDS::DataWriterListener_ptr a_listener, |
| 148 | const DDS::StatusMask& mask, |
| 149 | WeakRcHandle<DomainParticipantImpl> participant_servant, |
| 150 | PublisherImpl* publisher_servant) |
| 151 | { |
| 152 | DBG_ENTRY_LVL("DataWriterImpl", "init", 6); |
| 153 | topic_servant_ = topic_servant; |
| 154 | type_support_ = dynamic_cast<TypeSupportImpl*>(topic_servant->get_type_support()); |
| 155 | topic_name_ = topic_servant_->get_name(); |
| 156 | topic_id_ = topic_servant_->get_id(); |
| 157 | type_name_ = topic_servant_->get_type_name(); |
| 158 | |
| 159 | #if !defined (DDS_HAS_MINIMUM_BIT) |
| 160 | is_bit_ = topicIsBIT(topic_name_.in(), type_name_.in()); |
| 161 | #endif // !defined (DDS_HAS_MINIMUM_BIT) |
| 162 | |
| 163 | qos_ = qos; |
| 164 | passed_qos_ = qos; |
| 165 | |
| 166 | set_listener(a_listener, mask); |
| 167 | |
| 168 | // Only store the participant pointer, since it is our "grand" |
| 169 | // parent, we will exist as long as it does. |
| 170 | participant_servant_ = participant_servant; |
| 171 | |
| 172 | RcHandle<DomainParticipantImpl> participant = participant_servant.lock(); |
| 173 | domain_id_ = participant->get_domain_id(); |
| 174 | |
| 175 | // Only store the publisher pointer, since it is our parent, we will |
| 176 | // exist as long as it does. |
| 177 | publisher_servant_ = *publisher_servant; |
| 178 | } |
| 179 | |
| 180 | DDS::InstanceHandle_t |
| 181 | DataWriterImpl::get_instance_handle() |
nothing calls this directly
no test coverage detected