summary refs log tree commit diff
path: root/synapse/notifier.py (follow)
Commit message (Expand)AuthorAgeFilesLines
* Add EventStreamPosition type github/erikj/stream_position erikj/stream_positionErik Johnston2020-09-101-26/+29
* Make StreamToken.room_key use proper type.Erik Johnston2020-09-101-4/+12
* Clean up `Notifier.on_new_room_event` code path (#8288)Erik Johnston2020-09-101-23/+39
* Clean up types for PaginationConfig (#8250)Erik Johnston2020-09-081-2/+3
* Stop sub-classing object (#8249)Patrick Cloke2020-09-041-3/+3
* Fix typing for notifier (#8064)Erik Johnston2020-08-121-4/+8
* Add typing info to Notifier (#8058)Erik Johnston2020-08-111-48/+83
* Convert streams to async. (#8014)Patrick Cloke2020-08-041-2/+2
* Fix some spelling mistakes / typos. (#7811)Patrick Cloke2020-07-091-1/+1
* Fix new flake8 errors (#7470)Erik Johnston2020-05-121-4/+6
* Convert the synapse.notifier module to async/await. (#7395)Patrick Cloke2020-05-011-10/+7
* Don't relay REMOTE_SERVER_UP cmds to same conn. (#7352)Erik Johnston2020-04-291-9/+0
* Wake up transaction queue when remote server comes back online (#6706)Erik Johnston2020-01-171-3/+28
* Port SyncHandler to async/awaitErik Johnston2019-12-051-16/+13
* Port to use state storageErik Johnston2019-10-301-1/+5
* Remove unnecessary parentheses around return statements (#5931)Andrew Morgan2019-08-301-3/+3
* Replace returnValue with return (#5736)Amber Brown2019-07-231-9/+9
* Move logging utilities out of the side drawer of util/ and into logging/ (#5606)Amber Brown2019-07-041-2/+2
* Run Black. (#5482)Amber Brown2019-06-201-34/+36
* Remove redundant PreserveLoggingContextRichard van der Hoff2019-03-041-10/+5
* Remove unused `wait_for_replication` methodRichard van der Hoff2019-03-041-50/+0
* Make the metrics less racy (#4061)Amber Brown2018-10-191-3/+3
* Run notify_app_services as a bg processRichard van der Hoff2018-09-261-2/+6
* FixupErik Johnston2018-09-191-4/+1
* Replace custom DeferredTimeoutError with defer.TimeoutErrorErik Johnston2018-09-191-3/+2
* Update to use new timeout function everywhere.Erik Johnston2018-09-191-6/+7
* Rename async to async_helpers because `async` is a keyword on Python 3.7 (#3678)Amber Brown2018-08-101-1/+1
* WIP to announce deleted devices over federationMatthew Hodgson2018-07-121-1/+1
* run isortAmber Brown2018-07-091-11/+10
* Pass around the reactor explicitly (#3385)Amber Brown2018-06-221-0/+3
* cleanup pep8 errorsAmber Brown2018-05-221-1/+2
* fixesAmber Brown2018-05-221-3/+3
* replacing portionsAmber Brown2018-05-211-13/+10
* Merge remote-tracking branch 'origin/develop' into rav/deferred_timeoutRichard van der Hoff2018-04-271-4/+9
|\
| * Improve exception handling for background processesRichard van der Hoff2018-04-271-4/+9
* | Backport deferred.addTimeoutRichard van der Hoff2018-04-271-8/+14
* | Use deferred.addTimeout instead of time_bound_deferredRichard van der Hoff2018-04-231-12/+11
|/
* add __bool__ alias to __nonzero__ methodsAdrian Tschira2018-04-151-0/+1
* Clear logcontext before starting fed txn queue runnerRichard van der Hoff2017-11-281-7/+10
* replace 'except:' with 'except Exception:'Richard van der Hoff2017-10-231-1/+1
* Don't start user_directory handling on workersErik Johnston2017-06-071-3/+0
* Add user_directory to databaseErik Johnston2017-05-311-1/+5
* Merge branch 'develop' of github.com:matrix-org/synapse into erikj/repl_tcp_s...Erik Johnston2017-04-041-13/+10
|\
| * Remove spurious PreserveLoggingContextRichard van der Hoff2017-04-031-6/+5
| * preserve_fn some deferred-returning thingsRichard van der Hoff2017-04-031-2/+5
| * Remove spurious @preserve_fn decoratorsRichard van der Hoff2017-04-031-5/+0
* | Use callbacks to notify tcp replication rather than deferredsErik Johnston2017-03-311-6/+11
* | Add a simple hook to wait for replication trafficErik Johnston2017-03-301-0/+6
|/
* Don't recreate so many setsErik Johnston2017-03-161-4/+2
* Format presence events on the edges instead of reformatting them multiple timesErik Johnston2017-03-151-0/+10
* Add some metrics on notifierErik Johnston2017-03-151-0/+6
* Reduce spurious calls to generate syncErik Johnston2017-03-141-13/+31
* Make presence.get_new_events a bit fasterErik Johnston2017-02-021-0/+1
* Correctly handle timeout errorsErik Johnston2016-12-091-6/+14
* Fix rare notifier bug where listeners dont timeoutErik Johnston2016-12-091-11/+9
* Ensure only main or federation_sender process can send federation trafficErik Johnston2016-11-231-2/+9
* Handle sending events and device messages over federationErik Johnston2016-11-171-0/+2
* Explicitly specify state_key for history_visibility fetchingErik Johnston2016-09-021-1/+2
* Preserve some logcontextsErik Johnston2016-08-241-1/+6
* defer.returnValue must not be called within MeasureErik Johnston2016-08-191-2/+1
* Add measure blocks to notifierErik Johnston2016-08-191-15/+18
* Make AppserviceHandler stream events from databaseErik Johnston2016-08-181-1/+1
* Remove dead appservice codeErik Johnston2016-08-171-39/+2
* Notify users for events in rooms they join.Mark Haines2016-06-071-8/+6
* Move the AS handler out of the Handlers object.Mark Haines2016-05-311-6/+4
* move filter_events_for_client out of base handlerMark Haines2016-05-111-2/+3
* Run filter_events_for_clientDavid Baker2016-04-271-1/+1
* Use google style doc strings.Mark Haines2016-04-011-7/+8
* Hook up adding a pusher to the notifier for replication.Mark Haines2016-03-151-0/+6
* Hook up the push rules to the notifierMark Haines2016-03-031-1/+1
* Add a /replication API for extracting the updates that happened onMark Haines2016-03-011-0/+48
* Fix up logcontextsErik Johnston2016-02-081-29/+29
* Fix flake8 warnings for new flake8Daniel Wagner-Hall2016-02-021-1/+1
* Don't use before_token. Its wrong. Use actual limit.Erik Johnston2016-01-311-6/+3
* Deal with None limitErik Johnston2016-01-291-1/+5
* Make /events always return a newer token, if one existsErik Johnston2016-01-291-9/+10
* Only fetch events for rooms and receiptsErik Johnston2016-01-211-3/+3
* SYN-606: Peeking does not wake up /eventsErik Johnston2016-01-211-1/+3
* Allow non-guests to peek on rooms using /eventsDaniel Wagner-Hall2016-01-201-23/+48
* Skip, rather than erroring, invalid guest requestsDaniel Wagner-Hall2016-01-051-2/+1
* Missing yield on guest access auth checkMark Haines2015-12-231-1/+1
* Return non-room events from guest /events callsDaniel Wagner-Hall2015-11-121-3/+17
* Open up /events to anonymous users for room events onlyDaniel Wagner-Hall2015-11-051-8/+34
* Merge branch 'develop' into daniel/removesomeliesMark Haines2015-11-041-1/+1
|\
| * 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 _NotifierUserSt...Erik Johnston2015-06-181-66/+56
* 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
* Make sure the notifier stream token goes forward when it is updated. Sort the...Mark Haines2015-05-181-4/+4
* 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
* 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 hasn't...Mark Haines2015-05-131-2/+6
* 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
|\
| * Merge branch 'develop' into notifier_unifyMark Haines2015-05-121-13/+10
| |\
| | * 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 c...Mark Haines2015-05-121-1/+1
* | | 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
* 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 wh...Erik Johnston2015-04-081-5/+31
* Fix bug where we didn't inform the NotificataionListeners about new rooms the...Erik Johnston2015-04-081-0/+3
* 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 o...Paul "LeoNerd" Evans2015-03-121-0/+39
* Rename rooms_to_listeners to room_to_listeners, for consistency with user_ an...Paul "LeoNerd" Evans2015-03-051-8/+8
* Notify appservices of invites mid-poll.Kegan Dougal2015-02-271-1/+29
* 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
* | Glue AS work to general event notifications. Add more exception handling when...Kegan Dougal2015-02-051-0/+6
|/
* 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 updates....Mark Haines2015-01-191-2/+2
* 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 b...Mark Haines2014-11-201-0/+3
* remove unused importMark Haines2014-11-191-1/+1
* Preserve logging context in a few more places, drop the logging context after...Mark Haines2014-11-191-18/+22
* Fix pep8 warningsMark Haines2014-10-301-1/+2
* Use floating-point rather than integer division to handle timeouts so that no...Paul "LeoNerd" Evans2014-10-291-1/+1
* fix the copyright holder from matrix.org to OpenMarket Ltd, as matrix.org has...Matthew Hodgson2014-09-031-1/+1
* 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
|\
| * 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 tha...Paul "LeoNerd" Evans2014-08-291-10/+20
|/
* 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 reflects...Erik Johnston2014-08-261-0/+184
generated by cgit-pink 1.4.1 (git 2.36.1) at 2024-11-10 05:41:51 +0000