good morning!!!!

Skip to content
Snippets Groups Projects
Commit 594ed499 authored by Hao Duan's avatar Hao Duan Committed by Igor Mandrigin
Browse files

ethstats: avoid blocking chan when received invalid stats request (#21073)


* ethstats: avoid blocking chan when received invalid stats request

* ethstats: minor code polishes

Co-authored-by: default avatarPéter Szilágyi <peterke@gmail.com>
parent ad1cbef8
No related branches found
No related tags found
No related merge requests found
...@@ -312,8 +312,11 @@ func (s *Service) readLoop(conn *websocket.Conn) { ...@@ -312,8 +312,11 @@ func (s *Service) readLoop(conn *websocket.Conn) {
request, ok := msg["emit"][1].(map[string]interface{}) request, ok := msg["emit"][1].(map[string]interface{})
if !ok { if !ok {
log.Warn("Invalid stats history request", "msg", msg["emit"][1]) log.Warn("Invalid stats history request", "msg", msg["emit"][1])
s.histCh <- nil select {
continue // Ethstats sometime sends invalid history requests, ignore those case s.histCh <- nil: // Treat it as an no indexes request
default:
}
continue
} }
list, ok := request["list"].([]interface{}) list, ok := request["list"].([]interface{})
if !ok { if !ok {
...@@ -341,7 +344,7 @@ func (s *Service) readLoop(conn *websocket.Conn) { ...@@ -341,7 +344,7 @@ func (s *Service) readLoop(conn *websocket.Conn) {
} }
} }
// nodeInfo is the collection of metainformation about a node that is displayed // nodeInfo is the collection of meta information about a node that is displayed
// on the monitoring page. // on the monitoring page.
type nodeInfo struct { type nodeInfo struct {
Name string `json:"name"` Name string `json:"name"`
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment