MCPcopy Create free account
hub / github.com/OpenDDS/OpenDDS / ReplayerImpl

Method ReplayerImpl

dds/DCPS/ReplayerImpl.cpp:51–90  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

49
50
51ReplayerImpl::ReplayerImpl()
52 : data_dropped_count_(0),
53 data_delivered_count_(0),
54 n_chunks_(TheServiceParticipant->n_chunks()),
55 association_chunk_multiplier_(TheServiceParticipant->association_chunk_multiplier()),
56 qos_(TheServiceParticipant->initial_DataWriterQos()),
57 participant_servant_(0),
58 topic_id_(GUID_UNKNOWN),
59 topic_servant_(0),
60 listener_mask_(DEFAULT_STATUS_MASK),
61 domain_id_(0),
62 publisher_servant_(0),
63 publication_id_(GUID_UNKNOWN),
64 sequence_number_(SequenceNumber::SEQUENCENUMBER_UNKNOWN()),
65 // data_container_(0),
66 // liveliness_lost_(false),
67 // last_deadline_missed_total_count_(0),
68 is_bit_(false),
69 empty_condition_(lock_),
70 pending_write_count_(0)
71{
72 // liveliness_lost_status_.total_count = 0;
73 // liveliness_lost_status_.total_count_change = 0;
74 //
75 // offered_deadline_missed_status_.total_count = 0;
76 // offered_deadline_missed_status_.total_count_change = 0;
77 // offered_deadline_missed_status_.last_instance_handle = DDS::HANDLE_NIL;
78
79 offered_incompatible_qos_status_.total_count = 0;
80 offered_incompatible_qos_status_.total_count_change = 0;
81 offered_incompatible_qos_status_.last_policy_id = 0;
82 offered_incompatible_qos_status_.policies.length(0);
83
84 publication_match_status_.total_count = 0;
85 publication_match_status_.total_count_change = 0;
86 publication_match_status_.current_count = 0;
87 publication_match_status_.current_count_change = 0;
88 publication_match_status_.last_subscription_handle = DDS::HANDLE_NIL;
89
90}
91
92// This method is called when there are no longer any reference to the
93// the servant.

Callers

nothing calls this directly

Calls 4

SEQUENCENUMBER_UNKNOWNFunction · 0.85
n_chunksMethod · 0.45
lengthMethod · 0.45

Tested by

no test coverage detected