diff options
| author | Erik Johnston <erik@matrix.org> | 2017-07-11 10:04:21 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2017-07-11 10:04:21 +0100 |
| commit | 925b3638ff3e47f2fc02e178cd480cce5e934da9 (patch) | |
| tree | 45ecb7a936733321e8e6620a37d4681e7bbf465a | |
| parent | Include registration and as stores in frontend proxy (diff) | |
| download | synapse-925b3638ff3e47f2fc02e178cd480cce5e934da9.tar.xz | |
Reduce log levels in tcp replication
| -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 062272f8dd..d59503b905 100644 --- a/synapse/replication/tcp/protocol.py +++ b/synapse/replication/tcp/protocol.py @@ -244,7 +244,7 @@ class BaseReplicationStreamProtocol(LineOnlyReceiver): becoming full. """ if self.state == ConnectionStates.CLOSED: - logger.info("[%s] Not sending, connection closed", self.id()) + logger.debug("[%s] Not sending, connection closed", self.id()) return if do_buffer and self.state != ConnectionStates.ESTABLISHED: @@ -264,7 +264,7 @@ class BaseReplicationStreamProtocol(LineOnlyReceiver): def _queue_command(self, cmd): """Queue the command until the connection is ready to write to again. """ - logger.info("[%s] Queing as conn %r, cmd: %r", self.id(), self.state, cmd) + logger.debug("[%s] Queing as conn %r, cmd: %r", self.id(), self.state, cmd) self.pending_commands.append(cmd) if len(self.pending_commands) > self.max_line_buffer: |