62 std::unordered_map<SubprotocolPacketType, std::unordered_map<dev::p2p::NodeID, std::set<PacketData::PacketId>>>
Definition packet_data.hpp:12
Definition packets_blocking_mask.hpp:16
dev::RLP dagBlockFromDagPacket(const PacketData &packet_data) const
Definition packets_blocking_mask.cpp:82
bool isDagBlockPacketBlockedByLevel(const PacketData &packet_data) const
Definition packets_blocking_mask.cpp:164
std::shared_ptr< PbftManager > pbft_mgr_
Definition packets_blocking_mask.hpp:82
void markPacketAsPeerOrderUnblocked(const PacketData &blocking_packet, SubprotocolPacketType packet_type_to_unblock)
Definition packets_blocking_mask.cpp:49
void setDagBlockBeingProcessed(const PacketData &packet)
Definition packets_blocking_mask.cpp:93
void markPacketAsHardUnblocked(const PacketData &blocking_packet, SubprotocolPacketType packet_type_to_unblock)
Definition packets_blocking_mask.cpp:20
static constexpr size_t kRequiredDagPacketSizeV3
Definition packets_blocking_mask.hpp:84
std::unordered_map< SubprotocolPacketType, std::unordered_map< dev::p2p::NodeID, std::set< PacketData::PacketId > > > peer_order_blocked_packet_types_
Definition packets_blocking_mask.hpp:63
std::map< taraxa::sig_t, PacketData::PacketId > processing_dag_blocks_
Definition packets_blocking_mask.hpp:80
void unsetDagBlockBeingProcessed(const PacketData &packet)
Definition packets_blocking_mask.cpp:104
PacketsBlockingMask(const PacketsBlockingMask &)=default
PacketsBlockingMask(PacketsBlockingMask &&)=default
std::unordered_map< SubprotocolPacketType, std::unordered_set< PacketData::PacketId > > hard_blocked_packet_types_
Definition packets_blocking_mask.hpp:55
std::map< taraxa::level_t, std::unordered_set< PacketData::PacketId > > processing_dag_levels_
Definition packets_blocking_mask.hpp:75
static constexpr size_t kRequiredDagPacketSizeV2
Definition packets_blocking_mask.hpp:86
bool isPacketBlocked(const PacketData &packet_data) const
Definition packets_blocking_mask.cpp:205
bool isPacketHardBlocked(const PacketData &packet_data) const
Definition packets_blocking_mask.cpp:154
void unsetDagBlockLevelBeingProcessed(const PacketData &packet)
Definition packets_blocking_mask.cpp:132
PacketsBlockingMask & operator=(const PacketsBlockingMask &)=default
static constexpr size_t kDagBlockPosV3
Definition packets_blocking_mask.hpp:85
void setDagBlockLevelBeingProcessed(const PacketData &packet)
Definition packets_blocking_mask.cpp:114
std::optional< taraxa::level_t > getSmallestDagLevelBeingProcessed() const
Definition packets_blocking_mask.cpp:74
bool isPacketPeerOrderBlocked(const PacketData &packet_data) const
Definition packets_blocking_mask.cpp:179
PacketsBlockingMask & operator=(PacketsBlockingMask &&)=default
void markPacketAsHardBlocked(const PacketData &blocking_packet, SubprotocolPacketType packet_type_to_block)
Definition packets_blocking_mask.cpp:10
void markPacketAsPeerOrderBlocked(const PacketData &blocking_packet, SubprotocolPacketType packet_type_to_block)
Definition packets_blocking_mask.cpp:38
bool isDagBlockPacketBlockedBySameDagBlock(const PacketData &packet_data) const
Definition packets_blocking_mask.cpp:159
~PacketsBlockingMask()=default
Definition node_stats.hpp:18
SubprotocolPacketType
SubprotocolPacketType is used in networking layer to differentiate packet types.
Definition packet_types.hpp:12