Skip to content

Commit aa9d0d7

Browse files
committed
ETCM-760: Fix comments
1 parent 4a443aa commit aa9d0d7

File tree

4 files changed

+20
-22
lines changed

4 files changed

+20
-22
lines changed

src/main/scala/io/iohk/ethereum/blockchain/sync/Blacklist.scala

Lines changed: 17 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -43,8 +43,8 @@ object Blacklist {
4343
val group = "RegularSyncBlacklistGroup"
4444
}
4545
//this group is directly translated from WireProtocol
46-
trait Peer2PeerBlacklistGroup {
47-
val group = "Peer2PeerBlacklistGroup"
46+
trait P2PBlacklistGroup {
47+
val group = "P2PBlacklistGroup"
4848
}
4949
}
5050

@@ -103,51 +103,51 @@ object Blacklist {
103103
val code: Int = 12
104104
val name: String = "PivotBlockElectionTimeout"
105105
}
106-
case object DisconnectRequestedType extends BlacklistReasonType with Peer2PeerBlacklistGroup {
106+
case object DisconnectRequestedType extends BlacklistReasonType with P2PBlacklistGroup {
107107
val code: Int = 13
108108
val name: String = "DisconnectRequested"
109109
}
110-
case object TcpSubsystemErrorType extends BlacklistReasonType with Peer2PeerBlacklistGroup {
110+
case object TcpSubsystemErrorType extends BlacklistReasonType with P2PBlacklistGroup {
111111
val code: Int = 14
112112
val name: String = "TcpSubsystemError"
113113
}
114-
case object UselessPeerType extends BlacklistReasonType with Peer2PeerBlacklistGroup {
114+
case object UselessPeerType extends BlacklistReasonType with P2PBlacklistGroup {
115115
val code: Int = 15
116116
val name: String = "UselessPeer"
117117
}
118-
case object TooManyPeersType extends BlacklistReasonType with Peer2PeerBlacklistGroup {
118+
case object TooManyPeersType extends BlacklistReasonType with P2PBlacklistGroup {
119119
val code: Int = 16
120120
val name: String = "TooManyPeers"
121121
}
122-
case object AlreadyConnectedType extends BlacklistReasonType with Peer2PeerBlacklistGroup {
122+
case object AlreadyConnectedType extends BlacklistReasonType with P2PBlacklistGroup {
123123
val code: Int = 17
124124
val name: String = "AlreadyConnected"
125125
}
126-
case object IncompatibleP2pProtocolVersionType extends BlacklistReasonType with Peer2PeerBlacklistGroup {
126+
case object IncompatibleP2pProtocolVersionType extends BlacklistReasonType with P2PBlacklistGroup {
127127
val code: Int = 18
128128
val name: String = "IncompatibleP2pProtocolVersion"
129129
}
130-
case object NullNodeIdentityReceivedType extends BlacklistReasonType with Peer2PeerBlacklistGroup {
130+
case object NullNodeIdentityReceivedType extends BlacklistReasonType with P2PBlacklistGroup {
131131
val code: Int = 19
132132
val name: String = "NullNodeIdentityReceived"
133133
}
134-
case object ClientQuittingType extends BlacklistReasonType with Peer2PeerBlacklistGroup {
134+
case object ClientQuittingType extends BlacklistReasonType with P2PBlacklistGroup {
135135
val code: Int = 20
136136
val name: String = "ClientQuitting"
137137
}
138-
case object UnexpectedIdentityType extends BlacklistReasonType with Peer2PeerBlacklistGroup {
138+
case object UnexpectedIdentityType extends BlacklistReasonType with P2PBlacklistGroup {
139139
val code: Int = 21
140140
val name: String = "UnexpectedIdentity"
141141
}
142-
case object IdentityTheSameType extends BlacklistReasonType with Peer2PeerBlacklistGroup {
142+
case object IdentityTheSameType extends BlacklistReasonType with P2PBlacklistGroup {
143143
val code: Int = 22
144144
val name: String = "IdentityTheSame"
145145
}
146-
case object TimeoutOnReceivingAMessageType extends BlacklistReasonType with Peer2PeerBlacklistGroup {
146+
case object TimeoutOnReceivingAMessageType extends BlacklistReasonType with P2PBlacklistGroup {
147147
val code: Int = 23
148148
val name: String = "TimeoutOnReceivingAMessage"
149149
}
150-
case object OtherSubprotocolSpecificReasonType extends BlacklistReasonType with Peer2PeerBlacklistGroup {
150+
case object OtherSubprotocolSpecificReasonType extends BlacklistReasonType with P2PBlacklistGroup {
151151
val code: Int = 24
152152
val name: String = "OtherSubprotocolSpecificReason"
153153
}
@@ -290,7 +290,7 @@ object Blacklist {
290290
val description: String = s"Block import error: $error"
291291
}
292292

293-
private val allPeer2PeerReasons = List(
293+
private val allP2PReasons = List(
294294
DisconnectRequested,
295295
TcpSubsystemError,
296296
UselessPeer,
@@ -305,8 +305,8 @@ object Blacklist {
305305
OtherSubprotocolSpecificReason
306306
)
307307

308-
def getPeer2PeerBlacklistReasonByDescription(description: String): BlacklistReason = {
309-
allPeer2PeerReasons.find(_.description == description).getOrElse(OtherSubprotocolSpecificReason)
308+
def getP2PBlacklistReasonByDescription(description: String): BlacklistReason = {
309+
allP2PReasons.find(_.description == description).getOrElse(OtherSubprotocolSpecificReason)
310310
}
311311
}
312312
}

src/main/scala/io/iohk/ethereum/blockchain/sync/regular/BlockFetcherState.scala

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -125,9 +125,7 @@ case class BlockFetcherState(
125125
*/
126126
def validateBodies(receivedBodies: Seq[BlockBody]): Either[BlacklistReason, Seq[Block]] =
127127
bodiesAreOrderedSubsetOfRequested(waitingHeaders.toList, receivedBodies)
128-
.toRight(
129-
BlacklistReason.UnrequestedBodies
130-
)
128+
.toRight(BlacklistReason.UnrequestedBodies)
131129

132130
// Checks that the received block bodies are an ordered subset of the ones requested
133131
@tailrec

src/main/scala/io/iohk/ethereum/blockchain/sync/regular/StateNodeFetcher.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ class StateNodeFetcher(
5353

5454
validatedNode match {
5555
case Left(err) =>
56-
log.debug(err.description)
56+
log.debug("State node validation failed with {}", err.description)
5757
peersClient ! BlacklistPeer(peer.id, err)
5858
context.self ! StateNodeFetcher.FetchStateNode(stateNodeRequester.hash, stateNodeRequester.replyTo)
5959
Behaviors.same[StateNodeFetcherCommand]

src/main/scala/io/iohk/ethereum/network/PeerManagerActor.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -187,7 +187,7 @@ class PeerManagerActor(
187187
blacklist.add(
188188
PeerAddress(peerAddress),
189189
getBlacklistDuration(reason),
190-
Blacklist.BlacklistReason.getPeer2PeerBlacklistReasonByDescription(Disconnect.reasonToString(reason))
190+
Blacklist.BlacklistReason.getP2PBlacklistReasonByDescription(Disconnect.reasonToString(reason))
191191
)
192192

193193
case HandlePeerConnection(connection, remoteAddress) =>

0 commit comments

Comments
 (0)