diff --git a/pkg/progress/progress.go b/pkg/progress/progress.go index 6940ad1dd01..855aa793a83 100644 --- a/pkg/progress/progress.go +++ b/pkg/progress/progress.go @@ -36,13 +36,13 @@ const ( // Manager is used to maintain the progresses we care about. type Manager struct { syncutil.RWMutex - progesses map[string]*progressIndicator + progresses map[string]*progressIndicator } // NewManager creates a new Manager. func NewManager() *Manager { return &Manager{ - progesses: make(map[string]*progressIndicator), + progresses: make(map[string]*progressIndicator), } } @@ -81,7 +81,7 @@ func (m *Manager) Reset() { m.Lock() defer m.Unlock() - m.progesses = make(map[string]*progressIndicator) + m.progresses = make(map[string]*progressIndicator) } // Option is used to do some action for progressIndicator. @@ -106,15 +106,6 @@ func (m *Manager) AddProgress(progress string, current, total float64, updateInt history := list.New() history.PushBack(current) -<<<<<<< HEAD - if _, exist = m.progesses[progress]; !exist { - m.progesses[progress] = &progressIndicator{ - total: total, - remaining: total, - history: history, - windowLengthLimit: int(speedStatisticalWindow / updateInterval), - updateInterval: updateInterval, -======= if _, exist = m.progresses[progress]; !exist { pi := &progressIndicator{ total: total, @@ -123,7 +114,6 @@ func (m *Manager) AddProgress(progress string, current, total float64, updateInt windowCapacity: int(maxSpeedCalculationWindow/updateInterval) + 1, windowLength: int(minSpeedCalculationWindow / updateInterval), updateInterval: updateInterval, ->>>>>>> 945e29c03 (cluster: dynamic progress time window for offline scene (#7722)) } for _, op := range opts { op(pi) @@ -140,14 +130,10 @@ func (m *Manager) UpdateProgress(progress string, current, remaining float64, is m.Lock() defer m.Unlock() -<<<<<<< HEAD - if p, exist := m.progesses[progress]; exist { -======= if p, exist := m.progresses[progress]; exist { for _, op := range opts { op(p) } ->>>>>>> 945e29c03 (cluster: dynamic progress time window for offline scene (#7722)) p.remaining = remaining if p.total < remaining { p.total = remaining @@ -193,7 +179,7 @@ func (m *Manager) UpdateProgressTotal(progress string, total float64) { m.Lock() defer m.Unlock() - if p, exist := m.progesses[progress]; exist { + if p, exist := m.progresses[progress]; exist { p.total = total } } @@ -203,8 +189,8 @@ func (m *Manager) RemoveProgress(progress string) (exist bool) { m.Lock() defer m.Unlock() - if _, exist = m.progesses[progress]; exist { - delete(m.progesses, progress) + if _, exist = m.progresses[progress]; exist { + delete(m.progresses, progress) return } return @@ -216,7 +202,7 @@ func (m *Manager) GetProgresses(filter func(p string) bool) []string { defer m.RUnlock() processes := []string{} - for p := range m.progesses { + for p := range m.progresses { if filter(p) { processes = append(processes, p) } @@ -229,7 +215,7 @@ func (m *Manager) Status(progress string) (process, leftSeconds, currentSpeed fl m.RLock() defer m.RUnlock() - if p, exist := m.progesses[progress]; exist { + if p, exist := m.progresses[progress]; exist { process = 1 - p.remaining/p.total if process < 0 { process = 0 diff --git a/pkg/progress/progress_test.go b/pkg/progress/progress_test.go index 524d216d0ea..a7b159bc907 100644 --- a/pkg/progress/progress_test.go +++ b/pkg/progress/progress_test.go @@ -46,11 +46,7 @@ func TestProgress(t *testing.T) { for i := 0; i < 1000; i++ { m.UpdateProgress(n, 30, 30, false) } -<<<<<<< HEAD - re.Equal(61, m.progesses[n].history.Len()) -======= re.Equal(721, m.progresses[n].history.Len()) ->>>>>>> 945e29c03 (cluster: dynamic progress time window for offline scene (#7722)) p, ls, cs, err = m.Status(n) re.NoError(err) re.Equal(0.7, p)