This commit is contained in:
Ford 2023-12-06 20:00:14 +00:00
parent 55b483d82a
commit 9374c1afc2
3 changed files with 4 additions and 4 deletions

View file

@ -41,7 +41,7 @@ var (
// Request is a pending request to allow tracking it and delivering a response // Request is a pending request to allow tracking it and delivering a response
// back to the requester on their chosen channel. // back to the requester on their chosen channel.
type Request struct { type Request struct {
peer *Peer // Peer to which this request belogs for untracking peer *Peer // Peer to which this request belongs for untracking
id uint64 // Request ID to match up replies to id uint64 // Request ID to match up replies to
sink chan *Response // Channel to deliver the response on sink chan *Response // Channel to deliver the response on
@ -224,7 +224,7 @@ func (p *Peer) dispatcher() {
switch { switch {
case res.Req == nil: case res.Req == nil:
// Response arrived with an untracked ID. Since even cancelled // Response arrived with an untracked ID. Since even cancelled
// requests are tracked until fulfilment, a dangling response // requests are tracked until fulfillment, a dangling response
// means the remote peer implements the protocol badly. // means the remote peer implements the protocol badly.
resOp.fail <- errDanglingResponse resOp.fail <- errDanglingResponse

View file

@ -84,7 +84,7 @@ type Peer struct {
txBroadcast chan []common.Hash // Channel used to queue transaction propagation requests txBroadcast chan []common.Hash // Channel used to queue transaction propagation requests
txAnnounce chan []common.Hash // Channel used to queue transaction announcement requests txAnnounce chan []common.Hash // Channel used to queue transaction announcement requests
reqDispatch chan *request // Dispatch channel to send requests and track then until fulfilment reqDispatch chan *request // Dispatch channel to send requests and track then until fulfillment
reqCancel chan *cancel // Dispatch channel to cancel pending requests and untrack them reqCancel chan *cancel // Dispatch channel to cancel pending requests and untrack them
resDispatch chan *response // Dispatch channel to fulfil pending requests and untrack them resDispatch chan *response // Dispatch channel to fulfil pending requests and untrack them

View file

@ -95,7 +95,7 @@ func LevelString(l slog.Level) string {
case slog.LevelWarn: case slog.LevelWarn:
return "warn" return "warn"
case slog.LevelError: case slog.LevelError:
return "eror" return "error"
case LevelCrit: case LevelCrit:
return "crit" return "crit"
default: default: