mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-02-25 05:53:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Remove redundant comments for now

Browse source
This commit is contained in:
Kegan Dougal 2017-04-07 16:56:50 +01:00
parent cf20835436
commit 465ddc2204
1 changed files with 0 additions and 26 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
src/github.com/matrix-org/dendrite/clientapi/sync/requestpool.go
View file

@ -134,32 +134,6 @@ func (rp *RequestPool) waitForEvents(req syncRequest) syncStreamPosition {
func (rp *RequestPool) currentSyncForUser(req syncRequest) ([]gomatrixserverlib.Event, error) { func (rp *RequestPool) currentSyncForUser(req syncRequest) ([]gomatrixserverlib.Event, error) {
currentPos := rp.waitForEvents(req) currentPos := rp.waitForEvents(req)
return rp.db.EventsInRange(int64(req.since), int64(currentPos)) return rp.db.EventsInRange(int64(req.since), int64(currentPos))
// https://github.com/matrix-org/synapse/blob/v0.19.3/synapse/handlers/sync.py#L179
// Check if we are going to return immediately and if so, calculate the current
// sync for this user and return.
// if req.since == 0 || req.timeout == time.Duration(0) || req.wantFullState {
// return []gomatrixserverlib.Event{}, nil
// }
// Steps: (no token)
// - get all rooms the user is joined to.
// - f.e room, get room state.
// - f.e room, get latest N messages.
// - rollback state by N messages.
// Steps: (up-to-date token)
// - Wait for new event.
// - Check if event should notify user.
// - Notify user or continue waiting, eventually timing out.
// Steps: (partial token, less than threshold)
// - Get rooms the user is joined to.
// - Get all events between token and now for those rooms.
// - Work out state and message delta and return.
// Steps: (partial token, more than threshold (too expensive to do the above))
// - Ignore for now, meaning this code path will be horrendously slow.
} }
func getTimeout(timeoutMS string) time.Duration { func getTimeout(timeoutMS string) time.Duration {