summary refs log tree commit diff
path: root/synapse/state/v1.py
diff options
context:
space:
mode:
authorRichard van der Hoff <1389908+richvdh@users.noreply.github.com>2018-09-27 11:27:46 +0100
committerGitHub <noreply@github.com>2018-09-27 11:27:46 +0100
commit92abd3d6d620c47d971214f1b20b0eeb0ae27903 (patch)
tree687fa669a109479fa350a15045f35ebf6954ceac /synapse/state/v1.py
parentInclude eventid in log lines when processing incoming federation transactions... (diff)
parentLogging improvements (diff)
downloadsynapse-92abd3d6d620c47d971214f1b20b0eeb0ae27903.tar.xz
Merge pull request #3966 from matrix-org/rav/rx_txn_logging_2
Logging improvements
Diffstat (limited to 'synapse/state/v1.py')
-rw-r--r--synapse/state/v1.py14
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)