diff options
author | Patrick Cloke <clokep@users.noreply.github.com> | 2020-10-01 08:09:18 -0400 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-10-01 08:09:18 -0400 |
commit | 4ff0201e6235b8b2efc5ce5a7dc3c479ea96df53 (patch) | |
tree | 632703075ef78aac894ac884f6fe722ec0b8784a /synapse/replication/tcp/protocol.py | |
parent | Add prometheus metrics to track federation delays (#8430) (diff) | |
download | synapse-4ff0201e6235b8b2efc5ce5a7dc3c479ea96df53.tar.xz |
Enable mypy checking for unreachable code and fix instances. (#8432)
Diffstat (limited to 'synapse/replication/tcp/protocol.py')
-rw-r--r-- | synapse/replication/tcp/protocol.py | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/synapse/replication/tcp/protocol.py b/synapse/replication/tcp/protocol.py index 0b0d204e64..a509e599c2 100644 --- a/synapse/replication/tcp/protocol.py +++ b/synapse/replication/tcp/protocol.py @@ -51,10 +51,11 @@ import fcntl import logging import struct from inspect import isawaitable -from typing import TYPE_CHECKING, List +from typing import TYPE_CHECKING, List, Optional from prometheus_client import Counter +from twisted.internet import task from twisted.protocols.basic import LineOnlyReceiver from twisted.python.failure import Failure @@ -152,9 +153,10 @@ class BaseReplicationStreamProtocol(LineOnlyReceiver): self.last_received_command = self.clock.time_msec() self.last_sent_command = 0 - self.time_we_closed = None # When we requested the connection be closed + # When we requested the connection be closed + self.time_we_closed = None # type: Optional[int] - self.received_ping = False # Have we reecived a ping from the other side + self.received_ping = False # Have we received a ping from the other side self.state = ConnectionStates.CONNECTING @@ -165,7 +167,7 @@ class BaseReplicationStreamProtocol(LineOnlyReceiver): self.pending_commands = [] # type: List[Command] # The LoopingCall for sending pings. - self._send_ping_loop = None + self._send_ping_loop = None # type: Optional[task.LoopingCall] # a logcontext which we use for processing incoming commands. We declare it as a # background process so that the CPU stats get reported to prometheus. |