diff options
| author | Daniel Wagner-Hall <daniel@matrix.org> | 2016-01-06 13:52:16 +0000 |
|---|---|---|
| committer | review.rocks <nobody@review.rocks> | 2016-01-06 13:52:16 +0000 |
| commit | 5880de186b2cd5708189c3a6e9a847174fedd495 (patch) | |
| tree | 4a9cea4cb7861a36554111f983cbc3e645e1c53e /synapse/storage | |
| parent | Merge pull request #463 from matrix-org/daniel/hashtagnofilter (diff) | |
| download | synapse-5880de186b2cd5708189c3a6e9a847174fedd495.tar.xz | |
Log when we skip daily messages
Diffstat (limited to 'synapse/storage')
| -rw-r--r-- | synapse/storage/events.py | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/synapse/storage/events.py b/synapse/storage/events.py index fc5725097c..ab500d728a 100644 --- a/synapse/storage/events.py +++ b/synapse/storage/events.py @@ -936,6 +936,7 @@ class EventsStore(SQLBaseStore): ) now_reporting = self.cursor_to_dict(txn) if not now_reporting: + logger.info("Calculating daily messages skipped; no now_reporting") return None now_reporting = now_reporting[0]["stream_ordering"] @@ -948,11 +949,18 @@ class EventsStore(SQLBaseStore): ) if not last_reported: + logger.info("Calculating daily messages skipped; no last_reported") return None # Close enough to correct for our purposes. yesterday = (now - 24 * 60 * 60) - if math.fabs(yesterday - last_reported[0]["reported_time"]) > 60 * 60: + since_yesterday_seconds = yesterday - last_reported[0]["reported_time"] + any_since_yesterday = math.fabs(since_yesterday_seconds) > 60 * 60 + if any_since_yesterday: + logger.info( + "Calculating daily messages skipped; since_yesterday_seconds: %d" % + (since_yesterday_seconds,) + ) return None txn.execute( @@ -968,6 +976,7 @@ class EventsStore(SQLBaseStore): ) rows = self.cursor_to_dict(txn) if not rows: + logger.info("Calculating daily messages skipped; messages count missing") return None return rows[0]["messages"] |