mirrors/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse.git synced 2024-11-28 07:00:51 +03:00
Code Issues Projects Releases Packages Wiki Activity

Remove debug logging

Browse source
This commit is contained in:
Erik Johnston 2024-06-26 13:14:42 +01:00
parent fe9fa90af4
commit b8b6fe0da3
1 changed files with 0 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
synapse/storage/databases/main/event_federation.py
View file

@ -399,8 +399,6 @@ class EventFederationWorkerStore(SignatureWorkerStore, EventsWorkerStore, SQLBas
yield cached_links yield cached_links
logger.info("CHAINS: Found cached chain links %d", len(found_cached_chains))
# This query is structured to first get all chain IDs reachable, and # This query is structured to first get all chain IDs reachable, and
# then pull out all links from those chains. This does pull out more # then pull out all links from those chains. This does pull out more
# rows than is strictly necessary, however there isn't a way of # rows than is strictly necessary, however there isn't a way of
@ -439,23 +437,16 @@ class EventFederationWorkerStore(SignatureWorkerStore, EventsWorkerStore, SQLBas
chains_to_fetch_sorted = SortedSet(chains_to_fetch) chains_to_fetch_sorted = SortedSet(chains_to_fetch)
chains_to_fetch_sorted.difference_update(found_cached_chains) chains_to_fetch_sorted.difference_update(found_cached_chains)
logger.info("CHAINS: Fetching chain links %d", len(chains_to_fetch_sorted))
start_block = time.monotonic() start_block = time.monotonic()
while chains_to_fetch_sorted: while chains_to_fetch_sorted:
batch2 = list(chains_to_fetch_sorted.islice(-BATCH_SIZE)) batch2 = list(chains_to_fetch_sorted.islice(-BATCH_SIZE))
chains_to_fetch_sorted.difference_update(batch2) chains_to_fetch_sorted.difference_update(batch2)
logger.info("CHAINS: batch2 %d", len(batch2))
clause, args = make_in_list_sql_clause( clause, args = make_in_list_sql_clause(
txn.database_engine, "origin_chain_id", batch2 txn.database_engine, "origin_chain_id", batch2
) )
start_query = time.monotonic()
txn.execute(sql % (clause,), args) txn.execute(sql % (clause,), args)
end_query = time.monotonic()
logger.info("CHAINS: query took %d ms", (end_query - start_query) * 1000)
links: Dict[int, List[Tuple[int, int, int]]] = {} links: Dict[int, List[Tuple[int, int, int]]] = {}
@ -494,15 +485,10 @@ class EventFederationWorkerStore(SignatureWorkerStore, EventsWorkerStore, SQLBas
chains_to_fetch_sorted.difference_update(links) chains_to_fetch_sorted.difference_update(links)
logger.info("CHAINS: returned %d", len(links))
logger.info("CHAINS: remaining %d", len(chains_to_fetch_sorted))
yield links yield links
end_block = time.monotonic() end_block = time.monotonic()
logger.info("CHAINS: block took %d ms", (end_block - start_block) * 1000)
def _get_auth_chain_ids_txn( def _get_auth_chain_ids_txn(
self, txn: LoggingTransaction, event_ids: Collection[str], include_given: bool self, txn: LoggingTransaction, event_ids: Collection[str], include_given: bool
) -> Set[str]: ) -> Set[str]:
@ -689,7 +675,6 @@ class EventFederationWorkerStore(SignatureWorkerStore, EventsWorkerStore, SQLBas
# are reachable from any event. # are reachable from any event.
# (We need to take a copy of `seen_chains` as the function mutates it) # (We need to take a copy of `seen_chains` as the function mutates it)
logger.info("CHAINS: for room %s", room_id)
for links in self._get_chain_links(txn, seen_chains, self._chain_links_cache): for links in self._get_chain_links(txn, seen_chains, self._chain_links_cache):
for chains in set_to_chain: for chains in set_to_chain:
for chain_id in links: for chain_id in links:
@ -700,8 +685,6 @@ class EventFederationWorkerStore(SignatureWorkerStore, EventsWorkerStore, SQLBas
seen_chains.update(chains) seen_chains.update(chains)
logger.info("CHAINS: materialized chains %d", len(chains))
# Now for each chain we figure out the maximum sequence number reachable # Now for each chain we figure out the maximum sequence number reachable
# from *any* state set and the minimum sequence number reachable from # from *any* state set and the minimum sequence number reachable from
# *all* state sets. Events in that range are in the auth chain # *all* state sets. Events in that range are in the auth chain