mirror of
https://git.anonymousland.org/anonymousland/synapse-product.git
synced 2024-10-01 08:25:44 -04:00
Add more logging. Up the event stream timer to 10s
This commit is contained in:
parent
b8b52ca09d
commit
e0ba81344c
@ -98,8 +98,9 @@ class EventStreamHandler(BaseHandler):
|
|||||||
)
|
)
|
||||||
del self._stop_timer_per_user[auth_user]
|
del self._stop_timer_per_user[auth_user]
|
||||||
|
|
||||||
|
logger.debug("Scheduling _later: for %s", auth_user)
|
||||||
self._stop_timer_per_user[auth_user] = (
|
self._stop_timer_per_user[auth_user] = (
|
||||||
self.clock.call_later(5, _later)
|
self.clock.call_later(10, _later)
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
|
@ -517,6 +517,7 @@ class PresenceHandler(BaseHandler):
|
|||||||
)
|
)
|
||||||
|
|
||||||
@defer.inlineCallbacks
|
@defer.inlineCallbacks
|
||||||
|
@trace_function
|
||||||
def push_presence(self, user, statuscache):
|
def push_presence(self, user, statuscache):
|
||||||
assert(user.is_mine)
|
assert(user.is_mine)
|
||||||
|
|
||||||
@ -559,6 +560,7 @@ class PresenceHandler(BaseHandler):
|
|||||||
)
|
)
|
||||||
|
|
||||||
@defer.inlineCallbacks
|
@defer.inlineCallbacks
|
||||||
|
@trace_function
|
||||||
def _send_presence_to_distribution(self, srcuser, localusers=set(),
|
def _send_presence_to_distribution(self, srcuser, localusers=set(),
|
||||||
remotedomains=set(), statuscache=None):
|
remotedomains=set(), statuscache=None):
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user