| 198 | } |
| 199 | |
| 200 | DDS::InstanceHandle_t BitSubscriber::add_thread_status(const InternalThreadBuiltinTopicData& ts, |
| 201 | DDS::ViewStateKind view_state, |
| 202 | const SystemTimePoint& timestamp) |
| 203 | { |
| 204 | #ifndef DDS_HAS_MINIMUM_BIT |
| 205 | ACE_GUARD_RETURN(ACE_Thread_Mutex, g, mutex_, DDS::HANDLE_NIL); |
| 206 | |
| 207 | if (!bit_subscriber_) { |
| 208 | return DDS::HANDLE_NIL; |
| 209 | } |
| 210 | |
| 211 | DDS::DataReader_var d = bit_subscriber_->lookup_datareader(BUILT_IN_INTERNAL_THREAD_TOPIC); |
| 212 | if (!d) { |
| 213 | return DDS::HANDLE_NIL; |
| 214 | } |
| 215 | |
| 216 | InternalThreadBuiltinTopicDataDataReaderImpl* bit = dynamic_cast<InternalThreadBuiltinTopicDataDataReaderImpl*>(d.in()); |
| 217 | if (!bit) { |
| 218 | return DDS::HANDLE_NIL; |
| 219 | } |
| 220 | |
| 221 | return bit->store_synthetic_data(ts, view_state, timestamp); |
| 222 | #else |
| 223 | ACE_UNUSED_ARG(ts); |
| 224 | ACE_UNUSED_ARG(view_state); |
| 225 | ACE_UNUSED_ARG(timestamp); |
| 226 | return DDS::HANDLE_NIL; |
| 227 | #endif /* DDS_HAS_MINIMUM_BIT */ |
| 228 | } |
| 229 | |
| 230 | void BitSubscriber::remove_thread_status(const InternalThreadBuiltinTopicData& ts) |
| 231 | { |
no test coverage detected