n/nyxmuks
1
0
Fork 0
forked from Mirrors/gomuks
Code Pull requests Activity

Add debug logs to sync progress bar

Browse source
This commit is contained in:
FIGBERT 2023-07-23 14:45:58 +03:00
parent 477326228e
commit 8889e2df54
No known key found for this signature in database
GPG key ID: 67F1598D607A844B
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
matrix/sync.go
View file

@ -60,12 +60,15 @@ func (s *GomuksSyncer) ProcessResponse(res *mautrix.RespSync, since string) (err
debug.Print("Received sync response") debug.Print("Received sync response")
s.Progress.SetMessage("Processing sync response") s.Progress.SetMessage("Processing sync response")
steps := len(res.Rooms.Join) + len(res.Rooms.Invite) + len(res.Rooms.Leave) steps := len(res.Rooms.Join) + len(res.Rooms.Invite) + len(res.Rooms.Leave)
s.Progress.SetSteps(steps + 2 + len(s.globalListeners)) visualSteps := steps + 2 + len(s.globalListeners)
debug.Printf("[SYNC] Creating a progress bar with %s steps (%s rooms, %s global listeners)", visualSteps, steps, len(s.globalListeners))
s.Progress.SetSteps(visualSteps)
wait := &sync.WaitGroup{} wait := &sync.WaitGroup{}
callback := func() { callback := func() {
wait.Done() wait.Done()
s.Progress.Step() s.Progress.Step()
debug.Print("[SYNC] Stepping progress bar")
} }
wait.Add(len(s.globalListeners)) wait.Add(len(s.globalListeners))
s.notifyGlobalListeners(res, since, callback) s.notifyGlobalListeners(res, since, callback)