22 #include <OnixS/HandlerCore/FeedEngine/PacketContainer.h> 23 #include <OnixS/ItchCore/MoldUDP64/PacketHeader.h> 24 #include <OnixS/ItchCore/MoldUDP64/PacketProcessor.h> 29 #include <util/String.h> 34 ONIXS_HANDLER_NAMESPACE_BEGIN
36 RetransmissionPacketProcessor::RetransmissionPacketProcessor(HandlerLogger* logger,
const Logging::LogFacility* parent,
MessageRepository* messageRepository) :
37 Logging::LogFacility(
"Glimpse", parent,
OnixS::Logging::LOG_LEVEL_DEBUG),
39 messageRepository_(messageRepository)
41 BOOST_ASSERT(logger_ !=
nullptr);
54 const OnixS::ItchCore::MoldUDP64::PacketHeader* unitHeader =
55 &OnixS::ItchCore::MoldUDP64::PacketHelper::header(packetContainer);
64 messageRepository_->
onPacket(dataSource, packetContainer);
67 ONIXS_HANDLER_NAMESPACE_END
Origin origin
the way data received
UInt16 packetMessageCount
Message sequence number.
void onPacket(OnixS::HandlerCore::MarketData::FE::PacketContainer &) override
const Byte * session
Session Id.
void onPacket(DataSource &dataSource, OnixS::HandlerCore::MarketData::FE::PacketContainer &packetContainer, bool runProcessCachedMessages=true)
UInt8 Byte
Alias for Byte.
UInt64 messageSeqNum
Message sequence number.
Timestamp packetReceptionTime
Time when the packet was received by Handler from UDP, in system ticks,.
virtual ~RetransmissionPacketProcessor()