summary refs log tree commit diff
path: root/synapse/notifier.py (follow)
Commit message (Collapse)AuthorAgeFilesLines
* Open up /events to anonymous users for room events onlyDaniel Wagner-Hall2015-11-051-8/+34
| | | | Squash-merge of PR #345 from daniel/anonymousevents
* Merge branch 'develop' into daniel/removesomeliesMark Haines2015-11-041-1/+1
|\ | | | | | | | | Conflicts: synapse/notifier.py
| * Inform the client of new room tags using v1 /eventsMark Haines2015-10-291-1/+1
| |
* | Remove unused arguments and codeDaniel Wagner-Hall2015-11-021-3/+3
|/
* Don't make pushers handle presence/typing eventsErik Johnston2015-08-241-1/+6
|
* Improve namingDaniel Wagner-Hall2015-07-201-2/+2
|
* Consolidate duplicate code in notifierErik Johnston2015-07-021-24/+11
|
* Add receipts_key to StreamTokenErik Johnston2015-07-021-1/+1
|
* Fix typoErik Johnston2015-06-191-1/+1
|
* PEP8Erik Johnston2015-06-181-2/+3
|
* DocumentationErik Johnston2015-06-181-4/+11
|
* Don't bother proxying lookups on _NotificationListener to underlying deferredErik Johnston2015-06-181-10/+2
|
* Refactor the notifier.wait_for_events code to be clearer. Add ↵Erik Johnston2015-06-181-66/+56
| | | | _NotifierUserStream.new_listener that accpets a token to avoid races.
* Fix notifier leakErik Johnston2015-06-181-21/+20
|
* Iterate over the user_streams not the user_idsMark Haines2015-05-261-1/+1
|
* Oops, get_rooms_for_user returns a namedtuple, not a room_idMark Haines2015-05-211-0/+1
|
* Don't bother sorting by the room_stream_ids, it shouldn't matter which order ↵Mark Haines2015-05-181-1/+1
| | | | they are notified in
* Make sure the notifier stream token goes forward when it is updated. Sort ↵Mark Haines2015-05-181-4/+4
| | | | the pending events by the correct room_stream_id
* Add some doc-strings to notifierMark Haines2015-05-141-19/+33
|
* Use the current token when timing out a notifier, make sure the user_id is a ↵Mark Haines2015-05-141-2/+2
| | | | string in on_new_user_event
* Fix v2 sync, update the last_notified_ms only if there was an active listenerMark Haines2015-05-141-5/+6
|
* Fix metric counterMark Haines2015-05-131-2/+2
|
* Discard unused NotifierUserStreamsMark Haines2015-05-131-16/+34
|
* Don't set a timer if there's already a result to returnMark Haines2015-05-131-3/+10
|
* Don't bother checking for new events from a source if the stream token ↵Mark Haines2015-05-131-2/+6
| | | | hasn't advanced for that source
* Don't bother checking for updates if the stream token hasn't advanced for a userMark Haines2015-05-131-24/+51
|
* Merge branch 'notifier_unify' into notifier_performanceMark Haines2015-05-121-13/+10
|\ | | | | | | | | Conflicts: synapse/notifier.py
| * Merge branch 'develop' into notifier_unifyMark Haines2015-05-121-13/+10
| |\ | | | | | | | | | | | | Conflicts: synapse/notifier.py
| | * PEP8Erik Johnston2015-05-081-3/+2
| | |
| | * Change the way we do logging contexts so that they survive divergencesErik Johnston2015-05-081-9/+7
| | |
* | | Merge branch 'notifier_unify' into notifier_performanceMark Haines2015-05-121-1/+1
|\| |
| * | Update the end_token correctly, otherwise the token doesn't advance and the ↵Mark Haines2015-05-121-1/+1
| | | | | | | | | | | | client gets duplicate events
* | | Add a NotifierUserStream to hold all the notification listeners for a userMark Haines2015-05-121-114/+116
|/ /
* | Don't bother passing the events to the notifier since it isn't using themMark Haines2015-05-111-95/+18
| |
* | Use wait_for_events to implement 'get_events'Mark Haines2015-05-111-79/+30
|/
* Remove some run_on_reactorsErik Johnston2015-05-011-5/+0
|
* Change from exception to warnErik Johnston2015-04-151-1/+1
|
* Add commentMark Haines2015-04-091-0/+1
|
* Unset the timer in the timeout callback so that we don't try to cancel it if ↵Mark Haines2015-04-091-0/+1
| | | | it has been called
* SYN-339: Cancel the notifier timeout when the notifier firesMark Haines2015-04-091-4/+26
|
* Move comment into docstringErik Johnston2015-04-081-5/+2
|
* Factor out loops into '_discard_if_notified'Erik Johnston2015-04-081-15/+14
|
* Also perform paranoia checks in 'on_new_user_event'Erik Johnston2015-04-081-2/+16
|
* Add paranoia checks to make sure that we evict stale NotificationListeners ↵Erik Johnston2015-04-081-5/+31
| | | | when we are about to process them
* Fix bug where we didn't inform the NotificataionListeners about new rooms ↵Erik Johnston2015-04-081-0/+3
| | | | they have been subscribed to. This meant that the listeners didn't clean themselves up fully from all the dicts
* Appease pep8Paul "LeoNerd" Evans2015-03-121-6/+9
|
* Add a counter to track total number of events served by the notifierPaul "LeoNerd" Evans2015-03-121-0/+3
|
* Use _ instead of . as a metric namespacing separator, for PrometheusPaul "LeoNerd" Evans2015-03-121-1/+1
|
* Put some gauge metrics on the number of notifier listeners, and notified-on ↵Paul "LeoNerd" Evans2015-03-121-0/+39
| | | | objects (users, rooms, appservices)
* Rename rooms_to_listeners to room_to_listeners, for consistency with user_ ↵Paul "LeoNerd" Evans2015-03-051-8/+8
| | | | and appservice_*
* Notify appservices of invites mid-poll.Kegan Dougal2015-02-271-1/+29
| | | | | | | | This requires the notifier to have knowledge of appservice listeners so it can do the regex checks on incoming invites to see if the state_key matches. It isn't enough to just rely on the room listeners and store.get_app_service_rooms as the room will initially not exist or won't be on the ASes radar due to having none of its users in the room.
* Merge branch 'consumeErrors' of github.com:matrix-org/synapse into developErik Johnston2015-02-171-2/+4
|\
| * Use consumeErrors=True on all DeferredLists.Erik Johnston2015-02-171-2/+4
| | | | | | | | | | | | This is so that the DeferredLists actually consume the error instead of propogating down the non-existent errback chain. This should reduce the number of unhandled errors we are seeing.
* | Glue AS work to general event notifications. Add more exception handling ↵Kegan Dougal2015-02-051-0/+6
|/ | | | when poking ASes.
* Fix FormattingMark Haines2015-01-271-2/+2
|
* Wait for events if the incremental sync is empty and a timeout is givenMark Haines2015-01-271-0/+48
|
* Only start the notifier timeout once we've had a chance to check for ↵Mark Haines2015-01-191-2/+2
| | | | updates. Otherwise the timeout could fire while we are waiting for the database to return any updates it might have
* Update copyright noticesMark Haines2015-01-061-1/+1
|
* Remember to hook up the typing event stream to the notifier as wellPaul "LeoNerd" Evans2014-12-151-7/+25
|
* Fix pep8 codestyle warningsMark Haines2014-11-201-0/+1
|
* Add a few missing yields, Move deferred lists inside PreserveLoggingContext ↵Mark Haines2014-11-201-0/+3
| | | | because they don't interact well with the logging contexts
* remove unused importMark Haines2014-11-191-1/+1
|
* Preserve logging context in a few more places, drop the logging context ↵Mark Haines2014-11-191-18/+22
| | | | after it has been stashed to reduce potential for confusion
* Fix pep8 warningsMark Haines2014-10-301-1/+2
|
* Use floating-point rather than integer division to handle timeouts so that ↵Paul "LeoNerd" Evans2014-10-291-1/+1
| | | | non-zero but sub-second waits don't collapse to zero
* fix the copyright holder from matrix.org to OpenMarket Ltd, as matrix.org ↵Matthew Hodgson2014-09-031-1/+1
| | | | hasn't been incorporated in time for launch.
* Make sure to print exceptions properly from notifier failuresPaul "LeoNerd" Evans2014-09-031-1/+6
|
* Merge branch 'master' of github.com:matrix-org/synapse into release-v0.2.0Erik Johnston2014-09-021-2/+19
|\ | | | | | | | | | | | | Conflicts: synapse/notifier.py webclient/room/room-controller.js webclient/room/room.html
| * When notifying listeners, don't do so in a serial fashionErik Johnston2014-08-291-2/+19
| |
* | Have EventSource's get_new_events_for_user() API work only on keys within ↵Paul "LeoNerd" Evans2014-08-291-10/+20
|/ | | | that source, not overall eventstream tokens
* Turn of trace_function loggingErik Johnston2014-08-281-2/+2
|
* And more logging.Erik Johnston2014-08-281-1/+2
|
* If timeout=0, return immediatelyErik Johnston2014-08-271-1/+5
|
* Comments!Erik Johnston2014-08-271-0/+35
|
* Index sources in a nicer fashion.Erik Johnston2014-08-271-3/+3
|
* Implement presence event source. Change the way the notifier indexes listenersErik Johnston2014-08-271-43/+42
|
* Enable presence again. Fix up api to match old api.Erik Johnston2014-08-261-1/+19
|
* WIP: Completely change how event streaming and pagination work. This ↵Erik Johnston2014-08-261-0/+184
reflects the change in the underlying storage model.
generated by cgit-pink 1.4.1 (git 2.36.1) at 2024-11-16 16:15:29 +0000