| 61 | namespace DCPS { |
| 62 | |
| 63 | DataReaderImpl::DataReaderImpl() |
| 64 | : qos_(TheServiceParticipant->initial_DataReaderQos()) |
| 65 | , reverse_sample_lock_(sample_lock_) |
| 66 | , topic_servant_(0) |
| 67 | , type_support_(0) |
| 68 | , topic_id_(GUID_UNKNOWN) |
| 69 | #ifndef OPENDDS_NO_OWNERSHIP_KIND_EXCLUSIVE |
| 70 | , is_exclusive_ownership_(false) |
| 71 | #endif |
| 72 | , coherent_(false) |
| 73 | , subqos_(TheServiceParticipant->initial_SubscriberQos()) |
| 74 | , topic_desc_(0) |
| 75 | , listener_mask_(DEFAULT_STATUS_MASK) |
| 76 | , domain_id_(0) |
| 77 | , n_chunks_(TheServiceParticipant->n_chunks()) |
| 78 | , reactor_(0) |
| 79 | , last_deadline_missed_total_count_(0) |
| 80 | , deadline_queue_enabled_(false) |
| 81 | , deadline_task_(make_rch<SporadicEvent>(TheServiceParticipant->event_dispatcher(), make_rch<DRIEvent>(rchandle_from(this), &DataReaderImpl::deadline_task))) |
| 82 | , is_bit_(false) |
| 83 | , always_get_history_(false) |
| 84 | , statistics_enabled_(false) |
| 85 | , raw_latency_buffer_size_(0) |
| 86 | , raw_latency_buffer_type_(DataCollector<double>::KeepOldest) |
| 87 | , transport_disabled_(false) |
| 88 | , mb_alloc_(DEFAULT_TRANSPORT_RECEIVE_BUFFERS) |
| 89 | { |
| 90 | reactor_ = TheServiceParticipant->timer(); |
| 91 | |
| 92 | liveliness_changed_status_.alive_count = 0; |
| 93 | liveliness_changed_status_.not_alive_count = 0; |
| 94 | liveliness_changed_status_.alive_count_change = 0; |
| 95 | liveliness_changed_status_.not_alive_count_change = 0; |
| 96 | liveliness_changed_status_.last_publication_handle = |
| 97 | DDS::HANDLE_NIL; |
| 98 | |
| 99 | requested_deadline_missed_status_.total_count = 0; |
| 100 | requested_deadline_missed_status_.total_count_change = 0; |
| 101 | requested_deadline_missed_status_.last_instance_handle = |
| 102 | DDS::HANDLE_NIL; |
| 103 | |
| 104 | requested_incompatible_qos_status_.total_count = 0; |
| 105 | requested_incompatible_qos_status_.total_count_change = 0; |
| 106 | requested_incompatible_qos_status_.last_policy_id = 0; |
| 107 | requested_incompatible_qos_status_.policies.length(0); |
| 108 | |
| 109 | subscription_match_status_.total_count = 0; |
| 110 | subscription_match_status_.total_count_change = 0; |
| 111 | subscription_match_status_.current_count = 0; |
| 112 | subscription_match_status_.current_count_change = 0; |
| 113 | subscription_match_status_.last_publication_handle = |
| 114 | DDS::HANDLE_NIL; |
| 115 | |
| 116 | sample_lost_status_.total_count = 0; |
| 117 | sample_lost_status_.total_count_change = 0; |
| 118 | |
| 119 | sample_rejected_status_.total_count = 0; |
| 120 | sample_rejected_status_.total_count_change = 0; |
nothing calls this directly
no test coverage detected