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

Method control_received

dds/DCPS/transport/multicast/ReliableSession.cpp:196–222  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

194
195
196bool
197ReliableSession::control_received(char submessage_id,
198 const Message_Block_Ptr& control)
199{
200 if (MulticastSession::control_received(submessage_id, control)) {
201 return true; // base class handled message
202 }
203
204 switch (submessage_id) {
205 case MULTICAST_NAK:
206 nak_received(control);
207 break;
208
209 case MULTICAST_NAKACK:
210 nakack_received(control);
211 break;
212
213 default:
214 ACE_ERROR((LM_WARNING,
215 ACE_TEXT("(%P|%t) WARNING: ")
216 ACE_TEXT("ReliableSession::control_received: ")
217 ACE_TEXT("unknown TRANSPORT_CONTROL submessage: 0x%x!\n"),
218 submessage_id));
219 break;
220 }
221 return true;
222}
223
224void
225ReliableSession::syn_hook(const SequenceNumber& seq)

Callers 1

sample_receivedMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected