diff --git a/server.go b/server.go index ce6babe25..8ee1ba5bc 100644 --- a/server.go +++ b/server.go @@ -722,9 +722,8 @@ func (s *Server) Open() error { if now := time.Now(); now.Sub(prevMsg) > time.Second { progressRatio := float64(i+1) / float64(len(toSend)) - numSentMessages := len(toSend) - (i + 1) - messagesLeft := len(toSend) - numSentMessages - avgTimePerMessage := float64(now.Sub(start)) / float64(numSentMessages) + messagesLeft := len(toSend) - i + avgTimePerMessage := float64(now.Sub(start)) / float64(i) timeRemaining := time.Duration(avgTimePerMessage * float64(messagesLeft)) s.logger.Printf("synced %d/%d messages (%.2f%% complete; %s remaining)", i+1, len(toSend), 100*progressRatio, timeRemaining) prevMsg = now