diff options
author | Richard van der Hoff <1389908+richvdh@users.noreply.github.com> | 2018-09-27 11:27:46 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-09-27 11:27:46 +0100 |
commit | 92abd3d6d620c47d971214f1b20b0eeb0ae27903 (patch) | |
tree | 687fa669a109479fa350a15045f35ebf6954ceac /synapse/state | |
parent | Include eventid in log lines when processing incoming federation transactions... (diff) | |
parent | Logging improvements (diff) | |
download | synapse-92abd3d6d620c47d971214f1b20b0eeb0ae27903.tar.xz |
Merge pull request #3966 from matrix-org/rav/rx_txn_logging_2
Logging improvements
Diffstat (limited to 'synapse/state')
-rw-r--r-- | synapse/state/v1.py | 14 |
1 files changed, 12 insertions, 2 deletions
diff --git a/synapse/state/v1.py b/synapse/state/v1.py index c95477d318..7a7157b352 100644 --- a/synapse/state/v1.py +++ b/synapse/state/v1.py @@ -65,10 +65,15 @@ def resolve_events_with_factory(state_sets, event_map, state_map_factory): for event_ids in itervalues(conflicted_state) for event_id in event_ids ) + needed_event_count = len(needed_events) if event_map is not None: needed_events -= set(iterkeys(event_map)) - logger.info("Asking for %d conflicted events", len(needed_events)) + logger.info( + "Asking for %d/%d conflicted events", + len(needed_events), + needed_event_count, + ) # dict[str, FrozenEvent]: a map from state event id to event. Only includes # the state events which are in conflict (and those in event_map) @@ -85,11 +90,16 @@ def resolve_events_with_factory(state_sets, event_map, state_map_factory): ) new_needed_events = set(itervalues(auth_events)) + new_needed_event_count = len(new_needed_events) new_needed_events -= needed_events if event_map is not None: new_needed_events -= set(iterkeys(event_map)) - logger.info("Asking for %d auth events", len(new_needed_events)) + logger.info( + "Asking for %d/%d auth events", + len(new_needed_events), + new_needed_event_count, + ) state_map_new = yield state_map_factory(new_needed_events) state_map.update(state_map_new) |