kaslo/synapse
1
0
Fork 0
Code Wiki Activity

Add length to the list of events

Browse Source
This commit is contained in:
Eric Eastwood
2022-08-06 01:37:36 -05:00
parent 552b7f13b6
commit c51883e509
2 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
synapse/handlers/federation_event.py
View File

@@ -737,6 +737,11 @@ class FederationEventHandler:
backfilled: True if this is part of a historical batch of events (inhibits
notification to clients, and validation of device keys.)
"""
set_attribute(
SynapseTags.FUNC_ARG_PREFIX + f"event_ids ({len(events)})",
str([event.event_id for event in events]),
)
set_attribute(SynapseTags.FUNC_ARG_PREFIX + "backfilled", str(backfilled))
logger.debug(
"processing pulled backfilled=%s events=%s",
backfilled,
@@ -1495,9 +1500,10 @@ class FederationEventHandler:
"""
event_map = {event.event_id: event for event in events}
event_ids = event_map.keys()
set_attribute(
SynapseTags.FUNC_ARG_PREFIX + "event_ids",
str(event_map.keys()),
SynapseTags.FUNC_ARG_PREFIX + f"event_ids ({len(event_ids)})",
str(event_ids),
)
# filter out any events we have already seen. This might happen because
@@ -2104,7 +2110,7 @@ class FederationEventHandler:
if not backfilled: # Never notify for backfilled events
with start_active_span("notify_persisted_events"):
set_attribute(
SynapseTags.FUNC_ARG_PREFIX + "event_ids",
SynapseTags.FUNC_ARG_PREFIX + f"event_ids ({len(events)})",
str([ev.event_id for ev in events]),
)
for event in events:

2
synapse/storage/controllers/persist_events.py
View File

@@ -391,7 +391,7 @@ class EventsPersistenceStorageController:
a room that has been un-partial stated.
"""
set_attribute(
SynapseTags.FUNC_ARG_PREFIX + "event_ids",
SynapseTags.FUNC_ARG_PREFIX + f"event_ids ({len(events_and_contexts)})",
str([e.event_id for e, _ in events_and_contexts]),
)
set_attribute(SynapseTags.FUNC_ARG_PREFIX + "backfilled", str(backfilled))