| 172 | } |
| 173 | |
| 174 | void BitSubscriber::remove_connection_record(const ConnectionRecord& cr) |
| 175 | { |
| 176 | #ifndef DDS_HAS_MINIMUM_BIT |
| 177 | ACE_GUARD(ACE_Thread_Mutex, g, mutex_); |
| 178 | |
| 179 | if (!bit_subscriber_) { |
| 180 | return; |
| 181 | } |
| 182 | |
| 183 | DDS::DataReader_var d = bit_subscriber_->lookup_datareader(BUILT_IN_CONNECTION_RECORD_TOPIC); |
| 184 | |
| 185 | if (!d) { |
| 186 | return; |
| 187 | } |
| 188 | |
| 189 | ConnectionRecordDataReaderImpl* bit = dynamic_cast<ConnectionRecordDataReaderImpl*>(d.in()); |
| 190 | if (!bit) { |
| 191 | return; |
| 192 | } |
| 193 | |
| 194 | bit->set_instance_state(bit->lookup_instance(cr), DDS::NOT_ALIVE_DISPOSED_INSTANCE_STATE); |
| 195 | #else |
| 196 | ACE_UNUSED_ARG(cr); |
| 197 | #endif |
| 198 | } |
| 199 | |
| 200 | DDS::InstanceHandle_t BitSubscriber::add_thread_status(const InternalThreadBuiltinTopicData& ts, |
| 201 | DDS::ViewStateKind view_state, |
no test coverage detected