| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Allow multiple workers to write to receipts stream. (#16432) | Erik Johnston | 2023-10-25 | 1 | -2/+43 |
| | | | | Fixes #16417 | ||||
| * | Some refactors around receipts stream (#16426) | Erik Johnston | 2023-10-04 | 1 | -9/+8 |
| | | |||||
| * | Use StrCollection in additional places. (#16301) | Patrick Cloke | 2023-09-13 | 1 | -3/+3 |
| | | |||||
| * | Add ability to wait for locks and add locks to purge history / room deletion ↵ | Erik Johnston | 2023-07-31 | 1 | -0/+16 |
| | | | | | | (#15791) c.f. #13476 | ||||
| * | Move ThirdPartyEventRules into module_api/callbacks (#15535) | Andrew Morgan | 2023-05-04 | 1 | -1/+1 |
| | | |||||
| * | Fix a bug in the send_local_online_presence_to module API (#14880) | Patrick Cloke | 2023-01-25 | 1 | -1/+2 |
| | | | | | | | | Destination was being used incorrectly (a single destination instead of a list of destinations was being passed). This also updates some of the types in the area to not use Collection[str], which is a footgun. | ||||
| * | Faster joins: omit partial rooms from eager syncs until the resync completes ↵ | David Robertson | 2023-01-23 | 1 | -0/+26 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | (#14870) * Allow `AbstractSet` in `StrCollection` Or else frozensets are excluded. This will be useful in an upcoming commit where I plan to change a function that accepts `List[str]` to accept `StrCollection` instead. * `rooms_to_exclude` -> `rooms_to_exclude_globally` I am about to make use of this exclusion mechanism to exclude rooms for a specific user and a specific sync. This rename helps to clarify the distinction between the global config and the rooms to exclude for a specific sync. * Better function names for internal sync methods * Track a list of excluded rooms on SyncResultBuilder I plan to feed a list of partially stated rooms for this sync to ignore * Exclude partial state rooms during eager sync using the mechanism established in the previous commit * Track un-partial-state stream in sync tokens So that we can work out which rooms have become fully-stated during a given sync period. * Fix mutation of `@cached` return value This was fouling up a complement test added alongside this PR. Excluding a room would mean the set of forgotten rooms in the cache would be extended. This means that room could be erroneously considered forgotten in the future. Introduced in #12310, Synapse 1.57.0. I don't think this had any user-visible side effects (until now). * SyncResultBuilder: track rooms to force as newly joined Similar plan as before. We've omitted rooms from certain sync responses; now we establish the mechanism to reintroduce them into future syncs. * Read new field, to present rooms as newly joined * Force un-partial-stated rooms to be newly-joined for eager incremental syncs only, provided they're still fully stated * Notify user stream listeners to wake up long polling syncs * Changelog * Typo fix Co-authored-by: Sean Quah <8349537+squahtx@users.noreply.github.com> * Unnecessary list cast Co-authored-by: Sean Quah <8349537+squahtx@users.noreply.github.com> * Rephrase comment Co-authored-by: Sean Quah <8349537+squahtx@users.noreply.github.com> * Another comment Co-authored-by: Sean Quah <8349537+squahtx@users.noreply.github.com> * Fixup merge(?) * Poke notifier when receiving un-partial-stated msg over replication * Fixup merge whoops Thanks MV :) Co-authored-by: Mathieu Velen <mathieuv@matrix.org> Co-authored-by: Mathieu Velten <mathieuv@matrix.org> Co-authored-by: Sean Quah <8349537+squahtx@users.noreply.github.com> | ||||
| * | Always notify replication when a stream advances (#14877) | Erik Johnston | 2023-01-20 | 1 | -5/+26 |
| | | | | This ensures that all other workers are told about stream updates in a timely manner, without having to remember to manually poke replication. | ||||
| * | Batch up notifications after event persistence (#14033) | Shay | 2022-10-05 | 1 | -34/+41 |
| | | |||||
| * | Notifier: accept callbacks to fire on room joins (#13254) | David Robertson | 2022-07-13 | 1 | -0/+18 |
| | | |||||
| * | Reduce the amount of state we pull from the DB (#12811) | Erik Johnston | 2022-06-06 | 1 | -1/+1 |
| | | |||||
| * | Rename storage classes (#12913) | Erik Johnston | 2022-05-31 | 1 | -2/+2 |
| | | |||||
| * | Additional constants for EDU types. (#12884) | Patrick Cloke | 2022-05-27 | 1 | -2/+2 |
| | | | | Instead of hard-coding strings in many places. | ||||
| * | Add `StreamKeyType` class and replace string literals with constants (#12567) | Andrew Morgan | 2022-05-16 | 1 | -2/+3 |
| | | |||||
| * | Immediately retry any requests that have backed off when a server comes back ↵ | Erik Johnston | 2022-05-10 | 1 | -3/+5 |
| | | | | | | online. (#12500) Otherwise it can take up to a minute for any in-flight `/send` requests to be retried. | ||||
| * | Remove `HomeServer.get_datastore()` (#12031) | Richard van der Hoff | 2022-02-23 | 1 | -1/+1 |
| | | | | | | | | The presence of this method was confusing, and mostly present for backwards compatibility. Let's get rid of it. Part of #11733 | ||||
| * | Add some tests for propagation of device list changes between local users ↵ | Andrew Morgan | 2022-02-15 | 1 | -2/+2 |
| | | | | | (#11972) | ||||
| * | Adds misc missing type hints (#11953) | Patrick Cloke | 2022-02-11 | 1 | -19/+24 |
| | | |||||
| * | Send to-device messages to application services (#11215) | Andrew Morgan | 2022-02-01 | 1 | -1/+3 |
| | | | | Co-authored-by: Richard van der Hoff <1389908+richvdh@users.noreply.github.com> | ||||
| * | Remove `log_function` and its uses (#11761) | Richard van der Hoff | 2022-01-18 | 1 | -3/+0 |
| | | | | | | | | I've never found this terribly useful. I think it was added in the early days of Synapse, without much thought as to what would actually be useful to log, and has just been cargo-culted ever since. Rather, it tends to clutter up debug logs with useless information. | ||||
| * | Use auto_attribs/native type hints for attrs classes. (#11692) | Patrick Cloke | 2022-01-13 | 1 | -7/+7 |
| | | |||||
| * | Convert EventStreamResult to attrs. (#11574) | Patrick Cloke | 2021-12-15 | 1 | -6/+19 |
| | | |||||
| * | Fix providing a `RoomStreamToken` instance to ↵ | Andrew Morgan | 2021-11-02 | 1 | -29/+9 |
| | | | | | | `_notify_app_services_ephemeral` (#11137) Co-authored-by: Richard van der Hoff <1389908+richvdh@users.noreply.github.com> | ||||
| * | Implement an `on_new_event` callback (#11126) | Brendan Abolivier | 2021-10-26 | 1 | -4/+13 |
| | | | | Co-authored-by: Andrew Morgan <1342360+anoadragon453@users.noreply.github.com> | ||||
| * | Improve docstrings for methods related to sending EDUs to application ↵ | Andrew Morgan | 2021-10-21 | 1 | -2/+16 |
| | | | | | services (#11138) | ||||
| * | Add type hints for event streams. (#10856) | Patrick Cloke | 2021-09-21 | 1 | -1/+1 |
| | | |||||
| * | Generics for `ObservableDeferred` (#10491) | Richard van der Hoff | 2021-07-28 | 1 | -2/+3 |
| | | | | | | Now that `Deferred` is a generic class, let's update `ObeservableDeferred` to follow suit. | ||||
| * | Use inline type hints in various other places (in `synapse/`) (#10380) | Jonathan de Jong | 2021-07-15 | 1 | -9/+9 |
| | | |||||
| * | Improve opentracing annotations for Notifier (#10111) | Richard van der Hoff | 2021-06-03 | 1 | -33/+33 |
| | | | | | | | | The existing tracing reports an error each time there is a timeout, which isn't really representative. Additionally, we log things about the way `wait_for_events` works (eg, the result of the callback) to the *parent* span, which is confusing. | ||||
| * | Add debug logging for issue #9533 (#9959) | Richard van der Hoff | 2021-05-11 | 1 | -0/+8 |
| | | | | | | Hopefully this will help us track down where to-device messages are getting lost/delayed. | ||||
| * | Remove `synapse.types.Collection` (#9856) | Richard van der Hoff | 2021-04-22 | 1 | -7/+2 |
| | | | | This is no longer required, since we have dropped support for Python 3.5. | ||||
| * | Remove redundant "coding: utf-8" lines (#9786) | Jonathan de Jong | 2021-04-14 | 1 | -1/+0 |
| | | | | | | | | Part of #9744 Removes all redundant `# -*- coding: utf-8 -*-` lines from files, as python 3 automatically reads source code as utf-8 now. `Signed-off-by: Jonathan de Jong <jonathan@automatia.nl>` | ||||
| * | Bugbear: Add Mutable Parameter fixes (#9682) | Jonathan de Jong | 2021-04-08 | 1 | -8/+11 |
| | | | | | | | | Part of #9366 Adds in fixes for B006 and B008, both relating to mutable parameter lint errors. Signed-off-by: Jonathan de Jong <jonathan@automatia.nl> | ||||
| * | Update mypy configuration: `no_implicit_optional = True` (#9742) | Jonathan de Jong | 2021-04-05 | 1 | -1/+1 |
| | | |||||
| * | Improve tracing for to device messages (#9686) | Erik Johnston | 2021-04-01 | 1 | -2/+43 |
| | | |||||
| * | Update black, and run auto formatting over the codebase (#9381) | Eric Eastwood | 2021-02-16 | 1 | -12/+18 |
| | | | | | | | | - Update black version to the latest - Run black auto formatting over the codebase - Run autoformatting according to [`docs/code_style.md `](https://github.com/matrix-org/synapse/blob/80d6dc9783aa80886a133756028984dbf8920168/docs/code_style.md) - Update `code_style.md` docs around installing black to use the correct version | ||||
| * | Fix "Starting metrics collection from sentinel context" errors (#9053) | Erik Johnston | 2021-01-08 | 1 | -20/+19 |
| | | |||||
| * | Do not assume that the contents dictionary includes history_visibility. (#8945) | Patrick Cloke | 2020-12-16 | 1 | -2/+4 |
| | | |||||
| * | Don't pull event from DB when handling replication traffic. (#8669) | Erik Johnston | 2020-10-28 | 1 | -13/+55 |
| | | | | | | I was trying to make it so that we didn't have to start a background task when handling RDATA, but that is a bigger job (due to all the code in `generic_worker`). However I still think not pulling the event from the DB may help reduce some DB usage due to replication, even if most workers will simply go and pull that event from the DB later anyway. Co-authored-by: Patrick Cloke <clokep@users.noreply.github.com> | ||||
| * | Start fewer opentracing spans (#8640) | Erik Johnston | 2020-10-26 | 1 | -23/+11 |
| | | | | | | | | #8567 started a span for every background process. This is good as it means all Synapse code that gets run should be in a span (unless in the sentinel logging context), but it means we generate about 15x the number of spans as we did previously. This PR attempts to reduce that number by a) not starting one for send commands to Redis, and b) deferring starting background processes until after we're sure they're necessary. I don't really know how much this will help. | ||||
| * | Fix typos and spelling errors. (#8639) | Patrick Cloke | 2020-10-23 | 1 | -1/+1 |
| | | |||||
| * | Send some ephemeral events to appservices (#8437) | Will Hunt | 2020-10-15 | 1 | -0/+25 |
| | | | | Optionally sends typing, presence, and read receipt information to appservices. | ||||
| * | Fix not sending events over federation when using sharded event persisters ↵ | Erik Johnston | 2020-10-14 | 1 | -3/+3 |
| | | | | | | | | | | | | | | | | | | (#8536) * Fix outbound federaion with multiple event persisters. We incorrectly notified federation senders that the minimum persisted stream position had advanced when we got an `RDATA` from an event persister. Notifying of federation senders already correctly happens in the notifier, so we just delete the offending line. * Change some interfaces to use RoomStreamToken. By enforcing use of `RoomStreamTokens` we make it less likely that people pass in random ints that they got from somewhere random. | ||||
| * | Add type hints to some handlers (#8505) | Patrick Cloke | 2020-10-09 | 1 | -1/+1 |
| | | |||||
| * | Various clean ups to room stream tokens. (#8423) | Erik Johnston | 2020-09-29 | 1 | -2/+2 |
| | | |||||
| * | Add EventStreamPosition type (#8388) | Erik Johnston | 2020-09-24 | 1 | -26/+29 |
| | | | | | | | | | | | | | | | The idea is to remove some of the places we pass around `int`, where it can represent one of two things: 1. the position of an event in the stream; or 2. a token that partitions the stream, used as part of the stream tokens. The valid operations are then: 1. did a position happen before or after a token; 2. get all events that happened before or after a token; and 3. get all events between two tokens. (Note that we don't want to allow other operations as we want to change the tokens to be vector clocks rather than simple ints) | ||||
| * | Use slots in attrs classes where possible (#8296) | Patrick Cloke | 2020-09-14 | 1 | -3/+1 |
| | | | | | | slots use less memory (and attribute access is faster) while slightly limiting the flexibility of the class attributes. This focuses on objects which are instantiated "often" and for short periods of time. | ||||
| * | Make `StreamToken.room_key` be a `RoomStreamToken` instance. (#8281) | Erik Johnston | 2020-09-11 | 1 | -4/+12 |
| | | |||||
| * | Clean up `Notifier.on_new_room_event` code path (#8288) | Erik Johnston | 2020-09-10 | 1 | -23/+39 |
| | | | | | | | | | | | | | | The idea here is that we pass the `max_stream_id` to everything, and only use the stream ID of the particular event to figure out *when* the max stream position has caught up to the event and we can notify people about it. This is to maintain the distinction between the position of an item in the stream (i.e. event A has stream ID 513) and a token that can be used to partition the stream (i.e. give me all events after stream ID 352). This distinction becomes important when the tokens are more complicated than a single number, which they will be once we start tracking the position of multiple writers in the tokens. The valid operations here are: 1. Is a position before or after a token 2. Fetching all events between two tokens 3. Merging multiple tokens to get the "max", i.e. `C = max(A, B)` means that for all positions P where P is before A *or* before B, then P is before C. Future PR will change the token type to a dedicated type. | ||||
| * | Clean up types for PaginationConfig (#8250) | Erik Johnston | 2020-09-08 | 1 | -2/+3 |
| | | | | This removes `SourcePaginationConfig` and `get_pagination_rows`. The reasoning behind this is that these generic classes/functions erased the types of the IDs it used (i.e. instead of passing around `StreamToken` it'd pass in e.g. `token.room_key`, which don't have uniform types). | ||||
| * | Stop sub-classing object (#8249) | Patrick Cloke | 2020-09-04 | 1 | -3/+3 |
| | | |||||
| * | Fix typing for notifier (#8064) | Erik Johnston | 2020-08-12 | 1 | -4/+8 |
| | | |||||
| * | Add typing info to Notifier (#8058) | Erik Johnston | 2020-08-11 | 1 | -48/+83 |
| | | |||||
| * | Convert streams to async. (#8014) | Patrick Cloke | 2020-08-04 | 1 | -2/+2 |
| | | |||||
| * | Fix some spelling mistakes / typos. (#7811) | Patrick Cloke | 2020-07-09 | 1 | -1/+1 |
| | | |||||
| * | Fix new flake8 errors (#7470) | Erik Johnston | 2020-05-12 | 1 | -4/+6 |
| | | |||||
| * | Convert the synapse.notifier module to async/await. (#7395) | Patrick Cloke | 2020-05-01 | 1 | -10/+7 |
| | | |||||
| * | Don't relay REMOTE_SERVER_UP cmds to same conn. (#7352) | Erik Johnston | 2020-04-29 | 1 | -9/+0 |
| | | | | | | | | | | | | | | | For direct TCP connections we need the master to relay REMOTE_SERVER_UP commands to the other connections so that all instances get notified about it. The old implementation just relayed to all connections, assuming that sending back to the original sender of the command was safe. This is not true for redis, where commands sent get echoed back to the sender, which was causing master to effectively infinite loop sending and then re-receiving REMOTE_SERVER_UP commands that it sent. The fix is to ensure that we only relay to *other* connections and not to the connection we received the notification from. Fixes #7334. | ||||
| * | Wake up transaction queue when remote server comes back online (#6706) | Erik Johnston | 2020-01-17 | 1 | -3/+28 |
| | | | | | | This will be used to retry outbound transactions to a remote server if we think it might have come back up. | ||||
| * | Port SyncHandler to async/await | Erik Johnston | 2019-12-05 | 1 | -16/+13 |
| | | |||||
| * | Port to use state storage | Erik Johnston | 2019-10-30 | 1 | -1/+5 |
| | | |||||
| * | Remove unnecessary parentheses around return statements (#5931) | Andrew Morgan | 2019-08-30 | 1 | -3/+3 |
| | | | | | | Python will return a tuple whether there are parentheses around the returned values or not. I'm just sick of my editor complaining about this all over the place :) | ||||
| * | Replace returnValue with return (#5736) | Amber Brown | 2019-07-23 | 1 | -9/+9 |
| | | |||||
| * | Move logging utilities out of the side drawer of util/ and into logging/ (#5606) | Amber Brown | 2019-07-04 | 1 | -2/+2 |
| | | |||||
| * | Run Black. (#5482) | Amber Brown | 2019-06-20 | 1 | -34/+36 |
| | | |||||
| * | Remove redundant PreserveLoggingContext | Richard van der Hoff | 2019-03-04 | 1 | -10/+5 |
| | | | | | | Both (!) things that register as replication listeners do the right thing wrt logcontexts, so this is redundant. | ||||
| * | Remove unused `wait_for_replication` method | Richard van der Hoff | 2019-03-04 | 1 | -50/+0 |
| | | | | | I guess this was used once? It's not now, anyway. | ||||
| * | Make the metrics less racy (#4061) | Amber Brown | 2018-10-19 | 1 | -3/+3 |
| | | |||||
| * | Run notify_app_services as a bg process | Richard van der Hoff | 2018-09-26 | 1 | -2/+6 |
| | | | | | | | | | This ensures that its resource usage metrics get recorded somewhere rather than getting lost. (It also fixes an error when called from a nested logging context which completes before the bg process) | ||||
| * | Fixup | Erik Johnston | 2018-09-19 | 1 | -4/+1 |
| | | |||||
| * | Replace custom DeferredTimeoutError with defer.TimeoutError | Erik Johnston | 2018-09-19 | 1 | -3/+2 |
| | | |||||
| * | Update to use new timeout function everywhere. | Erik Johnston | 2018-09-19 | 1 | -6/+7 |
| | | | | | | | | The existing deferred timeout helper function (and the one into twisted) suffer from a bug when a deferred's canceller throws an exception, #3842. The new helper function doesn't suffer from this problem. | ||||
| * | Rename async to async_helpers because `async` is a keyword on Python 3.7 (#3678) | Amber Brown | 2018-08-10 | 1 | -1/+1 |
| | | |||||
| * | WIP to announce deleted devices over federation | Matthew Hodgson | 2018-07-12 | 1 | -1/+1 |
| | | | | | | | Previously we queued up the poke correctly when the device was deleted, but then the actual EDU wouldn't get sent, as the device was no longer known. Instead, we now send EDUs for deleted devices too if there's a poke for them. | ||||
| * | run isort | Amber Brown | 2018-07-09 | 1 | -11/+10 |
| | | |||||
| * | Pass around the reactor explicitly (#3385) | Amber Brown | 2018-06-22 | 1 | -0/+3 |
| | | |||||
| * | cleanup pep8 errors | Amber Brown | 2018-05-22 | 1 | -1/+2 |
| | | |||||
| * | fixes | Amber Brown | 2018-05-22 | 1 | -3/+3 |
| | | |||||
| * | replacing portions | Amber Brown | 2018-05-21 | 1 | -13/+10 |
| | | |||||
| * | Merge remote-tracking branch 'origin/develop' into rav/deferred_timeout | Richard van der Hoff | 2018-04-27 | 1 | -4/+9 |
| |\ | |||||
| | * | Improve exception handling for background processes | Richard van der Hoff | 2018-04-27 | 1 | -4/+9 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | There were a bunch of places where we fire off a process to happen in the background, but don't have any exception handling on it - instead relying on the unhandled error being logged when the relevent deferred gets garbage-collected. This is unsatisfactory for a number of reasons: - logging on garbage collection is best-effort and may happen some time after the error, if at all - it can be hard to figure out where the error actually happened. - it is logged as a scary CRITICAL error which (a) I always forget to grep for and (b) it's not really CRITICAL if a background process we don't care about fails. So this is an attempt to add exception handling to everything we fire off into the background. | ||||
| * | | Backport deferred.addTimeout | Richard van der Hoff | 2018-04-27 | 1 | -8/+14 |
| | | | | | | | | | Twisted 16.0 doesn't have addTimeout, so let's backport it. | ||||
| * | | Use deferred.addTimeout instead of time_bound_deferred | Richard van der Hoff | 2018-04-23 | 1 | -12/+11 |
| |/ | | | | This doesn't feel like a wheel we need to reinvent. | ||||
| * | add __bool__ alias to __nonzero__ methods | Adrian Tschira | 2018-04-15 | 1 | -0/+1 |
| | | | | | Signed-off-by: Adrian Tschira <nota@notafile.com> | ||||
| * | Clear logcontext before starting fed txn queue runner | Richard van der Hoff | 2017-11-28 | 1 | -7/+10 |
| | | | | | | These processes take a long time compared to the request, so there is lots of "Entering|Restoring dead context" in the logs. Let's try to shut it up a bit. | ||||
| * | replace 'except:' with 'except Exception:' | Richard van der Hoff | 2017-10-23 | 1 | -1/+1 |
| | | | | | what could possibly go wrong | ||||
| * | Don't start user_directory handling on workers | Erik Johnston | 2017-06-07 | 1 | -3/+0 |
| | | |||||
| * | Add user_directory to database | Erik Johnston | 2017-05-31 | 1 | -1/+5 |
| | | |||||
| * | Merge branch 'develop' of github.com:matrix-org/synapse into ↵ | Erik Johnston | 2017-04-04 | 1 | -13/+10 |
| |\ | | | | | | | erikj/repl_tcp_server | ||||
| | * | Remove spurious PreserveLoggingContext | Richard van der Hoff | 2017-04-03 | 1 | -6/+5 |
| | | | | | | | | | | | In `on_new_room_event`, remove `PreserveLoggingContext` - we can call its subroutines with the logcontext set. | ||||
| | * | preserve_fn some deferred-returning things | Richard van der Hoff | 2017-04-03 | 1 | -2/+5 |
| | | | | | | | | | | | In `Notifier._on_new_room_event`, `preserve_fn` around its subroutines which return deferreds, so that it is safe to call it with an active logcontext. | ||||
| | * | Remove spurious @preserve_fn decorators | Richard van der Hoff | 2017-04-03 | 1 | -5/+0 |
| | | | | | | | | | | | | | | | | | Remove `@preserve_fn` decorators on `on_new_room_event`, `_notify_pending_new_room_events`, `_on_new_room_event`, `on_new_event`, and `on_new_replication_data` - none of these functions return a deferred, and the decorator does nothing unless the wrapped function returns a deferred, so the decorator was a no-op. | ||||
| * | | Use callbacks to notify tcp replication rather than deferreds | Erik Johnston | 2017-03-31 | 1 | -6/+11 |
| | | | |||||
| * | | Add a simple hook to wait for replication traffic | Erik Johnston | 2017-03-30 | 1 | -0/+6 |
| |/ | |||||
| * | Don't recreate so many sets | Erik Johnston | 2017-03-16 | 1 | -4/+2 |
| | | |||||
| * | Format presence events on the edges instead of reformatting them multiple times | Erik Johnston | 2017-03-15 | 1 | -0/+10 |
| | | |||||
| * | Add some metrics on notifier | Erik Johnston | 2017-03-15 | 1 | -0/+6 |
| | | |||||
| * | Reduce spurious calls to generate sync | Erik Johnston | 2017-03-14 | 1 | -13/+31 |
| | | |||||
| * | Make presence.get_new_events a bit faster | Erik Johnston | 2017-02-02 | 1 | -0/+1 |
| | | | | | We do this by caching the set of users a user shares rooms with. | ||||
| * | Correctly handle timeout errors | Erik Johnston | 2016-12-09 | 1 | -6/+14 |
| | | |||||
| * | Fix rare notifier bug where listeners dont timeout | Erik Johnston | 2016-12-09 | 1 | -11/+9 |
| | | | | | | | There was a race condition that caused the notifier to 'miss' the timeout notification, since there were no other checks for the timeout this caused listeners to get stuck in a loop until something happened. | ||||
| * | Ensure only main or federation_sender process can send federation traffic | Erik Johnston | 2016-11-23 | 1 | -2/+9 |
| | | |||||
| * | Handle sending events and device messages over federation | Erik Johnston | 2016-11-17 | 1 | -0/+2 |
| | | |||||
| * | Explicitly specify state_key for history_visibility fetching | Erik Johnston | 2016-09-02 | 1 | -1/+2 |
| | | |||||
| * | Preserve some logcontexts | Erik Johnston | 2016-08-24 | 1 | -1/+6 |
| | | |||||
| * | defer.returnValue must not be called within Measure | Erik Johnston | 2016-08-19 | 1 | -2/+1 |
| | | |||||
| * | Add measure blocks to notifier | Erik Johnston | 2016-08-19 | 1 | -15/+18 |
| | | |||||
| * | Make AppserviceHandler stream events from database | Erik Johnston | 2016-08-18 | 1 | -1/+1 |
| | | | | | | | | | | This is for two reasons: 1. Suppresses duplicates correctly, as the notifier doesn't do any duplicate suppression. 2. Makes it easier to connect the AppserviceHandler to the replication stream. | ||||
| * | Remove dead appservice code | Erik Johnston | 2016-08-17 | 1 | -39/+2 |
| | | |||||
| * | Notify users for events in rooms they join. | Mark Haines | 2016-06-07 | 1 | -8/+6 |
| | | | | | | | Change how the notifier updates the map from room_id to user streams on receiving a join event. Make it update the map when it notifies for the join event, rather than using the "user_joined_room" distributor signal | ||||
| * | Move the AS handler out of the Handlers object. | Mark Haines | 2016-05-31 | 1 | -6/+4 |
| | | | | | | | Access it directly from the homeserver itself. It already wasn't inheriting from BaseHandler storing it on the Handlers object was already somewhat dubious. | ||||
| * | move filter_events_for_client out of base handler | Mark Haines | 2016-05-11 | 1 | -2/+3 |
| | | |||||
| * | Run filter_events_for_client | David Baker | 2016-04-27 | 1 | -1/+1 |
| | | | | | so we don't accidentally mail out events people shouldn't see | ||||
| * | Use google style doc strings. | Mark Haines | 2016-04-01 | 1 | -7/+8 |
| | | | | | | | | pycharm supports them so there is no need to use the other format. Might as well convert the existing strings to reduce the risk of people accidentally cargo culting the wrong doc string format. | ||||
| * | Hook up adding a pusher to the notifier for replication. | Mark Haines | 2016-03-15 | 1 | -0/+6 |
| | | |||||
| * | Hook up the push rules to the notifier | Mark Haines | 2016-03-03 | 1 | -1/+1 |
| | | |||||
| * | Add a /replication API for extracting the updates that happened on | Mark Haines | 2016-03-01 | 1 | -0/+48 |
| | | | | | | | | | | | | | | | | | | | | | | | | | synapse This is necessary for replicating the data in synapse to be visible to a separate service because presence and typing notifications aren't stored in a database so won't be visible to another process. This API can be used to either get the raw data by requesting the tables themselves or to just receive notifications for updates by following the streams meta-stream. Returns updates for each table requested a JSON array of arrays with a row for each row in the table. Each table is prefixed by a header row with the: name of the table, current stream_id position for the table, number of rows, number of columns and the names of the columns. This is followed by the rows that have been added to the server since the requester last asked. The API has a timeout and is hooked up to the notifier so that a slave can long poll for updates. | ||||
| * | Fix up logcontexts | Erik Johnston | 2016-02-08 | 1 | -29/+29 |
| | | |||||
| * | Fix flake8 warnings for new flake8 | Daniel Wagner-Hall | 2016-02-02 | 1 | -1/+1 |
| | | |||||
| * | Don't use before_token. Its wrong. Use actual limit. | Erik Johnston | 2016-01-31 | 1 | -6/+3 |
| | | |||||
| * | Deal with None limit | Erik Johnston | 2016-01-29 | 1 | -1/+5 |
| | | |||||
| * | Make /events always return a newer token, if one exists | Erik Johnston | 2016-01-29 | 1 | -9/+10 |
| | | |||||
| * | Only fetch events for rooms and receipts | Erik Johnston | 2016-01-21 | 1 | -3/+3 |
| | | |||||
| * | SYN-606: Peeking does not wake up /events | Erik Johnston | 2016-01-21 | 1 | -1/+3 |
| | | | | | | | If a real user attempted to first peek into one room, and then another, their room event stream would not be woken up for events in the later room. | ||||
| * | Allow non-guests to peek on rooms using /events | Daniel Wagner-Hall | 2016-01-20 | 1 | -23/+48 |
| | | |||||
| * | Skip, rather than erroring, invalid guest requests | Daniel Wagner-Hall | 2016-01-05 | 1 | -2/+1 |
| | | | | | | | | | | | Erroring causes problems when people make illegal requests, because they don't know what limit parameter they should pass. This is definitely buggy. It leaks message counts for rooms people don't have permission to see, via tokens. But apparently we already consciously decided to allow that as a team, so this preserves that behaviour. | ||||
| * | Missing yield on guest access auth check | Mark Haines | 2015-12-23 | 1 | -1/+1 |
| | | | | | Needs matrix-org/sytest#125 to land first | ||||
| * | Return non-room events from guest /events calls | Daniel Wagner-Hall | 2015-11-12 | 1 | -3/+17 |
| | | |||||
| * | Open up /events to anonymous users for room events only | Daniel Wagner-Hall | 2015-11-05 | 1 | -8/+34 |
| | | | | | Squash-merge of PR #345 from daniel/anonymousevents | ||||
| * | Merge branch 'develop' into daniel/removesomelies | Mark Haines | 2015-11-04 | 1 | -1/+1 |
| |\ | | | | | | | | | Conflicts: synapse/notifier.py | ||||
| | * | Inform the client of new room tags using v1 /events | Mark Haines | 2015-10-29 | 1 | -1/+1 |
| | | | |||||
| * | | Remove unused arguments and code | Daniel Wagner-Hall | 2015-11-02 | 1 | -3/+3 |
| |/ | |||||
| * | Don't make pushers handle presence/typing events | Erik Johnston | 2015-08-24 | 1 | -1/+6 |
| | | |||||
| * | Improve naming | Daniel Wagner-Hall | 2015-07-20 | 1 | -2/+2 |
| | | |||||
| * | Consolidate duplicate code in notifier | Erik Johnston | 2015-07-02 | 1 | -24/+11 |
| | | |||||
| * | Add receipts_key to StreamToken | Erik Johnston | 2015-07-02 | 1 | -1/+1 |
| | | |||||
| * | Fix typo | Erik Johnston | 2015-06-19 | 1 | -1/+1 |
| | | |||||
| * | PEP8 | Erik Johnston | 2015-06-18 | 1 | -2/+3 |
| | | |||||
| * | Documentation | Erik Johnston | 2015-06-18 | 1 | -4/+11 |
| | | |||||
| * | Don't bother proxying lookups on _NotificationListener to underlying deferred | Erik Johnston | 2015-06-18 | 1 | -10/+2 |
| | | |||||
| * | Refactor the notifier.wait_for_events code to be clearer. Add ↵ | Erik Johnston | 2015-06-18 | 1 | -66/+56 |
| | | | | | _NotifierUserStream.new_listener that accpets a token to avoid races. | ||||
| * | Fix notifier leak | Erik Johnston | 2015-06-18 | 1 | -21/+20 |
| | | |||||
| * | Iterate over the user_streams not the user_ids | Mark Haines | 2015-05-26 | 1 | -1/+1 |
| | | |||||
| * | Oops, get_rooms_for_user returns a namedtuple, not a room_id | Mark Haines | 2015-05-21 | 1 | -0/+1 |
| | | |||||
| * | Don't bother sorting by the room_stream_ids, it shouldn't matter which order ↵ | Mark Haines | 2015-05-18 | 1 | -1/+1 |
| | | | | | they are notified in | ||||
| * | Make sure the notifier stream token goes forward when it is updated. Sort ↵ | Mark Haines | 2015-05-18 | 1 | -4/+4 |
| | | | | | the pending events by the correct room_stream_id | ||||
| * | Add some doc-strings to notifier | Mark Haines | 2015-05-14 | 1 | -19/+33 |
| | | |||||
| * | Use the current token when timing out a notifier, make sure the user_id is a ↵ | Mark Haines | 2015-05-14 | 1 | -2/+2 |
| | | | | | string in on_new_user_event | ||||
| * | Fix v2 sync, update the last_notified_ms only if there was an active listener | Mark Haines | 2015-05-14 | 1 | -5/+6 |
| | | |||||
| * | Fix metric counter | Mark Haines | 2015-05-13 | 1 | -2/+2 |
| | | |||||
| * | Discard unused NotifierUserStreams | Mark Haines | 2015-05-13 | 1 | -16/+34 |
| | | |||||
| * | Don't set a timer if there's already a result to return | Mark Haines | 2015-05-13 | 1 | -3/+10 |
| | | |||||
| * | Don't bother checking for new events from a source if the stream token ↵ | Mark Haines | 2015-05-13 | 1 | -2/+6 |
| | | | | | hasn't advanced for that source | ||||
| * | Don't bother checking for updates if the stream token hasn't advanced for a user | Mark Haines | 2015-05-13 | 1 | -24/+51 |
| | | |||||
| * | Merge branch 'notifier_unify' into notifier_performance | Mark Haines | 2015-05-12 | 1 | -13/+10 |
| |\ | | | | | | | | | Conflicts: synapse/notifier.py | ||||
| | * | Merge branch 'develop' into notifier_unify | Mark Haines | 2015-05-12 | 1 | -13/+10 |
| | |\ | | | | | | | | | | | | | Conflicts: synapse/notifier.py | ||||
| | | * | PEP8 | Erik Johnston | 2015-05-08 | 1 | -3/+2 |
| | | | | |||||
| | | * | Change the way we do logging contexts so that they survive divergences | Erik Johnston | 2015-05-08 | 1 | -9/+7 |
| | | | | |||||
| * | | | Merge branch 'notifier_unify' into notifier_performance | Mark Haines | 2015-05-12 | 1 | -1/+1 |
| |\| | | |||||
| | * | | Update the end_token correctly, otherwise the token doesn't advance and the ↵ | Mark Haines | 2015-05-12 | 1 | -1/+1 |
| | | | | | | | | | | | | | client gets duplicate events | ||||
| * | | | Add a NotifierUserStream to hold all the notification listeners for a user | Mark Haines | 2015-05-12 | 1 | -114/+116 |
| |/ / | |||||
| * | | Don't bother passing the events to the notifier since it isn't using them | Mark Haines | 2015-05-11 | 1 | -95/+18 |
| | | | |||||
| * | | Use wait_for_events to implement 'get_events' | Mark Haines | 2015-05-11 | 1 | -79/+30 |
| |/ | |||||
| * | Remove some run_on_reactors | Erik Johnston | 2015-05-01 | 1 | -5/+0 |
| | | |||||
| * | Change from exception to warn | Erik Johnston | 2015-04-15 | 1 | -1/+1 |
| | | |||||
| * | Add comment | Mark Haines | 2015-04-09 | 1 | -0/+1 |
| | | |||||
| * | Unset the timer in the timeout callback so that we don't try to cancel it if ↵ | Mark Haines | 2015-04-09 | 1 | -0/+1 |
| | | | | | it has been called | ||||
| * | SYN-339: Cancel the notifier timeout when the notifier fires | Mark Haines | 2015-04-09 | 1 | -4/+26 |
| | | |||||
| * | Move comment into docstring | Erik Johnston | 2015-04-08 | 1 | -5/+2 |
| | | |||||
| * | Factor out loops into '_discard_if_notified' | Erik Johnston | 2015-04-08 | 1 | -15/+14 |
| | | |||||
| * | Also perform paranoia checks in 'on_new_user_event' | Erik Johnston | 2015-04-08 | 1 | -2/+16 |
| | | |||||
| * | Add paranoia checks to make sure that we evict stale NotificationListeners ↵ | Erik Johnston | 2015-04-08 | 1 | -5/+31 |
| | | | | | when we are about to process them | ||||
| * | Fix bug where we didn't inform the NotificataionListeners about new rooms ↵ | Erik Johnston | 2015-04-08 | 1 | -0/+3 |
| | | | | | they have been subscribed to. This meant that the listeners didn't clean themselves up fully from all the dicts | ||||
| * | Appease pep8 | Paul "LeoNerd" Evans | 2015-03-12 | 1 | -6/+9 |
| | | |||||
| * | Add a counter to track total number of events served by the notifier | Paul "LeoNerd" Evans | 2015-03-12 | 1 | -0/+3 |
| | | |||||
| * | Use _ instead of . as a metric namespacing separator, for Prometheus | Paul "LeoNerd" Evans | 2015-03-12 | 1 | -1/+1 |
| | | |||||
| * | Put some gauge metrics on the number of notifier listeners, and notified-on ↵ | Paul "LeoNerd" Evans | 2015-03-12 | 1 | -0/+39 |
| | | | | | objects (users, rooms, appservices) | ||||
| * | Rename rooms_to_listeners to room_to_listeners, for consistency with user_ ↵ | Paul "LeoNerd" Evans | 2015-03-05 | 1 | -8/+8 |
| | | | | | and appservice_* | ||||
| * | Notify appservices of invites mid-poll. | Kegan Dougal | 2015-02-27 | 1 | -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 develop | Erik Johnston | 2015-02-17 | 1 | -2/+4 |
| |\ | |||||
| | * | Use consumeErrors=True on all DeferredLists. | Erik Johnston | 2015-02-17 | 1 | -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 Dougal | 2015-02-05 | 1 | -0/+6 |
| |/ | | | | when poking ASes. | ||||
| * | Fix Formatting | Mark Haines | 2015-01-27 | 1 | -2/+2 |
| | | |||||
| * | Wait for events if the incremental sync is empty and a timeout is given | Mark Haines | 2015-01-27 | 1 | -0/+48 |
| | | |||||
| * | Only start the notifier timeout once we've had a chance to check for ↵ | Mark Haines | 2015-01-19 | 1 | -2/+2 |
| | | | | | updates. Otherwise the timeout could fire while we are waiting for the database to return any updates it might have | ||||
| * | Update copyright notices | Mark Haines | 2015-01-06 | 1 | -1/+1 |
| | | |||||
| * | Remember to hook up the typing event stream to the notifier as well | Paul "LeoNerd" Evans | 2014-12-15 | 1 | -7/+25 |
| | | |||||
| * | Fix pep8 codestyle warnings | Mark Haines | 2014-11-20 | 1 | -0/+1 |
| | | |||||
| * | Add a few missing yields, Move deferred lists inside PreserveLoggingContext ↵ | Mark Haines | 2014-11-20 | 1 | -0/+3 |
| | | | | | because they don't interact well with the logging contexts | ||||
| * | remove unused import | Mark Haines | 2014-11-19 | 1 | -1/+1 |
| | | |||||
| * | Preserve logging context in a few more places, drop the logging context ↵ | Mark Haines | 2014-11-19 | 1 | -18/+22 |
| | | | | | after it has been stashed to reduce potential for confusion | ||||
| * | Fix pep8 warnings | Mark Haines | 2014-10-30 | 1 | -1/+2 |
| | | |||||
| * | Use floating-point rather than integer division to handle timeouts so that ↵ | Paul "LeoNerd" Evans | 2014-10-29 | 1 | -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 Hodgson | 2014-09-03 | 1 | -1/+1 |
| | | | | | hasn't been incorporated in time for launch. | ||||
| * | Make sure to print exceptions properly from notifier failures | Paul "LeoNerd" Evans | 2014-09-03 | 1 | -1/+6 |
| | | |||||
| * | Merge branch 'master' of github.com:matrix-org/synapse into release-v0.2.0 | Erik Johnston | 2014-09-02 | 1 | -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 fashion | Erik Johnston | 2014-08-29 | 1 | -2/+19 |
| | | | |||||
| * | | Have EventSource's get_new_events_for_user() API work only on keys within ↵ | Paul "LeoNerd" Evans | 2014-08-29 | 1 | -10/+20 |
| |/ | | | | that source, not overall eventstream tokens | ||||
| * | Turn of trace_function logging | Erik Johnston | 2014-08-28 | 1 | -2/+2 |
| | | |||||
| * | And more logging. | Erik Johnston | 2014-08-28 | 1 | -1/+2 |
| | | |||||
| * | If timeout=0, return immediately | Erik Johnston | 2014-08-27 | 1 | -1/+5 |
| | | |||||
| * | Comments! | Erik Johnston | 2014-08-27 | 1 | -0/+35 |
| | | |||||
| * | Index sources in a nicer fashion. | Erik Johnston | 2014-08-27 | 1 | -3/+3 |
| | | |||||
| * | Implement presence event source. Change the way the notifier indexes listeners | Erik Johnston | 2014-08-27 | 1 | -43/+42 |
| | | |||||
| * | Enable presence again. Fix up api to match old api. | Erik Johnston | 2014-08-26 | 1 | -1/+19 |
| | | |||||
| * | WIP: Completely change how event streaming and pagination work. This ↵ | Erik Johnston | 2014-08-26 | 1 | -0/+184 |
| reflects the change in the underlying storage model. | |||||
 |
index : matrix/thirdparty/synapse.git | |
| Unnamed repository; edit this file 'description' to name the repository. |
| summary refs log tree commit diff |