diff options
| author | Erik Johnston <erik@matrix.org> | 2016-06-08 11:55:31 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2016-06-08 11:55:31 +0100 |
| commit | 17aab5827a1a1eace4e44d130eef7da4dda6984f (patch) | |
| tree | 06f84350069ba08e7a28041e6a4d3b90abc1b768 /synapse | |
| parent | Merge pull request #850 from matrix-org/erikj/gc_threshold (diff) | |
| download | synapse-17aab5827a1a1eace4e44d130eef7da4dda6984f.tar.xz | |
Add some logging for when servers ask for missing events
Diffstat (limited to 'synapse')
| -rw-r--r-- | synapse/federation/federation_server.py | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/synapse/federation/federation_server.py b/synapse/federation/federation_server.py index f1d231b9d8..9f2a64dede 100644 --- a/synapse/federation/federation_server.py +++ b/synapse/federation/federation_server.py @@ -377,10 +377,20 @@ class FederationServer(FederationBase): @log_function def on_get_missing_events(self, origin, room_id, earliest_events, latest_events, limit, min_depth): + logger.info( + "on_get_missing_events: earliest_events: %r, latest_events: %r," + " limit: %d, min_depth: %d", + earliest_events, latest_events, limit, min_depth + ) missing_events = yield self.handler.on_get_missing_events( origin, room_id, earliest_events, latest_events, limit, min_depth ) + if len(missing_events) < 5: + logger.info("Returning %d events: %r", len(missing_events), missing_events) + else: + logger.info("Returning %d events", len(missing_events)) + time_now = self._clock.time_msec() defer.returnValue({ @@ -490,6 +500,11 @@ class FederationServer(FederationBase): latest = set(latest) latest |= seen + logger.info( + "Missing %d events for room %r: %r...", + len(prevs - seen), pdu.room_id, list(prevs - seen)[:5] + ) + missing_events = yield self.get_missing_events( origin, pdu.room_id, @@ -517,6 +532,10 @@ class FederationServer(FederationBase): prevs = {e_id for e_id, _ in pdu.prev_events} seen = set(have_seen.keys()) if prevs - seen: + logger.info( + "Still missing %d events for room %r: %r...", + len(prevs - seen), pdu.room_id, list(prevs - seen)[:5] + ) fetch_state = True if fetch_state: |