diff options
| author | Erik Johnston <erik@matrix.org> | 2017-04-04 14:14:03 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2017-04-04 14:14:03 +0100 |
| commit | 4264ceb31c1a7cf497fa8ce2c4bc78e9457fa8c6 (patch) | |
| tree | 0392856351375aa60ea31ccc904fb091d7e9de64 | |
| parent | Merge pull request #2082 from matrix-org/erikj/repl_tcp_server (diff) | |
| download | synapse-4264ceb31c1a7cf497fa8ce2c4bc78e9457fa8c6.tar.xz | |
Fiddle tcp replication logging
| -rw-r--r-- | synapse/replication/tcp/protocol.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/replication/tcp/protocol.py b/synapse/replication/tcp/protocol.py index 80f732b455..6ae3c86a8d 100644 --- a/synapse/replication/tcp/protocol.py +++ b/synapse/replication/tcp/protocol.py @@ -365,6 +365,7 @@ class ServerReplicationStreamProtocol(BaseReplicationStreamProtocol): self.streamer.new_connection(self) def on_NAME(self, cmd): + logger.info("[%s] Renamed to %r", self.id(), cmd.data) self.name = cmd.data def on_USER_SYNC(self, cmd): @@ -442,7 +443,7 @@ class ServerReplicationStreamProtocol(BaseReplicationStreamProtocol): self.send_command(RdataCommand(stream_name, token, data)) elif stream_name in self.connecting_streams: # 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)) else: # The client isn't subscribed @@ -453,7 +454,6 @@ class ServerReplicationStreamProtocol(BaseReplicationStreamProtocol): def on_connection_closed(self): BaseReplicationStreamProtocol.on_connection_closed(self) - logger.info("[%s] Replication connection closed", self.id()) self.streamer.lost_connection(self) |