Skip to content

Commit

Permalink
Minor fixes (#3983)
Browse files Browse the repository at this point in the history
  • Loading branch information
phearnot authored Jan 17, 2025
1 parent 23808c2 commit e5839ee
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ import scala.util.control.NonFatal

abstract class LegacyFrameCodec(peerDatabase: PeerDatabase) extends ByteToMessageCodec[Any] with ScorexLogging {

protected def filterBySpecOrChecksum(spec: BasicMessagesRepo.Spec, checkSum: Array[Byte]): Boolean
protected def filterBySpecOrChecksum(spec: BasicMessagesRepo.Spec, checkSum: Array[Byte]): Boolean = true
protected def specsByCodes: Map[Byte, BasicMessagesRepo.Spec]
protected def messageToRawData(msg: Any): MessageRawData
protected def rawDataToMessage(rawData: MessageRawData): AnyRef
Expand Down Expand Up @@ -92,7 +92,7 @@ class LegacyFrameCodecL1(peerDatabase: PeerDatabase, receivedTxsCacheTimeout: Fi

protected def specsByCodes: Map[MessageCode, Spec] = BasicMessagesRepo.specsByCodes

protected def filterBySpecOrChecksum(spec: BasicMessagesRepo.Spec, checkSum: Array[Byte]): Boolean = {
protected override def filterBySpecOrChecksum(spec: BasicMessagesRepo.Spec, checkSum: Array[Byte]): Boolean = {
spec != TransactionSpec || {
val actualChecksumStr = Base64.encode(checkSum)
if (receivedTxsCache.getIfPresent(actualChecksumStr) == null) {
Expand Down

0 comments on commit e5839ee

Please sign in to comment.