| 228 | } |
| 229 | |
| 230 | void BitSubscriber::remove_thread_status(const InternalThreadBuiltinTopicData& ts) |
| 231 | { |
| 232 | #ifndef DDS_HAS_MINIMUM_BIT |
| 233 | ACE_GUARD(ACE_Thread_Mutex, g, mutex_); |
| 234 | |
| 235 | if (!bit_subscriber_) { |
| 236 | return; |
| 237 | } |
| 238 | |
| 239 | DDS::DataReader_var d = bit_subscriber_->lookup_datareader(BUILT_IN_INTERNAL_THREAD_TOPIC); |
| 240 | |
| 241 | if (!d) { |
| 242 | return; |
| 243 | } |
| 244 | |
| 245 | InternalThreadBuiltinTopicDataDataReaderImpl* bit = dynamic_cast<InternalThreadBuiltinTopicDataDataReaderImpl*>(d.in()); |
| 246 | if (!bit) { |
| 247 | return; |
| 248 | } |
| 249 | |
| 250 | bit->set_instance_state(bit->lookup_instance(ts), DDS::NOT_ALIVE_DISPOSED_INSTANCE_STATE); |
| 251 | #else |
| 252 | ACE_UNUSED_ARG(ts); |
| 253 | #endif |
| 254 | } |
| 255 | |
| 256 | void BitSubscriber::bit_pub_listener_hack(DomainParticipantImpl* participant) |
| 257 | { |
no test coverage detected