Patch for concurrent iterator & others (onto v1.11.6) #386

Closed
roysc wants to merge 1565 commits from v1.11.6-statediff-v5 into master
Showing only changes of commit 5869789d75 - Show all commits

View File

@ -353,7 +353,7 @@ func (s *Service) loop(chainHeadCh chan core.ChainHeadEvent, txEventCh chan core
// it, if they themselves are requests it initiates a reply, and lastly it drops // it, if they themselves are requests it initiates a reply, and lastly it drops
// unknown packets. // unknown packets.
func (s *Service) readLoop(conn *connWrapper) { func (s *Service) readLoop(conn *connWrapper) {
// If the read loop exists, close the connection // If the read loop exits, close the connection
defer conn.Close() defer conn.Close()
for { for {