Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-12-24 08:09:25 -05:00
Code Issues Packages Projects Releases Wiki Activity

Fiddle tcp replication logging

Browse Source
This commit is contained in:
Erik Johnston 2017-04-04 14:14:03 +01:00
parent 27cc627e42
commit 4264ceb31c
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
synapse/replication/tcp/protocol.py
View File

@ -365,6 +365,7 @@ class ServerReplicationStreamProtocol(BaseReplicationStreamProtocol):
self.streamer.new_connection(self) self.streamer.new_connection(self)
def on_NAME(self, cmd): def on_NAME(self, cmd):
logger.info("[%s] Renamed to %r", self.id(), cmd.data)
self.name = cmd.data self.name = cmd.data
def on_USER_SYNC(self, cmd): def on_USER_SYNC(self, cmd):
@ -442,7 +443,7 @@ class ServerReplicationStreamProtocol(BaseReplicationStreamProtocol):
self.send_command(RdataCommand(stream_name, token, data)) self.send_command(RdataCommand(stream_name, token, data))
elif stream_name in self.connecting_streams: elif stream_name in self.connecting_streams:
# The client is being subscribed to the stream # The client is being subscribed to the stream
logger.info("[%s] Queuing RDATA %r %r", self.id(), stream_name, token) logger.debug("[%s] Queuing RDATA %r %r", self.id(), stream_name, token)
self.pending_rdata.setdefault(stream_name, []).append((token, data)) self.pending_rdata.setdefault(stream_name, []).append((token, data))
else: else:
# The client isn't subscribed # The client isn't subscribed
@ -453,7 +454,6 @@ class ServerReplicationStreamProtocol(BaseReplicationStreamProtocol):
def on_connection_closed(self): def on_connection_closed(self):
BaseReplicationStreamProtocol.on_connection_closed(self) BaseReplicationStreamProtocol.on_connection_closed(self)
logger.info("[%s] Replication connection closed", self.id())
self.streamer.lost_connection(self) self.streamer.lost_connection(self)