mirror of
https://git.anonymousland.org/anonymousland/synapse-product.git
synced 2024-12-24 23:59:23 -05:00
Add some debug logging
This commit is contained in:
parent
d7e8ea67b3
commit
753126b8cc
@ -15,6 +15,10 @@
|
|||||||
|
|
||||||
from ._base import SQLBaseStore
|
from ._base import SQLBaseStore
|
||||||
|
|
||||||
|
import logging
|
||||||
|
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
|
|
||||||
class StateStore(SQLBaseStore):
|
class StateStore(SQLBaseStore):
|
||||||
""" Keeps track of the state at a given event.
|
""" Keeps track of the state at a given event.
|
||||||
@ -54,6 +58,8 @@ class StateStore(SQLBaseStore):
|
|||||||
if group:
|
if group:
|
||||||
groups.add(group)
|
groups.add(group)
|
||||||
|
|
||||||
|
logger.debug("Got groups: %s", groups)
|
||||||
|
|
||||||
res = {}
|
res = {}
|
||||||
for group in groups:
|
for group in groups:
|
||||||
state_ids = self._simple_select_onecol_txn(
|
state_ids = self._simple_select_onecol_txn(
|
||||||
@ -62,6 +68,12 @@ class StateStore(SQLBaseStore):
|
|||||||
keyvalues={"state_group": group},
|
keyvalues={"state_group": group},
|
||||||
retcol="event_id",
|
retcol="event_id",
|
||||||
)
|
)
|
||||||
|
|
||||||
|
logger.debug(
|
||||||
|
"Got %d events for group %s",
|
||||||
|
len(state_ids), group
|
||||||
|
)
|
||||||
|
|
||||||
state = self._get_events_txn(txn, state_ids)
|
state = self._get_events_txn(txn, state_ids)
|
||||||
|
|
||||||
res[group] = state
|
res[group] = state
|
||||||
|
Loading…
Reference in New Issue
Block a user