Method saveStatusLoop

ethstorage/p2p/protocol/syncclient.go:440–454

saveStatusLoop marshals the remaining sync tasks into leveldb.

()

// saveStatusLoop marshals the remaining sync tasks into leveldb.
func (s *SyncClient) saveStatusLoop() {
	defer s.wg.Done()

	ticker := time.NewTicker(5 * time.Minute)
	defer ticker.Stop()
	for {
		select {
		case <-ticker.C:
			s.saveSyncStatus()
		case <-s.resCtx.Done():
			s.lg.Info("Stopped P2P sync client save status")
			return
		}
	}
}

// cleanTasks removes kv range retrieval tasks that have already been completed.
func (s *SyncClient) cleanTasks() {