diff options
| author | Neil Alexander <neilalexander@users.noreply.github.com> | 2021-01-08 16:59:06 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-01-08 16:59:06 +0000 |
| commit | b5a8935042dfb358f4176bc1ca46d0b8ebd62615 (patch) | |
| tree | b3b0409cc184f6392eb0230f2127d10d0752b4af /eduserver | |
| parent | 56a7839aedfdf849193bf25c0e2fcd8f4a0146d8 (diff) | |
Sync refactor — Part 1 (#1688)
* It's half-alive
* Wakeups largely working
* Other tweaks, typing works
* Fix bugs, add receipt stream
* Delete notifier, other tweaks
* Dedupe a bit, add a template for the invite stream
* Clean up, add templates for other streams
* Don't leak channels
* Bring forward some more PDU logic, clean up other places
* Add some more wakeups
* Use addRoomDeltaToResponse
* Log tweaks, typing fixed?
* Fix timed out syncs
* Don't reset next batch position on timeout
* Add account data stream/position
* End of day
* Fix complete sync for receipt, typing
* Streams package
* Clean up a bit
* Complete sync send-to-device
* Don't drop errors
* More lightweight notifications
* Fix typing positions
* Don't advance position on remove again unless needed
* Device list updates
* Advance account data position
* Use limit for incremental sync
* Limit fixes, amongst other things
* Remove some fmt.Println
* Tweaks
* Re-add notifier
* Fix invite position
* Fixes
* Notify account data without advancing PDU position in notifier
* Apply account data position
* Get initial position for account data
* Fix position update
* Fix complete sync positions
* Review comments @Kegsay
* Room consumer parameters
Diffstat (limited to 'eduserver')
| -rw-r--r-- | eduserver/cache/cache.go | 13 |
1 files changed, 0 insertions, 13 deletions
diff --git a/eduserver/cache/cache.go b/eduserver/cache/cache.go index dd535a6d..f637d7c9 100644 --- a/eduserver/cache/cache.go +++ b/eduserver/cache/cache.go @@ -113,19 +113,6 @@ func (t *EDUCache) AddTypingUser( return t.GetLatestSyncPosition() } -// AddSendToDeviceMessage increases the sync position for -// send-to-device updates. -// Returns the sync position before update, as the caller -// will use this to record the current stream position -// at the time that the send-to-device message was sent. -func (t *EDUCache) AddSendToDeviceMessage() int64 { - t.Lock() - defer t.Unlock() - latestSyncPosition := t.latestSyncPosition - t.latestSyncPosition++ - return latestSyncPosition -} - // addUser with mutex lock & replace the previous timer. // Returns the latest typing sync position after update. func (t *EDUCache) addUser( |