Skip to content
Snippets Groups Projects
Commit 925b3638 authored by Erik Johnston's avatar Erik Johnston
Browse files

Reduce log levels in tcp replication

parent d4d12dae
Branches
Tags
No related merge requests found
...@@ -244,7 +244,7 @@ class BaseReplicationStreamProtocol(LineOnlyReceiver): ...@@ -244,7 +244,7 @@ class BaseReplicationStreamProtocol(LineOnlyReceiver):
becoming full. becoming full.
""" """
if self.state == ConnectionStates.CLOSED: if self.state == ConnectionStates.CLOSED:
logger.info("[%s] Not sending, connection closed", self.id()) logger.debug("[%s] Not sending, connection closed", self.id())
return return
if do_buffer and self.state != ConnectionStates.ESTABLISHED: if do_buffer and self.state != ConnectionStates.ESTABLISHED:
...@@ -264,7 +264,7 @@ class BaseReplicationStreamProtocol(LineOnlyReceiver): ...@@ -264,7 +264,7 @@ class BaseReplicationStreamProtocol(LineOnlyReceiver):
def _queue_command(self, cmd): def _queue_command(self, cmd):
"""Queue the command until the connection is ready to write to again. """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) self.pending_commands.append(cmd)
if len(self.pending_commands) > self.max_line_buffer: if len(self.pending_commands) > self.max_line_buffer:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment