forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

beacon/light/request: bug fixed, more logs

Browse source
This commit is contained in:
Zsolt Felfoldi 2023-12-24 15:03:24 +01:00 committed by Felix Lange
parent 4587d6b372
commit 86d3c3bd81
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
beacon/light/request/server.go
View file

@ -238,6 +238,7 @@ func (s *serverWithLimits) eventCallback(event Event) {
if s.parallelLimit < minParallelLimit { if s.parallelLimit < minParallelLimit {
s.parallelLimit = minParallelLimit s.parallelLimit = minParallelLimit
} }
log.Debug("Server timeout", "count", s.timeoutCount, "parallelLimit", s.parallelLimit)
case EvResponse, EvFail: case EvResponse, EvFail:
var id ID var id ID
if event.Type == EvResponse { if event.Type == EvResponse {
@ -248,9 +249,10 @@ func (s *serverWithLimits) eventCallback(event Event) {
if _, ok := s.softTimeouts[id]; ok { if _, ok := s.softTimeouts[id]; ok {
delete(s.softTimeouts, id) delete(s.softTimeouts, id)
s.timeoutCount-- s.timeoutCount--
log.Debug("Server timeout finalized", "count", s.timeoutCount, "parallelLimit", s.parallelLimit)
} }
if event.Type == EvResponse && s.pendingCount >= int(s.parallelLimit) { if event.Type == EvResponse && s.pendingCount >= int(s.parallelLimit) {
s.parallelLimit -= parallelAdjustUp s.parallelLimit += parallelAdjustUp
} }
s.pendingCount-- s.pendingCount--
if canRequest, _ := s.canRequestNow(); canRequest { if canRequest, _ := s.canRequestNow(); canRequest {
@ -328,7 +330,9 @@ func (s *serverWithLimits) delay(delay time.Duration) {
s.delayCounter++ s.delayCounter++
delayCounter := s.delayCounter delayCounter := s.delayCounter
log.Debug("Server delay started", "length", delay)
s.delayTimer = s.clock.AfterFunc(delay, func() { s.delayTimer = s.clock.AfterFunc(delay, func() {
log.Debug("Server delay ended", "length", delay)
/*if s.scheduler.testTimerResults != nil { /*if s.scheduler.testTimerResults != nil {
s.scheduler.testTimerResults = append(s.scheduler.testTimerResults, true) // simulated timer finished s.scheduler.testTimerResults = append(s.scheduler.testTimerResults, true) // simulated timer finished
}*/ }*/