trigger feed recovey. MaxGapsize or max number of gap
RDFD::Asio::UDPSessionController
Or
FeedRecoveryHandler
- start_feed_recovery- cancel_feed_recovery- feed_recovery_complete- is_in_feed_recovery
EmbargoRecoveryManagerHandler
- gap_occurred()
Arbiter
- SeqTest()
+ output_sink_+ embargo_sink_+ lifted_embargo_sink_+ embargo_gap_cache_
RDFD::Asio::TcpSessionController
- OnMessageReceived()- OnReadFailure()- ......
UDPInputLine
RecoveryManagerHandler
- gap_occurred()- gapFilled()
InputLine
- open()- start()- stop()
RDFD::Asio::TcpSession
- Open()- Close()- Connected()
+ TcpSessionController*
TCPInputLine
- OnMessageReceived()- OnMessageTransmitted()- OnReadFailure()- do_open()- do_start()- do_stop
SegmentDecoder
- decode()- startFeedRecovery() - start embargo message
+ arbiter_+ feed_recovery_embargo_container_;+ output_message_sink_
GapRecoveryHandler
- gap_occurred()- gap_filled()- gap_partially_filled()- do_stop()
GapCache
- insert()- fill_gap()
GapRecovery
- attributeA- attributeB
RDFD::Asio::UDPSession
TCPHandler
- messageReceived()
+ std::deque bufferedWriteMessages_
